写了两个程序，一个作为服务端，用msgget（）建立一个消息队列，然后将消息队列ID加入epoll中进行监听。
另一个作为客户端，往这个消息队列发送消息。但是epoll wait函数始终返回0。代码如下：
server.c：
struct msg_st {
long mtype; //自定义消息类型
int date; //自定义消息内容
};
int epfd;
void signal_handler()
{
close(epfd);
return;
}
int main()
{
struct msg_st msg;
int i = 0;
signal(SIGINT, signal_handler);
int msgque_id = msgget((key_t)1234, 0666 | IPC_CREAT);
if (msgque_id < 0)
{
printf("create message queue fail\n");
return -1;
}
printf("msgque_id = %d\n", msgque_id);
//声明epoll_event结构体的变量,ev用于注册事件,数组用于回传要处理的事件
struct epoll_event ev, events[20];
//创建一个epoll的句柄，size用来告诉内核这个监听的数目一共有多大
epfd = epoll_create(256); //生成用于处理accept的epoll专用的文件描述符
printf("epfd = %d\n", epfd);
//设置用于读操作的文件描述符
ev.data.fd = msgque_id;
//设置用于注册的读操作事件
ev.events = EPOLLIN | EPOLLET;
epoll_ctl(epfd, EPOLL_CTL_ADD, msgque_id, &ev);
for (; ; )
{
//等待epoll事件的发生
//返回需要处理的事件数目nfds，如返回0表示已超时。
int nfds = epoll_wait(epfd, events, 20, 500);
printf("nfds = %d\n",nfds);
//处理所发生的所有事件
for (i = 0; i < nfds; ++i)
{
if (events[i].data.fd == msgque_id)
{
if (msgrcv(msgque_id, (void*)&msg, sizeof(msg), 0, 0) < 0)
{
printf("message recv fail\n");
return -1;
}
printf("message recv success,msg = %d,%d\n", msg.mtype, msg.date);
}
else
{
printf("unknown fd\n");
}
}
}
return 0;
}
client.c:
struct msg_st {
long mtype; //自定义消息类型
int date; //自定义消息内容
};
int msgque_id;
void signal_handler()
{
if (msgctl(msgque_id, IPC_RMID, 0) < 0)
{
printf("delete message queue fail\n");
}
return;
}
int main()
{
struct msg_st msg;
signal(SIGINT, signal_handler);
msgque_id = msgget((key_t)1234, 0666);
if (msgque_id < 0)
{
printf("create message queue fail\n");
return -1;
}
printf("msgque_id = %d\n", msgque_id);
//向队列中写入消息
while (1)
{
msg.mtype = 1;
msg.date = 1;
if (msgsnd(msgque_id, (void*)&msg, sizeof(msg), 0) < 0)
{
printf("message send fail\n");
return -1;
}
sleep(1);
}
return 0;
}
