自己实现 message queue 的思路

先写一个思路 有空来写着玩

基于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 函数名

评论

2 楼 zuroc 2008-10-17  

可惜不能持久化

1 楼 heipn 2008-10-17  

ICE有自己的消息队列机制