springboot整合消息队列——RabbitMQ

深碍√TFBOYSˉ_ 2024-03-25 10:07 22阅读 0赞

**RabbitMQ常用的三种Exchange Type：fanout、direct、topic。**

1.  fanout:把所有发送到该Exchange的消息投递到所有与它绑定的队列中。
2.  direct:把消息投递到那些binding key与routing key完全匹配的队列中。
3.  topic:将消息路由到binding key与routing key模式匹配的队列中。

这里基于springboot整合 消息队列 ，测试这三种Exchange。

#### 1，启动RabbitMQ ####

双击运行rabbitmq-server.bat  
![在这里插入图片描述][29405a12c0d9490fb12df029ee7bebaf.png]

SpringBoot整合RabbitMQ——Direct模式（默认模式）  
创建springboot web项目——发送者 springboot-sender

#### 2，追加测试和rabbitmq所需的依赖 ####

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-test</artifactId>
    </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-test</artifactId>
      <version>5.0.9.RELEASE</version>
    </dependency>

#### 3，修改配置文件 application.yml 或 application.properties： ####

server:
      port: 7001
    spring:
      application:
        name: spirngboot-sender
        rabbitmq:
          host: 127.0.0.1
          port: 5672
          username: guest
          password: guest

发送的信息可以是 基本数据类型 也可以是 对象 ，这里创建一个用户对象

public class User implements Serializable{
        
        private String username;
        private String password;
     
        public String getUsername() {
        
            return username;
        }
     
        public void setUsername(String username) {
        
            this.username = username;
        }
     
        public String getPassword() {
        
            return password;
        }
     
        public void setPassword(String password) {
        
            this.password = password;
        }
    }

#### 4，创建一个配置类： SenderConfiguration.java ####

一个名为 queue1 的 队列

@Configuration
    public class SenderConfiguration {
        
        @Bean
        public Queue directQueue() {
        
            return new Queue("queue1");
        }
    }

创建一个发送信息类： SenderService.java

发送 user 对象给 queue1 队列

@Component
    public class SenderService {
        
        @Autowired
        private AmqpTemplate template;
     
        public void sendUser() {
        
            User user=new User();
            user.setUsername("张三");
            user.setPassword("123456");
            template.convertAndSend("queue1",user);
        }
    }

#### 5，创建一个测试类： TestRabbitMQ.java ####

@SpringBootTest(classes=SpringbootSenderApplication.class)
    @RunWith(SpringJUnit4ClassRunner.class)
    public class TestRabbitMQ {
        
        @Autowired
        private SenderService senderService;
     
        @Test
        public void testRabbit() {
        
            senderService.sendUser();
        }
    }

运行 testRabbit 方法：  
![在这里插入图片描述][174b651e964c4684bc7aca13a752337b.png]

#### 6，创建springboot web项目——接收者 springboot-receiver ####

修改配置文件 application.yml 或 application.properties：

server:
      port: 7002
    spring:
      application:
        name: spirngboot-receiver
        rabbitmq:
          host: 127.0.0.1
          port: 5672
          username: guest
          password: guest

添加接收类： ReceiverService.java

@Component
    public class ReceiverService {
        
        @RabbitListener(queues="queue1")
        public void receiveUser(User user) {
        
            System.out.println("username:"+user.getUsername()+" password:"+user.getPassword());
        }
    }

运行启动类：  
SpringbootApplication.java，结果：  
![在这里插入图片描述][1d819ad9a5a74e6c9e58ec054783c86a.png]  
![在这里插入图片描述][8d1e527144e34d929c6875b38b335fd4.png]

信息成功被接收。

#### 7，SpringBoot整合RabbitMQ——Topic模式（模糊匹配） ####

步骤与Direct差不多。

发送者：

#### 8，修改配置类SenderConfiguration.java： ####

创建两个队列 topic1,topic2，创建一个topic交换器，绑定交换机和队列以及绑定规则

@Test
    public void testRabbit() {
        
        senderService.sendUser();
    }@Bean(name="topic1")
    public Queue topicQueue1() {
        
        return new Queue("topic1");
    }
    @Bean(name="topic2")
    public Queue topicQueue2() {
        
        return new Queue("topic2");
    }
     
    @Bean
    public TopicExchange exchange() {
        
        //创建一个topic交换器
        return new TopicExchange("topicExchange");
    }
    @Bean
    Binding bindingExchangeTopic1(@Qualifier("topic1") Queue queueMessage, TopicExchange exchange) {
        
        //设置topic1绑定规则
        return BindingBuilder.bind(queueMessage).to(exchange).with("topic.queue");
    }
    @Bean
    Binding bindingExchangeTopic2(@Qualifier("topic2") Queue queueMessages, TopicExchange exchange) {
         
        //设置topic2绑定规则 *表示一个词,#表示零个或多个词
        return BindingBuilder.bind(queueMessages).to(exchange).with("topic.#");
    }

#### 9，修改发送类 SenderService.java ： ####

User user=new User();
    user.setUsername("张三");
    user.setPassword("123456");
    //发送给topicExchange的交换机
    template.convertAndSend("topicExchange","topic.queue",user);
    template.convertAndSend("topicExchange","topic.anyting",user);

运行 testRabbit 方法：  
![在这里插入图片描述][92bcfa954c434509b8c9884a6394eb8c.png]

#### 9，成功广播出去两条信息 ####

接收者：  
修改接收类 ReceiverService.java ：

@RabbitListener(queues="fanout1")
    public void receiveFanout1(User user) {
        
        System.out.println("队列：fanout1 username:"+user.getUsername()+" password:"+user.getPassword());
    }
    @RabbitListener(queues="fanout2")
    public void receiveFanout2(User user) {
        
        System.out.println("队列：fanout2 username:"+user.getUsername()+" password:"+user.getPassword());
    }

运行启动类，结果：  
![在这里插入图片描述][95dabb29a44342fcbd34f6b3e924797c.png]  
![在这里插入图片描述][310e39194f004544b1d73e5757677ae3.png]

消息成功被发送接收。

[29405a12c0d9490fb12df029ee7bebaf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/2329c74fcaf345b48ba87e64d12f6d44.png
[174b651e964c4684bc7aca13a752337b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/0680e96a203a4bb39ec1f7fbd91c6613.png
[1d819ad9a5a74e6c9e58ec054783c86a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/a0df00bc7af84227b2e0c92cc087c070.png
[8d1e527144e34d929c6875b38b335fd4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/18936cf6693042cc980b71b440494f34.png
[92bcfa954c434509b8c9884a6394eb8c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/1c1228cb54d341a8882d37826e2cc4f1.png
[95dabb29a44342fcbd34f6b3e924797c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/05da8be84bfc41ecb328be948bf377f2.png
[310e39194f004544b1d73e5757677ae3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/3708f446d9274996ac08570b6f4ff9b7.png