锐客网

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

消息队列java代码 java消息队列应用场景( 二 )

IT技术消息


int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg);
msgid是由msgget函数返回的消息队列标识符 。
msg_ptr是一个指向准备发送消息的指针 ， 但是消息的数据结构却有一定的要求，指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体，接收函数将用这个成员来确定消息的类型 。所以消息结构要定义成这样：
struct my_message{
long int message_type;
/* The data you wish to transfer*/
};
msg_sz是msg_ptr指向的消息的长度，注意是消息的长度 ， 而不是整个结构体的长度，也就是说msg_sz是不包括长整型消息类型成员变量的长度 。
msgflg用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情 。
如果调用成功，消息数据的一分副本将被放到消息队列中，并返回0，失败时返回-1.
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)

推荐阅读


上一篇：电视怎么屏蔽机顶盒频道，电视怎么屏蔽机顶盒频道广告

下一篇：直播有趣绘画素材下载，直播画稿