Kafka是一个分布式的消息中间件，可以粗略的将其划分为三部分：Producer、Broker和Consumer。其中，Producer负责产生消息并负责将消息发送给Kafka；Broker可以简单的理解为Kafka集群中的每一台机器，其负责完成消息队列的主要功能（接收消息、消息的持久化存储、为Consumer提供消息、消息清理.....)；Consumer从Broker获取消息并进行后续的操作。...
分类：
其他好文 时间：
2014-06-27 23:55:13
阅读次数：
387
标题：阅读权限：关键词：从已有的关键词中选择文章正文：MSMQ(消息队列)利用MSMQ（Microsoft
Message
Queue），应用程序开发人员可以通过发送和接收消息方便地与应用程序进行快速可靠的通信。消息处理为您提供了有保障的消息传递和执行许多业务处理的可靠的防故障方法。MSMQ与XML...
分类：
其他好文 时间：
2014-06-16 00:23:15
阅读次数：
339
最近一段时间以来，mina很火，和移动开发一样，异常的火爆。前面写了几篇移动开发的文章，都还不错，你们的鼓励就是我最大的动力。好了，废话少说。我们来看下tcp通讯吧。
tcp通讯对于java来说是很简单的。就是socket，也就是大家常说的套接字。大家不要把它看的很难。说白了tcp通讯其实就是数据流的读写。一条输入流，一条输出流。分别复杂发消息和接收消息。
明白了这些，ok，我们来看看我写的例子吧。先看服务器段的源码：...
分类：
Web程序 时间：
2014-06-15 18:16:25
阅读次数：
376
同步服务为每个请求创建单一线程，由此线程完成请求任务：接收消息，处理消息，返回数据；这种情况下服务器资源对所有入栈请求开放，服务器资源被所有入栈请求竞争使用，如果入栈请求过多就会导致服务器资源耗尽宕机，或者导致竞争加剧，资源调度频繁，服务器资源利用效率降低。异步服务则可以分别设置两个线程队列，一个专...
分类：
其他好文 时间：
2014-05-29 16:55:36
阅读次数：
293
在工业生产控制系统中，有许多需要定时完成的操作，如定时显示当前时间，定时刷新屏幕上的进度条，上位机定时向下位机发送命令和传送数据等。特别是在对控制性能要求较高的实时控制系统和数据采集系统中，就更需要精确定时操作。
众所周知，Windows 是基于消息机制的系统，任何事件的执行都是通过发送和接收消息....
消息传递（Message Passing）
通常可用把并行程序理解为一组相互独立的、能够发关和接收消息的组件，这也称为角色模型（ActorModel），在维基百科上可找到更正式的解释
http://en.wikipedia.org/wiki/Actor_model。虽然使用消息传递的场景往往相当复杂，但是其背后的思想却相对简单，正像下面将要看到的示例一样：
消息传递背后的基本思想是这...
分类：
其他好文 时间：
2014-05-18 08:16:28
阅读次数：
373
23.1 介绍
Spring提供了一个JSM集成框架，简化了JMS API的使用。这点很像Spring对JDBC的集成。
JMS大致提供生产消息和消费消息两类功能。JmsTemplate类用来生产消息和同步接收消息【译注：接收消息也就是消费消息】。为了异步接收消息（异步接收消息类似于JavaEE的消息驱动Bean（Message-Driven Bean,MDB），Spring提供了一组消息监听器容器（messagelistener containers），用来创建多个消息驱动POJO（Message-D...
分类：
编程语言 时间：
2014-05-07 15:39:58
阅读次数：
666
MFC应用程序中处理消息的顺序1.AfxWndProc()
该函数负责接收消息，找到消息所属的CWnd对象，然后调用AfxCallWndProc2.AfxCallWndProc()
该函数负责保存消息(保存的内容主要是消息标识符和消息参数)供应用程序以后使用，然后调用WindowProc()函数3....
分类：
其他好文 时间：
2014-05-02 12:51:48
阅读次数：
267
