網(wǎng)絡(luò)服務(wù)器軟件開發(fā)/中間件開發(fā)，關(guān)注ACE/ICE/boost

     message queue亦即消息隊列，在linux 下有msgsnd，msgrcv系列，在windows下有msmq，關(guān)于他們的相似及區(qū)別，請查閱相關(guā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í)難度不高。下面測試一下send的發(fā)送速度：
    測試代碼：

#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;//記錄時間，多方便！
  
   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;
}

  我的測試結(jié)果如下：
500    0.16s
1000   0.41/0.50  -->表示測了2次，第一次0.41s，第二次0.50s，下同
5000條 5.88s/6.16
10000  22.81s/22.34
20000  87.92/91.22

   最后簡單總結(jié)一下boost message queue：
  優(yōu)點：速度還不錯，接口學(xué)習(xí)起來簡單，方便易用
  缺點：我在windows下測試，當(dāng)一直在寫隊列時，用ctrl + c中斷，然后用另一進(jìn)程讀讀隊列，讀操作時阻塞。單步跟蹤發(fā)現(xiàn)
  是阻塞在interprocess_mutex::lock加鎖的操作上，健壯程度遠(yuǎn)不如msgsnd，msgrcv系列，及msmq，該缺點比較致命。目前沒有測試linux下的情況。