kafka的并行度与JStorm性能优化
> Consumers
Messaging traditionally has two models: queuing and publish-subscribe. In a queue, a pool of consumers may read from a server and each message goes to one of th...
分类:
Web程序 时间:
2015-08-18 01:20:54
阅读次数:
1040
《JAVA与模式》之观察者模式在阎宏博士的《JAVA与模式》一书中开头是这样描述观察者(Observer)模式的: 观察者模式是对象的行为模式,又叫发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听器(Source/Listener)模式或从属者....
分类:
其他好文 时间:
2015-08-11 20:45:27
阅读次数:
134
最近有项目中用到消息队列,JMS规范中实现最好的开源框架就是activemq,所以选择它(当然这是我老大决定的,像我这中刚入职场的小菜鸟考虑问题还不太全面)作为消息队列传输数据,公司有有成型的消息队列框架的实现,可是公司中的框架 实现的好繁琐,考虑的好全面,考虑到了同步消息传输和异步消息传输,持久化消息存储和非持久化消息存储,消息之间点对点传输还是pubilc/subscribe(订阅)等等,考虑...
分类:
其他好文 时间:
2015-08-09 12:39:39
阅读次数:
141
redis高级应用-发布与订阅、发布/订阅的简易模型、发布与订阅(pub/sub)类别、 redis 通过 publish 、subscribe、unsubscribe等命令实现了订阅与发布模式, 这个功能提供两种信息机制,分别是订阅/发布到频道和订阅/发布到模式...
分类:
其他好文 时间:
2015-08-09 10:52:19
阅读次数:
206
redis支持pub/sub功能(可以用于消息服务器),这个功能类似mq,这里做一个简单的介绍Pub/Sub Pub/Sub 从字面上理解就是发布(Publish)与订阅(Subscribe),在Redis中,你可以设定对某一个key值进行消息发布及消息订阅, 当一个key值上...
分类:
其他好文 时间:
2015-08-07 19:32:03
阅读次数:
131
1意图定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。2别名依赖(Dependents), 发布-订阅(Publish-Subscribe)3动机将一个系统分割成一系列相互协作的类有一个常见的副作用:需要维护相关对象间的一致性。我们不希望为了维...
分类:
编程语言 时间:
2015-08-02 19:39:40
阅读次数:
161
一、 发布订阅消息
发布订阅(pub/Sub)是一种消息通信模式,主要的目的是解除消息发布者和消订阅者之间的耦合,Redis作为一个pub/sub的server,在订阅者和发布者之间起到了消息路由的功能。订阅者可以通过subscribe和psubscribe命令向Redis Server订阅自己感兴趣的消息类型,Redis将信息类型称为通道(channel).当发布者通过publish...
分类:
其他好文 时间:
2015-07-31 18:20:56
阅读次数:
108
http://www.cocoachina.com/industry/20140609/8737.html1.对数组的观察有了这些Category,大部分的Delegate都可以使用RAC来做。或许你会想,可不可以subscribe NSMutableArray.rac_sequence.signa...
分类:
其他好文 时间:
2015-07-31 01:19:30
阅读次数:
198
简单说吧,该模式就只有两种角色,观察者对象(主题)和被观察者对象(观察者)。主题接收被观察者,有更新就通知被观察者。根据依赖倒转原则高内聚低耦合的目标,我们分别对此增加两个抽象接口。
概念:
观察者模式(Observer),又称发布\订阅模式(Publish\Subscribe)。它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有...
分类:
其他好文 时间:
2015-07-29 19:26:01
阅读次数:
135
概述及基本概念
**EventBus**是一个Android端优化的publish/subscribe消息总线,简化了应用程序内各组件间、组件与后台线程间的通信。比如请求网络,等网络返回时通过Handler或Broadcast通知UI,两个Fragment之间需要通过Listener通信,这些需求都可以通过**EventBus**实现。
作为一个消息总线,有三个主要的元素:
Event:...
分类:
移动开发 时间:
2015-07-23 10:44:34
阅读次数:
269