@Bean public Binding insertQueueBinding(){ return BindingBuilder.bind(insertQueue()).to(topicExchange()).with(MqConstants.HAMALL_INSERT_KEY); }

时间: 2024-03-18 22:45:20 浏览: 71

springboot2.1.4集成rabbitmq，三种模式：fanout direct topic的实现

在IT行业中，Spring Boot是一个非常流行的Java框架，它简化了创建独立、生产级的Spring应用程序。RabbitMQ则是一个开源的消息代理和队列服务器，广泛用于处理异步任务和实现微服务之间的通信。本篇文章将深入探讨如何在Spring Boot 2.1.4版本中集成RabbitMQ，并实现三种主要的交换机类型：Fanout、Direct和Topic模式。我们需要在Spring Boot项目中添加RabbitMQ的相关依赖。在`pom.xml`文件中，引入`spring-boot-starter-amqp`依赖： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> ``` 接下来，配置RabbitMQ的相关参数。在`application.yml`或`application.properties`文件中，设置RabbitMQ服务器的地址、端口、用户名和密码： ```yaml spring: rabbitmq: host: localhost port: 5672 username: guest password: guest ``` 现在，我们来详细讲解三种交换机模式： 1. **Fanout模式**：这是最简单的模式，类似于广播。消息会被发送到所有绑定到该交换机的队列，无需关心路由键。在Spring Boot中，创建一个Fanout交换机并发送消息： ```java @Configuration public class RabbitConfig { @Bean public FanoutExchange fanoutExchange() { return new FanoutExchange("fanout-exchange"); } } @Service public class RabbitService { @Autowired private AmqpTemplate rabbitTemplate; public void sendFanoutMessage(String message) { rabbitTemplate.convertAndSend("fanout-exchange", "", message); } } ``` 这里创建了一个名为`fanout-exchange`的Fanout交换机，然后通过`AmqpTemplate`发送消息。 2. **Direct模式**：Direct模式基于路由键和队列绑定键的完全匹配。每个队列至少有一个绑定，绑定键和路由键相同时，消息才会被投递。例如： ```java @Bean public DirectExchange directExchange() { return new DirectExchange("direct-exchange"); } @Bean public Queue queueA() { return new Queue("queue-a"); } @Bean public Queue queueB() { return new Queue("queue-b"); } @Bean public Binding bindingA(DirectExchange directExchange, Queue queueA) { return BindingBuilder.bind(queueA).to(directExchange).with("key-a"); } @Bean public Binding bindingB(DirectExchange directExchange, Queue queueB) { return BindingBuilder.bind(queueB).to(directExchange).with("key-b"); } ``` 这里有两个队列`queue-a`和`queue-b`，分别通过`key-a`和`key-b`绑定到`direct-exchange`。 3. **Topic模式**：Topic模式允许使用通配符进行路由，如`*.log`或`audit.#`。这种模式在需要根据消息类型进行路由时非常有用。创建Topic交换机并发送消息： ```java @Bean public TopicExchange topicExchange() { return new TopicExchange("topic-exchange"); } @Bean public Queue queueLogs() { return new Queue("logs"); } @Bean public Queue queueAudit() { return new Queue("audit"); } @Bean public Binding bindingLogs(TopicExchange topicExchange, Queue queueLogs) { return BindingBuilder.bind(queueLogs).to(topicExchange).with("*.log"); } @Bean public Binding bindingAudit(TopicExchange topicExchange, Queue queueAudit) { return BindingBuilder.bind(queueAudit).to(topicExchange).with("audit.#"); } @Service public class RabbitService { // ... (同Fanout发送消息) } ``` 这里，`*.log`会匹配所有以`log`结尾的路由键，而`audit.#`会匹配所有以`audit`开头的路由键，包括多级。总结来说，Spring Boot 2.1.4与RabbitMQ的集成提供了丰富的消息传递能力，通过Fanout、Direct和Topic模式可以灵活地处理不同场景下的消息路由需求。在实际项目中，可以根据业务需求选择合适的模式，实现高效、可靠的异步通信和任务处理。

这段代码是使用 Spring AMQP 实现 RabbitMQ 的队列绑定操作。具体来说，它创建了一个名为 "insertQueueBinding" 的 Bean，该 Bean 返回一个 Binding 对象，用于将一个名为 "insertQueue" 的队列绑定到一个名为 "topicExchange" 的主题交换机上，并使用绑定键为 MqConstants.HAMALL_INSERT_KEY。这意味着，当消息使用该绑定键发送到主题交换机时，它将被路由到与该绑定键匹配的队列中。

阅读全文

@Bean public Binding insertQueueBinding(){ return BindingBuilder.bind(insertQueue()).to(topicExchange()).with(MqConstants.HAMALL_INSERT_KEY); }

相关推荐

netty-server中采用的分包拆包源码，java开发用于实战项目

Spring Boot整合RabbitMQ实例（Topic模式）

spring下queue与非持久订阅topic实现

springboot整合rabbitmq topic代码

springboot3 整合rabbitmq 配置topic

【中国房地产业协会-2024研报】2024年第三季度房地产开发企业信用状况报告.pdf

【中国银行-2024研报】美国大选结果对我国芯片产业发展的影响和应对建议.pdf

RM1135开卡工具B17A

毕业设计&课设_宿舍管理系统：计算机毕业设计项目.zip

毕业设计&课设_画手交易管理系统：Java 毕设项目.zip

跑腿平台系统 微信小程序+SSM毕业设计 源码+数据库+论文+启动教程.zip

Visual Studio 2013 Shell

【UBS-2024研报】US Equity Strategy _Earnings Brief 3Q24 November.pdf

Mentor Graphics ModelSim SE 2020.4 x64安装包

毕业设计&课设_智慧社区管理系统：Java 毕设项目.zip

【毕马威-2024研报】2024中国第七届领先汽车科技50榜单.pdf

使用 yolo v3 检测物体的方向.zip

最新推荐

C#应用BindingSource实现数据同步的方法

Android Studio3.6新特性之视图绑定ViewBinding使用指南

WinForm之BindingSource基础操作实例教程

【中国房地产业协会-2024研报】2024年第三季度房地产开发企业信用状况报告.pdf

JHU荣誉单变量微积分课程教案介绍

管理建模和仿真的文件

【实战篇：自定义损失函数】：构建独特损失函数解决特定问题，优化模型性能

如何在ZYNQMP平台上配置TUSB1210 USB接口芯片以实现Host模式，并确保与Linux内核的兼容性？

Naruto爱好者必备CLI测试应用

"互动学习：行动中的多样性与论文攻读经历"

跑腿平台系统微信小程序+SSM毕业设计源码+数据库+论文+启动教程.zip