springboot整合rabbitMQ

2021-09-19 17:00:48 阅读：145 来源： 互联网

标签：return springboot exchange boot rabbitMQ queue 整合 public

1.创建一个springboot工程

2.导入rabbitMQ相关依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

3.yml配置文件配置mq五大参数即加上虚拟主机

spring:
  rabbitmq:
    host: 192.168.200.129     #rabbitMQ的IP地址
    port: 5672                #rabbitMQ连接端口
    username: test            #登录用户名
    password: test            #登录密码
    virtual-host: /test       #虚拟主机

4.声明exchange、queue,并且绑定它们,这是一个配置类

@Configuration
public class RabbitMQConfig {
    //1. 创建exchange - topic
    @Bean
    public TopicExchange getTopicExchange(){
        return new TopicExchange("boot-topic-exchange",true,false);
    }

    //2. 创建queue
    @Bean
    public Queue getQueue(){
        return new Queue("boot-queue",true,false,false,null);
    }

    //3. 绑定在一起
    @Bean
    public Binding getBinding(TopicExchange topicExchange, Queue queue){
        return BindingBuilder.bind(queue).to(topicExchange).with("*.red.*");//with指定路由条件
    }
}

5.测试类模拟生产者发布消息到RabbitMQ

@SpringBootTest
class SpringbootRabbitmqApplicationTests {

    @Autowired
    private RabbitTemplate rabbitTemplate;//这是springboot提供的一个工具类

    @Test
    void contextLoads() {
        rabbitTemplate.convertAndSend("boot-topic-exchange","slow.red.dog","红色大狼狗！！");//参数:交换机   路由  发送消息
    }

}

6.创建消费者监听消息

@Component
public class Consumer {

    @RabbitListener(queues = "boot-queue")//指定监听的列队名
    public void getMessage(Object message){
        System.out.println("接收到消息：" + message);//接收到消息
    }

}

标签：return,springboot,exchange,boot,rabbitMQ,queue,整合,public
来源： https://blog.csdn.net/m0_59054066/article/details/120381889

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

springboot整合rabbitMQ