锐客网

  1. 首页 > 睿知 > it技术 > >

java即时消息源代码 java如何实现实时消息推送( 三 )

IT技术消息


3、msgrcv函数
该函数用来从一个消息队列获取消息 ， 它的原型为
int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg);
msgid, msg_ptr, msg_st的作用也函数msgsnd函数的一样 。
msgtype可以实现一种简单的接收优先级 。如果msgtype为0，就获取队列中的第一个消息 。如果它的值大于零 ， 将获取具有相同消息类型的第一个信息 。如果它小于零 ， 就获取类型等于或小于msgtype的绝对值的第一个消息 。
msgflg用于控制当队列中没有相应类型的消息可以接收时将发生的事情 。
调用成功时，该函数返回放到接收缓存区中的字节数，消息被复制到由msg_ptr指向的用户分配的缓存区中，然后删除消息队列中的对应消息 。失败时返回-1.
4、msgctl函数
该函数用来控制消息队列，它与共享内存的shmctl函数相似 ， 它的原型为：
int msgctl(int msgid, int command, struct msgid_ds *buf);
command是将要采取的动作 ， 它可以取3个值 ， 
IPC_STAT：把msgid_ds结构中的数据设置为消息队列的当前关联值 ， 即用消息队列的当前关联值覆盖msgid_ds的值 。
IPC_SET：如果进程有足够的权限，就把消息列队的当前关联值设置为msgid_ds结构中给出的值
IPC_RMID：删除消息队列
buf是指向msgid_ds结构的指针，它指向消息队列模式和访问权限的结构 。msgid_ds结构至少包括以下成员：
struct msgid_ds
{
uid_t shm_perm.uid;
uid_t shm_perm.gid;
mode_t shm_perm.mode;
};
成功时返回0，失败时返回-1.
三、使用消息队列进行进程间通信
马不停蹄 ， 介绍完消息队列的定义和可使用的接口之后，我们来看看它是怎么让进程进行通信的 。由于可以让不相关的进程进行行通信，所以我们在这里将会编写两个程序 ， msgreceive和msgsned来表示接收和发送信息 。根据正常的情况，我们允许两个程序都可以创建消息，但只有接收者在接收完最后一个消息之后，它才把它删除 。
接收信息的程序源文件为msgreceive.c的源代码为：
#include unistd.h
#include stdlib.h
#include stdio.h
#include string.h
#include errno.h
#include sys/msg.h
struct msg_st
{
long int msg_type;
char text[BUFSIZ];
};
int main()
{
int running = 1;
int msgid = -1;
struct msg_st data;
long int msgtype = 0; //注意1
//建立消息队列
msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
if(msgid == -1)
{
fprintf(stderr, "msgget failed with error: %d\n", errno);
exit(EXIT_FAILURE);
}
//从队列中获取消息，直到遇到end消息为止
while(running)
{
if(msgrcv(msgid, (void*)data, BUFSIZ, msgtype, 0) == -1)
{
fprintf(stderr, "msgrcv failed with errno: %d\n", errno);
exit(EXIT_FAILURE);
}
printf("You wrote: %s\n",data.text);
//遇到end结束
if(strncmp(data.text, "end", 3) == 0)
running = 0;
}
//删除消息队列
if(msgctl(msgid, IPC_RMID, 0) == -1)
{
fprintf(stderr, "msgctl(IPC_RMID) failed\n");
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
发送信息的程序的源文件msgsend.c的源代码为：
#include unistd.h
#include stdlib.h
#include stdio.h
#include string.h
#include sys/msg.h
#include errno.h
#define MAX_TEXT 512
struct msg_st
{
long int msg_type;
char text[MAX_TEXT];
};
int main()
{
int running = 1;
struct msg_st data;
char buffer[BUFSIZ];

推荐阅读


上一篇：小米电视3安卓软件怎么用，小米电视三方软件在哪

下一篇：直播话术瑜伽裤，搜索瑜伽直播