原理 EventBus的核心工作机制如下图 在EventBus3.0架构图： EventBus类 在EventBus3.0框架的内部，核心类就是EventBus,订阅者的注册/订阅，解除注册，以及事件的分发全部在这个核心类中实现; 对于EventBus对象的创建，在框架内部是通过单例模式进行创建;我 ...
分类：
其他好文 时间：
2017-04-25 19:59:39
阅读次数：
209
观察者模式/发布订阅模式：发布者有一个接口，订阅者也有一个接口。发布者中有一个列表 List<Observer> mList = new ArrayList<>();，该列表中存储着所有订阅此发布的订阅者的信息，订阅者接口中有一个方法update，任何订阅者都要实现这个方法。当发布的时候，发布者按照 ...
分类：
其他好文 时间：
2017-04-24 17:17:29
阅读次数：
137
看到一幅有趣的关于Rx学习的图，想知道学习Rx的学习曲线？不，是峭壁！我们可以直接通过Rx的Observer来创建Observable对象。但是，使用这种方式往往比较复杂，在特定的场景下，我们可以直接使用Rx提供的特定Subject来实现Observable。这些特定的Subject是主题和订阅者的混合体..
分类：
其他好文 时间：
2017-04-20 12:11:05
阅读次数：
247
声明：本文非EamonSec原创，copy自网上下载的某个个文件 1、RocketMQ介绍 1.1. 简介 RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力 选用理由： ...
分类：
其他好文 时间：
2017-04-16 21:09:56
阅读次数：
259
关键词：编程范式,事件驱动,回调函数,观察者模式 举个简单的例子：有些人喜欢的某个公众号，然后去关注这个公众号，哪天这个公众号发布了篇新的文章，没多久订阅者就会在微信里收到这个公众号推送的新消息，如果感兴趣就打开来阅读。 事件驱动模型可以理解为上面的例子，是设计模式中观察者模式的一种典型应用。除了订 ...
分类：
其他好文 时间：
2017-04-14 22:26:07
阅读次数：
152
控制器之间的交互方式广播 broadcast, 发射 emit 事件 类似于 js中的事件 , 可以自己定义事件 向上传递直到 document 在AngularJs中 向上传递直到 rootScope 观察者模式, 订阅发布模式 类似于js中的事件机制 订阅者.on('xx发布博客', funct ...
分类：
Web程序 时间：
2017-04-12 20:47:45
阅读次数：
1490
Redis发送订阅通信模式 Redis发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。 Redis 发布订阅(pub/sub)实现了消息系统，发送者(在redis术语中称为发布者)在接收者(订阅者)接收消息时发送消息。传送消息的链路称为信道。 在Re ...
分类：
其他好文 时间：
2017-04-10 15:16:14
阅读次数：
174
启动服务 首先启动 go-nats-streaming 服务。为了更加能说明问题，我们启动的时候不使用默认端口号 编写一个简单的应用 上面的代码使用了订阅者启动参数的 StartWithLastReceived，这个函数的含义为：读取刚才发布者最近发布的消息内容。具体还有哪些启动参数，以下列出详情： ...
分类：
其他好文 时间：
2017-04-07 19:44:03
阅读次数：
875
订阅者可以订阅一个或多个频道，发布者向一个频道发送消息后，所有订阅这个频道的订阅者都将收到消息，而发布者也将收到一个数值，这个数值是收到消息的订阅者的数量。订阅者只能收到自它开始订阅后发布者所发布的消息，之前发布的消息呢，就不可能收到了。多的不说看代码！！..
分类：
编程语言 时间：
2017-03-23 22:34:53
阅读次数：
173
