java——spring boot集成RabbitMQ——spring boot实现路由模式——生产者

古城微笑少年丶 2023-09-29 20:51 10阅读 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>springrmqtopicsender</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>

![455ac45d0895d9714c6f3b9bcafeb2ab.png][]

yml文件：

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

![49083af99a18e314cc7749182db0b841.png][]

config配置文件：

package org.example.config;
    
    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);
    
        }
    
    
    }

![ffb2282660824d146939afb67b6a76a3.png][]

发送：

package org.example.sender;
    
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    /**
     * 消息生产者 发送消息
     */
    @Component
    public class MessageSender {
    
        @Autowired
        RabbitTemplate rabbitTemplate;
    
        /**
         * 发送消息
         * @param info
         */
        public void send(String info)
        {
    
            System.out.println("发送消息>>>"+info);
    
    
            rabbitTemplate.convertAndSend("amqp-topic","huawei.a",info);
        }
    
    }

![cb740bff5b52b7fe619033ece3e2eca0.png][]

触发：

package org.example.controller;
    
    import org.example.sender.MessageSender;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * @Auther: moerhai@qq.com
     * @Date: 2020/10/4 11:34
     */
    @RestController
    public class IndexController {
    
        @Autowired
        MessageSender messageSender;
    
        @RequestMapping("/index")
        public String index()
        {
    
            messageSender.send("中国——路由——华为");
            return "SUCCESS";
        }
    
    }

![2462db867730fbc5652528365e43caaf.png][]

![3d44b12c0a62ba74a7144e1b74cf2747.png][]

![1b5657307f5439348ea63d6681b1d87d.png][]

[455ac45d0895d9714c6f3b9bcafeb2ab.png]: https://img-blog.csdnimg.cn/img_convert/455ac45d0895d9714c6f3b9bcafeb2ab.png
[49083af99a18e314cc7749182db0b841.png]: https://img-blog.csdnimg.cn/img_convert/49083af99a18e314cc7749182db0b841.png
[ffb2282660824d146939afb67b6a76a3.png]: https://img-blog.csdnimg.cn/img_convert/ffb2282660824d146939afb67b6a76a3.png
[cb740bff5b52b7fe619033ece3e2eca0.png]: https://img-blog.csdnimg.cn/img_convert/cb740bff5b52b7fe619033ece3e2eca0.png
[2462db867730fbc5652528365e43caaf.png]: https://img-blog.csdnimg.cn/img_convert/2462db867730fbc5652528365e43caaf.png
[3d44b12c0a62ba74a7144e1b74cf2747.png]: https://img-blog.csdnimg.cn/img_convert/3d44b12c0a62ba74a7144e1b74cf2747.png
[1b5657307f5439348ea63d6681b1d87d.png]: https://img-blog.csdnimg.cn/img_convert/1b5657307f5439348ea63d6681b1d87d.png