1. 简介

一般在开发过程中：
生产者工程：

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

消费者工程：

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

2.成产者：

2.1依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.2配置RabbitMQ

2.2.1配置文件

spring:
  rabbitmq:
    host: localhost
    port: 5672
    virtual-host: /demo
    username: guest
    password: guest

2.2.2绑定交换机和队列

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

@Configuration
public class RabbitMQConfig {
    //交换机名称
    public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
    //队列名称
    public static final String ITEM_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(ITEM_QUEUE).build();
    }
?
    //绑定队列和交换机
    @Bean
    public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue,
                                     @Qualifier("itemTopicExchange") Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
    }
}

2.3生产者Controller

/**
 * 发送消息的测试类
 */
@RestController
public class SendMsgController {
?
    //注入RabbitMQ的模板
    @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 "发送消息成功！";
    }
}

3消费者

依赖和配置文件同生产者

3.1消息监听处理类

@Component
public class MyListener {
?
    /**
     * 监听某个队列的消息
     * @param message 接收到的消息
     */
    @RabbitListener(queues = "item_queue")
    public void myListener1(String message){
        System.out.println("消费者接收到的消息为：" + message);
    }
}

4.测试

在这里插入图片描述
在生产者工程中创建测试类，发送消息：

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitMQTest {
?
    @Autowired
    private RabbitTemplate rabbitTemplate;
?
    @Test
    public void test(){
        rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE, "item.insert", "商品新增，routing key 为item.insert");
        rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE, "item.update", "商品修改，routing key 为item.update");
        rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE, "item.delete", "商品删除，routing key 为item.delete");
    }
}