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();

        }

    }

}

修改消息接收的主运行类