在上篇文章中,我们解决了从发送端(Producer)向接收端(Consumer)发送“Hello World”的问题。在实际的应用场景中,这是远远不够的。从本篇文章开始,我们将结合更加实际的应用场景来讲解更多的高级用法。 当有Consumer需要大量的运算时,RabbitMQ Server需要一定的...
分类:
其他好文 时间:
2015-01-06 13:21:35
阅读次数:
179
2. Sending第一个program send.cs:发送Hello world 到queue。正如我们在上篇文章提到的,你程序的第9行就是建立连接,第12行就是创建channel,第14行创建名字为hello的queue。 1 using System; 2 using RabbitMQ.Cl...
分类:
其他好文 时间:
2015-01-06 11:53:32
阅读次数:
106
handler 主要用于发送消息和接收消息,handler可以更新ui延时更新uilooper 主要用于从消息队列中循环读取消息并把消息发送给handlermessageQueue 是一个消息队列,用来存储消息。下面从源码的角度分析三者的关系:Handler handler = new Handle...
分类:
其他好文 时间:
2015-01-05 21:45:44
阅读次数:
195
无锁队列
第一篇文章末尾我们提到的《无锁队列的实现》(陈皓(hào)),该文末尾提到的“用数组实现无锁队列”,即用 RingBuffer 实现的无锁队列。
分类:
其他好文 时间:
2015-01-05 10:44:19
阅读次数:
305
今天在搭建OpenStack的时候需要安装RabbitMQ,可是使用yum install rabbitmq-server安装之后,按照OpenStack官方提供的文档修改guest用户密码的时候却出现了如下错误:[root@controller ~]# rabbitmqctl change_p.....
分类:
其他好文 时间:
2015-01-04 21:21:12
阅读次数:
895
进入命令行:C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.3.3\sbin运行下面命令来启用管理插件:rabbitmq-plugins enable rabbitmq_management可以看到下面的输出停止RabbitMQ服务:...
分类:
其他好文 时间:
2015-01-04 18:56:58
阅读次数:
166
MQ全称为Message Queue,消息队列(MQ)是一种应用程序对应用程序的通信方法RabbitMQ是流行的开源消息队列系统,用erlang语言开发几个概念说明:Broker:简单来说就是消息队列服务器实体。 Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。 Queu...
分类:
其他好文 时间:
2015-01-04 16:35:20
阅读次数:
295
前续一个无锁消息队列引发的血案:怎样做一个真正的程序员?(一)——地:起因平行时空 在复制好上面那一行我就先停下来了,算是先占了个位置,虽然我知道大概要怎么写,不过感觉还是很乱。 我突然想到,既然那么纠结,那么混乱,那么不知所措,我们不如换个视角。记得高中时看过的为数不多的长篇小说《穆斯林的葬礼.....
分类:
其他好文 时间:
2015-01-03 23:43:46
阅读次数:
518
原文出处:http://shmilyaw-hotmail-com.iteye.com/blog/1897635简介 在前面一篇文章里讨论过几种应用系统集成的方式,发现实际上面向消息队列的集成方案算是一个总体比较合理的选择。这里,我们先针对具体的一个消息队列Activemq的基本通信方式进行探讨。a....
分类:
其他好文 时间:
2015-01-03 21:04:35
阅读次数:
180
程序msg1.c用于接收消息
#include
#include
#include
#include
#include
#include
struct my_msg_st {
long int my_msg_type;
char some_text[BUFSIZ];
};
int main()
{
int running = 1;
int msg...
分类:
系统相关 时间:
2015-01-03 17:23:46
阅读次数:
262