鱼C论坛

 找回密码
 立即注册
查看: 2282|回复: 0

消息队列

[复制链接]
发表于 2021-11-21 15:37:12 | 显示全部楼层 |阅读模式

马上注册,结交更多好友,享用更多功能^_^

您需要 登录 才可以下载或查看,没有账号?立即注册

x
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define MSGKEY 75
struct msgform
{
        long mtype;
        char mtext[512];
        
};

int main()
{
        struct msgform msg;
        int msgqid,pid,*pint;
        msgqid =msgget (MSGKEY,0777);
        pid= getpid ();
        pint =(int*)msg.mtext;
        *pint=pid;
        msg.mtype=1;//定义消息类型
        msgsnd(msgqid,&msg,sizeof(int),0);//发送消息
        msgrcv(msgqid,&msg,512,pid,0);//接受服务者server消息
        printf("client: receive from pid %d\n",*pint);
        
}

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#define MSGKEY 75
struct msgform
{
        long mtype;
        char mtext[512];
        
}msg;
int msgqid;

int main()
{
        int i,pid,*pint;
        extern cleanup();
        for(i=0;i<20;i++){//软中断处理
                signal (i,cleanup);
        }
        //建立与顾客进程相同的消息队列
        msgqid=msgget(MSGKEY,0777|IPC_CREAT);
        for(;;)
        {
                msgrcv(msgqid,&msg, 512,1,0);
                pint=(int*)msg.mtext;
                pid =*pint;
                printf ("server:receive from pid %d\n",pid);//接受客户client消息
                msg.mtype= pid;
                *pint= getpid();
                msgsnd(msgqid,&msg,sizeof(int),0);
        }
        
}

cleanup()
{
        msgctl(msgqid,IPC_RMID,0);
        exit (1);
}
 

 
请问为什么在我运行server接收不到消息?

ipc消息

ipc消息
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

小黑屋|手机版|Archiver|鱼C工作室 ( 粤ICP备18085999号-1 | 粤公网安备 44051102000585号)

GMT+8, 2024-11-15 01:27

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

快速回复 返回顶部 返回列表