SpringBoot SpringBoot 开发实用篇 5 整合第三方技术 5.24 SpringBoot 整合 RabbitMQ(topic 模式)_资讯

SpringBoot SpringBoot 开发实用篇 5 整合第三方技术 5.24 SpringBoot 整合 RabbitMQ(topic 模式)

创始人

2024-02-08 23:42:56

0次

SpringBoot

【黑马程序员SpringBoot2全套视频教程，springboot零基础到项目实战（spring boot2完整版）】

SpringBoot 开发实用篇

文章目录

- - SpringBoot
  - SpringBoot 开发实用篇
  - 5 整合第三方技术
  - - 5.24 SpringBoot 整合 RabbitMQ(topic 模式)
    - - 5.24.1 整合RabbitMQ 【topic 模式】
      - 5.24.2 小结

5 整合第三方技术

5.24 SpringBoot 整合 RabbitMQ(topic 模式)

5.24.1 整合RabbitMQ 【topic 模式】

之前我们已经使用直连交换机模式【direct 】

在这里插入图片描述

完成了消息队列的使用，现在来用一下另一种模式，主题交换机

直接把直连的代码复制一份

在这里插入图片描述

等修改完成后，笔者会给出所有的代码

消息服务实现类

package com.dingjiaxiong.service.impl.rabbitmq.topic;import com.dingjiaxiong.service.MessageService;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** ClassName: MessageServiceRabbitmqDirectImpl* date: 2022/10/22 21:25** @author DingJiaxiong*/@Service
public class MessageServiceRabbitmqTopicImpl implements MessageService {@Autowiredprivate AmqpTemplate amqpTemplate;@Overridepublic void sendMessage(String id) {System.out.println("待发送短信的订单已纳入处理队列(rabbitmq topic)，id " + id);amqpTemplate.convertAndSend("topicExchange","topic.order.id",id);}@Overridepublic String doMessage() {return null;}
}

配置类

package com.dingjiaxiong.service.impl.rabbitmq.topic.config;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** ClassName: RabbitConfigtopic* date: 2022/10/22 21:29** @author DingJiaxiong*/@Configuration
public class RabbitConfigTopic {//存储消息的消息队列的对象@Beanpublic Queue topicQueue(){return new Queue("topic_queue"); //是否持久化、是否连接专用、是否自动删除【后面其实有三个boolean参数，默认值是tff】}//还可以再来个队列，让它绑在同一个交换机上@Beanpublic Queue topicQueue2(){return new Queue("topic_queue2"); //是否持久化、是否连接专用、是否自动删除【后面其实有三个boolean参数，默认值是tff】}//消息队列不能直接使用，需要使用一个交换机去绑定它@Beanpublic TopicExchange topicExchange(){return new TopicExchange("topicExchange");}//做消息队列与交换机的绑定关系@Beanpublic Binding bindingTopic(){return BindingBuilder.bind(topicQueue()).to(topicExchange()).with("topic.order.id");}//做消息队列与交换机的绑定关系@Beanpublic Binding bindingTopic2(){return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with("topic2");}}

两个监听器，删掉2，留一个

package com.dingjiaxiong.service.impl.rabbitmq.topic.listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;/*** ClassName: MessageListener* date: 2022/10/22 21:40** @author DingJiaxiong*/@Component
public class MessageListener {//收一个消息@RabbitListener(queues = "topic_queue")public void receive(String id){System.out.println("已完成短信发送业务(rabbitmq topic 绑的1号消息队列)，id：" + id);}//收一个消息@RabbitListener(queues = "topic_queue2")public void receive2(String id){System.out.println("已完成短信发送业务(rabbitmq topic 绑的2号消息队列)，id：" + id);}}

然后把direct 那套处理一下，全部加载就乱套了

在这里插入图片描述