Chinaunix首页 | 论坛 | 博客
  • 博客访问: 291371
  • 博文数量: 109
  • 博客积分: 2116
  • 博客等级: 大尉
  • 技术积分: 1062
  • 用 户 组: 普通用户
  • 注册时间: 2009-10-22 15:38
文章分类

全部博文(109)

文章存档

2013年(2)

2011年(16)

2010年(90)

2009年(1)

我的朋友

分类: LINUX

2010-07-09 11:30:27

今天完成消息队列的使用。

消息队列类似FIFO,但是可以实现随机查询。

主要函数:msgget,msgsnd,msgrcv,msgctl

实验实现两个进程之间的通信。

一个发送,一个接受。并不需要额外实现进程同步。

源代码来自华清远见:

发送:

#include

#include

#include

#include

#include

#include

#include

 

#define BUFFER_SIZE 512

 

struct message

{

    long msg_type;

    char msg_text[BUFFER_SIZE];

};

 

int main()

{

    int qid;

    key_t key;

    struct message msg;

       //ftok根据不同路径和关键字产生标准的KEY

    if((key = ftok(".", 'a')) == -1)

    {

        perror("ftok");

        exit(1);

    }

 

    if((qid = msgget(key, IPC_CREAT|0666)) == -1)//创建

    {

        perror("msgget");

        exit(1);

    }

    printf("open queue %d\n", qid);

 

    while(1)

    {

        printf("enter some message to the queue:");

        if((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL)

        {

            puts("no message");

            exit(1);

        }

 

        msg.msg_type = getpid();//消息类型为进程号

 

        if((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0)//发送消息

        {

            perror("message posted");

            exit(1);

        }

 

        if(strncmp(msg.msg_text, "quit", 4) == 0)

        {

            break;

        }

    }

    exit(0);

}

 

接收:

#include

#include

#include

#include

#include

#include

#include

 

#define BUFFER_SIZE 512

 

struct message

{

    long msg_type;

    char msg_text[BUFFER_SIZE];

};

 

int main()

{

    int qid;

    key_t key;

    struct message msg;

 

    if((key = ftok(".", 'a')) == -1)

    {

        perror("ftok");

        exit(1);

    }

 

    if((qid = msgget(key, IPC_CREAT|0666)) == -1)//创建

    {

        perror("msgget");

        exit(1);

    }

    printf("open queue %d\n", qid);

 

    do

    {

        memset(msg.msg_text, 0, BUFFER_SIZE);

        if(msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0)//接收消息

        {

            perror("msgrcv");

            exit(1);

        }

        printf("the message from process %d : %s", msg.msg_type, msg.msg_text);

    }while(strncmp(msg.msg_text, "quit", 4));

 

    if((msgctl(qid, IPC_RMID, NULL)) < 0)//从系统内核移走消息队列

    {

        perror("msgctl");

        exit(1);

    }

    exit(0);

}

 

打开两个终端,1号发送,2号接收。

编译以后结果如下:

阅读(436) | 评论(0) | 转发(0) |
0

上一篇:命名管道

下一篇:多进程实验

给主人留下些什么吧!~~