三、RabbitMQ中模式—简单模式Hello World

我们将用Java编写两个程序，发送单个消息的生产者和接收消息并打印出来的消费者。将介绍Java API中的一些细节。
在下图中，"P"是我们的生产者，"C"是我们的消费者。中间的框是一个队列——RabbitMQ代表使用者保留的消息缓冲区。

    
        
        
            com.rabbitmq
            amqp-client
            5.8.0
        
        
        
            commons-io
            commons-io
            2.6
        
    

    
    
        
            
                org.apache.maven.plugins
                maven-compiler-plugin
                
                    8
                    8
                
            
        
    

package com.xbmu.rabbitmq.one;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


public class Producer {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) {
        // 创建一个连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 设置工厂IP,连接rabbitmq的队列
        factory.setHost("192.168.184.110");
        // 用户名
        factory.setUsername("admin");
        // 密码
        factory.setPassword("123");

        try {
            // 创建连接
            Connection connection = factory.newConnection();
            // 从连接中获取一个通道
            // channel 实现了自动close接口 自动关闭 不需要显示关闭
            Channel channel = connection.createChannel();
            
            channel.queueDeclare(QUEUE_NAME,false,false,false,null);
            // 发消息
            String message = "hello world";
            
            channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
            System.out.printf("消息发送完毕");
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

package com.xbmu.rabbitmq.one;

import com.rabbitmq.client.*;

public class Consumer {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) {
        // 创建一个连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 设置工厂IP,连接rabbitmq的队列
        factory.setHost("192.168.184.110");
        // 用户名
        factory.setUsername("admin");
        // 密码
        factory.setPassword("123");
        try {
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            System.out.println("等待接收消息......");
            // 推送的消息如何进行消费的接口回调
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody());
                System.out.println(message);
            };
            // 取消消费的一个回调接口 如在消费的时候队列被删除掉了
            CancelCallback cancelCallback = (consumerTag) -> {
                System.out.println("消息消费被中断");
            };
            
            channel.basicConsume(QUEUE_NAME,true,deliverCallback,cancelCallback);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

首先确保，rabbitmq所在的Linux服务器上，确保：
5672：client端通信端口、15672：管理界面ui端口，开放。

执行生产者类

此时，MQ中产生了一个消息队列，消息是存放在队列中的，队列名为"hello"。


执行消费者类，去消费生产者产生的消息。输出了消息的信息"hello world"。