利用C语言消息队列实现双向通信(非阻塞),终端A手动发消息给终端B,消息 自动接收,终端B也可以手动发消息给终端B,消息自动接收。没有发送和接收消息时 不需要提示用户输入要发送给进程消息

时间: 2024-03-30 15:37:02 浏览: 15
好的,这是一个非常好的问题。我来解答一下。 首先,需要明确一下消息队列的概念。消息队列是一种进程间通信的方式,它可以实现进程之间的数据传递,而不需要像管道、套接字那样需要建立连接。消息队列是一种先进先出的数据结构,它的优点是可以在发送方和接收方之间进行异步通信,即发送方不需要等待接收方的响应,可以直接进行下一步操作。 在C语言中,可以使用系统提供的消息队列函数来实现消息队列的创建、发送和接收等操作。下面是一个简单的例子,实现了两个进程之间的双向通信: ```c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/msg.h> #define MAX_MSG_SIZE 1024 #define MSG_TYPE_A_TO_B 1 #define MSG_TYPE_B_TO_A 2 struct msgbuf { long mtype; char mtext[MAX_MSG_SIZE]; }; int main() { int mqid_a_to_b, mqid_b_to_a; key_t key_a_to_b, key_b_to_a; struct msgbuf msg; // 创建消息队列A->B和B->A key_a_to_b = ftok(".", 'a'); mqid_a_to_b = msgget(key_a_to_b, IPC_CREAT|0666); if (mqid_a_to_b == -1) { perror("msgget failed"); exit(1); } key_b_to_a = ftok(".", 'b'); mqid_b_to_a = msgget(key_b_to_a, IPC_CREAT|0666); if (mqid_b_to_a == -1) { perror("msgget failed"); exit(1); } while (1) { // 接收A发来的消息 if (msgrcv(mqid_a_to_b, &msg, MAX_MSG_SIZE, MSG_TYPE_A_TO_B, IPC_NOWAIT) != -1) { printf("Received from A: %s\n", msg.mtext); } // 接收B发来的消息 if (msgrcv(mqid_b_to_a, &msg, MAX_MSG_SIZE, MSG_TYPE_B_TO_A, IPC_NOWAIT) != -1) { printf("Received from B: %s\n", msg.mtext); } // 发送消息给B fgets(msg.mtext, MAX_MSG_SIZE, stdin); if (msg.mtext[0] != '\n') { msg.mtype = MSG_TYPE_A_TO_B; msgsnd(mqid_b_to_a, &msg, strlen(msg.mtext)+1, IPC_NOWAIT); } // 发送消息给A if (msgrcv(mqid_a_to_b, &msg, MAX_MSG_SIZE, MSG_TYPE_A_TO_B, IPC_NOWAIT) != -1) { msg.mtype = MSG_TYPE_B_TO_A; msgsnd(mqid_a_to_b, &msg, strlen(msg.mtext)+1, IPC_NOWAIT); } usleep(100); } return 0; } ``` 在上面的代码中,我们创建了两个消息队列A->B和B->A,并使用一个死循环来接收和发送消息。在每次循环中,我们先尝试接收A和B发来的消息,如果有消息就打印出来。然后从终端输入一个消息,如果不是空行就发送给B。接着尝试从A->B的消息队列中接收消息,如果有消息就将其发送给A->B的消息队列。注意,在发送消息时我们使用了`IPC_NOWAIT`标志,表示如果消息队列已满就立即返回,不会阻塞等待。这样可以保证消息的非阻塞发送和接收。 另外,我们还定义了两个消息类型`MSG_TYPE_A_TO_B`和`MSG_TYPE_B_TO_A`,分别表示A->B和B->A的消息。这样可以在发送和接收消息时进行区分。 希望这个例子能够帮助到你,如果有任何问题欢迎继续提问。

相关推荐

最新推荐

recommend-type

C语言用栈和队列实现的回文检测功能示例

主要介绍了C语言用栈和队列实现的回文检测功能,结合具体实例形式分析了C语言栈和队列的定义及使用栈和队列进行回文检测的操作技巧,需要的朋友可以参考下
recommend-type

C语言实现socket简单通信实例

主要介绍了C语言实现socket简单通信的方法,是学习C语言网络编程非常基础而又实用的实例,需要的朋友可以参考下
recommend-type

C语言利用EasyX实现图形化界面的小游戏

C语言利用EasyX实现图形化界面的小游戏,可实操性很强,干货满满,学完C语言不知道干啥,可以写着玩一下
recommend-type

优先队列(priority_queue)的C语言实现代码

本文简要介绍一种基于数组二叉堆实现的优先队列,定义的数据结构和实现的函数接口说明如下
recommend-type

基于C语言的RS232串行接口通信实现_葛磊蛟.pdf

串口通信是一种广泛使用且实用的通信方式,介绍 RS232 串行通信的联结方式,研究利用 C 语言编程实 现 RS232 串行通信的过程.结合实际应用,在约定双方串行通信协议的基础上,运用 C 语言开发的串行通信软 件,实现...
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

MATLAB遗传算法自动优化指南:解放算法调优,提升效率

![MATLAB遗传算法自动优化指南:解放算法调优,提升效率](https://help-static-aliyun-doc.aliyuncs.com/assets/img/zh-CN/8487939061/p208348.png) # 1. MATLAB遗传算法概述** 遗传算法是一种受生物进化启发的优化算法,它模拟了自然选择和遗传的过程。在MATLAB中,遗传算法工具箱提供了丰富的函数和类,用于创建和运行遗传算法。 **1.1 遗传算法的基本原理** 遗传算法的工作原理如下: - **初始化:**创建由随机个体组成的初始种群。 - **评估:**根据目标函数计算每个个体的适应度。 -
recommend-type

failed to register layer: ApplyLayer exit status 1 stdout: stderr: archive/tar: invalid tar header

很抱歉听到这个问题。这个错误通常是由于Docker镜像损坏或Docker存储库中缺少所需的图层引起的。您可以尝试以下几种方法来解决这个问题: 1. 清理Docker镜像和容器:使用命令“docker system prune”清理不再使用的Docker对象。 2. 检查Docker存储库:确保您正在使用可靠的Docker存储库,并检查是否存在所有必需的图层。 3. 重新下载Docker镜像:如果您确定问题是由于损坏的Docker镜像引起的,则可以尝试重新下载Docker镜像。 4. 更新Docker版本:如果您使用的是旧版Docker,则可能会出现此问题。尝试更新到最新版本的Docke
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。