`
- 浏览:
1289101 次
- 性别:
- 来自:
江苏
-
先写一个思路 有空来写着玩
基于ICE和Mysql的message queue
基本流程:
== 服务器端 ==
class Task:
table_id
id
----------------------
1.写数据到数据库
2.Mq.add(task)
写入任务表
检查是否有idle client
有
开一个线程
try:
update 任务表的任务 为对应的client
try:
idle_client.process(task)
except:
取消任务表的任务认领状态
else:
任务表.delete(i)
if not buffer:
从数据库中取没有人认领数据填入
if buffer:
idle_client.process(task)
else:
idle_client_list.add(idle_client)
结束线程
无 加入buffer
== 客户端 ==
接受到服务器端发来的任务:
do(i)
== 表结构 ==
任务表结构 id table_id id client
以下3个表需要做进程内缓存:
task类别的表 id table_name
client表结构 id client地址
表 <-> 处理函数的表 id 函数名
分享到:
Global site tag (gtag.js) - Google Analytics
相关推荐
1. Message Queue的角色 在你的Android程序里,新诞生一个线程,或称执行(Thread)时,并不会自动建立其Message Loop。 Android里并没有Global的Message Queue数据结构,例如,不同APK里的对象不能透过...
MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战MessageQueue实战
详细描述了Android的消息处理机制,Message和MessageQueue类的详解
Message,MessageQueue,Looper,Handler详解
进程间通信之消息队列 ( message queue ) 消息队列是消息的链表,具有特定的格式,并由消息队列标识符标识. 七种进程间通信方式: 一.无名管道( pipe ) 二.有名管道( fifo ) 三.共享内存 ( shared memory ) 四....
Looper MessageQueue 源码解析,通过源码 手写一套自己的Handler。
Handler+Looper+MessageQueue
是一个快速的开源消息组件(框架),支持集群,同等网络,自动检测,TCP,SSL,广播,持久化,XA,和J2EE1.4容器无缝结合,并且支持轻量级容器和大多数跨语言客户端上的Java虚拟机。消息异步接受,减少软件多系统集成...
本例子主要是发送不同的消息。然后根所ID得到指定的消息内容。
Qload Webpshere message queue, WMQ, MQ
Open Message Queue是Sun Java System Message Queue的一个开源版本。Open message queue是一个企业级,可升级,非常成熟的消息服务器。它为面向消息的系统集成提供一套完整的JMS(Java Message Service )实现。...
比较了Zermoq MQTT Rabbitmq 等多种Message Queue方案
基于Websphere Message Queue 的Client通信技术,韩珊珊,翟文军,Websphere Message Queue (WMQ)是一款应用广泛的IBM的商业通讯中间件(Commercial Messaging Middleware),适用于任何需要进行网络通信的系统。...
Sun Java System Message Queue
一个 windows message queue 的通讯例子,消息机制的客户端和服务器端交互通通讯。
一、消息处理中的主要概念 “消息”是在两台计算机间传送的数据单位。消息可以非常简单,例如只包含文本字符串;也可以更复杂,可能包含嵌入对象。 消息被发送到队列中。“消息队列”是在消息的传输过程中保存消息...
Handler获取当前线程中的looper对象,looper用来从存放Message的MessageQueue中取出Message,再有Handler进行Message的分发和处理. 简单定义: 1、Message Queue(消息队列): 用来存放通过Handler发布的消息,通常...
1. 创建多 Task,为每个Task 创建私有的Message Queue,每个Task 只通过自己的私有Message Queue 接收消息;Task 间消息通信通过向对方私有Message Queue 发送消息完 成。 2. Task1:管理Task。负责系统启动时同步...
自己对MessageQueue在Native层的工作不太熟悉,借此机会分析一下。 一、MessageQueue的创建 当需要使用Looper时,我们会调用Looper的prepare函数: public static void prepare() { prepare(true); } private
http://blog.csdn.net/lindonglian