《UNIX网络编程 卷2》读书笔记(二)

简介:
 如何知道进程在一个空消息队列中放入一个消息?如果阻塞在msgrcv调用中,则除了等待无法做其他事情,如果给msgrcv指定非阻塞标志(IPC_NOWAIT),尽管不阻塞了,但必须持续调用该函数来确定何时有消息到达,也就是采用轮询方式(polling),Posix消息队列允许异步事件通知来通知何时有消息放入到某个空消息队列中,有2种方式:
1)产生一个信号
2)创建一个线程执行一个指定函数
这通过mq_notify建立。
union sigval
{
   int sival_int;
   void *sival_ptr;
};

struct sigevent
{
   int sigev_notify;
   int sigev_signo;
   union sigval sigev_value;
   void (*sigev_notify_function)(union sigval);
   pthread_attr_t *sigev_notify_attributes;
};


    
#include "unpipc.h"

volatile sig_atomic_t mqflag;
static void sig_usr1(int signo)
{

    mqflag = 1;
    return;
}
int main(int argc,char** argv)
{

    mqd_t mqd;
    void * buff;
    SSIZE_T n;
    sigset_t zeromask,newmask,oldmask;
    struct mq_attr attr;
    struct sigevent sigev;
    mqd = mq_open(argv[1],O_RDONLY|O_NONBLOCK);//打开消息队列
    mq_getattr(mqd,&attr);
    buff = malloc(attr.mq_msgsize);//创建接收缓冲区
    sigemptyset(&zeromask);
    sigemptyset(&newmask);
    sigemptyset(&oldmask);
    sigaddset(&newmask,SIGUSR1);
    //初始化信号处理
    signal(SIGUSR1,sig_usr1);
    sigev.sigev_notify = SIGEV_SIGNAL;
    sigev.sigev_signo = SIGUSR1;
    mq_notify(mqd,&sigev);
    for(;;)
    {
        sigprocmask(SIG_BLOCK,&newmask,&oldmask);//阻塞SIGUSR1信号
        while(mqflag==0)sigsuspend(&zeromask);
        mqflag = 0;
        mq_notify(mqd,&sigev);
        while((n=mq_receive(mqd,buff,attr.mq_msgsize,NULL))>=0)
        {//循环接收数据
            printf("read %ld bytes\n",(long)n);
        }
        sigprocmask(SIG_UNBLOCK,&newmask,NULL);
    }
    exit(0);
    
}


struct msqid_ds
{
  struct ipc_perm msg_perm;
  struct msg* msg_first;
  struct msg* msg_last;
  msgle_t msg_cbytes;
  msgqnum_t msg_qnum;
  msglen_t  msg_qbytes;
  pid_t msg_lspid;
  pid_t msg_lrpid;
  time_t msg_stime;
  time_t msg_rtime;
  time_t msg_ctime;
};

msgget创建一个新的消息队列或访问一个已经存在的消息队列
msgsnd发送一个消息,消息是下面这样的结构体:
struct msgbuf
{
 long mtype;//消息类型
 char mtext[1];//消息数据
};

 
但这个预定的结构一般无法满足自己的需求,因此一般定义自己的结构
typedef struct my_msgbuf
{
  long mtype;
  int16_t mshort;//消息数据起始
  char mchar[MY_DATA];
}Message;

发送数据时可以指定flag为IPC_NOWAIT,这个标志使得msgsnd调用非阻塞,
 
调用msgrcv函数时,若type指定为0,则返回消息队列第一个消息,若type小于0,则返回类型值小于或等于type绝对值的消息中类型值最小的
第一个消息
 
使用两个消息队列来实现前面的客户—服务器例子,一个队列用于从客户方到服务器的消息,一个队列用于从服务器到客户的消息。

#include "unpipc.h"
#define MQ_KEY1 1234L
#define MQ_KEY2 2345L

int main()
{
    int readid,writeid;
    readid = msgget(MQ_KEY1,SVMSG_MODE|IPC_CREATE);
    writeid = msgget(MQ_KEY2,SVMSG_MODE|IPC_CREATE);
    server(readid,writeid);
    exit(0);
}

int main()
{
    int readid,writeid;
    readid = msgget(MQ_KEY2,0);
    writeid = msgget(MQ_KEY1,0);
    client(readid,writeid);
    //删除消息队列
    msgctl(readid,IPC_RMID,NULL)
    msgctl(writeid,IPC_RMID,NULL);
    exit(0);

}

第8节使用一个队列来实现单服务器,多客户端的通信,但互斥,死锁可能存在,另一种思路就是为每个实体单独设置一个私有队列,消息都发送到自己的队列中,也只从自己的队列中取消息.
System V的消息队列比Posix消息队列差多了,要使用select模型同时处理网络连接和IPC连接时,必须产生子进程,使用管道作为中介,另外一个弱点是无法Peek一个消息.



本文转自Phinecos(洞庭散人)博客园博客,原文链接:http://www.cnblogs.com/phinecos/archive/2008/05/27/1208521.html,如需转载请自行联系原作者
相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
2月前
|
存储 网络协议 Linux
《网络是怎么样连接的》读书笔记 - WEB服务端请求和响应(五)
《网络是怎么样连接的》读书笔记 - WEB服务端请求和响应(五)
36 0
|
2月前
|
缓存 负载均衡 网络协议
《网络是怎么样连接的》读书笔记 - 服务器端的局域网中(四)
《网络是怎么样连接的》读书笔记 - 服务器端的局域网中(四)
42 0
|
2月前
|
存储 设计模式 缓存
《网络是怎么样连接的》读书笔记 - 集线器、路由器和路由器(三)
《网络是怎么样连接的》读书笔记 - 集线器、路由器和路由器(三)
28 0
|
2月前
|
缓存
《网络是怎么样连接的》读书笔记 - FTTH
《网络是怎么样连接的》读书笔记 - FTTH
36 0
|
2月前
|
存储 缓存 网络协议
《网络是怎么样连接的》读书笔记 - Tcp/IP连接(二)
《网络是怎么样连接的》读书笔记 - Tcp/IP连接(二)
52 0
|
2月前
|
域名解析 缓存 网络协议
《网络是怎么样连接的》读书笔记 - 认识网络基础概念(一)
《网络是怎么样连接的》读书笔记 - 认识网络基础概念(一)
97 1
|
4月前
|
缓存 网络协议 网络安全
《网络是怎么样连接的》读书笔记 - 汇总篇(二)
《网络是怎么样连接的》读书笔记 - 汇总篇
65 0
《网络是怎么样连接的》读书笔记 - 汇总篇(二)
|
4月前
|
域名解析 缓存 网络协议
《网络是怎么样连接的》读书笔记 - 汇总篇(一)
《网络是怎么样连接的》读书笔记 - 汇总篇
101 0
《网络是怎么样连接的》读书笔记 - 汇总篇(一)
|
4月前
|
存储 网络协议 Linux
《网络是怎么样连接的》读书笔记 - WEB服务端请求和响应(五)
《网络是怎么样连接的》读书笔记 - WEB服务端请求和响应(五)
28 0
《网络是怎么样连接的》读书笔记 - WEB服务端请求和响应(五)
|
4月前
|
缓存 负载均衡 网络协议
《网络是怎么样连接的》读书笔记 - 服务器端的局域网中(四)
《网络是怎么样连接的》读书笔记 - 服务器端的局域网中(四)
33 0
《网络是怎么样连接的》读书笔记 - 服务器端的局域网中(四)

热门文章

最新文章