java——spring boot集成RabbitMQ——spring boot实现发布订阅模式——消费者

古城微笑少年丶 2023-09-29 20:51 18阅读 0赞

![394ab2c29915e1ad3cdcc2ff13f99d5a.png][]

pom文件：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>org.example</groupId>
        <artifactId>springrmq</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.4.5</version>
            <relativePath/>
        </parent>
    
    
        <dependencies>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
    
        </dependencies>
    
    
    </project>

![762f64ff45907b5aa03ede0c8aa52d69.png][]

配置文件：

MyRabbitConfig

package org.example.config;
    
    import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.FanoutExchange;
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class MyRabbitConfig
    {
    
        public final static String FANOUT_NAME ="amqp-fanout";
    
        @Bean
        FanoutExchange fanoutExchange(){
            return new FanoutExchange(FANOUT_NAME,true,false);
        }
    
        @Bean
        Queue queueOne(){
            return new Queue("queue-one");
        }
    
        @Bean
        Queue queueTwo(){
            return new Queue("queue-two");
        }
    
        @Bean
        Binding bindingOne(){
            return BindingBuilder.bind(queueOne()).to(fanoutExchange());
        }
    
        @Bean
        Binding bindingTwo(){
            return BindingBuilder.bind(queueTwo()).to(fanoutExchange());
        }
    
    }

![99727c99a14d7875b149255a0b40982e.png][]

监听-接收消息：

FanoutReceiver

package org.example.receiver;
    
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /**
     * 配置消费者
     * 两个消费者分别监听两个不同的队列
     */
    @Component
    public class FanoutReceiver {
    
        @RabbitListener(queues = "queue-one")
        public void handler1(String msg)
        {
    
            System.out.println("第一个队列>>>"+msg);
    
        }
    
        @RabbitListener(queues = "queue-two")
        public void handler2(String msg)
        {
    
            System.out.println("第二个队列>>>"+msg);
    
    
        }
    
    
    }

![338c59d71c169b78a14f4284aa9f1d8d.png][]

启动后就可以接收消息了：

![4d69f22b7408cb9d8dc4fed480de79b4.png][]

![bb5a2f64e267fd6067f1708c02e16e39.png][]

接收消息后，消息被消费了，所有为0

![5bb23c07d01849c1eea3375e95065533.png][]

[394ab2c29915e1ad3cdcc2ff13f99d5a.png]: https://img-blog.csdnimg.cn/img_convert/394ab2c29915e1ad3cdcc2ff13f99d5a.png
[762f64ff45907b5aa03ede0c8aa52d69.png]: https://img-blog.csdnimg.cn/img_convert/762f64ff45907b5aa03ede0c8aa52d69.png
[99727c99a14d7875b149255a0b40982e.png]: https://img-blog.csdnimg.cn/img_convert/99727c99a14d7875b149255a0b40982e.png
[338c59d71c169b78a14f4284aa9f1d8d.png]: https://img-blog.csdnimg.cn/img_convert/338c59d71c169b78a14f4284aa9f1d8d.png
[4d69f22b7408cb9d8dc4fed480de79b4.png]: https://img-blog.csdnimg.cn/img_convert/4d69f22b7408cb9d8dc4fed480de79b4.png
[bb5a2f64e267fd6067f1708c02e16e39.png]: https://img-blog.csdnimg.cn/img_convert/bb5a2f64e267fd6067f1708c02e16e39.png
[5bb23c07d01849c1eea3375e95065533.png]: https://img-blog.csdnimg.cn/img_convert/5bb23c07d01849c1eea3375e95065533.png