From d744cf8d4ef575f9bff3618caa20a0faf4851355 Mon Sep 17 00:00:00 2001 From: Wonder Date: Fri, 14 Nov 2025 09:38:48 +0800 Subject: [PATCH] =?UTF-8?q?=20=F0=9F=94=84Update:=20=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/cn/hezhaohui/mq/Send.java | 38 +++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 src/main/java/cn/hezhaohui/mq/Send.java diff --git a/src/main/java/cn/hezhaohui/mq/Send.java b/src/main/java/cn/hezhaohui/mq/Send.java new file mode 100644 index 0000000..cfde3b4 --- /dev/null +++ b/src/main/java/cn/hezhaohui/mq/Send.java @@ -0,0 +1,38 @@ +package cn.hezhaohui.mq; + +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; + +import java.io.IOException; +import java.util.Scanner; +import java.util.concurrent.TimeoutException; + +public class Send { + private final static String QUEUE_NAME = "hello"; + + public static void main(String[] args) { + ConnectionFactory connectionFactory = new ConnectionFactory(); + try (Connection connection = connectionFactory.newConnection(); + Channel channel = connection.createChannel(); + Scanner scanner = new Scanner(System.in)){ + channel.queueDeclare(QUEUE_NAME, false, false, false, null); + System.out.println(" === Now you can send message ==="); + + while (true) { + System.out.println("[Send]:"); + String message = scanner.nextLine(); + channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); + System.out.println(" [x] Sent '" + message + "'"); + + if ("exit".equalsIgnoreCase(message)) { + System.out.println(" [x] Bye"); + break; + } + } + + } catch (IOException | TimeoutException e) { + throw new RuntimeException(e); + } + } +}