1)概述 BUS（总线） 是一个简单的系统，它采用自己的线程机制将一个管道线程的消息分发到一个应用程序当中。总线的优势是：当使用GStreamer的时候，应用程序不需要线程识别，即便GStreamer已经被加载了多个线程。 每一个管道默认包含一个总线，所以应用程序不需要再创建总线。应用程序只需要在总...
分类：
其他好文 时间：
2015-06-09 13:29:18
阅读次数：
302
basic.consume指的是channel在 某个队列上注册消费者,那在这个队列有消息来了之后,就会把消息转发到给此channel处理,如果 这个队列有多个消费者,则会采用轮转的方式将消息分发给消息者.首先是rabbit_reader接收数据包后,解析组装出其中的method,channel方法...
分类：
其他好文 时间：
2015-06-08 01:02:09
阅读次数：
134
原文来源，http://blog.csdn.net/sushengmiyan/article/details/86355501.VCL 概貌先看一下VCL类图的主要分支，如图4.1所示。在图中可以看到，TObject是VCL的祖先类，这也是Object Pascal语言所规定的。但实际上，TObje...
---恢复内容开始---1.Touch事件传递机制 过程有点儿类似于栈, ViewGroup的子类有都继承它的以下3个方法: public boolean dispatchTouchEvent(MotionEvent event); //消息分发, 相当于在一个函数中调用其他函数 public...
分类：
移动开发 时间：
2015-05-08 23:27:44
阅读次数：
211
本文介绍了Kafka的创建背景，设计目标，使用消息系统的优势以及目前流行的消息系统对比。并介绍了Kafka的架构，Producer消息路由，Consumer Group以及由其实现的不同消息分发方式，Topic & Partition，最后介绍了Kafka Consumer为何使用pull模式以及K...
分类：
其他好文 时间：
2015-03-29 19:20:03
阅读次数：
226
RabbitMQ（三） -- Publish/Subscribe`rabbitmq`支持一对多的模式，一般称为发布/订阅。也就是说，生产者产生一条消息后，`rabbitmq`会把该消息分发给所有的消费者。Exchanges之前的教程中，仅仅使用了基本的消息模型：生产者产生消息把消息添加到消息队列消费...
分类：
其他好文 时间：
2015-03-16 22:58:29
阅读次数：
210
在上篇文章RabbitMQ消息队列（五）：Routing 消息路由 中，我们实现了一个简单的日志系统。Consumer可以监听不同severity（严重级别）的log。但是，这也是它之所以叫做简单日志系统的原因，因为是仅仅能够通过severity（严重级别）设定。不支持更多的标准。 比如syslog...
分类：
其他好文 时间：
2015-01-06 15:28:42
阅读次数：
135
排序在所有数据结构中我认为实际使用频率最大之一，并且看似简单，好像都会用，但实际上在合适地方使用合适的排序方式并不简单，并且是其他很多解决问题模型的基础；最近工作过程中实现一个消息总线，过程要解决消息分发时搜索消息效率问题，发现以前学习的数据结构大都已经还回去了，于是抽空好好再学习一下，并且总结.....
分类：
编程语言 时间：
2014-11-27 01:29:06
阅读次数：
147
笔者使用ActiveMQ作为系统中消息分发的服务器，由Java Web程序读取数据库实时记录作为Producer，接收端为C++Builder开发的客户端程序，常驻客户端右下角，弹窗显示实时消息。
测试时发现，当客户端断网（网线拔掉）或者服务器重启等连接中断时，客户端会直接退出，windows也没有报程序崩溃的问题，很是费解。
Debug调试代码发现问题出在自定义的Concumer...
分类：
其他好文 时间：
2014-11-12 11:50:25
阅读次数：
364
实现思路：
WindowManagerService循环读取下面按键消息并分发给窗口，在消息分发前会在PhoneWindowManager.interceptKeyBeforeQueueing方法中进行消息的过滤。因此该实现方式为在消息分发前的interceptKeyBeforeQueueing方法中监听当前按键为音量下键，如果当前状态为锁屏状态，并按键为音量下键，且两次按键间隔时间小于...
分类：
移动开发 时间：
2014-11-11 12:45:41
阅读次数：
239
