多个Consumer的消息分发 之前讲过一个queue对应一个consumer的小例子， 但是在实际项目中，一个consumber肯定是不够的，queue中的消息过多。一个consumber明显会处理过慢，等待时间过长。这时候就需要多个consumber来缓解压力。 消息发布端 无论是创建conne... ...
分类：
其他好文 时间：
2016-12-15 07:23:40
阅读次数：
1386
目录 第1章定时器 1 1.1 创建定时器 1 1.2 销毁定时器 1 1.3 定时器的运作 1 1.3.1 产生WM_TIMER消息 1 1.3.2 分发WM_TIMER消息 2 1.4 WM_TIMER 消息的重入 3 第1章定时器 1.1 创建定时器 请使用API函数 SetTimer 来创建 ...
RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。 消息中间件在互联网公司的使用中越来越多，刚才还看到新闻阿里将RocketMQ捐献给了apache，当然了今天的主角还是讲RabbitMQ。 消息中间件最主要的作用是解耦，中间件最标准的用法是 ...
分类：
其他好文 时间：
2016-12-01 11:43:46
阅读次数：
254
一、Rabbitmq RabbitMQ 即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。RabbitMQ使用的是AMQP协议，它是一种二进制协议。默认启动端口 5672。在 RabbitMQ 中，如下图结构： 左侧 P 代表 生产者，也就是往 RabbitM ...
分类：
编程语言 时间：
2016-10-21 08:00:04
阅读次数：
203
前面四篇已经涵盖了skynet的c层核心，剩下的timer，socket模块本身和actor模型没什么关系，且比较独立，最后再看吧。光用skynet的c接口，是很难在这上面写业务逻辑的，所以要找一种更爽快的方式来使用。官方推荐的是lua,利用lua的协程对skynet的消息分发做了封装，使得acto ...
分类：
Web程序 时间：
2016-09-26 21:35:21
阅读次数：
551
1.微信消息应答流程微信服务器是客户手机和开发服务器信息流通的桥梁。消息流程图如下： 2.微信服务器向开发服务器请求消息1)文本消息处理2)事件消息处理3)开发者认证处理 微信消息处理入口操作，代码示例如下： WeixinApiDispatch消息分发管理类，它提取请求消息的内容，并构建不同类型的消 ...
分类：
微信 时间：
2016-09-18 23:34:48
阅读次数：
297
看过我之前文章的园友可能知道我是做游戏开发，我的很多思路和出发点是按照游戏思路来处理的，所以和web的话可能会有冲突，不相符合。 来说说为啥我要自定义线程模型呢？ 按照我做的mmorpg或者mmoarpg游戏划分，线程被划分为，主线程，全局同步线程，聊天线程，组队线程，地图线程，以及地图消息分发派送 ...
分类：
编程语言 时间：
2016-08-25 20:17:15
阅读次数：
197
常规的网络编程，在消息处理上大概会采用如下方式 定义如上的消息结构 接收方接收后，按如上的消息结构解析数据 然后消息处理，会按msg_id，将消息分发到不同的消息处理函数 RPC则是对这种繁琐的消息处理过程做了封装，自动生成一一对应的消息响应代码，使开发者可以专注于逻辑的处理。 典型的RPC框架有p ...
分类：
其他好文 时间：
2016-07-08 13:36:08
阅读次数：
172
摘要
Kafka是由LinkedIn开发并开源的分布式消息系统，因其分布式及高吞吐率而被广泛使用，现已与Cloudera Hadoop，Apache Storm，Apache Spark集成。本文介绍了Kafka的创建背景，设计目标，使用消息系统的优势以及目前流行的消息系统对比。并介绍了Kafka的架构，Producer消息路由，Consumer Group以及由其实现的不同消息分发方式...
分类：
其他好文 时间：
2016-05-12 13:33:19
阅读次数：
285
