Linux系统编程（七）进程间通信IPC

进程间通讯的7种方式_进程间通信的几种方法-CSDN博客

  1. 管道 pipe（命名管道和匿名管道）；
  2. 信号 signal；
  3. 共享内存；
  4. 消息队列；
  5. 信号量 semaphore；
  6. 套接字 socket；

1. 管道

内核提供，单工，自同步机制。 

1.1 匿名管道

磁盘上无法看到，只能有亲缘关系的进程才能用匿名管道。一般用于父子进程间通信。

pipe(2) 系统调用可以创建一个匿名管道 pipefd，文件描述符 pipefd[0] 为读管道，pipefd[1] 为写管道。  

#include <unistd.h>int pipe(int pipefd[2]);#define _GNU_SOURCE             /* See feature_test_macros(7) */
#include <fcntl.h>              /* Obtain O_* constant definitions */
#include <unistd.h>int pipe2(int pipefd[2], int flags);

例子，父进程通过管道发送 hello 给子进程：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>int main()
{pid_t pid;int pipefd[2];if (pipe(pipefd) < 0) {perror("pipe");exit(1);}pid = fork();if (pid > 0) {// parentclose(pipefd[0]);write(pipefd[1], "hello", 5);close(pipefd[1]);wait(NULL);exit(0);}else if (pid == 0) {// childclose(pipefd[1]);char buf[50];int len = read(pipefd[0], buf, 50);printf("%d\n", len);write(1, buf, len);close(pipefd[0]);exit(0);}else {perror("fork");exit(1);}exit(0);
}

1.2 命名管道

磁盘上能看到，文件类型为 p 的文件。

mkfifo(3) 函数可以创建一个 fifo 特殊文件（命名管道）。

#include <sys/types.h>
#include <sys/stat.h>int mkfifo(const char *pathname, mode_t mode);

2 XSI -> SysV

2.1 消息队列，message queue 

主动端，先发包的一方；被动端，先收包的一方；消息队列可以用于没有亲缘关系的进程间通信。

例子，proto.h，包含了传递的内容:

#ifndef PROTO_H__
#define PROTO_H__#define KEYPATH "/etc/services"
#define KEYPROJ 'g'#define NAMESIZE 32struct msg_st
{long mtype;char name[NAMESIZE];int math;int chinese;
};#endif

receiver.c，接收者：

#include <stdio.h>
#include <stdlib.h>
#include "proto.h"
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int main()
{key_t key;int msgid;struct msg_st rbuf;key = ftok(KEYPATH, KEYPROJ);if (key < 0) {perror("ftok");exit(1);}msgid = msgget(key, IPC_CREAT | 0600);if (msgid < 0) {perror("msgget");exit(1);}while (1){if (msgrcv(msgid, &rbuf, sizeof(rbuf) - sizeof(long), 0, 0) < 0){perror("msgrcv");exit(1);}printf("NAME = %s\n", rbuf.name);printf("MATH = %d\n", rbuf.math);printf("CHINESE = %d\n", rbuf.chinese);}msgctl(msgid, IPC_RMID, NULL);exit(0);
}

运行接收者可以看到创建的 msg queue： 

sender.c，发送者： 

#include <stdio.h>
#include <stdlib.h>
#include "proto.h"
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>int main()
{key_t key;struct msg_st sbuf;int msgid;key = ftok(KEYPATH, KEYPROJ);if (key < 0) {perror("ftock");exit(1);}msgid = msgget(key, 0);if (msgid < 0){perror("msgget");exit(1);}sbuf.mtype = 1;strcpy(sbuf.name, "lzp");sbuf.math = 99;sbuf.chinese = 100;if (msgsnd(msgid, &sbuf, sizeof(sbuf) - sizeof(long), 0) < 0) {perror("msgsend");exit(1);}puts("ok!");exit(0);
}

先运行 receiver，然后运行 sender 发送信息： 

2.2 信号量，semaphore arrays

semget、semop、semctl；可以用于没有亲缘关系的进程间通信。

2.3 共享内存，shared memory segment

shmget、shmop、shmctl；之前可以通过 mmap 实现共享内存，不过只能在有亲缘关系的进程间通信。匿名 ipc 也只能在有亲缘关系的进程间通信；

3. 网络套接字 socket

3.1 跨主机的传输

  • 字节序：大端存储（低地址处放高字节）和小端存储（低地址处放低字节，x86）；主机字节序（host）和网络字节序（network）；主机序转网络序，网络序转主机序；htons，htonl，ntohs，ntohl。
  • 对齐：结构体中 char 类型可能会占 4 个字节；如果不对齐，那么 int 类型的存储地址可能就不是在 4 的倍数的地址上了，可能需要两次访存才能取出一个 int 类型。深入理解字节对齐-CSDN博客
  • 类型长度问题：不同主机间的架构，机器字长可能不一样，结构体类型大小也可能不一样。解决方案（int32_t，int16_t ...）；

socket(2) 系统调用如下： 

#include <sys/types.h>    
#include <sys/socket.h>int socket(int domain, int type, int protocol);
  • domain 指定协议族；
    • AF_INET      IPv4 Internet protocols    ip(7)
    • AF_INET6     IPv6 Internet protocols   ipv6(7)
  • type 指定通信语义；
    • SOCK_STREAM（流式传输）：Provides sequenced, reliable, two-way, connection-based byte streams.
    • SOCK_DGRAM（报式传输）  ：Supports datagrams (connectionless, unreliable messages of a fixed maximum length).
  • protocol 指定协议族中的协议；

bind(2) 系统调用可以给 socket 绑定地址。

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

recvfrom(2) 可以从 socket 上接收一条 message： 

#include <sys/types.h>
#include <sys/socket.h>ssize_t recv(int sockfd, void *buf, size_t len, int flags);ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);
  1. recv(2) 是用于流式套接字的，是提前建立好连接的，一对一的，点对点的， 不需要记录对方的 socket 地址；
  2. recvfrom(2) 可以用于报式和流式套接字，每次需要传入需要通信的 socket 地址；

sendto(2) 函数可以发送 msg 到对应的 socket 地址，可以用于流式和报式传输；而 send(2) 函数不需要指定 socket 地址，只能用于事先建立好连接的流式传输。

#include <sys/types.h>
#include <sys/socket.h>ssize_t send(int sockfd, const void *buf, size_t len, int flags);ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen);ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags);

3.2 报式套接字（udp）

被动端（先运行）：

  1. 取得 socket（socket）；
  2. 给 socket 取得地址，相当于绑定本地的地址（bind）；
  3. 收/发消息（recvfrom）；
  4. 关闭 socket（close）；

主动端：

  1. 取得 socket；
  2. 给 socket 取得地址（可省略）；
  3. 收/发消息；
  4. 关闭 socket；

__attribute__((packed))：packed属性：使用该属性可以使得变量或者结构体成员使用最小的对齐方式，即对变量是一字节对齐，对域（field）是位对齐。即不进行对齐。

使用如下指令查看被动段的地址和端口（u代表udp）：

netstat -anu

proto.h 约定传输格式和内容： 

#ifndef PROTO_H__
#define PROTO_H__#define RCVPORT 1989#define NAMESIZE  11// communication struct
struct msg_st
{char name[NAMESIZE];int math;int ch;
} __attribute__((packed));#endif

receiver.c 接收方， 注意多字节需要使用 ntohl() 来转换：

#include <stdio.h>
#include <stdlib.h>
#include "proto.h"
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>#define IPSTRSIZE 40int main()
{int sd; // socket fdstruct sockaddr_in laddr;struct sockaddr_in raddr;struct msg_st rbuf;socklen_t raddr_len;char ipstr[IPSTRSIZE];// IPV4 DGRAM UDPsd = socket(AF_INET, SOCK_DGRAM, 0/* IPPROTO_UDP */);if (sd < 0) {perror("socket");exit(1);}laddr.sin_family = AF_INET;laddr.sin_port = htons(RCVPORT);inet_pton(AF_INET, "0.0.0.0", &laddr.sin_addr);if (bind(sd, (struct sockaddr *)&laddr, sizeof(laddr)) < 0) {perror("bindqqq");exit(1);}/* !!! */raddr_len = sizeof(raddr);while (1){recvfrom(sd, &rbuf, sizeof(rbuf), 0, (struct sockaddr *)&raddr, &raddr_len);inet_ntop(AF_INET, &raddr.sin_addr, ipstr, IPSTRSIZE);printf("message from %s:%d---\n", ipstr, ntohs(raddr.sin_port));printf("name = %s\n", rbuf.name);printf("name = %d\n", ntohl(rbuf.math));printf("name = %d\n", ntohl(rbuf.ch));}close(sd);exit(0);
}

sender.c 发送方，发送报文给对应的地址： 

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include "proto.h"
#include <unistd.h>int main(int argc, char *argv[])
{int sd;struct msg_st sbuf;struct sockaddr_in raddr;if (argc < 2){fprintf(stderr, "usage..\n");exit(1);}sd = socket(AF_INET, SOCK_DGRAM, 0);if (sd < 0){perror("socket");exit(1);}//bind();strcpy(sbuf.name, "Alan");sbuf.math = htonl(99);sbuf.ch = htonl(93);raddr.sin_family = AF_INET;raddr.sin_port = htons(RCVPORT);inet_pton(AF_INET, argv[1], &raddr.sin_addr);if (sendto(sd, &sbuf, sizeof(sbuf), 0, (struct sockaddr *)&raddr, sizeof(raddr)) < 0){perror("sendto");exit(1);}puts("ok\n");close(sd);exit(0);
}

运行结果： 

报式套接字还能实现多播、广播（全网广播和子网广播）、组播：

可以通过 getsockopt() 和 setsockopt() 来打开广播选项。然后将发送的目标地址改成 255.255.255.255 就可以发送广播了。

多点通信（广播、多播、组播）只能用报式套接字实现，因为流式套接字是一对一的，点对点的。

udp 会出现丢包的问题，TTL生存周期（路由跳转个数） ，丢包是由阻塞造成的，当等待队列快满的时候会发生丢包（网络太拥塞），可以使用流量控制解决（限制发送端的速率）。

3.3 流式套接字（tcp）

协议，约定双方对话的格式。

三次握手容易被ddos攻击，可以去掉半连接池，然后使用cookie（对方的ip+端口加上我放的ip+端口加上一个内核产生的令牌）。

Client 端和 Server 端：

client：

  1. 获取 socket；
  2. 给 socket 取得地址；
  3. 发送连接；
  4. 收/发消息；
  5. 关闭连接；

server：

  1. 获取 socket；
  2. 给 socket 取得地址；
  3. 将 socket 置为监听模式；
  4. 接受连接；
  5. 收/发消息；
  6. 关闭；

服务端（server.c）：

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <time.h>
#include "proto.h"#define IPSTRSIZE 40
#define BUFSIZE 1024static void server_job(int sd)
{char buf[BUFSIZE];int len = sprintf(buf, FMT_STAMP, (long long)time(NULL));if (send(sd, buf, len, 0) < 0) {perror("send()");exit(1);}
}int main()
{struct sockaddr_in laddr, raddr;socklen_t raddr_len;char ipstr[IPSTRSIZE];int sd = socket(AF_INET, SOCK_STREAM, 0/* default IPPROTO_TCP */);if (sd < 0) {perror("socket()");exit(1);}laddr.sin_family = AF_INET;laddr.sin_port = htons(atoi(SERVERPORT));inet_pton(AF_INET, "0.0.0.0", &laddr.sin_addr);if (bind(sd, (void *)&laddr, sizeof(laddr)) < 0) {perror("bind()");exit(1);}// listen for connections on a socketif (listen(sd, 200) < 0){perror("listen()");exit(1);}raddr_len = sizeof(raddr);while (1) {// accept a connection on a socketint newsd;if ((newsd = accept(sd, (void *)&raddr, &raddr_len)) < 0) {perror("accept()");exit(1);}inet_ntop(AF_INET, &raddr.sin_addr, ipstr, IPSTRSIZE);printf("Client: %s : %d\n", ipstr, ntohs(raddr.sin_port));server_job(newsd);// close newsdclose(newsd);}close(sd);exit(0);
}

运行后使用 netstat -ant 可以查看：

当连接被释放后，服务端会进入一段时间的 timewait 状态。

客户端（client.c）：

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <arpa/inet.h>
#include "proto.h"
int main(int argc, char* argv[])
{struct sockaddr_in raddr;long long stamp;if (argc < 2) {fprintf(stderr, "Usage...\n");exit(1);}int sd = socket(AF_INET, SOCK_STREAM, 0);if (sd < 0) {perror("socket()");exit(1);}// initiate a connection on a socketraddr.sin_family = AF_INET;raddr.sin_port = htons(atoi(SERVERPORT));inet_pton(AF_INET, argv[1], &raddr.sin_addr);if (connect(sd, (void *)&raddr, sizeof(raddr)) < 0) {perror("connect()");exit(1);}FILE* fp = fdopen(sd, "r+");if (fp == NULL) {perror("fdopen()");exit(1);}if (fscanf(fp, FMT_STAMP, &stamp) < 1) {fprintf(stderr, "bad format\n");}else {fprintf(stdout, "stamp = %lld\n", stamp);}fclose(fp);exit(0);
}

上面这种方法有一个缺点，就是假如 server_job 的任务执行时间太长的话，需要等待 server_job 执行完后才能继续 accept 下一个连接请求，这样效率十分低，所以可以采用多线程的方式来解决，每个进程或线程处理一个连接请求。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/36692.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Arduino平台软硬件原理及使用——SR04超声波传感器的使用

Arduino平台软硬件原理及使用——SR04超声波传感器的使用

文章目录&#xff1a; 一、超声波传感器工作原理 二、SR04超声波库的使用 三、SR04超声波传感器在Arduino中的使用 一、超声波传感器工作原理 如上图所示&#xff1a;HCSR04超声波传感器拥有4个针脚&#xff0c;除了VCC接正极、GND接负极外&#xff0c;还有两个引脚“Trig”及“…
阅读更多...
Linux线程互斥锁

Linux线程互斥锁

目录 &#x1f6a9;看现象&#xff0c;说原因 &#x1f6a9;解决方案 &#x1f6a9;互斥锁 &#x1f680;关于互斥锁的理解 &#x1f680;关于原子性的理解 &#x1f680;如何理解加锁和解锁是原子的 &#x1f6a9;对互斥锁的简单封装 引言 大家有任何疑问&#xff0c;可…
阅读更多...
CCSP自考攻略+经验总结

CCSP自考攻略+经验总结

备考攻略 备考攻略准备阶段通读阶段精度阶段总复习阶段刷题阶段命运审判 写到最后 备考攻略 趁着对ssp知识点的理解还在&#xff0c;开始ccsp的考证之路&#xff0c;文章结构还是按照cissp备考篇的结构梳理。本次备考和cissp的离职在家备考不同&#xff0c;ccsp是在职利用非工…
阅读更多...
如何用亚马逊合作伙伴网络快速上线跨境电商

如何用亚马逊合作伙伴网络快速上线跨境电商

目前跨境电商已成为行业发展主流&#xff0c;如何快速、低成本打造品牌海外独立站和智能客服营销中心、构建全链路跨境电商体系是出海电商商家都会遇到的难题。亚马逊云科技凭借与亚马逊电商平台易于集成的先天优势成为首选的电商解决方案平台。本文介绍了如何用亚马逊云科技平…
阅读更多...
Elasticsearch8.x聚合查询全面指南：从理论到实战

Elasticsearch8.x聚合查询全面指南：从理论到实战

聚合查询的概念 聚合查询&#xff08;Aggregation Queries&#xff09;是Elasticsearch中用于数据汇总和分析的查询类型。它不同于普通的查询&#xff0c;而是用于执行各种聚合操作&#xff0c;如计数、求和、平均值、最小值、最大值、分组等。 聚合查询的分类 分桶聚合&…
阅读更多...
centos7 安装单机MongoDB

centos7 安装单机MongoDB

centos7安装单机 yum 安装 1、配置yum源 vim /etc/yum.repos.d/mongodb.repo [mongodb-org-7.0] nameMongoDB Repository baseurlhttps://repo.mongodb.org/yum/redhat/$releasever/mongodb-org/7.0/x86_64/ gpgcheck1 enabled1 gpgkeyhttps://www.mongodb.org/static/pgp…
阅读更多...
未来已来，如何打造智慧养殖场？

未来已来，如何打造智慧养殖场？

近年来&#xff0c;国家出台了一系列扶持政策&#xff0c;以促进养殖行业高质量发展&#xff0c;推动行业转型升级。在国家政策和市场需求的双重驱动下&#xff0c;养殖行业正迎来前所未有的发展机遇。智慧养殖以其高效、智能和可持续的特点&#xff0c;正逐步取代传统养殖方式…
阅读更多...
6.26.4.1 基于交叉视角变换的未配准医学图像多视角分析

6.26.4.1 基于交叉视角变换的未配准医学图像多视角分析

1. 介绍 许多医学成像任务使用来自多个视图或模式的数据&#xff0c;但很难有效地将这些数据结合起来。虽然多模态图像通常可以在神经网络中作为多个输入通道进行配准和处理&#xff0c;但来自不同视图的图像可能难以正确配准(例如&#xff0c;[2])。因此&#xff0c;大多数多视…
阅读更多...
学生表的er关系图和模型图

学生表的er关系图和模型图

er关系图 模型图
阅读更多...
吴恩达2022机器学习专项课程C2W3：2.27 选修_数据倾斜

吴恩达2022机器学习专项课程C2W3：2.27 选修_数据倾斜

目录 处理不平衡数据集1.分类需求描述2.计算精确率和召回率 权衡精确率和召唤率1.手动调整阈值2.F1分数 总结 处理不平衡数据集 1.分类需求描述 如果你在处理一个机器学习应用&#xff0c;其中正例和负例的比例&#xff08;用于解决分类问题&#xff09;非常不平衡&#xff0…
阅读更多...
数据库怎么同步

数据库怎么同步

数据库要怎么同步呢&#xff0c;有很多方法&#xff0c;看你用什么数据库&#xff0c;如果是Sqlserver,你要数据库同步&#xff0c;那么可以使用自带的订阅发布&#xff0c;订阅发布应该是不错的方法&#xff0c;但是我上次要配置双向同步&#xff0c;它的对等发布好像没部署成…
阅读更多...
Ansible-综合练习-生产案例

Ansible-综合练习-生产案例

斌的招儿 网上教程大多都是官网模板化的教程和文档&#xff0c;这里小斌用自己实际生产环境使用的例子给大家做一个详解。涉及到一整套ansible的使用&#xff0c;对于roles的使用&#xff0c;也仅涉及到tasks和files目录&#xff0c;方便大家快速上手并规范化管理。 0.环境配置…
阅读更多...
聚星文社AI工具

聚星文社AI工具

聚星文社AI工具是一种基于人工智能技术开发的工具&#xff0c;旨在辅助作者和写作人员提升创作效率和质量。 点击下载 该工具可以提供多项功能&#xff0c;包括语法纠错、智能推荐、文章自动摘要等。 通过使用聚星文社AI工具&#xff0c;用户可以在写作过程中得到即时的纠错建…
阅读更多...
ECMAScript6介绍及环境搭建

ECMAScript6介绍及环境搭建

这实际上说明&#xff0c;对象的解构赋值是下面形式的简写。 let { foo: foo, bar: bar } { foo: ‘aaa’, bar: ‘bbb’ }; 也就是说&#xff0c;对象的解构赋值的内部机制&#xff0c;是先找到同名属性&#xff0c;然后再赋给对应的变量。真正被赋值的是后者&#xff0c;而…
阅读更多...
数据结构_绪论

数据结构_绪论

1.数据结构的研究内容 研究数据的特性和数据之间的关系 用计算机解决一个问题的步骤 1.具体问题抽象成数学模型 实质: 分析问题--->提取操作对象--->找出操作对象之间的关系(数据结构)--->用数学语言描述 操作对象对象之间的关系 2.设计算法 3.编程,调试,运行 …
阅读更多...
【数据结构与算法】哈希函数 详解

【数据结构与算法】哈希函数 详解

哈希函数的构造方法有哪些&#xff1f; 直接定址法&#xff1a;直接使用关键字或者关键字的某个线性函数值作为哈希地址。 数字分析法&#xff1a;对关键字进行分析&#xff0c;选择关键字中的某几位或者进行某种运算得到的结果作为哈希地址。 平方取中法&#xff1a;先计算关…
阅读更多...
通信协议总结

通信协议总结

IIC 基本特点 同步&#xff0c;半双工 标准100KHz&#xff0c;最高400KHz&#xff08;IIC主要应用于低速设备&#xff09; 硬件组成 需外接上拉电阻 通信过程 空闲状态 SDA和SCL都处于高电平 开始信号S和终止信号P 在数据传输过程中&#xff0c;当SCL0时&#xff0c;SDA才…
阅读更多...
十常侍乱政 | 第2集 | 愿领精兵五千，斩关入内，册立新君，诛杀宦党，扫清朝廷，以安天下 | 三国演义 | 逐鹿群雄

十常侍乱政 | 第2集 | 愿领精兵五千，斩关入内，册立新君，诛杀宦党，扫清朝廷，以安天下 | 三国演义 | 逐鹿群雄

&#x1f64b;大家好&#xff01;我是毛毛张! &#x1f308;个人首页&#xff1a; 神马都会亿点点的毛毛张 &#x1f4cc;这篇博客是毛毛张分享三国演义文学剧本中的经典台词和语句&#xff0c;本篇分享的是《三国演义》第Ⅰ部分《群雄逐鹿》的第2️⃣集《十常侍乱政治》&am…
阅读更多...
汇聚荣做拼多多运营第一步是什么？

汇聚荣做拼多多运营第一步是什么？

汇聚荣做拼多多运营第一步是什么?在众多电商平台中&#xff0c;拼多多凭借其独特的社交电商模式迅速崛起&#xff0c;吸引了大量消费者和商家的目光。对于希望在拼多多上开店的商家而言&#xff0c;了解如何进行有效运营是成功的关键。那么&#xff0c;汇聚荣做拼多多运营的第…
阅读更多...
算法入门：二分查找及其Java实现

算法入门：二分查找及其Java实现

在程序开发中&#xff0c;算法是解决问题的核心。本篇博客将详细讲解一种高效的查找算法——二分查找&#xff0c;并通过Java代码示例帮助你理解其实现和应用。 如果你觉得这篇文章对你有帮助&#xff0c;不要忘记点赞、收藏和关注我&#xff0c;这将是对我最大的支持和鼓励&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023