3-1 RabbitMQ 整合 SpringBoot2.x 生產者發送消息

創建 SpringBoot 項目
application.properties 配置

spring.rabbitmq.host=192.168.152.128
spring.rabbitmq.port=5672
spring.rabbitmq.username=root
spring.rabbitmq.password=root

創建SendService.java

SpringBoot 主運行類

3-2 RabbitMQ 整合 SpringBoot2.x 消費者接受消息

創建 SpringBoot 項目

創建ReveiveService.java

SpringBoot 主運行類

3-3 使用 JSON 傳遞消息

發送和接收的 SpringBoot 工程添加 fastjson 依賴

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.36</version>
</dependency>

發送和接收的 SpringBoot 工程添加 User 實體類

修改 SendService.java

修改 ReceiveService.java

3-4 使用監聽器接收消息(否則ReceiveService無法實時接收消息)
接收消息的 SpringBoot 工程添加 RabbitMQListener.java

@Component("rabbitMQListener")
public class RabbitMQListener {
    //指定當前方法是RabbitMQ的一個監聽器的方法，用於監聽某些隊列，如果隊列中擁有新的消息則直接進行消息的接收
 

    @RabbitListener(queues = {"myQueue"})//參數 queues 是一個數組的參數，用於指定被監聽的消息隊列名稱
    public void listenerReceive(Message message){//自定義的接收消息的方法，參數是一個Message對象，這個對象就是我們的消息數據
        try {
            //使用消息對象調用getBody方法獲取具體的消息數據，並轉換成對應的json字符串
            String jsonData=new String(message.getBody(),"UTF-8");
            //使用FastJSON將json字符串轉換成對象
            User user= JSONObject.parseObject(jsonData,User.class);
            System.out.println(user.getId()+"    "+user.getName());

        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
    }
}

修改消息接收的主運行類

RabbitMQ(三) SpringBoot2.x 集成 RabbitMQ