Linux POSIX IPC 消息隊列

来源:http://www.cnblogs.com/xiaojiang1025/archive/2016/10/08/5937510.html
-Advertisement-
Play Games

模型: 1. 創建/獲取消息隊列fd :mq_open() 設置/獲取消息隊列屬性 :mq_get() 發送/接收消息 :mq_send()/mq_receive() 脫接消息隊列 :mq_close() 刪除消息隊列 :mq_unlink() 頭文件 POSIX mq VS Sys V mq的優勢 ...


模型:

  1. 創建/獲取消息隊列fd :mq_open()
  • 設置/獲取消息隊列屬性 :mq_get()
  • 發送/接收消息 :mq_send()/mq_receive()
  • 脫接消息隊列 :mq_close()
  • 刪除消息隊列 :mq_unlink()

頭文件

#include<mqueue.h>
#include <sys/stat.h>
#include <fcntl.h>

POSIX mq VS Sys V mq的優勢

  • 更簡單的基於文件的應用介面
  • 完全支持消息優先順序(優先順序最終決動隊列中消息的位置)
  • 完全支持消息到達的非同步通知,這通過信號或是線程創建實現
  • 用於阻塞發送與接收操作的超時機制

消息隊列名

$man mq_overview知:消息隊列由一個形如'/somename'的名字唯一標識,名字字元串的最大長度不能朝著哦NAME_MAX(i.e.,255),兩個進程通過使用同一個消息隊列的名字來通信

mq_open()

//創建一個POSIX消息隊列或打開一個已經存在的消息隊列,成功返回消息隊列描述符mqdes供其他函數使用,失敗返回(mqd_t)-1設errno
//Link with -lrt.
mqd_t mq_open(const char *name, int oflag);
mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr);

oflag
must include one of:

  • O_RDONLY表示以只接收消息的形式打開消息隊列
  • O_WRONLY表示以只發送消息的形式打開消息隊列
  • O_RDWR表示以可接收可發送的形式打開消息隊列

can be Bitwised ORed:

  • O_NONBLOCK以nonblocking的模式打開消息隊列
  • O_CREAT如果一個消息隊列不存在就創建它,消息隊列的擁有者的UID被設為調用進程的effective UID,GID被設為調用進程的effective GID
  • O_EXCL確保消息隊列被創建,如果消息隊列已經存在,則發生錯誤

mode如果oflag里有O_CREAT,則mode用來表示新創建的消息隊列的許可權
attr如果oflag里有O_CREAT,則attr表示消息隊列的屬性,如果attr是NULL,則會按照預設設置配置消息隊列(mq_overview(7) for details.)

mq_setattr() / mq_getattr()

//設置/修改 / 獲取消息隊列屬性,成功返回0,失敗返回-1設errno
//Link with -lrt.
int mq_setattr(mqd_t mqdes, const struct mq_attr *newattr, struct mq_attr *oldattr);
int mq_getattr(mqd_t mqdes, struct mq_attr *attr);

mqattr結構體

struct mq_attr {
    long mq_flags;      /* Flags: 0 or O_NONBLOCK */
    long mq_maxmsg;     /* Max. # of messages on queue */
    long mq_msgsize;    /* Max. message size (bytes) */
    long mq_curmsgs;    /* # of messages currently in queue */
};

mq_send() / mq_timesend()

//發送消息到mqdes指向的消息隊列。成功返回0,失敗返回-1設errno
//Link with -lrt.
int mq_send(mqd_t mqdes, const char *msg_ptr,size_t msg_len, unsigned int msg_prio);

//如果消息隊列滿
#include<time.h>        //額外的header
int mq_timedsend(mqd_t mqdes, const char *msg_ptr,size_t msg_len, unsigned int msg_prio,const struct timespec *abs_timeout);

msg_len msg_ptr指向的消息隊列的長度,這個長度必須<=消息隊列中消息長度,可以是0
msg_prio 一個用於表示消息優先順序的非0整數,消息按照優先順序遞減的順序被放置在消息隊列中,同樣優先順序的消息,新的消息在老的之後,如果消息隊列滿了,就進入blocked狀態,新的消息必須等到消息隊列有空間了進入,或者調用被signal中斷了。如果flag里有O_NOBLOCK選項,則此時會直接報錯
abs_timeout:如果消息隊列滿了,那麼就根據abs_timeout指向的結構體表明的時間進行鎖定,裡面的時間是從970-01-01 00:00:00 +0000 (UTC)開始按微秒計量的時間,如果時間到了,那麼mq_timesend()立即返回

struct timespec {
    time_t tv_sec;        /* seconds */
    long   tv_nsec;       /* nanoseconds */
};

mq_receive()/mq_timedreceive()

//從消息隊列中取出優先順序最高的裡面的最老的消息,成功返回消息取出消息的大小,失敗返回-1設errno
//具體功能參照mq_send()/mq_timesend()
//Link with -lrt.
ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned int *msg_prio);
#include<time.h>        //額外的header
ssize_t mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned int *msg_prio, const struct timespec *abs_timeout);

mq_notify()

//允許調用進程註冊或去註冊同步來消息的通知,成功返回0,失敗返回-1設errno
//Link with -lrt.
int mq_notify(mqd_t mqdes, const struct sigevent *sevp);

sevp指向sigevent的指針

  • 如果sevp不是NULL,那麼這個函數就將調用進程註冊到通知進程,只有一個進程可以被註冊為通知進程
  • 如果sevp是NULL且當前進程已經被註冊過了,則去註冊,以便其他進程註冊
union sigval {                  /* Data passed with notification */
    int     sival_int;          /* Integer value */
    void*   sival_ptr;          /* Pointer value */
};
struct sigevent {
    int     sigev_notify;       /* Notification method */
    int     sigev_signo;        /* Notification signal */
    union sigval    sigev_value;    /* Data passed with notification */
    void(*sigev_notify_function) (union sigval); //Function used for thread notification (SIGEV_THREAD)
    void*   sigev_notify_attributes;    // Attributes for notification thread (SIGEV_THREAD)
    pid_t   sigev_notify_thread_id;     /* ID of thread to signal (SIGEV_THREAD_ID) */
};

sigev_notify使用下列的巨集進行配置:

  • SIGEV_NONE調用進程仍舊被註冊,但是有消息來的時候什麼都不通知
  • SIGEV_SIGNAL通過給調用進程發送sigev_signo指定的信號來通知進程有消息來了
  • SIGEV_THREAD一旦有消息到了,就激活sigev_notify_function作為新的線程的啟動函數

mq_close()

//關閉消息隊列描述符mqdes,如果有進程存在針對這個隊列的notification request,那麼也會被移除
//成功返回0,失敗返回-1設errno
//Link with -lrt.
int mq_close(mqd_t mqdes);
//移除隊列名指定的消息隊列,一旦最後一個進程關閉了針對這個消息隊列的描述符,就會銷毀這個消息隊列
//成功返回0,失敗返回-1設errno
//Link with -lrt.
int mq_unlink(const char *name);

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 最近半年以來,Android熱補丁技術熱潮繼續爆發,各大公司相繼推出自己的開源框架。Tinker在最近也順利完成了公司的審核,並非常榮幸的成為github.com/Tencent上第一個正式公開的項目。 ...
  • 蘋果在iOS10開放了siriKit介面給第三方應用。目前,QQ已經率先適配了Siri的發消息和打電話功能。這意味著在iOS10中你可以直接告訴Siri讓它幫你發QQ消息和打QQ電話了,聽起來是不是很酷炫? 那麼第三方應用使用Siri的體驗究竟如何?哪些應用可以接入SiriKit?接入SiriKi... ...
  • 原文: http://www.2cto.com/kf/201512/455888.html http://blog.csdn.net/yangqingqo/article/details/48371123 http://inthecheesefactory.com/blog/things-you-n ...
  • 遇到這個問題 網上找到的解決辦法: 方法一:就是上面說的通過計算出來ListView或者GridView中的子列高度和 進行顯示:public void setListViewHeightBasedOnChildren(ListView listView) { ListAdapter listAda ...
  • self.mManager = [[CMMotionManager alloc]init]; self.mManager.deviceMotionUpdateInterval = 0.5; if (self.mManager.gyroAvailable) { [self.mManager start ...
  • 在前面的文章中,已經實現了“設置中心”第一欄的功能以及佈局 本文地址:http://www.cnblogs.com/wuyudong/p/5936016.html,轉載請註明出處。 自定義屬性聲明 接下來實現其他欄的佈局和功能,由於它們之間的功能和佈局類似,只是屬性名稱不同。所以本文在自定義控制項的基 ...
  • TCP : Transmission Control Protocol,傳輸控制協議,類似於打電話 UDP : User Datagram Protocol,用戶數據報協議,類似於寫信 IP : Internet Protocol互聯網協議,是上述兩種協議的底層協議 IP地址(IP Address) ...
  • 模型: 1. 初始化並打開有名信號量:sem_open() 創建/獲得無名信號量:sem_init() 操作信號量:sem_wait()/sem_trywait()/sem_timedwait()/sem_post()/sem_getvalue() 退出有名信號量:sem_close() 銷毀有名信 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...