文档 "http://cn.rx.js.org/manual/overview.html h24" Observables 是使用 Rx.Observable.create 或创建操作符创建的，并使用观察者来订阅（subscribe）它，然后执行它并发送 next / error / complet ...
分类：
Web程序 时间：
2018-04-05 11:33:12
阅读次数：
924
1.publish channel message：发布频道 publish news "hello" 发布消息到news 频道 2.subscribe channel [channel2] : 订阅频道(可以同时订阅多个频道) 3.unsubscribe channel [channel2] : ...
分类：
其他好文 时间：
2018-03-28 16:50:48
阅读次数：
151
/** * Created by Mrzou on 2018/3/11. *///实现简单的订阅与发布模式的代码块export function pattern() { let currentListeners = [] function subscribe(type, listener) { if ...
分类：
其他好文 时间：
2018-03-11 21:12:55
阅读次数：
153
mqtt协议-broker之moqutte源码研究二之SUBSCRIBE报文处理
分类：
其他好文 时间：
2018-02-28 16:26:59
阅读次数：
189
兔子的Publish/Subscribe是这样的： 有个生产者P，X代表交换机，交换机绑定队列，消费者从队列中取得消息。每次有消息，先发到交换机中，然后由交换机负责发送到它已知的队列中。 生产者代码： 消费者： 启动消费者和生产者，控制台打印 ...
分类：
其他好文 时间：
2018-02-26 13:25:05
阅读次数：
141
Kafka进阶知识 消息概念 消息指的是通信的基本单位。由消息生产者（producer）发布关于某个话题（topic）的消息。简单来说：消息以一种物理方式被发送给了作为代理（broker）的服务器（可能是另外一台机器）。若干的消息使用者（consumer）订阅（subscribe）某个话题，然后生产 ...
分类：
其他好文 时间：
2018-02-12 21:01:26
阅读次数：
176
概念 观察者模式又叫发布订阅模式（Publish/Subscribe），它定义了一种一对多的关系，让多个观察者对象同时监听某一个主题对象，这个主题对象的状态发生变化时就会通知所有的观察者对象，使得它们能够自动更新自己。 作用 注意事项 监听要在触发之前 ...
分类：
编程语言 时间：
2018-02-12 18:38:12
阅读次数：
175
RabbitMQ（三） ——发布订阅 （转载请附上本文链接——linhxx） 一、概述 RabbitMQ的发布订阅（Publish/Subscribe），其将生产者和消费者进一步解耦，生产者生产消息后，交付给交换机，消费者上线后，主动主动去队列中取数据进行处理。该模式也符合上一节工作队列中的ack、 ...
分类：
其他好文 时间：
2018-02-09 15:04:54
阅读次数：
118
14、观察者模式 定义：又被称为发布-订阅（Publish/Subscribe）模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有观察者对象，使它们能够自动更新自己。 UML： PS：事件委托就是观察者模式的一种应用，观察者注册主题对 ...
分类：
其他好文 时间：
2018-01-25 15:48:43
阅读次数：
184
EventBus是一个Android端优化的publish/subscribe消息总线，简化了应用程序内各组件间、组件与后台线程间的通信。 比如请求网络，等网络返回时通过Handler或Broadcast通知UI，两个Fragment之间需要通过Listener通信，这些需求都可以通过EventBu ...
分类：
移动开发 时间：
2018-01-02 16:51:15
阅读次数：
193
