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); + } + } +}