1 subscribe: 自动安排分区, 通过group自动重新的负载均衡； 关于Group的实验： 如果auto commit = true, 重新启动进程，如果是同样的groupID，从上次commit的地方开始消费数据，但是如果换了group后，就可以继续 消费了。 auto commit = ...
分类：
其他好文 时间：
2018-12-10 23:33:10
阅读次数：
270
1、Queue——简单队列 ，类似于Work Queue 2、Work queue——Work模式 ，基于队列queue。不需要提前订阅，也可以消费。但是，消息只能被一个消费者消费。 3、Publish/Subscribe——发布/订阅者模式 ，exchange=fanout。channel会把所有 ...
分类：
其他好文 时间：
2018-12-08 23:54:10
阅读次数：
225
1.一个发布者，多个订阅者 2.支持正则的匹配订阅者 -a 参数意思是指定redis的密码登录 redis-cli -a password #启动1个redis客户端 (订阅者1)SUBSCRIBE 频道名字 PSUBSCRIBE 频道名* redis-cli -a qiangdademima #启 ...
分类：
其他好文 时间：
2018-12-05 18:33:56
阅读次数：
178
1 回顾与本次目标 1.1 回顾 主题通配符 主题语义和用法 WireShark进行抓包分析了报文 报文分析： SUBSCRIBE——订阅主题 SUBACK——订阅确认 UNNSUBSCRIBE——取消订阅 UNSUBACK——取消订阅确认 PUBLISH——发布消息（Qos0，服务质量等级下一节再 ...
分类：
其他好文 时间：
2018-11-13 17:18:36
阅读次数：
171
var G_amount, G_orderid, G_mob, G_payUrl, G_mobilePhone, G_registerFlag, G_FromUserName, G_channel, G_goBackUrl, G_Subscribe, G_type, G_domain; var se... ...
分类：
Web程序 时间：
2018-11-13 10:29:51
阅读次数：
436
2.1 什么是JMS？ JMS是java的消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。 2.2 什么是消息模型 ○ Point-to-Point(P2P) 点对点 ○ Publish/Subscribe(Pub/Sub) 发布订阅 即点对点和发布订阅模型 2.2.1 P2P ( ...
分类：
其他好文 时间：
2018-11-09 19:17:35
阅读次数：
216
https://github.com/MetaMask/obs-store ObservableStore ObservableStore is a synchronous in-memory store for a single value, that you can subscribe to u ...
分类：
Web程序 时间：
2018-11-07 17:12:53
阅读次数：
146
发布订阅 ·服务器状态在pubsub_channels字典保存了所有频道的订阅关系：SUBSCRIBE命令负责将客户端和被订阅的频道关联到这个字典里面，而UNSUBSCRIBE命令则负责解除客户端和被退订频道之间的关联。 ·服务器状态在pubsub_patterns链表保存了所有模式的订阅关系：PS ...
分类：
其他好文 时间：
2018-11-04 11:04:41
阅读次数：
162
this.httpClient.post(url1, JSON.parse(data1) , {responseType: 'blob'}).subscribe(data => { const link = document.createElement('a'); const blob = new ...
分类：
其他好文 时间：
2018-10-18 16:53:48
阅读次数：
470
1.名称 MQTT kafka 2.历史 IBM推出的一种针对移动终端设备的发布/预订协议。 LinkedIn公司开发的分布式发布-订阅消息系统。后来，成为Apache项目的一部分。 3.原理 基于二进制消息 发布/订阅编程模式的消息协议。 发布/订阅（Publish/Subscribe）模式 4. ...
分类：
其他好文 时间：
2018-10-04 18:59:09
阅读次数：
231
