开源软件名称：

开源软件地址：

开源软件介绍：

BMsgQueue = lockMq + boost::bind

##第一阶段：

1. 实现高并发处理大量的SQL操作。(连接不同的数据服务器。处理一些DB事物)
2. 学习使用BOOST的一些库。
3. 试图在公司的某个应用中使用。（。。。。）

##完成情况：

1. 实现加锁消息队列
2. 用一个交换队列+N多个处理队列，实现消费处理注：最近看到一个实现，使用二级消息队列能在高并发的协同处理，不会使某些消息饿死？有空试试
3. 把DB操作等方法，用boost::bind 绑定上一个callback，形成一个执行节点，实现一种异步DB操作

##day day up

##第二阶段：

1. 在生产者、消费者之间加入Broker，实现Producer ==> Broker ==> Consumer{使得逻辑上解耦分离：生产者只需要知道Broker的存在，负责生产消息到Broker，不需要关心消费者的行为；消费者也只需要知道Broker的存在，负责消费处理Broker上某个MQ队列的消息，不需要关心生产者的行为。}
2. 独立DB模块，使得以后可以方便扩展使用其他数据库。(目前这个只适用Win下链接MySQL)
3. 优化生产者、消费者。(感觉条理不清晰。有可能重构。。。。。)
4. 优化boost::asio 异步Socket。感觉在处理分帧、粘包等问题上处理的不好
5. 每个独立模块加入单元测试代码。
6. 迁移开发环境到linux

##完成情况：

1. 增加一个用协程处理的异步socket

2. 改动目录结构

   --bin--obj--src----net----log----test--win

##更新记录:

• DB执行节点
• 简易DBPool
• 加锁MSG队列
• 增加读取配置文件
• 拆分BMsgQueue 为两个类 线程类BMsgThread和工作队列BMsgQueue
• 使用boost:bind 实现多态
• 加入测试
• 加入vs2010编译环境
• 加入毫秒级事件定时器BEventTimer
• 改DBPool为单例模式
• 定时器timer bug
• 用boost::circular_buffer 替代list
• 一些比较有意思的开源项目地址，作兴趣备注
• boost::asio实现异步socket

//commit b7b3c89acad940efc307bd4de20741f82834a1f1//适用于这个版本##测试代码:

//int main(){
zone.Init();boost::thread_group group;

//开一个交换处理线程group.create_thread(BMsgThread(SWAP_TYPE));//执行处理线程group.create_thread(BMsgThread(RUN_TYPE));group.create_thread(BMsgThread(RUN_TYPE));group.create_thread(BMsgThread(RUN_TYPE));group.create_thread(&test);//boost::asio::io_service ios; //定时器// 增加一个work对象  boost::asio::io_service::work work(ios);  boost::function<void()> func = boost::bind(&BDbWorkZone::TestEvent, zone);BEventTimer::GetTimerInstance()->SetEventListener(ios, func, -1, 1000);//ios.run();group.join_all();return 0;

}