java——spring boot集成RabbitMQ——spring boot实现路由模式——消费者

爱被打了一巴掌 2023-09-29 20:52 11阅读 0赞

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>springrmqtopicreceiver</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>

![e2eaebc11b455ac40b8d47f20cd0ec97.png][]

yml配置：

spring:
      rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: guest
        password: guest

![734ecb728cd692e891844a8a443b7488.png][]

config配置：

package org.example.config;
    
    import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.core.TopicExchange;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * 主题交换机
     * topic策略可以根据routingKey的规则(通配符方式)进行去匹配队列进行转发规则为*.#.*
     */
    @Configuration
    public class RabbitTopicConfig {
    
        public final static String TOPIC_NAME = "amqp-topic";
    
        @Bean
        TopicExchange topicExchange(){
            return new TopicExchange(TOPIC_NAME,true,false);
        }
    
        @Bean
        Queue xiaomi(){
            return new Queue("xiaomi");
        }
    
        @Bean
        Queue huawei(){
            return new Queue("huawei");
        }
    
    
        @Bean
        Binding xiaomiBinding(){
            //xiaomi.#：表示消息的routingKey是以xiaomi开头的就会路由到xiaomi的队列
            return BindingBuilder.bind(xiaomi()).to(topicExchange()).with("xiaomi.#");
        }
    
        @Bean
        Binding huaweiBinding(){
            return BindingBuilder.bind(huawei()).to(topicExchange()).with("huawei.#");
        }
    
    
    }

![05f272b6745b64678b159ee3f1a313d4.png][]

接收：

package org.example.receiver;
    
    import org.springframework.amqp.core.Message;
    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;
    
    /**
     *
     * @Auther: moerhai@qq.com
     * @Date: 2020/10/4 14:36
     */
    @Component
    public class TopicReceiver {
    
        //分别监听名称为xiaomi、huawei的队列
        @RabbitListener(queues = "xiaomi")
        public void handlerXM(String msg){
            System.out.println("TopicReceiver:handlerXM>>>"+msg);
        }
    
        @RabbitListener(queues = "huawei")
        public void handlerHW(String msg){
            System.out.println("TopicReceiver:handlerHW>>>"+msg);
        }
    
    
    }

![5817c8556258087a0a054418020cf34d.png][]

![0331ae883ba79506acc46c031f00393c.png][]

[e2eaebc11b455ac40b8d47f20cd0ec97.png]: https://img-blog.csdnimg.cn/img_convert/e2eaebc11b455ac40b8d47f20cd0ec97.png
[734ecb728cd692e891844a8a443b7488.png]: https://img-blog.csdnimg.cn/img_convert/734ecb728cd692e891844a8a443b7488.png
[05f272b6745b64678b159ee3f1a313d4.png]: https://img-blog.csdnimg.cn/img_convert/05f272b6745b64678b159ee3f1a313d4.png
[5817c8556258087a0a054418020cf34d.png]: https://img-blog.csdnimg.cn/img_convert/5817c8556258087a0a054418020cf34d.png
[0331ae883ba79506acc46c031f00393c.png]: https://img-blog.csdnimg.cn/img_convert/0331ae883ba79506acc46c031f00393c.png