当前位置: 首页 > news >正文

Linux ipc通信(消息对列)

前言:消息队列也是linux开发ipc机制中较为重要的一个进程间通信机制。

1.系统创建或获取消息对列
int msgget(key_t key, int mode);

创建消息队列,或者获取消息队列。
参数:
key - 使用ftok()获取到的key
mode - IPC_CREAT|0666
返回:
消息队列的ID

2.往队列里发送一条消息。此操作被中断后不会被重启(信号处理中SA_RESTART)

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

参数:
msgid: - 消息队列的id
msgp - 消息,通常为下面的结构体
struct msgbuf{
long mtype; /消息类型,必需>0/
char mtext[100]; /消息数据,可自定义类型与大小/
};
msgsz - 消息的长度,指的消息数据的长度
msgflg - IPC_NOWAIT(不阻塞),MSG_EXCEPT(接受不检测mtype),MSG_NOERROR(消息数据过长时会截断数据)
返回:
0表示成功, -1表示失败

*3.int msgrcv(int msgid, void msgp, int msgsz, long msgtyp, int msgflg);

作用:接收消息队列中的消息

所需要的头文件:
#include <sys/types>
#include <sys/ipc.h>
#include <sys/msg.h>

在这里插入图片描述
*4.int msgctl(int msqid, int cmd, struct msqid_ds buf)

作用:msgctl系统调用对msqid标识的消息队列执行cmd命令操作。

返回值:0,成功;-1,失败;EFAULT(buf指向的地址无效);EIDRM(在读取中队列被删除);EINVAL(msgqid无效,或者msgsz小于0);EPERM(IPC_SET或者IPC_RMID命令被使用,但调用程序没有写的权限)

使用命令:
IPC_STAT:读取消息队列的数据结构msqid_ds,并将其存储在buf指定的地址中。

IPC_SET:设置消息队列的数据结构msqid_ds中的ipc_perm元素的值。这个值取自buf参数。

IPC_RMID:从系统内核中移走消息队列。

我们再说一下队列的msqid_ds结构体,对于每一个队列都有一个msqid_ds来描述队列当前的状态
struct msqid_ds {//Linux系统中的定义
struct ipc_perm msg_perm; /* Ownership and permissions
time_t msg_stime; /* Time of last msgsnd() /
time_t msg_rtime; /
Time of last msgrcv() /
time_t msg_ctime; /
Time of last change /
unsigned long __msg_cbytes; /
Current number of bytes inqueue (non-standard) /
msgqnum_t msg_qnum; /
Current number of messagesin queue /
msglen_t msg_qbytes; /
Maximum number of bytesallowed in queue /
pid_t msg_lspid; /
PID of last msgsnd() /
pid_t msg_lrpid; /
PID of last msgrcv() */
};//不同的系统中此结构会有不同的新成员。这个结构体的作用是用来管理消息队列的,通过cmd指令来设置这结构体中的值,进而达到控制消息队列的目的

http://www.lryc.cn/news/162387.html

相关文章:

  • 【计算机网络】 ARP协议和DNS协议
  • 【逐步剖C++】-第一章-C++类和对象(上)
  • 索尼 toio™ 应用创意开发征文|探索创新的玩乐世界——索尼 toio™
  • 企业架构LNMP学习笔记23
  • 第六章 图 五、图的深度优先遍历(DFS算法)
  • React 中的 useLayoutEffect 钩子函数
  • upload-labs1-21关文件上传通关手册
  • MATLAB遗传算法求解生鲜货损制冷时间窗碳排放多成本车辆路径规划问题
  • 界面控件DevExpress .NET应用安全 Web API v23.1亮点:支持Swagger模式
  • SpringMVC之CRUD------增删改查
  • 微信小程序开发教学系列(4)- 抖音小程序组件开发
  • RabbitMQ反序列化失败:Failed to convert message
  • CTFSHOW 年CTF
  • 肖sir__设计测试用例方法之状态迁移法05_(黑盒测试)
  • 无涯教程-JavaScript - IMPRODUCT函数
  • yapi以及gitlab的容器化部署
  • TCP、UDP 协议的区别,各自的应用场景
  • C高级 DAY3
  • Linux CentOS7命令及命令行
  • 【C++入门到精通】C++入门 ——搜索二叉树(二叉树进阶)
  • 学成在线-网站搭建
  • stm32同芯片但不同flash工程更换Device出现报错
  • Element UI实现每次只弹出一个Message消息提示
  • 「网页开发|前端开发|Vue」04 快速掌握开发网站需要的Vue基础知识
  • 解决Redis分布式锁主从架构锁失效问题的终极方案 含面试题
  • 建站系列(三)--- 网络协议
  • jetson orin nx无显示器启动
  • 【APUE】标准I/O库
  • es6---模块化
  • 【项目 计网12】4.32UDP通信实现 4.33广播 4.34组播 4.35本地套接字通信