文章来自：http://www.cnblogs.com/hark0623/p/4173714.html 转发请注明因业务需求，需要flume收集MQTT(Mosquitto)的数据。 方法就是flume自定义source，source中来订阅(subscribe)MQTTflume source的j...
分类：
Web程序 时间：
2014-12-19 14:22:28
阅读次数：
269
一、回顾
让我们回顾一下，在上几章里都讲了什么？总结如下：
《柯南君：看大数据时代下的IT架构（1）业界消息队列对比》
《柯南君：看大数据时代下的IT架构（2）消息队列之RabbitMQ-基础概念详细介绍》
《柯南君：看大数据时代下的IT架构（3）消息队列之RabbitMQ-安装、配置与监控》
《柯南君：看大数据时代下的IT架构（4）消息队列之RabbitMQ--案例（Helloword起航）》
《柯南君：看大数据时代下的IT架构（5）消息队列之RabbitMQ--案例（Work Queues起航）》
二...
分类：
其他好文 时间：
2014-12-15 21:47:29
阅读次数：
154
SELECT TO_CHAR( SYSDATE,'MM-dd') AS beginTime,TO_CHAR( TO_DATE(MAX(C.SUBSCRIBE_DATE),'YYYY-MM-dd'),'MM-dd') AS endTime from TableName
分类：
数据库 时间：
2014-12-15 15:02:52
阅读次数：
196
毕竟是做Android的，对于ContentObserver是很熟悉的，在监听数据库变化时使用很频繁，android有一整套用来监听的API，直接拿来用就行了。观察者模式是用来监听对象的变化的行为型模式。 观察者（Observer）模式又名发布-订阅（Publish/Subscribe）模式。...
分类：
其他好文 时间：
2014-12-10 12:14:39
阅读次数：
181
观察者模式又叫发布订阅模式(publish/subscribe)、模型视图模式(model/view)、源/监听器模式(source/listener)，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。下面是不同编程语言实现的实例。1、java实现package com.sam...
分类：
其他好文 时间：
2014-12-08 19:13:47
阅读次数：
156
1.ZeroMQzmq是一个消息队列。可以在进程内、进程间、TCP、多播中，以消息为单位传输数据，而不是socket的字节流。官方主页上有下载、使用、文档，蛮全的。常用模式有：Request-Reply，Publish-Subscribe，Parallel Pipeline。官网：http://ap...
分类：
系统相关 时间：
2014-12-04 10:01:36
阅读次数：
212
一、发布和订阅机制 当一个客户端通过 PUBLISH 命令向订阅者发送信息的时候，我们称这个客户端为发布者(publisher)。 而当一个客户端使用 SUBSCRIBE 或者 PSUBSCRIBE 命令接收信息的时候，我们称这个客户端为订阅者(subscriber)。为了解耦发布者(publi.....
分类：
编程语言 时间：
2014-11-22 13:19:26
阅读次数：
226
http://www.cnblogs.com/zhenyulu/articles/73723.html一、观察者（Observer）模式观察者模式又叫做发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属...
分类：
其他好文 时间：
2014-11-22 11:53:02
阅读次数：
252
在publish/subscribe模式中使用fanout类型有个缺陷，就是不能选择性接收的消息。我们可以让consumer获得所有已发布的消息中指定的几个消息。在之前的例子中我们这样绑定exchange和队列：channel.queueBind(queueName, EXCHANGE_NAME, ...
分类：
其他好文 时间：
2014-11-15 21:39:10
阅读次数：
299
这次我们试试publish / subscribe模式，也就是将一个消息发送给多个consumer。这里用一个简单的小程序来说明publish / subscribe。由一个provider提供消息，这个消息会被多个consumer接收。consumer对同一个消息做出不同的反应，比如打印、保存到文...
分类：
其他好文 时间：
2014-11-15 21:29:33
阅读次数：
348
