linux环境下,如何用epoll监听消息队列?

写了两个程序,一个作为服务端,用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;

}

https://blog.csdn.net/fuyuande/article/details/80588962