message queue亦即消息隊(duì)列，在linux 下有msgsnd，msgrcv系列，在windows下有msmq，關(guān)于他們的相似及區(qū)別，請(qǐng)查閱相關(guān)資料，本文主要是簡(jiǎn)單介紹一下boost提供的解決方案，及其性能。
boost提供的message queue發(fā)送接口有send，try_send，timed_send，接收接口有receive，try_receive，timed_receive，其它接口有g(shù)et_max_msg，get_max_msg_size，get_num_msg，remove。學(xué)習(xí)難度不高。下面測(cè)試一下send的發(fā)送速度：
測(cè)試代碼：
#define BOOST_ALL_DYN_LINK
#include <boost/interprocess/ipc/message_queue.hpp>
#include <boost/format.hpp>
#include <boost/progress.hpp>
#include <iostream>
#include <string>
#include <vector>
using namespace boost;
using namespace boost::interprocess;
#define MAX_MSG_COUNT 50000
#define MAX_MSG_SIZE 1024
int main ()
{
try{
//Erase previous message queue
message_queue::remove("message_queue");
//Create a message_queue.
message_queue mq
(create_only //only create
,"message_queue" //name
,MAX_MSG_COUNT //max message number
,MAX_MSG_SIZE //max message size
);
{
progress_timer pt;//記錄時(shí)間，多方便！
for(int i = 0; i < 5000; ++i)//可靈活調(diào)整i的大小
{
std::string msg = str(format("hello world %d") % i);
bool bRet = mq.send(msg.c_str(),msg.size(),0);
}
}
}
catch(interprocess_exception &ex)
{
message_queue::remove("message_queue");
std::cout << ex.what() << std::endl;
return 1;
}
//message_queue::remove("message_queue");
return 0;
}
我的測(cè)試結(jié)果如下：
500 0.16s
1000 0.41/0.50 -->表示測(cè)了2次，第一次0.41s，第二次0.50s，下同
5000條 5.88s/6.16
10000 22.81s/22.34
20000 87.92/91.22
最后簡(jiǎn)單總結(jié)一下boost message queue：
優(yōu)點(diǎn)：速度還不錯(cuò)，接口學(xué)習(xí)起來(lái)簡(jiǎn)單，方便易用
缺點(diǎn)：我在windows下測(cè)試，當(dāng)一直在寫(xiě)隊(duì)列時(shí)，用ctrl + c中斷，然后用另一進(jìn)程讀讀隊(duì)列，讀操作時(shí)阻塞。單步跟蹤發(fā)現(xiàn)
是阻塞在interprocess_mutex::lock加鎖的操作上，健壯程度遠(yuǎn)不如msgsnd，msgrcv系列，及msmq，該缺點(diǎn)比較致命。目前沒(méi)有測(cè)試linux下的情況。