上篇我们介绍了distributed pub/sub消息传递机制。这是在同一个集群内的消息共享机制：发布者（publisher）和订阅者（subscriber）都在同一个集群的节点上，所有节点上的DistributedPubSubMediator通过集群内部的沟通机制在底层构建了消息流通渠道。在ac ...
分类：
其他好文 时间：
2018-12-10 11:31:16
阅读次数：
221
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
废话：上一篇https://www.cnblogs.com/adouwt/p/9928278.html 提到了vue实现的基本实现原理：Object.defineProperty() -数据劫持 和 发布订阅者模式（观察者），下面讲的就是数据劫持在代码中的具体实现。 1.先看如何调用 new一个对象 ...
分类：
其他好文 时间：
2018-11-30 13:53:51
阅读次数：
215
观察者模式，又被称为发布 订阅模式或消息机制，定义了一种依赖关系，解决了主体对象与观察者之间功能耦合。 虽然说观察者模式，又被称为发布 订阅模式，但是实际上它们之间存在差异的，区别在于调度的地方不同。 上图： 总结 1. 从两张图片可以看到，最大的区别是调度的地方。虽然两种模式都存在订阅者和发布者（ ...
分类：
其他好文 时间：
2018-11-25 13:26:09
阅读次数：
140
将redis发布订阅模式用做消息队列和rabbitmq的区别： 可靠性 可靠性 redis ：没有相应的机制保证消息的可靠消费，如果发布者发布一条消息，而没有对应的订阅者的话，这条消息将丢失，不会存在内存中； rabbitmq：具有消息消费确认机制，如果发布一条消息，还没有消费者消费该队列，那么这条 ...
分类：
其他好文 时间：
2018-11-23 21:04:08
阅读次数：
267
一、 EventBus简介 1.1、EventBus EventBus 是一个 Android 事件发布/订阅框架，通过解耦发布者和订阅者简化Android 事件传递，这里的事件可以理解为消息，本文中统一称为事件。事件传递既可用于 Android 四大组件间通讯，也可以用户异步线程和主线程间通讯等等 ...
分类：
其他好文 时间：
2018-11-12 11:34:58
阅读次数：
226
采用 数据劫持 + 发布-订阅 模式，通过Object.definePropety()来劫持各个属性的setter，getter，在数据变动时发布消息给订阅者，触发相应的监听回调 需要对observer的数据对象进行递归遍历，包括子属性对象的属性，都加上setter和getter ，这样，给这个对象 ...
分类：
其他好文 时间：
2018-11-12 11:22:53
阅读次数：
175
[toc] 操作符是用来干什么的？Rxjava中的每一个操作符基本都是用来创建Observable，也就是被订阅者。RxJava中常用的操作符包括：创建操作符，连接操作符，工具操作符，变换操作符，过滤操作符，条件操作符，布尔操作符，合并操作符。本次着重了解创建操作符的用法。 创建操作符 10种常用的 ...
分类：
编程语言 时间：
2018-11-11 15:58:07
阅读次数：
205
Kafka是最初由Linkedin公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式日志系统（也可以当做MQ系统），常见可以用于web/nginx日志、访问日志，消息服务等等，Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。
分类：
其他好文 时间：
2018-11-10 23:51:39
阅读次数：
164
