Spring集成RabbitMQ-必须知道的几个概念
上篇《Spring集成RabbiMQ-Spring AMQP新特性》我们了解了最新spring-rabbit的2.0.0.M5版本相较于之前有哪些变化。其实使用Spring-amqp确实简单,其主要就一些jar包,比如spring-amqp,spring-rabbit等。这篇就通过几个基本概念来了解下Spring amqp和原生amqp在用法上有何不同。
消息体
在《RabbitMQ入门》系列中,我们如果要发送一条消息,都是转成字节数组的,类似这样 channel.basicPublish("", QUEUE_NAME, null, "hello world".getBytes()); 但是在spring-amqp中,定义了一个消息类,用于存储消息实体和消息的属性信息。下面是该类的成员变量和方法
- getBody就是获取消息体的内容,相当于上面的“hello world”
- getMessageProperties可以得到有关消息本身的属性信息,比如messageId消息的id标识,timestamp时间戳等等的值
- 使用这将上面属性的值通过setHeader(String key, Object value)方法添加到消息类中
Exchange
读过《RabbitMQ入门》系列,想必对于Exchange应该就不会陌生。在RabbitMQ是实际上所有的消息都不是生产者直接送到消费者,而是需要经过一道Exchange。Exchange接收发送者发送的消息,并根据定好的路由规则将消息派发到相应的队列Queue中去,最终被消息者消费。 在原生的RabbitMQ中,我们通过类似这样的语句来指定需要使用哪种Exchange类型 channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.FANOUT); 显然,这里声明的是Fanout的exchange模式。同时,我们注意到这里并没有一个与Exchange直面相关的类,来设置响应的属性。 在spring-amqp中,就针对Exchange单独定义了一个接口Exchange。
- 通过方法名,我们就很清楚知道每个方法是干什么的,比如isDurable用于判定是否持久化了
- getType方法用于得到该Exchange是那种类型,前面我们已经说过,Exchange的类型主要有Direct、Fanout、Topic和Headers四种,相应的,也有四个实现类集成了接口Exchange,他们分别是DirectExchange、FanoutExchange、TopicExchange和HeadersExchange
下面我们看看DirectExchange和Exchange的关系
- 这四个实现类都是继承了抽象类AbstractExchange,而AbstractExchange也是Exchange的子类。
- DirectExchange的源码如下,我们可以看到其复写了getType方法,并赋值为ExchangeTypes.DIRECT
Queue
Queue是用来存储消息的,消费者从这里拿走消息并消费。与上面提到的Exchange类似,Spring-amqp中也是通过一个类Queue来定义了队列。
- Queue有多种重载形式的构造函数,可以设置queue的名称,是否持久化,是否自动删除等等
- 有一些判断的函数,比如是否持久化了,是否设置了自动删除等
Binding
我们应该还记得在原生的RabbitMQ中,Fanout模式下是如何绑定Exchange和Queue的 channel.queueBind(queueName, EXCHANGE_NAME, ""); 在Spring-amqp中,即使是绑定映射,也单独创建了一个类Binding
- 对于构造函数,后面我们通过几个例子就可以知道每个参数表示的含义
- 提供了一些函数用户获取绑定两端Exchange和Queue的基本信息
Direct模式的绑定 new Binding(someQueue, someDirectExchange, "foo.bar") Fanout模式的绑定 new Binding(someQueue, someFanoutExchange) Topic模式的绑定 new Binding(someQueue, someTopicExchange, "foo.*") 如果您觉得阅读本文对您有帮助,请点一下“推荐”按钮,您的“推荐”将是我最大的写作动力!如果您想持续关注我的文章,请扫描二维码,关注JackieZheng的微信公众号,我会将我的文章推送给您,并和您一起分享我日常阅读过的优质文章。
- Java管理Cookie增删改查操作。
- Intellij Idea乱码解决方案都在这里了
- 神奇,教你用随机数打印hello world
- Mapreduce任务实现邮件监控
- Eclipse中Maven打包程序并在Linux中运行
- SDN开发笔记(七):L2switch源码分析(上)
- spark使用zipWithIndex和zipWithUniqueId为rdd中每条数据添加索引数据
- Spring Boot Server容器配置
- Spring Boot读取配置的几种方式
- 如何用TensorFlow构建RNN?这里有一份极简的教程
- (1024程序员节快乐)阿里祭出大器,Java代码检查插件
- Java多线程神器:join使用及原理
- SpringCloud配置中心内容加密
- Spring Boot日志集成
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- Android Studio屏幕方向以及UI界面状态的保存代码详解
- webshell,禁止你执行
- android实现下拉菜单三级联动
- Flutter 假异步的实现示例
- 详解Android4.4 RIL短信接收流程分析
- android 使用kotlin 实现点击更换全局语言(中日英切换)
- EasySec基于XP的渗透平台
- Android集成腾讯X5实现文档浏览功能
- 8个小时8个小时的上机课!!
- Android实现根据评分添加星级条
- Android悬浮窗的实现(易错点)
- phpcms上传导致getshell详解及案例
- android popupwindow用法详解
- SpringAOP + 注解实现日志管理
- 删除一个表中所有含重复字段的数据