RabbitMQ(三) SpringBoot2.x 集成 RabbitMQ

时间 2020-05-06

标签 rabbitmq springboot2.x springboot 集成栏目 RabbitMQ 繁體版

原文原文链接

3-1 RabbitMQ 整合 SpringBoot2.x 生产者发送消息java

建立 SpringBoot 项目
application.properties 配置spring

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

建立SendService.javajson

SpringBoot 主运行类数组

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

建立 SpringBoot 项目
application.properties 配置和上面项目同样导入rabbitmq依赖spa

建立ReveiveService.java3d

SpringBoot 主运行类code

3-3 使用 JSON 传递消息对象

发送和接收的 SpringBoot 工程添加 fastjson 依赖blog

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

修改消息接收的主运行类