MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的“轻量级”通讯协议，该协议构建于TCP/IP协议上，由IBM在1999年发布。MQTT最大优点在于，可以以极少的代码和有限的带宽， ...
分类：
其他好文 时间：
2018-09-28 16:38:15
阅读次数：
569
Understanding sources and subscribers makes it much easier to understand what's going on with mergeMap under the hood. Where a typical operator invoke ...
分类：
Web程序 时间：
2018-09-27 19:46:48
阅读次数：
155
2018-09-21 20:57:03 观察者模式 观察者模式又叫做发布-订阅（Publish/Subscribe）模式。它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有的观察者对象，使它们能够自动更新自己。 观察者（Observer）模 ...
分类：
其他好文 时间：
2018-09-22 12:31:29
阅读次数：
198
CS模式（客户端/服务器模式） 最场景的信息传递模式，也称为Request/Response模式，或者调用模式。http/https协议即此模式。因为最常用所以大家一般都比较熟悉，这里不重点讲了，大家请看图下图： 发布/订阅模式(Publish/Subscribe) 发布订阅模式相对于BS模式稍微难 ...
分类：
其他好文 时间：
2018-09-22 00:59:44
阅读次数：
247
Store就是把它们联系到一起的对象。Store有以下职责： 维持应用的state： 提供getState( )方法获取state； 提供dispatch(action)方法更新state； 通过subscribe(listener)注册监听器； 通过subscribe(listener)返回的函数 ...
分类：
其他好文 时间：
2018-09-14 16:00:31
阅读次数：
7011
工作队列模式是直接在生产者与消费者里声明好一个队列，这种情况下消息只会对应同类型的消费者。 举个用户注册的列子：用户在注册完后一般都会发送消息通知用户注册成功（失败）。如果在一个系统中，用户注册信息有邮箱、手机号，那么在注册完后会向邮箱和手机号都发送注册完成信息。利用MQ实现业务异步处理，如果是用工 ...
分类：
其他好文 时间：
2018-09-09 18:02:21
阅读次数：
173
1. kafka介绍 1.1. 主要功能 根据官网的介绍，ApacheKafka®是一个分布式流媒体平台，它主要有3种功能： 1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka ...
分类：
其他好文 时间：
2018-09-06 16:15:10
阅读次数：
212
1.Concat 合并多个observables，当你一次性subscribe的时候，次操作符会合并多个observable的结果到输出的obserable中。 如果你的关注点在于输出的顺序的情况下，可以使用此操作符。比如当你需要按顺序发送ajax请求的时候可以使用此操作符。 2.forkJoin ...
分类：
Web程序 时间：
2018-09-03 02:42:14
阅读次数：
414
在ClusterClient源码分析中，我们知道，他是依托于“Distributed Publish Subscribe in Cluster”来实现消息的转发的，那本文就来分析一下Pub/Sub是如何实现的。 还记得之前分析Cluster源码的文章吗？其实Cluster只是把集群内各个节点的信息通 ...
分类：
其他好文 时间：
2018-08-17 17:13:29
阅读次数：
194
subscribe($queue); while(true) { //判断是否有读取的信息 if($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); //保存原始接收... ...
分类：
其他好文 时间：
2018-08-09 12:19:57
阅读次数：
269
