RabbitMQ(三) SpringBoot2.x 集成 RabbitMQ

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 項目
application.properties 配置和上面項目同樣 導入rabbitmq依賴

建立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(); } } }

修改消息接收的主運行類