inux应用开发-消息队列
一 消息队列
用于linux系统进程间通信的一个队列
二 使用的主要函数(详细内容参看系统man手册)
1 得到消息队列号
int msgget(key_t key, int flags)
2 发送消息
int msgsnd(int msgid, const void *msgp, size_t msgsz, int msgflag)
3 接...
分类:
系统相关 时间:
2015-05-18 18:57:35
阅读次数:
210
消息队列可以认为是一个消息链表,某个进程往一个消息队列中写入消息之前,不需要另外某个进程在该队列上等待消息的达到,这一点与管道和FIFO相反。Posix消息队列与System V消息队列的区别如下: 1. 对Posix消息队...
分类:
其他好文 时间:
2015-05-18 09:24:21
阅读次数:
159
kafka是一个分布式的消息队列由scala编写,不同于传统的一些消息队列,kafka的设计理念与众不同。
1、kafka的特点
。快速
单台kafka的broker实例能够支撑几千台机器每秒几百兆字节的读写,如果组成集群性能会更强进,从很多人的测试情况来看kafka的读写性能表现不输于当前流行的消息队,甚至领先很多。
。扩展性
弹性透明的扩展,不需要停机,kafka的数据是分区的,可以...
分类:
其他好文 时间:
2015-05-18 01:13:38
阅读次数:
389
一、概要 1.1 Storm(简介) ? ? ?Storm是一个实时的可靠地分布式流计算框架。 ? ? ?具体就不多说了,举个例子,它的一个典型的大数据实时计算应用场景:从Kafka消息队列读取消息(可以是logs,clicks,sensor ...
分类:
其他好文 时间:
2015-05-17 21:59:55
阅读次数:
220
1。什么是异步消息处理?答:对于普通的线程来说,执行完run()方法内的代码后线程就结束了。而异步消息处理线程是指:线程启动后会进入一个无限循环体之中,每执行一次,从线程内部的消息队列中取出一个消息,并回调相应的消息处理函数,执行完一个消息后则继续循环。如果消息队列为空,线程会暂停(一般也就是我们调...
分类:
其他好文 时间:
2015-05-17 18:10:49
阅读次数:
110
安装系统需求:需要2 GB硬盘剩余空间安装步骤:1、使用putty或类似的SSH工具登陆;登陆后运行:screen -S lnmp如果提示screen命令不存在可以执行:yum install screen或apt-get install screen安装,详细的screen教程点击这里。2、下载L...
分类:
其他好文 时间:
2015-05-15 19:44:20
阅读次数:
123
几种MQ产品说明:ZeroMQ : 扩展性好,开发比较灵活,采用C语言实现,实际上他只是一个socket库的重新封装,如果我们做为消息队列使用,需要开发大量的代码RabbitMQ :结合erlang语言本身的并发优势,性能较好,但是不利于做二次开发和维护ActiveMQ: 历史悠久的开源项目,已经在...
分类:
其他好文 时间:
2015-05-15 10:31:10
阅读次数:
1886
1、缘起;2、分布式消息队列功能设计;3、Redis功能分析;4、代码实现。...
分类:
其他好文 时间:
2015-05-15 06:46:33
阅读次数:
206
纯代码干货:访问Redis的工具类;队列接口;队列的Redis实现类;获取队列实例的工具类;向队列中添加任务的代码;从队列中取出任务执行的代码。...
分类:
其他好文 时间:
2015-05-15 06:46:28
阅读次数:
522
kafka是一个开源的分布式消息队列他提供可靠的集群容错机制,并保证故障切换时的数据完整性。下面简单记录一下安装步骤和常用命令。1、安装http://kafka.apache.org/documentation.html下载压缩包并解压可以解压到 /usr/local/kafka2、配置vim co...
分类:
其他好文 时间:
2015-05-14 23:39:51
阅读次数:
20804