上图的一台主机服务器架构的重大缺陷是容易死锁
因为客户端,服务器都往同一消息队列中发送接收消息,假设消息队列已经满了,此时客户端无法向队列中发送消息,阻塞了,
而服务器接收完一条消息后,想向消息队列发送消息,由于消息队列已经满了,也阻塞了,此时就会死锁。

改进型的一台主机服务器架构
建立两个消息队列,一个用于客户端写入服务器接收,一个用于服务器发送客户端接收,这样则永远不会出现死锁
//本机客户端
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <pthread.h> struct msgbuf
{
long mtype; /* message type, must be > 0 */
char mtext[]; /* message data */
}; int get_msqid(const char *pathname)
{
if (pathname == NULL)
{
printf("get_msqid() params not correct !\n");
return -;
}
char *pvalue1 = getenv(pathname);
if (pvalue1 == NULL)
{
printf("getenv() failed !\n");
return -;
}
key_t sendkey = ftok(pvalue1, );
if (sendkey == -)
{
perror("ftok() err");
return -;
}
int msqid = msgget(sendkey, | IPC_CREAT | IPC_EXCL);
if (msqid == -)
{
if (errno == EEXIST)
{
printf("该消息队列已经存在!\n");
msqid = msgget(sendkey, );
} else
{
perror("msgget() err");
return -;
}
}
return msqid;
} void * start_routine(void * arg)
{
//客户端发送消息队列
int msqid = get_msqid("SENDFILE");
struct msgbuf buf;
memset(&buf, , sizeof(buf));
buf.mtype = ;
//数据的前4个字节存放当前进程的pid
*((int *) buf.mtext) = getpid();
while (fgets(buf.mtext + , , stdin) != NULL)
{
//发送消息队列
if (msgsnd(msqid, &buf, sizeof(int) + strlen(buf.mtext + ), ) == -)
{
perror("msgsnd() err");
return NULL;
}
memset(buf.mtext + , , );
}
return NULL;
} int main(int arg, char * args[])
{
//开启多线程
pthread_t thr1;
//设置分离线程
pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
if (pthread_create(&thr1, &attr, start_routine, NULL) != )
{
printf("pthread_create() failed !\n");
return -;
}
//客户端接收消息队列
int msqid = get_msqid("RECVFILE");
//recv
int rc = ;
struct msgbuf buf;
while ()
{
memset(&buf, , sizeof(buf));
rc = msgrcv(msqid, &buf, , getpid(), );
if (rc == -)
{
perror("msgrcv() err");
break;
}
printf("服务器有消息到来,消息长度是%d\n",rc);
fputs(buf.mtext, stdout);
}
return ;
}
//本机服务器
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h> struct msgbuf
{
long mtype; /* message type, must be > 0 */
char mtext[]; /* message data */
}; int get_msqid(const char *pathname)
{
if (pathname == NULL)
{
printf("get_msqid() params not correct !\n");
return -;
}
char *pvalue1 = getenv(pathname);
if (pvalue1 == NULL)
{
printf("getenv() failed !\n");
return -;
}
key_t sendkey = ftok(pvalue1, );
if (sendkey == -)
{
perror("ftok() err");
return -;
}
int msqid = msgget(sendkey, | IPC_CREAT | IPC_EXCL);
if (msqid == -)
{
if (errno == EEXIST)
{
printf("该消息队列已经存在!\n");
msqid = msgget(sendkey, );
} else
{
perror("msgget() err");
return -;
}
}
return msqid;
} int main(int arg, char * args[])
{
/*客户端的发送消息队列,是服务器的接收消息队列*/
int send_msqid = get_msqid("RECVFILE");
if (send_msqid == -)
return -;
int recv_msqid = get_msqid("SENDFILE");
if (recv_msqid == -)
return -;
//接收消息再发送
int rc = ;
struct msgbuf recvbuf;
struct msgbuf sendbuf;
int pid=;
while ()
{
memset(&recvbuf,,sizeof(struct msgbuf));
memset(&sendbuf,,sizeof(struct msgbuf));
rc = msgrcv(recv_msqid, &recvbuf, , , );
if(rc==-)
{
perror("msgrcv() err");
return -;
}
printf("客户端有数据到来!数据的长度是%d\n",rc);
//解析数据
pid=*((int *)recvbuf.mtext);
sendbuf.mtype=pid;
strcpy(sendbuf.mtext,recvbuf.mtext+);
fputs(sendbuf.mtext,stdout);
//发送
if(msgsnd(send_msqid,&sendbuf,rc-,)==-)
{
perror("msgsnd() err");
return -;
}
}
return ;
}
.SUFFIXES:.c .o
CC=gcc
SRCS1=test01.c
OBJS1=$(SRCS1:.c=.o)
EXEC1=clt
SRCS2=tec02.c
OBJS2=$(SRCS2:.c=.o)
EXEC2=ser start:$(OBJS1) $(OBJS2)
$(CC) -o $(EXEC1) $(OBJS1) -lpthread
$(CC) -o $(EXEC2) $(OBJS2)
@echo "-------OK---------"
.c.o:
$(CC) -Wall -g -o $@ -c $<
clean:
rm -f $(OBJS1)
rm -f $(OBJS2)
rm -f $(EXEC1)
rm -f $(EXEC2)

Linux 进程间通讯详解七的更多相关文章

  1. Linux 进程间通讯详解二

    消息队列 --消息队列提供了本机上从一个进程向另外一个进程发送一块数据的方法 --每个数据块都被认为有一个类型,接收者进程接收的数据块可以有不同的类型值 --消息队列也有管道一样的不足,就是每个消息的 ...

  2. Linux 进程间通讯详解一

    进程间的通讯 两台主机间的进程通讯 --socket 一台主机间的进程通讯 --管道(匿名管道,有名管道) --System V进程间通信(IPC)包括System V消息队列,System V信号量 ...

  3. Linux 进程间通讯详解六

    ftok()函数 key_t ftok(const char *pathname, int proj_id); --功能:创建系统建立IPC通讯 (消息队列.信号量和共享内存) 时key值 --参数 ...

  4. Linux 进程间通讯详解三

    msgctl()函数 int msgctl(int msqid, int cmd, struct msqid_ds *buf); --参数 msqid:有msgget函数返回的消息队列标识码 cmd: ...

  5. Linux 进程间通讯详解五

    msgrcv函数 ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,int msgflg); --功能:是从一个消息队列接 ...

  6. Linux 进程间通讯详解四

    msgsnd函数 int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg); --功能:把一条消息添加到消息队列中 --参数 ...

  7. Linux 进程间通讯方式 pipe()函数 (转载)

    转自:http://blog.csdn.net/ta893115871/article/details/7478779 Linux 进程间通讯方式有以下几种: 1->管道(pipe)和有名管道( ...

  8. Linux 进程间通讯

    一.Linux 下进程间通讯方式 1)管道(Pipe)及有名管道(named pipe): 管道可用于具有亲缘关系进程间的通信,有名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它还允 ...

  9. [转] linux系统文件流、文件描述符与进程间关系详解

    http://blog.sina.com.cn/s/blog_67b74aea01018ycx.html linux(unix)进程与文件的关系错综复杂,本教程试图详细的阐述这个问题. 包括:     ...

随机推荐

  1. Tomcat 服务应用

    转自:http://wiki.jikexueyuan.com/project/tomcat/windows-service.html Tomcat8 是一个服务应用,能使 Tomcat 8 以 Win ...

  2. Android 自定义实现switch开关按钮

    前几天在看蘑菇街上有个开关按钮: 就在想是怎样实现的,于是反编译了它的源码,但是这时得到了下面的几张图片: 图片对应的名称: 无色长条:switch_frame; 白色圆点:switch_btn_pr ...

  3. jQuery学习总结(二)

    简单选择器: 在使用jQuery 选择器时,我们首先必须使用“$()”函数来包装我们的CSS 规则. 而CSS 规则作为参数传递到jQuery 对象内部后,再返回包含页面中对应元素的jQuery 对象 ...

  4. linux内核中的get_user和put_user

    linux内核中的get_user和put_user 在 内核空间和用户空间交换数据时,get_user和put_user是两个两用的函数.相对于copy_to_user和 copy_from_use ...

  5. CAF(C++ actor framework)使用随笔(延迟发送,消息转发,消息优先级)(四)

    e). 消息延迟发送(和前面没太大区别直接上代码) #include <iostream> #include "caf/all.hpp" #include " ...

  6. ListView与RadioButton组合——自定义单选列表

      标签: radiobuttonlistviewandroidlayout 2013-09-10 11:13 19396人阅读 评论(8) 收藏 举报  分类: Android(19)  版权声明: ...

  7. hiho1255 Mysterious Antiques in Sackler Museum

    题目链接:http://media.hihocoder.com/contests/icpcbeijing2015/problems.pdf 题目大意:给你四个矩形,判断是否能取其中任意三个组成一个大矩 ...

  8. java使用Redis6--sentinel单点故障主从自动切换

    Redis SentinelSentinel(哨兵)是用于监控redis集群中Master状态的工具,其已经被集成在redis2.4+的版本中 一.Sentinel作用:1):Master状态检测 2 ...

  9. 简易搭建git仓库、关联远程和本地仓库方法。克隆仓库方法。同一台电脑上创建两个git ssh key方法。

    一,在github上建仓库 react-js-antd-demo: 二:将远程仓库与本地仓库关联 git remote add origin git@github.com:begin256/react ...

  10. 改写python round()函数,解决四舍五入问题 round(1.365,2)=1.36

    round()函数四舍五入存在一个问题,遇到5不一定进一.如下图所示: print(round(1.365,2)) #1.36 没进一 print('%.2f'%1.365) print(round( ...