rabbitmq-5-案例1-简单的案例
最简单的案例:
git@gitee.com:n_zhe/rabbitMQ-demo.git
通过简单的例子分析mq是怎样发送和拉取消息的:
public Connection newConnection() throws IOException, TimeoutException { return newConnection(this.sharedExecutor, Collections.singletonList(new Address(getHost(), getPort()))); }
最终调用:
参数executor默认为null,addrs为mq的地址+端口,clientProvideName为null
继续观察:
FrameHandlerFactory fhFactory = createFrameHandlerFactory();
其实这个FrameHandlerFactory就是对SocketFactory进行了一次封装:
最终返回的为SocketFrameHandler类,该类是对Socket进行了封装:
继续向下走,会使用之前的返回的FrameHander对象new一个AMQConnection对象:
然后会调用AMQConnection的start()方法:
下边这个for循环,第一次启动后就直接return??
③返回AMQConnection对象
通过Connectin来创建Channel,返回ChannelN对象
④通过ChannelN对象的basicPublish方法发布消息
先通过exchange,routingKey等参数构建一个Publish,进而构建一个AMQCommand对象
最终:
流程:
消费端:
开始也是获取ConnectionFactory、Connection、Channel,然后通过Channel来操作(不管是生产端还是消费端,mq都是通过channel来进行操作的)
①消费端会声明一个消费队列
// 5、常见一个消费者 QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
②通过Channel将消费这和消息队列关联
队列消费者,用于监听队列中的消息。调用nextDelivery方法时,内部实现就是调用队列的take方法。该方法的作用:获取并移除此队列的头部,在元素变得可用之前一直等待(如果有必要)。说白了就是如果没有消息,就处于阻塞状态。
运行结果:
消费端:
等待获取消息======
生产端:
已经发送消息了
当生产端发送消息之后,消费端输出:
等待获取消息====== 消费端hello rabbit-mq 消费端hello rabbit-mq 消费端hello rabbit-mq 消费端hello rabbit-mq 消费端hello rabbit-mq
以上代码没有指定exchange,因此rabbitmq server会自动通过默认的exchange(即default exchange)取转发消息,如果生产者的routingkey和消费端的队列名称相同的话,则能够转发成功,否则失败
原文地址:https://www.cnblogs.com/nxzblogs/p/11595182.html
- python + selenium + PhantomJS 获取腾讯应用宝APP评论
- 简单实用的sql小技巧(第二篇)(r3笔记第86天)
- Java代码效率优化【面试+提高】
- 利用逻辑回归模型判断用户提问意图
- 关于reset sequence(r3笔记第85天)
- 【编程基础第十二讲】web开发编程基础--回调函数
- typeof的一些兼容性问题
- 类型转换的判定方式
- 【Java案例】打印杨辉三角
- html标签属性(attribute)和dom元素的属性(property)
- 关于long类型的转换(r3笔记第84天)
- jQuery的事件模型
- 关于索引的内部信息(r3笔记第83天)
- 【Java案例】打印五环
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 连Python产生器(Generator)的原理都解释不了,还敢说Python用了5年?
- WordPress插件File-Manager任意文件上传复现
- CVE-2020-15778:OpenSSH命令注入漏洞复现
- TokyoWesterns CTF 6th 2020 部分WP
- 极客巅峰2020 部分WriteUp
- norecon:一款自动化recon工具
- Bashtop:一款功能强大的LinuxOSXFreeBSD资源监控工具
- iOS 推送手机消息背后的技术
- 手把手教你使用 cert-manager 签发免费证书
- flink源码分析之TaskManager启动篇
- 【面试说】一年半前端 Bigo 一二三 面
- 【前端进阶】深入浅出浏览器事件循环【内附练习题】
- 【面试说】一年半前端 Shopee 面经
- 【前端进阶】深入浅出 JavaScript 中的 this
- 手把手带你玩转 AWS Lambda