Spring_AMQP实现RabbitMQ

雨点打透心脏的1/2处 2023-03-13 03:55 61阅读 0赞

# \[Springboot\]Spring\_AMQP实现RabbitMQ #

> 在本篇博客中我介绍了MQ及其实现RabbitMQ及其五种通信模型
> 
> 本篇博客介绍Spring提供的RabbitMQ启动器

Spring AMQP的页面：http://spring.io/projects/spring-amqp

Spring-amqp是对AMQP协议的抽象实现，而spring-rabbit 是对协议的具体实现，也是目前的唯一实现。底层使用的就是RabbitMQ。

我们使用SpringBoot

**依赖和配置**

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

在`application.yml`中添加RabbitMQ地址：

spring:
      rabbitmq:
        host: 192.168.56.111

**消费者代码**

package com.junsir.springamqp;
    
    import org.springframework.amqp.core.ExchangeTypes;
    import org.springframework.amqp.rabbit.annotation.Exchange;
    import org.springframework.amqp.rabbit.annotation.Queue;
    import org.springframework.amqp.rabbit.annotation.QueueBinding;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class Lisenner {
        
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = "spring.test.queue", durable = "true"),
                exchange = @Exchange(
                        value = "spring.test.exchange",
                        ignoreDeclarationExceptions = "true",
                        type = ExchangeTypes.TOPIC
                ),
                key = {
        "#.#"}))
        /*监听者/消费者*/
        public void listen(String msg){
        
            System.out.println("lisener接收到消息：" + msg);
        }
    }

*  `@Componet`：类上的注解，注册到Spring容器
 *  `@RabbitListener`：方法上的注解，声明这个方法是一个消费者方法，需要指定下面的属性：
    
     *  `bindings`：指定绑定关系，可以有多个。值是`@QueueBinding`的数组。`@QueueBinding`包含下面属性：
        
         *  `value`：这个消费者关联的队列。值是`@Queue`，代表一个队列
         *  `exchange`：队列所绑定的交换机，值是`@Exchange`类型
         *  `key`：队列和交换机绑定的`RoutingKey`

类似listen这样的方法在一个类中可以写多个，就代表多个消费者。

**生产者代码**

直接在测试类中运行即可

package com.junsir.springamqp;
    
    import org.junit.jupiter.api.Test;
    import org.junit.runner.RunWith;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    class SpringamqpApplicationTests {
        
    
        @Autowired
        private AmqpTemplate amqpTemplate ;
    
        @Test
        void testSend() {
        
            String msg = "hello, Spring boot amqp";
         //注意：消费者lisenner的key为key = {"#.#"}，是对应的
            amqpTemplate.convertAndSend("spring.test.exchange","a.b", msg);
            // 等待10秒后再结束
            try {
        
                Thread.sleep(10000);
            } catch (InterruptedException e) {
        
                e.printStackTrace();
            }
        }
    
    }

AmqpTemplate：

Spring为AMQP提供了统一的消息处理模板：AmqpTemplate，非常方便的发送消息，其发送方法：

amqpTemplate.convertAndSend(“spring.test.exchange”,“a.b”, msg);

![format_png][]

红框圈起来的是比较常用的3个方法，分别是：

*  指定交换机、RoutingKey和消息体
 *  指定消息
 *  指定RoutingKey和消息，会向默认的交换机发送消息

![format_png 1][]

[format_png]: /images/20230312/e1aff31f799e48f0933ab59aa8405323.png
[format_png 1]: /images/20230312/021ead07d8474c43b4fb7077d2c65104.png