在Kafka中，LogManager负责管理broker上所有的Log（每一个topic-partition为一个Log）。通过阅读源代码可知其具体完成的功能如下：
1. 按照预设规则对消息队列进行清理。
2. 按照预设规则对消息队列进行持久化（flush操作）。
3. 连接ZooKeeper进行broker、topic、partition相关的ZooKeeper操作。
4. 管理brok...
分类：
其他好文 时间：
2014-06-28 08:25:21
阅读次数：
208
1.Binder(IPC)Linux进程之间要能够互相通信，从而共享资源和信息。所以，操作系统内核必须提供进程间的通信机制（IPC，Inter-Process Communication）。IPC机制种类：采用命名管道（name pipe），消息队列（message queue），信号（signal...
分类：
其他好文 时间：
2014-06-26 20:48:54
阅读次数：
329
一、几个关键概念
1、MessageQueue：是一种数据结构，见名知义，就是一个消息队列，存放消息的地方。每一个线程最多只可以拥有一个MessageQueue数据结构。
创建一个线程的时候，并不会自动创建其MessageQueue。通常使用一个Looper对象对该线程的MessageQueue进行管理。主线程创建时，会创建一个默认的Looper对象，而Looper对象的创建，将自动创...
分类：
移动开发 时间：
2014-06-26 10:59:25
阅读次数：
307
MSMQ(MicroSoft Message Queue，微软消息队列)是在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。它的实现原理是：消息的发送者把自己想要发送的信息放入一个容器中（我们称之为Message），然后...
分类：
其他好文 时间：
2014-06-26 00:33:04
阅读次数：
295
基于RabbitMQ 消息队列的RPC实例！...
分类：
其他好文 时间：
2014-06-25 10:55:26
阅读次数：
891
三种IPC被称作XSI IPC，分别是：
消息队列信号量共享存储器
下面分别介绍三种IPC的用法。
1、消息队列
消息队列是消息的链接表，具有如下函数接口：
msgget：创建一个新队列或打开一个现存的队列。msgsnd：将消息添加到队列尾端。msgrcv：从队列中取消息。
我们可以自行定义一个表示消息的结构体，它由类型字段和实际数据组成：
struct ...
分类：
系统相关 时间：
2014-06-24 20:45:32
阅读次数：
319
前段时间学习EJB，接触到了JMS(Java消息服务)，JMS支持两种消息模型：Point-to-Point（P2P）和Publish/Subscribe（Pub/Sub），即点对点和发布订阅模型。
个人觉得这两个模型挺容易理解的，因为生活中的例子还挺多的。
1， P2P模型
有以下概念：消息队列(Queue)、发送者(Sender)、接收者(Receiver)。每个消息都被发送到一个特定...
分类：
其他好文 时间：
2014-06-22 22:41:24
阅读次数：
319
Android是消息驱动的，实现消息驱动有几个要素：
（1）消息的默示：Message
（2）消息队列：MessageQueue
（3）消息轮回，用于轮回取出消息进行处理惩罚：Looper
（4）消息处理惩罚，消息轮回从消息队列中取出消息后要对消息进行处理惩罚：Handler
日常平凡我们最常应用的就是Message与Handler了，若是应用过HandlerThread或者...
分类：
移动开发 时间：
2014-06-22 21:54:51
阅读次数：
200
前段时间研究WCF接触到了MSMQ，所以认真的学习了一下，下面是我的笔记。我理解的MSMQMSMQ可以被看成一个数据储存装置，就如同数据库，只不过数据存储的是一条一条的记录，而MSMQ存储的是一个一个的消息(messsge)。Message可以被理解为一种数据容器，我们在稍后会讲到。MSMQ一个重要...
分类：
其他好文 时间：
2014-06-21 17:15:58
阅读次数：
238
分析的内核版本号截止到2014-04-15，基于1.05正式版，blogs会及时跟进最新版本号的内核开发进度，若源代码凝视出现”？？？”字样，则是未深究理解部分。 Raw-OS官方站点：http://www.raw-os.org/ Raw-OS托管地址：https://github....
分类：
其他好文 时间：
2014-06-21 14:15:23
阅读次数：
242
