单一消息队列完成客户-服务器进程间的双向通信

2023-10-31 15:30

本文主要是介绍单一消息队列完成客户-服务器进程间的双向通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

单一消息队列完成客户—服务器进程间的双向通信,客户端接收输入字符串,如接收到的是exit字符串,直接退出,否则传送接收字符串到服务器端,并等待服务器端回传消息。服务器端:接收客户端请求,接收后将接收到的字符串逆序后回传到对应客户端。

//服务器端:
#include<sys/msg.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<stdio.h>
#include<sys/errno.h>
#include<string.h>
extern int errno;
struct mymsgbuf1
{long mtype;char ctext[100];
};
struct mymsgbuf
{long mtype;pid_t pid;char ctext[100];
};
void main(){struct mymsgbuf buf;struct mymsgbuf1 buf1;int msgid,ret,i,len;if((msgid = msgget(0x1234,0666|IPC_CREAT))<0){fprintf(stderr,"openmsg%xfailed.\n",0x1234);return;}while(1){memset(&buf,0,sizeof(buf));while((ret = msgrcv(msgid,&buf,sizeof(buf.ctext)+sizeof(buf.pid),1,0))<0){if(errno == EINTR)continue;return;}fprintf(stderr,"Receivemessageform%d,content:%s\n",buf.pid,buf.ctext);memset(&buf1,0,sizeof(buf1));//strcpy(buf1.ctext,buf.ctext);len=strlen(buf.ctext)for(i = 0;i < len;i++){buf1.ctext[len-1-i] = buf.ctext[i];}buf1.mtype = buf.pid;while((msgsnd(msgid,&buf1,strlen(buf1.ctext),0))<0){if(errno == EINTR)continue;return;}}
}
//客户端:
#include<sys/msg.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<stdio.h>
#include<sys/errno.h>
#include<string.h>
extern int errno;
struct tmymsgbuf1
{longmtype;charctext[100];
};
struct mymsgbuf
{long mtype;pid_t pid;char ctext[100];
};
void main()
{struct mymsgbuf buf;struct mymsgbuf1 buf1;int msgid,ret;pid_t pid = getpid();if((msgid = msgget(0x1234,0666|IPC_CREAT))<0){fprintf(stderr,"openmsg%xfailed.\n",0x1234);return;}while(1){memset(&buf,0,sizeof(buf));fgets(buf.ctext,sizeof(buf.ctext),stdin);if(!strcmp(buf.ctext,"exit"))break;buf.mtype = 1;buf.pid = pid;while((msgsnd(msgid,&buf,strlen(buf.ctext)+sizeof(buf.pid),0))<0){if(errno == EINTR)continue;return;}memset(&buf1,0,sizeof(buf1));while((ret = msgrcv(msgid,&buf1,sizeof(buf1.ctext),pid,0))<0){if(errno == EINTR)continue;return;}fprintf(stderr,"Receivemessageformservercontent:%s\n",buf1.ctext);}
}

在这里插入图片描述

一个服务器对应多个客户端,一个消息队列,客户端都将发送信息的类型设置为1,然后将自己的进程id放到数据部分,服务器接收所有客户端的请求,在返回给客户端信息的时候将类型设置为所接收的数据部分的进程id,客户端这边接收信息的函数里将接收类型设置为自己的进程id,就可以对应上了。

这篇关于单一消息队列完成客户-服务器进程间的双向通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/316332

相关文章

服务器集群同步时间手记

1.时间服务器配置(必须root用户) (1)检查ntp是否安装 [root@node1 桌面]# rpm -qa|grep ntpntp-4.2.6p5-10.el6.centos.x86_64fontpackages-filesystem-1.41-1.1.el6.noarchntpdate-4.2.6p5-10.el6.centos.x86_64 (2)修改ntp配置文件 [r

hdu1180(广搜+优先队列)

此题要求最少到达目标点T的最短时间,所以我选择了广度优先搜索,并且要用到优先队列。 另外此题注意点较多,比如说可以在某个点停留,我wa了好多两次,就是因为忽略了这一点,然后参考了大神的思想,然后经过反复修改才AC的 这是我的代码 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<

客户案例:安全海外中继助力知名家电企业化解海外通邮困境

1、客户背景 广东格兰仕集团有限公司(以下简称“格兰仕”),成立于1978年,是中国家电行业的领军企业之一。作为全球最大的微波炉生产基地,格兰仕拥有多项国际领先的家电制造技术,连续多年位列中国家电出口前列。格兰仕不仅注重业务的全球拓展,更重视业务流程的高效与顺畅,以确保在国际舞台上的竞争力。 2、需求痛点 随着格兰仕全球化战略的深入实施,其海外业务快速增长,电子邮件成为了关键的沟通工具。

poj 3190 优先队列+贪心

题意: 有n头牛,分别给他们挤奶的时间。 然后每头牛挤奶的时候都要在一个stall里面,并且每个stall每次只能占用一头牛。 问最少需要多少个stall,并输出每头牛所在的stall。 e.g 样例: INPUT: 51 102 43 65 84 7 OUTPUT: 412324 HINT: Explanation of the s

poj 2431 poj 3253 优先队列的运用

poj 2431: 题意: 一条路起点为0, 终点为l。 卡车初始时在0点,并且有p升油,假设油箱无限大。 给n个加油站,每个加油站距离终点 l 距离为 x[i],可以加的油量为fuel[i]。 问最少加几次油可以到达终点,若不能到达,输出-1。 解析: 《挑战程序设计竞赛》: “在卡车开往终点的途中,只有在加油站才可以加油。但是,如果认为“在到达加油站i时,就获得了一

Linux服务器Java启动脚本

Linux服务器Java启动脚本 1、初版2、优化版本3、常用脚本仓库 本文章介绍了如何在Linux服务器上执行Java并启动jar包, 通常我们会使用nohup直接启动,但是还是需要手动停止然后再次启动, 那如何更优雅的在服务器上启动jar包呢,让我们一起探讨一下吧。 1、初版 第一个版本是常用的做法,直接使用nohup后台启动jar包, 并将日志输出到当前文件夹n

[Linux]:进程(下)

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 🎈🎈养成好习惯,先赞后看哦~🎈🎈 所属专栏:Linux学习 贝蒂的主页:Betty’s blog 1. 进程终止 1.1 进程退出的场景 进程退出只有以下三种情况: 代码运行完毕,结果正确。代码运行完毕,结果不正确。代码异常终止(进程崩溃)。 1.2 进程退出码 在编程中,我们通常认为main函数是代码的入口,但实际上它只是用户级

poj3750约瑟夫环,循环队列

Description 有N个小孩围成一圈,给他们从1开始依次编号,现指定从第W个开始报数,报到第S个时,该小孩出列,然后从下一个小孩开始报数,仍是报到S个出列,如此重复下去,直到所有的小孩都出列(总人数不足S个时将循环报数),求小孩出列的顺序。 Input 第一行输入小孩的人数N(N<=64) 接下来每行输入一个小孩的名字(人名不超过15个字符) 最后一行输入W,S (W < N),用

POJ2010 贪心优先队列

c头牛,需要选n头(奇数);学校总共有f的资金, 每头牛分数score和学费cost,问合法招生方案中,中间分数(即排名第(n+1)/2)最高的是多少。 n头牛按照先score后cost从小到大排序; 枚举中间score的牛,  预处理左边与右边的最小花费和。 预处理直接优先队列贪心 public class Main {public static voi

Java 后端接口入参 - 联合前端VUE 使用AES完成入参出参加密解密

加密效果: 解密后的数据就是正常数据: 后端:使用的是spring-cloud框架,在gateway模块进行操作 <dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>30.0-jre</version></dependency> 编写一个AES加密