From 0628c6892ada604ec2f91e49d3a05b941b86fd81 Mon Sep 17 00:00:00 2001 From: Wonder Date: Thu, 13 Nov 2025 23:42:13 +0800 Subject: [PATCH] =?UTF-8?q?=20=F0=9F=94=84Update:=20=E6=8E=A5=E6=94=B6?= =?UTF-8?q?=E4=B8=80=E6=9D=A1=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/cn/hezhaohui/mq/Recv.java | 28 +++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 src/main/java/cn/hezhaohui/mq/Recv.java diff --git a/src/main/java/cn/hezhaohui/mq/Recv.java b/src/main/java/cn/hezhaohui/mq/Recv.java new file mode 100644 index 0000000..3a70c74 --- /dev/null +++ b/src/main/java/cn/hezhaohui/mq/Recv.java @@ -0,0 +1,28 @@ +package cn.hezhaohui.mq; + +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; +import com.rabbitmq.client.DeliverCallback; + +import java.io.IOException; +import java.nio.charset.StandardCharsets; +import java.util.concurrent.TimeoutException; + +public class Recv { + private final static String QUEUE_NAME = "hello"; + + public static void main(String[] args) throws IOException, TimeoutException { + ConnectionFactory connectionFactory = new ConnectionFactory(); + Connection connection = connectionFactory.newConnection(); + Channel channel = connection.createChannel(); + + System.out.println(" [*] Waiting for message"); + + DeliverCallback deliverCallback = (consumerTag, delivery) -> { + String message = new String(delivery.getBody(), StandardCharsets.UTF_8); + System.out.println(" [x] Received '" + message + "'"); + }; + channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {}); + } +}