ActiveMQ是一个开源兼容Java Message Service (JMS) 1.1面向消息的中件间. 来自Apache Software Foundation. ActiveMQ提供松耦合的应用程序架构. 先来看两个应用通过RPC通讯的紧耦合: 通过面向消息的中件间, 架构演变为: 我们看到...
分类:
其他好文 时间:
2014-09-09 15:26:38
阅读次数:
296
消息队列是一些平台的通信的基石,各个任务的通信基于消息队列,消息队列的处理速度往往影响整个系统的性能,为了避免多任务同时处理消息队列,通常有任务处理队列时需要加锁来互斥访问。1:假设每个模块有自己的消息队列,任何模块都可以给这个模块发消息,但只有本模块会从消息队列中取消息处理,如下图所示一个消息队列...
分类:
其他好文 时间:
2014-09-09 11:29:48
阅读次数:
257
Windows的应用程序一般包含窗口(Window),它主要为用户提供一种可视化的交互方式,窗口是总是在某个线程(Thread)内创建的。Windows系统通过消息机制来管理交互,消息(Message)被发送,保存,处理,一个线程会维护自己的一套消息队列(Message Queue),以保持线程间的...
1. Windows程序消息机制 Windows GUI程序是基于消息机制的,有个主线程维护着消息泵。这个消息泵让windows程序生生不息。 Windows程序有个消息队列,窗体上的所有消息是这个队列里面消息的最主要来源。这里的While循环使用了GetMessage() 这个方法,这是个阻塞方....
这两天温故了python的multiprocessing多进程模块,看到的pipe和queue这两种ipc方式,啥事ipc?ipc就是进程间的通信模式,常用的一半是socke,rpc,pipe和消息队列等。今个就再把pipe和queue搞搞。#coding:utf-8
importmultiprocessing
importtime
defproc1(pipe):
whileTrue:
..
分类:
编程语言 时间:
2014-09-08 03:16:16
阅读次数:
421
学习云风的skynet源代码,简单记录下。void skynet_globalmq_push(struct message_queue * queue) { struct global_queue *q= Q; uint32_t tail = GP(__sync_fetch_and_add(&q->...
分类:
Web程序 时间:
2014-09-06 17:24:23
阅读次数:
228
1:简要说明 MQ全称为Message Queue,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如.....
分类:
编程语言 时间:
2014-09-05 15:46:31
阅读次数:
187
redis支持发布、订阅的功能,基本的命令有publish、subscribe等。在jedis中,有对应的java方法,并且只能发布字符串消息。为了传输对象,需要将对象进行序列化,并封装成字符串进行处理。将对象序列化后,只能成为字节流,如何封装成字符串是一个难点。...
分类:
其他好文 时间:
2014-09-04 17:08:49
阅读次数:
264
许多朋友都不会使用MSDNLIBRARY(虽然MSDN跟MSDNLIBRARY不是一回事,但是下文中还是简写为MSDN),其实它是非常重要的东西。其实所有的说明都可以在MSDN中查到。环境:VS2008+SP1补丁MSDNLIBRARY2008+SP1补丁打开这个版本的MSDN后,可以看到如图的界面在最左下角,我们可以看到Co..
安装后检查1. 确保服务正常运行首先查看服务的运行状态: #service xxx status为防止对子服务有疏漏,可使用ps + grep 查看: # ps aux |grep xx2. 确保服务连接上消息队列查看相关日志。如nova的日志默认存在于/var/log/nova下。3. 确保各项服...
分类:
其他好文 时间:
2014-09-03 09:33:06
阅读次数:
183