RabbitMQ之Java实现HelloWorld

r囧r小猫 2022-02-03 15:45 235阅读 0赞

本文参考至官网：[https://www.rabbitmq.com/getstarted.html][https_www.rabbitmq.com_getstarted.html]

生产者：

import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    public class Send {
    
        private final static String QUEUE_NAM = "Hello";
    
        public static void main(String[] args) {
            //创建连接工厂
            ConnectionFactory factory = new ConnectionFactory();
            //设置主机名（IP地址） 这里没有这是端口号，是因为默认采用的默认端口号5672
            factory.setHost("localhost");
            try {
                //创建连接
                Connection connection = factory.newConnection();
                //创建信道
                Channel channel = connection.createChannel();
                //声明队列
                channel.queueDeclare(QUEUE_NAM, false, false, false, null);
                String message = "Hello World";
                //发布消息
                channel.basicPublish("", QUEUE_NAM, null, message.getBytes());
                System.out.println("[x] Sent '" + message + "'" );
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

消费者：

import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    public class Receive {
    
        private final static String QUEUE_NAME = "Hello";
    
        public static void main(String[] args) {
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("127.0.0.1");
            try {
                Connection connection = factory.newConnection();
                Channel channel = connection.createChannel();
                channel.queueDeclare(QUEUE_NAME, false, false, false, null);
                // 创建默认消费者
                Consumer consumer = new DefaultConsumer(channel) {
                    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                        // 将获取的消息打印至控制台
                        System.out.println(new String(body));
                    }
                };
                //监听消息
                channel.basicConsume(QUEUE_NAME, consumer);
                System.out.println("[*] Waiting for messages, To exit press Ctrl + c");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

先执行生产者， 在界面看一看到新建的队列 "Hello" 其中已经又一条消息准备好了！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h6cF9mb3JldmVy_size_16_color_FFFFFF_t_70][]

执行消费者，可以看到队列 "Hello" 中的消息已被消费！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h6cF9mb3JldmVy_size_16_color_FFFFFF_t_70 1][]

消费者控制台输出：

![20190509195620659.png][]

Hello World 程序Over!!!

[https_www.rabbitmq.com_getstarted.html]: https://www.rabbitmq.com/getstarted.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h6cF9mb3JldmVy_size_16_color_FFFFFF_t_70]: /images/20220203/c4c7e1d6b41a461dadbb4d9cc5e7306a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h6cF9mb3JldmVy_size_16_color_FFFFFF_t_70 1]: /images/20220203/c1aa61a6d04e48c28923d57fde600662.png
[20190509195620659.png]: /images/20220203/77033a4fa9b041fa86417a48e9a9b637.png