Linux多进程通信总结——进程间通信看这一篇足够啦！
1.基本介绍
1）消息队列的本质其实是一个内核提供的链表，内核基于这个链表，实现了一个数据结构，向消息队列中写数据，实际上是向这个数据结构中插入一个新结点；从消息队列汇总读数据，实际上是从这个数据结构中删除一个结点
2）消息队列独立于发送与接收进程，进程终止时，消息队列中的内容不会被删除，所以要记得删除消息队列
3）消息队列可以实现消息的随机查询，消息不一定要以先进先出的次序读取，也可以按照消息的类型读取
4）Linux环境中，最多有256个消息队列，每个消息最大为8K字节，总大小不能超过16K，否则在send时会阻塞，可以通过更改内核设置的方式更改大小。
2.API介绍
1）获取消息队列键值
#include <sys/types.h>
#include <sys/ipc.h>
key_t ftok(char *pathname, char proj);
pathname：路径名，是必须存在的，ftok只是根据文件inode在系统内的唯一性来取一个数值，和文件的权限无关。
proj：1-255之间的数字
返回值： 生成一个独有的数，失败则返回-1
key 31-24 proj_id 低8位
key 23-16 pathname的st_dev属性的低8位
key 15-0 pathname的st_ino属性的低16位32位组合而成一个int值，就是我们的ftok的返回值了
根据路径名以及数字，合成系统中唯一的Key值
2）创建/获取消息队列
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);
key：使用ftok获取到的唯一Key值
msgflag： 和其他的IPC通信一样，IPC_CREAT，如果消息队列对象不存在，则创建之，否则则进行打开操作。IPC_EXCL，如果消息对象不存在则创建之，否则产生一个错误并返回，可同时用IPC_CREATE | 0666
返回值：成功返回消息队列ID，失败则返回-1
3）msgsend发送消息
int msgsnd(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg);
msgid ：消息队列ID
msgptr：消息体，消息体的类型是一个结构体
msg_sz： 消息长度 消息体中的消息长度（不是一整个结构体的长度，只是mtext消息数据的长度）
msgflag ：发送flag 一般设置为0，阻塞式等待（消息队列满），也可以设置为 IPC_NOWAIT，则立刻返回
返回值：成功返回0，失败返回-1
调用成功后，发送内容的一个备份，会被放到消息队列中（这里会有个硬拷贝的过程）
4）msgrecv接收消息
ssize_t msgrcv(int msgid, const void *msgp, size_t msgsz，
int msgtype, int msgflag)
msgid：消息队列ID
msgp： 接收到的消息体
msgsz： 接收消息的长度
msgtype ：消息类型 ，对应发送时的m_type。
值为0：代表接收一个任意类型的消息
值大于0：获取消息类型为msgtype的第一个消息
值小于0：获取消息类型小于等于msgtype的第一个消息
msgflag ：接收的flag一般设置为0，阻塞式等待
msgflg=IPC_NOWAIT，队列没有可读消息不等待，返回ENOMSG错误。
msgflg=MSG_NOERROR，消息大小超过msgsz时被截断
msgtype>0且msgflg=MSC_EXCEPT，接收类型不等于msgtype的第一条消息。
返回值：调用成功时，返回接收到消息的字节数，失败返回-1
调用成功时消息被复制到由msg_ptr指向的用户分配的缓存区中，然后删除消息队列中的对应消息（这里会有个硬拷贝的过程）
5）控制消息队列
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
msgid：消息队列id
cmd：控制消息队列的命令选项
IPC_STAT：把msgid_ds结构中的数据设置为消息队列的当前关联值，即用消息队列的当前关联值覆盖msgid_ds的值。
IPC_SET：如果进程有足够的权限，就把消息列队的当前关联值设置为msgid_ds结构中给出的值
IPC_RMID：删除消息队列
其实对于IPC通信来说，这些基本都是通用的~
3.例程
1）服务端
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <pthread.h>
#define MSGQ_PATH "./"
#define MSGQ_PRI 100
typedef struct {
long mtype;
char mtext[256];
} MSGQ_T;
int iMsgId = 0;
int main(int argc, char **argv)
{
key_t msgkey = 0;
msgkey = ftok(MSGQ_PATH, MSGQ_PRI);
if (msgkey == -1)
{
printf("ftok error, pid:%d\n", getpid());
return -1;
}
iMsgId = msgget(msgkey, IPC_CREAT | 0644);
if (iMsgId == -1)
{
printf("msgget error, pid:%d\n", getpid());
return -1;
}
printf("msgget success, pid:%d, key:%d, msgid:%d\n", getpid(), msgkey, iMsgId);
while (1)
{
MSGQ_T msgBuf = {0};
int iMsgType = 0;
printf("input message type:\n");//输入消息类型
scanf("%d", &iMsgType);
if (iMsgType == 0)
{
printf("message type 0, break\n");
break;
}
char acBuf[256] = {0};
printf("input message to be send:\n");//输入消息信息
scanf("%s", acBuf);
msgBuf.mtype = iMsgType;
strncpy(msgBuf.mtext, acBuf, sizeof(msgBuf.mtext) - 1);
msgsnd(iMsgId, &msgBuf, sizeof(msgBuf), IPC_NOWAIT);
printf("msgq:%d, send msgtype:%d, msgtext:%s \n", iMsgId, msgBuf.mtype, msgBuf.mtext);
}
msgctl(iMsgId, IPC_RMID, NULL);
return 0;
}
2）客户端
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <pthread.h>
#define MSGQ_PATH "./"
#define MSGQ_PRI 100
typedef struct {
long mtype;
char mtext[256];
} MSGQ_T;
int iMsgId = 0;
pthread_t msgqRecvThread = 0;
void *msgqRecvThreadTask(void *arg)
{
while (1)
{
MSGQ_T msgBuf = {0};
int ret = msgrcv(iMsgId, &msgBuf, sizeof(msgBuf), 0, 0);
if (ret < 0)
{
return NULL;
}
printf("msgq:%d, recv msgtype:%d, msgtext:%s, ret:%d \n", iMsgId, msgBuf.mtype, msgBuf.mtext, ret);
}
return NULL;
}
int main(int argc, char **argv)
{
key_t msgkey = 0;
msgkey = ftok(MSGQ_PATH, MSGQ_PRI);
if (msgkey == -1)
{
printf("ftok error, pid:%d\n", getpid());
perror("....");
return -1;
}
iMsgId = msgget(msgkey, IPC_CREAT | 0644);
if (iMsgId == -1)
{
printf("msgget error, pid:%d\n", getpid());
perror("....");
return -1;
}
printf("msgget success, pid:%d, key:%d, msgid:%d\n", getpid(), msgkey, iMsgId);
pthread_create(&msgqRecvThread, NULL, msgqRecvThreadTask, NULL);
pthread_join(msgqRecvThread, NULL);
return 0;
}
可以通过指令分别编译客户端和服务端并执行
gcc server.c -o server -lpthread
gcc client.c -o client -lpthread
./server
./client
在输入框输入消息后，便可以在client观察到消息接收啦
此时输入ipcs -q后能看到创建的消息队列
这里我显示有两个消息队列，因为上一个没有用msgctl删除。
当服务端和客户端程序都正常退出时，调用msgctl则会正常删除消息队列，在例程中的server端输入0即可！
