SpringBoot学习-整合RabbitMQ

简介

在SpringBoot中，只需要引入对应的amqp启动器依赖即可，方便的使用RabbitTemplate发送消息，使用注解接收消息。

一般开发过程中：

生产者工程：

application.yml文件配置RabbitMQ相关信息；
在生产者工程中编写配置类，用于创建交换机和队列，并进行绑定；
注入RabbitTemplate对象，通过RabbitTemplate对象发送消息到交换机。

消费者工程：

application.yml文件配置RabbitMQ相关信息；
创建消息处理类，用于接收队列中的消息并进行处理。

搭建生产者工程

创建SpringBoot工程

引入依赖

<dependencies>
    <!--引入RabbitMQ依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <!--使用SpringMVC进行测试-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

编写配置文件

#RabbitMQ配置
spring:
  rabbitmq:
    host: 192.168.0.8
    port: 5672
    virtual-host: /ligangit
    username: ligangit
    password: ligangit

绑定交换机和队列

创建RabbitMQ队列与交换机绑定的配置类RabbitMQConfig

/**
 * RabbitMQ配置类
 */
@Configuration
public class RabbitMQConfig {
    //交换机名称
    public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
    //队列名称
    public static final String IMTE_QUEUE = "item_queue";

    //声明交换机
    @Bean("itemTopicExchange")
    public Exchange topicExchange() {
        return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
    }

    //声明队列
    @Bean("itemQueue")
    public Queue itemQueue() {
        return QueueBuilder.durable(IMTE_QUEUE).build();
    }

    //绑定队列和交换机
    @Bean
    public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue, @Qualifier("itemTopicExchange") Exchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
    }
}

消息发送Controller

/**
 * 发送消息的测试类
 */
@RestController
public class SendMsgController {

    //注入RabbitTemplate模板
    @Autowired
    private RabbitTemplate rabbitTemplate;
    /**
     * 测试
     */
    @GetMapping("/sendmsg")
    public String sendMsg(@RequestParam String msg, @RequestParam String key) {
        /**
         * 发送消息
         * 参数一：交换机名称
         * 参数二：路由key
         * 参数三：发送的消息
         */
        rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE,key,msg);
        //返回信息
        return "发送消息成功";
    }
}

测试

http://localhost:8888/sendmsg?msg=helloSpringboot&key=item.insert
结果

搭建消费者工程

创建SpringBoot工程

引入依赖

<dependencies>
    <!--引入RabbitMQ依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <!--使用SpringMVC进行测试-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

编写配置文件

#RabbitMQ配置
spring:
  rabbitmq:
    host: 192.168.0.8
    port: 5672
    virtual-host: /ligangit
    username: ligangit
    password: ligangit

编写消息监听处理类

/**
 * 消费者监听类
 */
@Component
public class MyListener {
    @RabbitListener(queues = "item_queue")
    public void msg(String msg) {
        System.out.println("消费者消费消息了："+msg);
    }
}