Barisan Mesej Linux IPC System V: Cara Klasik untuk Penghantaran Mesej Boleh Dipercayai

Sistem Linux ialah sistem pengendalian yang menyokong pelaksanaan serentak pelbagai tugas Ia boleh menjalankan berbilang proses pada masa yang sama, dengan itu meningkatkan penggunaan dan kecekapan sistem. Walau bagaimanapun, jika pertukaran data dan kerjasama diperlukan antara proses ini, beberapa kaedah komunikasi antara proses (IPC) perlu digunakan, seperti isyarat, memori dikongsi, semaphore, dsb. Antaranya, baris gilir mesej Sistem V adalah kaedah IPC yang agak klasik dan boleh dipercayai Ia membenarkan dua atau lebih proses menghantar mesej melalui baris gilir tanpa mengambil berat tentang kandungan dan format mesej. Artikel ini akan memperkenalkan kaedah baris gilir mesej Sistem V dalam sistem Linux, termasuk penciptaan, pembukaan, penghantaran, penerimaan, penutupan dan pemadaman baris gilir mesej.

Model

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

ftok()

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

pathname: nama fail
proj_id: nombor dari 1 hingga 255, mewakili project_id

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

msgget()

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

msgflg: bendera operasi khusus

• IPC_CREAT Jika ia tidak wujud, buatnya Anda memerlukan "|Maklumat Kebenaran" dalam msgflg;
IPC_EXCL
• Jika wujud, ciptaan gagal
0
• Dapatkan baris gilir mesej sedia ada
Kapasiti baris gilir mesej dikawal oleh msg_qbytes Semasa proses mencipta baris gilir mesej, saiz ini dimulakan kepada MSGMNB Had ini boleh diubah suai melalui msgctl()

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

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

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

Salin selepas log masuk

ID baris gilir mesej yang dikembalikan oleh msgget()msgp
Alamat pertama mesej Jenis data rujukan mesej adalah seperti berikut

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. 

Saiz mesej Parameter ini digunakan untuk menentukan saiz kandungan mesej, tidak termasuk jenis mesej. Ia hanya boleh saiz(Msgbuf.mtext), bukan saiz(Msgbuf)msgflg
Bendera dihantar, lalai ialah 0

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

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

Salin selepas log masuk

: ID baris gilir mesej (dikembalikan oleh msgget) msgp
: Alamat pertama penimbal tempat mesej yang diterima disimpan msgsz
: Saiz maksimum mesej, tidak termasuk jenis mesej ==> hanya saiz( Msgbuf.mtext), tidak boleh saiz(Msgbuf)

• Jika panjang mesej ialah >msgsz dan tiada MSG_NOERROR dalam msgflg, ralat akan berlaku dan E2BIG akan dilaporkan.

: Jenis mesej

0
• : Baca mesej pertama dalam baris gilir mesej
>0
• : Baca mesej pertama dengan taip msgtype dalam baris gilir mesej Melainkan terdapat MSG_EXCEPT dalam msg_flg, mesej pertama dalam baris gilir yang bukan msgtyp akan dibaca.
Baca jenis dalam baris gilir mesej

: Benderakan untuk dihantar, lalai kepada 0

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

// 消息操作，成功返回0,失败返回-1设errno
int msgctl(int msqid, int cmd, struct msqid_ds *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 */
};

//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;
}