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

柔光的暖阳◎ 2023-09-29 20:51 130阅读 0赞

![0d2c4727fc6a61d0f3e588035cd3e460.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>springrmqsender</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>

![9e4ae2f53342f64fbe25610f4fcf28d5.png][]

配置文件：

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

![b1af1b78f4094392c7004f16841c5db6.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);
        }
    
    
    }

![754f12706b0ecd87cba06e11084ad846.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-fanout","",info);
        }
    
    }

![7ebd01a02081267e03af277378bfcdf4.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";
        }
    
    }

![9c6b6bce86bd3aa288bffa10ffd89f92.png][]

![e6a8cfc167713e33b148cf680a626de5.png][]

![bcaf92724850884acb5d2d40da31bac4.png][]

![a7461c4ba8a6bf0a366133b8ec3c2f8c.png][]

[0d2c4727fc6a61d0f3e588035cd3e460.png]: https://img-blog.csdnimg.cn/img_convert/0d2c4727fc6a61d0f3e588035cd3e460.png
[9e4ae2f53342f64fbe25610f4fcf28d5.png]: https://img-blog.csdnimg.cn/img_convert/9e4ae2f53342f64fbe25610f4fcf28d5.png
[b1af1b78f4094392c7004f16841c5db6.png]: https://img-blog.csdnimg.cn/img_convert/b1af1b78f4094392c7004f16841c5db6.png
[754f12706b0ecd87cba06e11084ad846.png]: https://img-blog.csdnimg.cn/img_convert/754f12706b0ecd87cba06e11084ad846.png
[7ebd01a02081267e03af277378bfcdf4.png]: https://img-blog.csdnimg.cn/img_convert/7ebd01a02081267e03af277378bfcdf4.png
[9c6b6bce86bd3aa288bffa10ffd89f92.png]: https://img-blog.csdnimg.cn/img_convert/9c6b6bce86bd3aa288bffa10ffd89f92.png
[e6a8cfc167713e33b148cf680a626de5.png]: https://img-blog.csdnimg.cn/img_convert/e6a8cfc167713e33b148cf680a626de5.png
[bcaf92724850884acb5d2d40da31bac4.png]: https://img-blog.csdnimg.cn/img_convert/bcaf92724850884acb5d2d40da31bac4.png
[a7461c4ba8a6bf0a366133b8ec3c2f8c.png]: https://img-blog.csdnimg.cn/img_convert/a7461c4ba8a6bf0a366133b8ec3c2f8c.png