Heim > System-Tutorial > LINUX > Hauptteil

Linux IPC System V Message Queuing: Ein klassischer Weg zur zuverlässigen Nachrichtenzustellung

王林
Freigeben: 2024-02-12 15:33:15
nach vorne
1148 Leute haben es durchsucht

Linux-System ist ein Betriebssystem, das die gleichzeitige Ausführung mehrerer Aufgaben unterstützt. Es kann mehrere Prozesse gleichzeitig ausführen und dadurch die Systemauslastung und -effizienz verbessern. Wenn jedoch Datenaustausch und Zusammenarbeit zwischen diesen Prozessen erforderlich sind, müssen einige IPC-Methoden (Inter-Process Communication) verwendet werden, z. B. Signale, gemeinsam genutzter Speicher, Semaphore usw. Unter diesen ist die System-V-Nachrichtenwarteschlange eine relativ klassische und zuverlässige IPC-Methode. Sie ermöglicht es zwei oder mehr Prozessen, Nachrichten über eine Warteschlange zu übertragen, ohne sich um den Inhalt und das Format der Nachricht zu kümmern. In diesem Artikel wird die Methode der System V-Nachrichtenwarteschlange im Linux-System vorgestellt, einschließlich des Erstellens, Öffnens, Sendens, Empfangens, Schließens und Löschens der Nachrichtenwarteschlange.

Linux IPC System V 消息队列:一种实现可靠消息传递的经典方式

Modell

#include 
#include 
#include 
ftok()               //获取key值                               
msgget()             //创建/获取消息队列                        
msgsnd()/msgrcv()    //发消息到消息队列/从消息队列收信息        
msgctl()             //删除消息队列                           
Nach dem Login kopieren

ftok()

//获取key值, key值是System V IPC的标识符,成功返回key,失败返回-1设errno
//同pathname+同 proj_id==>同key_t;
key_t ftok(const char *pathname, int proj_id);
Nach dem Login kopieren

Pfadname: Dateiname
Projekt_ID: eine Zahl von 1 bis 255, die die Projekt_ID darstellt

key_t key=ftok(".",100);    //“.”就是一个存在且可访问的路径, 100是假设的proj_id
    if(-1==key)
        perror("ftok"),exit(-1);
Nach dem Login kopieren

msgget()

//创建/获取消息队列,成功返回shmid,失败返回-1
int msgget(key_t key, int msgflg);  //ATTENTION:用int msqid=msgget()比较好看
Nach dem Login kopieren

msgflg: spezifisches Operationsflag

  • IPC_CREAT Wenn es nicht existiert, erstellen Sie es. Sie benötigen „|Berechtigungsinformationen“ in msgflg; wenn es existiert, öffnen Sie es
  • IPC_EXCLWenn es vorhanden ist, schlägt die Erstellung fehl
  • 0 Holen Sie sich eine vorhandene Nachrichtenwarteschlange

Die Kapazität der Nachrichtenwarteschlange wird durch msg_qbytes gesteuert. Während des Erstellungsprozesses der Nachrichtenwarteschlange wird diese Größe auf MSGMNB initialisiert. Dieses Limit kann über msgctl() geändert werden

int msqid=msgget(key,IPC_CREAT|IPC_EXCL|0664);
if(-1==msqid)
    perror("msgget"),exit(-1);
Nach dem Login kopieren

msgsnd()
//向指定的消息队列发送指定的消息,如果消息队列已经满了,默认的行为是堵塞,直到队列有空间容纳新的消息,成

功返回0,失败返回-1设errno
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
Nach dem Login kopieren

msqid Die ID der von msgget() zurückgegebenen Nachrichtenwarteschlange
msgpDie erste Adresse der Nachricht ist wie folgt

struct msgbuf {
    long mtype;       /* message type, must be > 0 */   //消息的类型
    char mtext[1];    /* message data */                //消息的内容
};
ATTENTION:The  mtext field is an array (or other structure) whose size is
 specified by msgsz, a nonnegative integer value. 
Nach dem Login kopieren

msgszDie Größe der Nachricht wird verwendet, um die Größe des Nachrichteninhalts anzugeben, mit Ausnahme des Nachrichtentyps. Es kann nur sizeof(Msgbuf.mtext) sein, nicht sizeof(Msgbuf)
msgflgDas gesendete Flag, der Standardwert ist 0

Msg msg1={1,"hello"};//消息的类型是1,内容是hello
int res=msgsnd(msqid,&msg2,sizeof(msg2.buf),0);
if(-1==res)
    perror("msgsnd"),exit(-1);
Nach dem Login kopieren

msgrcv()
//向指定的消息队列取出指定的消息,成功返回实际接受到的byte数,失败返回-1设errno
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
Nach dem Login kopieren

msqid: Die ID der Nachrichtenwarteschlange (zurückgegeben von msgget)
msgp: Die erste Adresse des Puffers, in dem die empfangene Nachricht gespeichert wird
msgsz: Die maximale Größe der Nachricht, ohne den Typ der message ==> nur sizeof( Msgbuf.mtext), nicht sizeof(Msgbuf)

    Wenn die Länge der Nachricht > msgsz ist und MSG_NOERROR in msgflg vorhanden ist, wird die Nachricht abgeschnitten und der abgeschnittene Teil geht verloren
  • Wenn die Länge der Nachricht >msgsz ist und kein MSG_NOERROR in msgflg vorhanden ist, tritt ein Fehler auf und E2BIG wird gemeldet.

msgtyp: Art der Nachricht

  • 0: Lesen Sie die erste Nachricht in der Nachrichtenwarteschlange
  • >0: Liest die erste Nachricht mit dem Typ msgtype in der Nachrichtenwarteschlange, es sei denn, es gibt MSG_EXCEPT in msg_flg, die erste Nachricht in der Warteschlange, die nicht msgtyp ist, wird gelesen
  • Lesen Sie den Typ in der Nachrichtenwarteschlange

msgflg: Flag zum Senden, Standardwert 0

Msg msg1;
int res=msgrcv(msqid,&msg1,sizeof(msg1.buf),1,0);
if(-1==res)
    perror("msgrcv"),exit(-1);
Nach dem Login kopieren

msgctl()

// 消息操作,成功返回0,失败返回-1设errno
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
Nach dem Login kopieren

msqid :消息队列的ID,由msgget()
buf 结构体指针

struct msqid_ds {
    struct ipc_perm msg_perm;       /* Ownership and permissions */
    time_t          msg_stime;      /*Time of last msgsnd(2) */
    time_t          msg_rtime;      /* Time of last msgrcv(2) */
    time_t          msg_ctime;      /* Time of last change */
    unsigned long   __msg_cbytes;   /* Current number of bytes in queue (nonstandard) */
    msgqnum_t       msg_qnum;       /* Current number of messages in queue */
    msglen_t        msg_qbytes;     /* Maximum number of bytes allowed in queue */
    pid_t           msg_lspid;      /* PID of last msgsnd(2) */
    pid_t           msg_lrpid;      /* PID of last msgrcv(2) */
};
struct ipc_perm {
    key_t           __key;      /* Key supplied to msgget(2) */
    uid_t           uid;        /* Effective UID of owner */
    gid_t           gid;        /* Effective GID of owner */
    uid_t           cuid;       /* Effective UID of creator */
    gid_t           cgid;       /* Effective GID of creator */
    unsigned short  mode;       /* Permissions */
    unsigned short  __seq;      /* Sequence number */
};
Nach dem Login kopieren

cmd

  • IPC_STAT从内核相关结构体中拷贝消息队列相关的信息到buf指向的结构体中

  • IPC_SET把buf指向的结构体的内容写入到内核相关的结构体中,同时更显msg_ctimer成员,同时以下成员也会被更新:msg_qbytes, msg_perm.uid, msg_perm.gid, msg_perm.mode。调用队列的进程的effective UID必须匹配队列所有者或创建者的msg_perm.uid或msg_perm.cuid或者该进程拥有特权级别,

  • IPC_RMID立即销毁消息队列,唤醒所有正在等待读取或写入该消息队列进程,调用的进程的UID必须匹配队列所有者或创建者或者该进程拥有足够的特权级别

  • IPC_INFO (Linux-specific)返回整个系统对与消息队列的限制信息到buf指向的结构体中

    //_GNU_SOURCE
    //
    struct msginfo {
        int msgpool;/*Size in kibibytes of buffer pool used to hold message
     data; unused within kernel*/
        int msgmap; /*Maximum number of entries in message map; unused within 
    kernel*/
        int msgmax; /*Maximum number of bytes that can be written in a single
     message*/
        int msgmnb; /*Maximum number of bytes that can be written to queue; 
    used to initialize msg_qbytes  during queue creation*/
        int msgmni; /*Maximum number of message queues*/
        int msgssz; /*Message segment size; unused within kernel*/
        int msgtql; /*Maximum number of messages on all queues in system; unused
     within kernel*/
        unsigned short int  msgseg; /*Maximum number of segments; unused
     within kernel*/
    };
    
    Nach dem Login kopieren
    int res=msgctl(msqid,IPC_RMID,NULL);
    if(-1==res)
    perror("msgctl"),exit(-1);
    
    Nach dem Login kopieren

例子

//Sys V IPC msg
#include
#include
#include
#include
#include
typedef struct{
    long mtype;     //消息的类型
    char buf[20];       //消息的内容
}Msg;
int msqid;          //使用全局变量,这样就可以在fa中使用msqid了
void fa(int signo){
    printf("deleting..\n");
    sleep(3);
    int res=msgctl(msqid,IPC_RMID,NULL);
    if(-1==res)
        perror("msgctl"),exit(-1);
    exit(0);
}
int main(){
    //ftok()
    key_t key=ftok(".",150);
    if(-1==key)
        perror("ftok"),exit(-1);
    printf("key%#x\n",key);
    //msgget()
    msqid=msgget(key,IPC_CREAT|IPC_EXCL|0664);
    if(-1==msqid)
        perror("msgget"),exit(-1);
    printf("msqid%d\n",msqid);
    //msgsnd()
    Msg msg1={1,"hello"};//消息的类型是1,内容是hello
    Msg msg2={2,"world"};
    int res=msgsnd(msqid,&msg2,sizeof(msg2.buf),0);
    if(-1==res)
        perror("msgsnd"),exit(-1);
    res=msgsnd(msqid,&msg1,sizeof(msg1.buf),0);
    if(-1==res)
        perror("msgsnd"),exit(-1);
    //msgctl()
    //Ctrl+C delete msq
    printf("Press CTRL+C to delete msq\n");
    if(SIG_ERR==signal(SIGINT,fa))
        perror("signal"),exit(-1);
    while(1);
    return 0;
}
Nach dem Login kopieren

本文介绍了Linux系统中System V 消息队列的方法,包括消息队列的创建、打开、发送、接收、关闭和删除等方面。通过了解和掌握这些知识,我们可以更好地使用System V 消息队列来实现进程间通信,提高系统的稳定性和效率。当然,Linux系统中System V 消息队列还有很多其他的特性和用法,需要我们不断地学习和研究。希望本文能给你带来一些启发和帮助。

Das obige ist der detaillierte Inhalt vonLinux IPC System V Message Queuing: Ein klassischer Weg zur zuverlässigen Nachrichtenzustellung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Quelle:lxlinux.net
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage