RabbitMQ5. 主题模式（Topic）实现和原理步骤讲解，方式5

简单工作队类的实现配置步骤（5步）

引入AMQP的依赖
创建配置文件，链接消息队列（port name MQ账号密码
创建配置类，声明队列
使用消息生产者发送消息
使用消息消费者接受消息

1 . 引入AMQP的依赖

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

创建配置文件，链接消息队列（port name MQ账号密码

server:port: 9005
spring:application:name: demo04rabbitmq:host: 120.55.58.250port: 5672password: guestusername: guest

创建配置类，声明队列

@Configuration
public class TopicQueueConfig {public static String queueName01="topic.queue01";public static String queueName02="topic.queue02";public static String exchangeName="topic.exchange";@Beanpublic Queue topicQueue01(){return new Queue(queueName01);}@Beanpublic Queue topicQueue02(){return new Queue(queueName02);}@Beanpublic TopicExchange topicExchange(){return new TopicExchange(exchangeName);}@Bean//绑定交换机和队列public Binding bindingQueue01(Queue topicQueue01, TopicExchange topicExchange){return BindingBuilder.bind(topicQueue01).to(topicExchange).with("topic.A");}@Bean//绑定交换机和队列public Binding bindingQueue02(Queue topicQueue02,TopicExchange topicExchange){return BindingBuilder.bind(topicQueue02).to(topicExchange).with("topic.#");}
}

使用消息生产者发送消息

@RestController
public class TestController {@Autowiredprivate RabbitTemplate rabbitTemplate;@RequestMapping("/sendMessage01")public void sendMessage01(){for (int i=1;i<=5;i++){rabbitTemplate.convertAndSend("direct.exchange","routingkey.A","路由模式routingA"+i);}}@RequestMapping("/sendMessage02")public void sendMessage02(){for (int i=1;i<=5;i++){rabbitTemplate.convertAndSend("direct.exchange","routingkey.B","路由模式routingB"+i);}}
}

使用消息消费者接受消息

@Component
public class ReceiveListener {@RabbitListener(queues="direct.queue01")public void ReceiveMessage01(String message){System.out.println("ReceiveMessage01"+message);}@RabbitListener(queues="direct.queue02")public void ReceiveMessage02(String message){System.out.println("ReceiveMessage02"+message);}
}

路径

 http://localhost:9005/sendMessage02http://localhost:9005/sendMessage01

结果展示

http://localhost:9005/sendMessage01

http://localhost:9005/sendMessage02

RabbitMQ5. 主题模式（Topic）实现和原理步骤讲解，方式5相关推荐

RabbitMQ的三种模式-----主题模式(Topic)
主题模式(Topic): 任何发送到Topic Exchange的消息都会被转发到所有关心RouteKey中指定话题的Queue 上 1:简述如上图所示此类交换器使得来自不同的源头的消息可以到达一 ...
RabbitMQ学习系列（五）：routing路由模式和Topic主题模式
(一)routing路由模式在前面一篇博客中讲到了exchange的类型,其中direct类型的exchange就是用于routing路由模式.direct类型的交换机是指:交换机和队列绑定时会设置 ...
RabbitMQ-topic主题模式
RabbitMQ-topic主题模式 Topic: 所有符合routingKey(此时可以是一个表达式)的routingKey所绑定的队列可以接收消息: 发送到topic类型交换机的消息的routin ...
RabbitMQ主题模式（Topic）
主题模式(Topic) 主体模式其实就是在路由模式的基础上,支持了对key的通配符匹配(星号以及井号),以满足更加复杂的消息分发场景. "#" : 匹配一个或者多个 "* ...
（八）RabbitMQ消息队列-通过Topic主题模式分发消息
前两章我们讲了RabbitMQ的direct模式和fanout模式,本章介绍topic主题模式的应用.如果对direct模式下通过routingkey来匹配消息的模式已经有一定了解那fanout也很好 ...
RabbitMq 主题模式（Topic）
rabbitMq 主题模式介绍主题模式可以简单的理解为可以动态路由,*代表一个单词,#可以代替零个或多个单词,单词最多 255 个字节,通过相关的匹配规则后就会将满足条件的消息放到对应的队列中,每个 ...
RabbitMQ的Topics 通配符模式(Topic)
RabbitMQ的Topics 通配符模式(Topic) 模式说明 Topic 类型与 Direct 相比,都是可以根据 RoutingKey 把消息路由到不同的队列.只不过 Topic 类型Exch ...
RabbitMQ之订阅模式与主题模式，消息确认机制
1.订阅模式作用类似与微信公众号,你订阅了就可以接收到消息解读: 1.一个生产者,多个消费者. 2.每一个消费者都有自己的队列 3.生产者没有直搂把洧息发送到队列而是发到了交换机转发器exch ...
23种设计模式【全】包含：模式定义使用场景实现步骤优缺点模式区别 UML类图示例代码注意项等
23种设计模式(全) ***项目地址***:[GitHub](https://github.com/yjhroot/design-pattern) 声明模式分类(3大类) 创建型模式(共5种) 结构 ...

RabbitMQ5. 主题模式（Topic）实现和原理步骤讲解，方式5

路径

结果展示

RabbitMQ5. 主题模式（Topic）实现和原理步骤讲解，方式5相关推荐

最新文章

热门文章