Linux如何通过消息传递机制向进程发送信息(linux发送过消息给进程)

在Linux操作系统中,消息传递机制是进程之间进行通信的一种方式。它可以使不同进程之间在各自的地址空间中进行通信,相互之间不会干扰,从而提高了系统的安全性和可靠性。本文将介绍。

公司主营业务:成都网站制作、网站设计、外贸网站建设、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。成都创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联公司推出郑州免费做网站回馈大家。

1. 消息队列

消息队列是进程之间通信的一种方式,是Linux内核提供的一种数据结构。消息队列允许一个进程往队列中写入消息,而另一个进程则可以从队列中读取这些消息。每个消息都有一个类型和一个数据,进程可以通过消息类型来选择读取哪些消息。

在Linux中,使用消息队列的基本步骤如下:

(1)创建消息队列

通过系统调用msgget()函数可以创建消息队列。

#define IPC_CREATE 01000 //创建一个消息队列

#define KEY 1234 //消息队列键值

key_t key = ftok(“.”, KEY); //根据路径名和键值创建一个key

int msgqid = msgget(key, IPC_CREAT|0666);

上述代码使用ftok()函数根据当前路径和一个唯一的键值生成一个key,然后使用msgget()函数创建消息队列,并返回消息队列的标识符msgqid。IPC_CREAT表示如果不存在该消息队列则创建它。

(2)写入消息

通过将消息结构体msgbuf发送到消息队列中即可写入一条消息。

#include

struct msgbuf {

long mtype; //消息类型

char mtext[1024]; //消息文本

};

struct msgbuf msg;

msg.mtype = 1;

strcpy(msg.mtext, “This is a message”);

msgsnd(msgqid, &msg, strlen(msg.mtext), 0);

上述代码中,首先定义了一个消息结构体msgbuf,其中mtype表示消息的类型,mtext表示消息的内容。然后将需要写入的消息赋值到msg中,使用msgsnd()函数将该消息写入到消息队列中。

(3)读取消息

通过调用msgrcv()函数来读取消息。

struct msgbuf msg;

msgrcv(msgqid, &msg, 1024, 1, 0); //读取消息队列中等待的之一条类型为1的消息

上述代码中,调用msgrcv()函数读取消息队列中类型为1的消息,将消息存储在msg中。

(4)删除消息队列

消息队列使用完后需要使用msgctl()函数进行删除。

msgctl(msgqid, IPC_RMID, NULL);

上述代码中,调用msgctl()函数删除消息队列。IPC_RMID表示删除指定的消息队列。

2. 信号量

信号量是Linux内核提供的另一种进程间通信机制。它可以用于提供对临界资源的互斥访问,从而保证了多个进程同时访问同一资源时的安全性。

在Linux中,使用信号量的基本步骤如下:

(1)创建信号量

使用semget()函数可以创建一个新的或者获取一个已有的信号量。

#define KEY 1234

key_t key = ftok(“.”, KEY); //根据路径名和键值创建一个key

int semid = semget(key, 1, IPC_CREAT|0666); //创建信号量

上述代码中,使用ftok()函数根据当前路径和一个唯一的键值生成一个key,然后使用semget()函数创建信号量,并返回信号量的标识符semid。

(2)初始化信号量

使用semctl()函数来初始化信号量。

#include

union semun {

int val; //信号量值

struct semid_ds *buf; //semid_ds结构指针

unsigned short int *array; //数组指针

struct seminfo *__buf;

};

union semun semval;

semval.val = 1;

semctl(semid, 0, SETVAL, semval); //初始化信号量中的之一个信号量为1

上述代码中,定义了一个semun结构体,然后使用semctl()函数将信号量中的之一个信号量初始化为1。

(3)P操作和V操作

使用semop()函数进行P(wt)操作和V(signal)操作。

struct sembuf sembuf;

sembuf.sem_num = 0; //信号量中的之一个信号量

sembuf.sem_op = -1; //执行P操作

sembuf.sem_ = SEM_UNDO; //防止程序意外终止导致信号量未释放

semop(semid, &sembuf, 1);

sembuf.sem_num = 0;

sembuf.sem_op = 1;

sembuf.sem_ = SEM_UNDO;

semop(semid, &sembuf, 1);

上述代码中,先定义了一个sembuf结构体,然后使用semop()函数对该信号量中的之一个信号量执行P操作和V操作。

(4)删除信号量

信号量使用完后需要使用semctl()函数进行删除。

semctl(semid, 0, IPC_RMID);

上述代码中,调用semctl()函数删除信号量。

成都网站建设公司-创新互联,建站经验丰富以策略为先导10多年以来专注数字化网站建设,提供企业网站建设,高端网站设计,响应式网站制作,设计师量身打造品牌风格,热线:028-86922220

linux编程,进程的通信

给你发个例程,一起复习一下:

#include

#include

#include

void msg_stat(int,struct msqid_ds );

main()

{

int gflags,sflags,rflags;

key_t key;

int msgid;

int reval;

struct msguf{

int mtype;

char mtext;

}msg_uf;

struct msgmbuf

{

int mtype;

char mtext;

}msg_rbuf;

struct msqid_ds msg_ginfo,msg_sinfo;

char* msgpath=”/unix/msgqueue”;

key=ftok(msgpath,’a’);

gflags=IPC_CREAT|IPC_EXCL;

msgid=msgget(key,gflags|00666);

if(msgid==-1)

{

printf(“msg create error\n”);

return;

}

//创建一个消息队列后,输出消息队列缺省属性

msg_stat(msgid,msg_ginfo);

sflags=IPC_NOWAIT;

msg_uf.mtype=10;

msg_uf.mtext=’历掘春a’;

reval=msgsnd(msgid,&msg_uf,sizeof(msg_uf.mtext),sflags);

if(reval==-1)

{

printf(“message send error\n”);

}

//发送一个消息后,输出消息队列属性

msg_stat(msgid,msg_ginfo);

rflags=IPC_NOWAIT|MSG_NOERROR;

reval=msgrcv(msgid,&msg_rbuf,4,10,rflags);

if(reval==-1)

printf(“read msg error\n”);

else

printf(“read from msg queue %d bytes\n”,reval);

//从消息队列中读出消息后,输出消息队列属性

msg_stat(msgid,msg_ginfo);

msg_sinfo.msg_perm.uid=8;//just a try

msg_sinfo.msg_perm.gid=8;//

msg_sinfo.msg_qbytes=16388;

//此处验证超级用户可以更改消息队列的缺省msg_qbytes

//注意这里设置的值大于缺省值

reval=msgctl(msgid,IPC_SET,&msg_sinfo);

if(reval==-1)

{

printf(“msg set info error\n”);

return;

}

msg_stat(msgid,msg_ginfo);

//验证设置消息队列属性

reval=msgctl(msgid,IPC_RMID,NULL);//删除消息队列

if(reval==-1)

{

printf(“unlink msg queue error\n”);

return;

}

}

void msg_stat(int msgid,struct msqid_ds msg_info)

{

int reval;

sleep(1);//只是为了后面输出时间的方便

reval=msgctl(msgid,IPC_STAT,&msg_info);

if(reval==-1)

{

printf(“get msg info error\n”);

return;

}

printf(“\散弯n”);

printf(“current number of bytes on queue is %d\n”,msg_info.msg_cbytes);

printf(“number of messages in queue is %d\n”,msg_info.msg_qnum);

printf(“max number of bytes on queue is %d\n”,msg_info.msg_qbytes);

//每个消息队列的容量(字节数)都有限制MSGMNB,值的大小因系统而异。在创建新的消息队列时,肢耐//msg_qbytes的缺省值就是MSGMNB

printf(“pid of last msgsnd is %d\n”,msg_info.msg_lspid);

printf(“pid of last msgrcv is %d\n”,msg_info.msg_lrpid);

printf(“last msgsnd time is %s”, ctime(&(msg_info.msg_stime)));

printf(“last msgrcv time is %s”, ctime(&(msg_info.msg_rtime)));

printf(“last change time is %s”, ctime(&(msg_info.msg_ctime)));

printf(“msg uid is %d\n”,msg_info.msg_perm.uid);

printf(“msg gid is %d\n”,msg_info.msg_perm.gid);

}

linux 发送过消息给进程的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于linux 发送过消息给进程,Linux如何通过消息传递机制向进程发送信息,linux编程,进程的通信的信息别忘了在本站进行查找喔。

创新互联【028-86922220】值得信赖的成都网站建设公司。多年持续为众多企业提供成都网站建设,成都品牌建站设计,成都高端网站制作开发,SEO优化排名推广服务,全网营销让企业网站产生价值。

网站名称:Linux如何通过消息传递机制向进程发送信息(linux发送过消息给进程)
本文来源:http://www.shufengxianlan.com/qtweb/news17/43767.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联