进程间的通信"/>
Linux进程间的通信
Linux进程间的通信--消息队列
- 一.消息队列
- 1. 什么是消息队列
- 2.消息队列的获取
- 3. 消息的发送
- 4. 消息的接收
- 5. 消息的控制
- 二.举个栗子
- 1.程序A<发送消息>msg_send.cpp
- 2.程序B<接受消息>msg_receive.cpp
- 3编译&执行
- 4图解
一.消息队列
1. 什么是消息队列
消息队列,用于从一个进程向另一个进程发送数据。
但仅把数据发送到一个“队列”中,而不指定由哪个进程来接受。
消息队列,独立与发送消息的进程和接收消息的进程。
(信号、管道、命名管道都不独立与发送和接收进程)
消息队列,有最大长度限制:MSGMNB
消息队列中的单条消息,也有最大长度限制:MSGMAX
2.消息队列的获取
msgget
原型:
int msgget(key_t key, int msgflg);
功能:
获取或创建一个消息队列
参数:
与共享内存相似。 msgflag 可使用 IPC_CREAT
返回值:
成功,返回正整数,即“消息队列标识符”
失败,返回-1
3. 消息的发送
msgsnd
原型:
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
功能:
发送一个消息,即把消息添加到消息队列中
参数:
msgid 消息队列标识符
msgp 消息指针(注:消息的类型需要自己定义。但要求其第一个结构成员为 long int*
msgsz 消息的长度(不包含第一个成员 msg_type)
msgflg 如果包含: IPC_NOWAIT, 则消息队列满时,不发送该消息,而立即返回-1如果不包含:IPC_NOWAIT,则消息队列满时,挂起本进程,直到消息队列有 空间可用。
返回值:
成功,返回 0 失败,返回-1
4. 消息的接收
msgrcv
原型:
ssize_t msgrcv (int msqid, void *msgp, size_t msgsz, long msgtype,int msgflg);
功能:
从消息队列中接收一条消息。
参数:
msgid 消息队列标识符 msgp 用于接收消息的缓存
msgsz 要接收的消息的长度(不包括其第一个成员)
msgtype指定接收消息的类型
0: 从消息队列中获取第一个消息,以实现顺序接受(先发先收)
0: 从消队列中获取相同类型的第一个消息
<0: 从消息队列中获取消息类型<=(msgtyep 的绝对值)的第一个消息
msgflg:
如果包含 IPC_NOWAIT, 则当消息队列中没有指定类型的消息时,立即返回-1,
如果不包含:IPC_NOWAIT,则当消息队列中没有指定类型的消息时,挂起本进程,直到收到指定类型的消息
返回值:
成功,返回接收到的消息的长度(不包含第一个成员 msg_type) 失败,返回-1
5. 消息的控制
msgctl
原型:
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
功能:
与 shmctl 类似
参数:
cmd 常用命令: IPC_RMID 删除消息队列
返回值:
成功,返回 0
失败,返回-1
二.举个栗子
1.程序A<发送消息>msg_send.cpp
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>#define MSG_SIZE 80struct my_msg_st {long int msg_type;char msg[MSG_SIZE];
};int main(void)
{int msgid;int ret;struct my_msg_st msg;msgid = msgget((key_t)1235, 0666|IPC_CREAT);if (msgid == -1) {printf("msgget failed!\n");exit(1);}msg.msg_type = 1;strcpy(msg.msg, "Hello world!");ret = msgsnd(msgid, &msg, MSG_SIZE, 0);if (ret == -1) {printf("msgsnd failed!\n");exit(1);}return 0;
}
~
2.程序B<接受消息>msg_receive.cpp
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>#define MSG_SIZE 80struct my_msg_st {long int msg_type;char msg[MSG_SIZE];
};
int main(void)
{int msgid;int ret;struct my_msg_st msg;msgid = msgget((key_t)1235, 0666|IPC_CREAT);if (msgid == -1) {printf("msgget failed!\n");exit(1);}msg.msg_type = 0;ret = msgrcv(msgid, &msg, MSG_SIZE, 0, 0);if (ret == -1) {printf("msgrcv failed!\n");exit(1);}printf("received: %s\n", msg.msg);ret = msgctl(msgid, IPC_RMID, 0);if (ret == -1) {printf("msgctl(IPC_RMID) failed!\n");exit(1);}return 0;
}
3编译&执行
root@JXFUbuntu:/home/jxf/projects/shared_bilk/demo/msg_demo# gcc msg_send.cpp -o send.exe
root@JXFUbuntu:/home/jxf/projects/shared_bilk/demo/msg_demo# gcc msg_receive.cpp -o receive.exe
root@JXFUbuntu:/home/jxf/projects/shared_bilk/demo/msg_demo# ll
总用量 72
drwxr-xr-x 2 root root 4096 9月 14 21:20 ./
drwxr-xr-x 5 root root 4096 9月 14 16:43 ../
-rw-r--r-- 1 root root 684 9月 14 18:15 msg_receive.cpp
-rw-r--r-- 1 root root 596 9月 14 18:09 msg_send.cpp
-rwxr-xr-x 1 root root 8845 9月 14 21:20 receive.exe*
-rwxr-xr-x 1 root root 8738 9月 14 21:19 send.exe*
root@JXFUbuntu:/home/jxf/projects/shared_bilk/demo/msg_demo# ./send.exe
root@JXFUbuntu:/home/jxf/projects/shared_bilk/demo/msg_demo# ./receive.exe
received: Hello world!
4图解
更多推荐
Linux进程间的通信
发布评论