disque 实现简略 按照作者的定义,disque是一个DIStributed以及DISorder的QUEue,也就是分布式乱序队列,更准确地说,是一个消息代理,用队列这个词地话,总是给人一种这是个顺序队列的错觉。? 下文中,我会这个...
分类:
其他好文 时间:
2015-05-03 13:30:06
阅读次数:
188
1.客户端是一个OutSideRuntimeClient,在这个客户端类中有一个消息代理中心transport(类型为ProxiedMessageCenter)2.ProxiedMessageCenter通过取模,将消息请求负载到Silo集群中(即不同的GatewayConnection中)3.消息...
分类:
其他好文 时间:
2015-04-29 23:00:32
阅读次数:
257
本文是 OpenStack 中的 RabbitMQ 使用研究 两部分中的第一部分,将介绍 RabbitMQ 的基本概念,即RabbitMQ 是什么。第二部分将介绍其在 OpenStack 中的使用。1 RabbitMQ 的基本概念RabbitMQ 是实现了高级消息队列协议(AMQP)的开源消息代理软...
分类:
其他好文 时间:
2015-02-16 11:32:56
阅读次数:
424
RabbitMQ是一个消息代理,核心原理:发送消息,接收消息。RabbitMQ主要用于组件之间的解耦,消息发送者无需知道消息使用者的存在,反之亦然。 单向解耦 双向解耦(如:RPC)例如一个日志系统,很容易使用RabbitMQ简化工作量,一个Consumer进行消息的正常处理,另一个Co...
分类:
其他好文 时间:
2014-12-19 15:40:47
阅读次数:
199
RabbitMQ是一个消息代理。它的核心原理非常简单:接收和发送消息。你可以把它想像成一个邮局:你把信件放入邮箱,邮递员就会把信件投递到你的收件人处。在这个比喻中,RabbitMQ是一个邮箱、邮局、邮递员。RabbitMQ和邮局的主要区别是,它处理的不是纸,而是接收、存储和发送二进制的数据——消息。...
分类:
Web程序 时间:
2014-12-18 20:28:12
阅读次数:
346
RMI使用的是同步通信,JMS使用的是异步通信。 JMS中有两个主要的概念:消息代理(message broker)和目的地(destination)。 同步通信的缺点,这也是使用JMS所能够解决的: 运行apache-activemq-5.10.0-bin[1]\...
分类:
编程语言 时间:
2014-11-27 15:58:16
阅读次数:
204
Spring提供的JmsTemplate对原生的JMS API进行了一层薄薄的封装,使用起来非常的方便。 我使用的JMS消息代理插件是Apache的ActiveMQ,建议安装最新版本,因为我之前安装老版本,各种不兼容,各种bug,最新版的act...
分类:
编程语言 时间:
2014-11-19 14:19:53
阅读次数:
126
1、相关概念RabbitMQ是一个消息代理,事实上,它接收生产者产生的消息,然后将消息传递给消费者。在这个过程中,它可以路由,可以缓冲,或者更具你设定的规则来将消息持久化。RabbitMQ和消息传输过程中一般会用一些术语:生产者(Producing):意思无非是指发送消息的那一端,如果一个程序发送消...
分类:
其他好文 时间:
2014-10-19 12:47:40
阅读次数:
394
本文说明如何在树莓派上安装Mosquitto。本文通过两个简单的例子说明树莓派中如何使用MQTT协议实现消息订阅,这些例子包括Mosquitto_sub指令实现消息订阅和paho-python扩展库实现GPIO端口的远程控制。本文中使用了两个工具——Mosquitto paho-python,其中Mosquitto是一款实现了 MQTT v3.1 协议的开源消息代理软件,提供轻量级的,支持发布/订阅的的消息推送模式,使设备对设备之间的消息通信简单易用;另外,paho-python是一个符合MQTT v3.1...
分类:
编程语言 时间:
2014-09-13 21:29:26
阅读次数:
576
MQTT是IBM开发的一个即时通讯协议。MQTT是面向M2M和物联网的连接协议,采用轻量级发布和订阅消息传输机制。Mosquitto是一款实现了 MQTT v3.1 协议的开源消息代理软件,提供轻量级的,支持发布/订阅的的消息推送模式,使设备对设备之间的短消息通信简单易用。...
分类:
其他好文 时间:
2014-09-13 17:21:15
阅读次数:
247