⑴ 请教一个关于linux消息队列的问题
一般使用步骤:
1. 用ftok产生一个key。
2. 调用msgget(使用key作为参数)产生一个队列
3. 进程可以用msgsnd发送消息到这个队列,相应的别的进程用msgrcv读取。
这里需要注意msgsnd可能会失败的两个情况:
a) 可能被中断打断(包括msgsnd和msgrcv). 尤其是大流量应用中更容易出现. 比较安全的用法是判断操作是否被中断打断,如果被打断, 则需要继续尝试。
b) 消息队列满。产生这个错误,则需要考虑提高系统消息队列规格,或者查看消息接收处是否有问题
4. msgctl函数可以用来删除消息队列
消息队列产生之后,除非明确的删除(可以用),产生的队列会一直保留在系统中。linux下消息队列的个数是有限的,注意不要泄露。如果 使用已经达到上限,msgget调用会失败,产生的错误码对应的提示信息为no space left on device.
注意点:
1.消息的类型 mtype 不需为非0值。如果使用0,则msgsnd会失败,并得到”Invalid argument“错误。
2.msgflg为0表示阻塞等待,如果msgflg为IPC_NOWAIT表示非阻塞。
3.最好使用root权限执行消息队列,否则msgrcv 提示 "Permission denied"。
⑵ linux内核工作队列怎么工作的
Linux 2.6内核使用了不少工作队列来处理任务,他在使用上和 tasklet最大的不同是工作队列的函数可以使用休眠,而tasklet的函数是不允许使用休眠的。
工作队列的使用又分两种情况,一种是利用系统共享的工作队列来添加自己的工作,这种情况处理函数不能消耗太多时间,这样会影响共享队列中其他任务的处理;另外一种是创建自己的工作队列并添加工作。
(一)利用系统共享的工作队列添加工作:
第一步:声明或编写一个工作处理函数
void my_func();
第二步:创建一个工作结构体变量,并将处理函数和参数的入口地址赋给这个工作结构体变量
DECLARE_WORK(my_work,my_func,&data); //编译时创建名为my_work的结构体变量并把函数入口地址和参数地址赋给它;
如果不想要在编译时就用DECLARE_WORK()创建并初始化工作结构体变量,也可以在程序运行时再用INIT_WORK()创建
struct work_struct my_work; //创建一个名为my_work的结构体变量,创建后才能使用INIT_WORK()
INIT_WORK(&my_work,my_func,&data); //初始化已经创建的my_work,其实就是往这个结构体变量中添加处理函数的入口地址和data的地址,通常在驱动的open函数中完成
第三步:将工作结构体变量添加入系统的共享工作队列
schele_work(&my_work); //添加入队列的工作完成后会自动从队列中删除
或schele_delayed_work(&my_work,tick); //延时tick个滴答后再提交工作
(二)创建自己的工作队列来添加工作
第一步:声明工作处理函数和一个指向工作队列的指针
void my_func();
struct workqueue_struct *p_queue;
第二步:创建自己的工作队列和工作结构体变量(通常在open函数中完成)
p_queu=create_workqueue("my_queue"); //创建一个名为my_queue的工作队列并把工作队列的入口地址赋给声明的指针
struct work_struct my_work;
INIT_WORK(&my_work, my_func, &data); //创建一个工作结构体变量并初始化,和第一种情况的方法一样
第三步:将工作添加入自己创建的工作队列等待执行
queue_work(p_queue, &my_work);
//作用与schele_work()类似,不同的是将工作添加入p_queue指针指向的工作队列而不是系统共享的工作队列
第四步:删除自己的工作队列
destroy_workqueue(p_queue); //一般是在close函数中删除
⑶ 如何用JAVA实现Linux上的消息队列功能
下面来说说如何用不用消息队列来进行进程间的通信,消息队列与命名管回道有很多相似之处。有关命答名管道的更多内容可以参阅我的另一篇文章:Linux进程间通信——使用命名管道 一、什么是消息队列 消息队列提供了一种从一个进程向另一个进程发送一个数
⑷ linux 进程通信方式 pipe无名管道 fifo有名管道 共享内存映射 socket 消息队列
在Linux系统中,进程间的通信(IPC, Inter-Process Communication)主要通过四种机制实现:管道(pipe)、有名管道(fifo)、共享内存映射以及Unix域socket。这些方法各自适用于不同的场景,让进程能够有效地交换数据。
1. 管道(pipe):无名管道,由`pipe()`函数创建,适合于有血缘关系的进程间通信,如父子进程。它在内核中创建一个缓冲区,通过`filedes`参数传递给用户进程,用于单向通信,数据写满后会阻塞。
2. 有名管道(fifo):解决无血缘关系进程间的通信,使用`mkfifo`创建,相当于磁盘上的一个文件,通过文件名访问。它实质上是基于管道的,只是给管道起了个名字,读写需要进程都打开文件。
3. 共享内存映射(mmap):通过`mmap`函数将磁盘文件的一部分映射到内存,支持同步修改(share映射)和独立修改(private映射)。这常用于进程间的数据传递,特别是权限受限的情况下。
4. Unix域socket(socket):利用网络通信技术,适用于远程进程间的通信,常用于服务器-客户端模型,数据按照协议解析。
消息队列,虽然视频中未提及,但它是另一种间接通信方式,类似于邮箱系统,接收方根据消息类型从中间体获取信息。消息队列提供了一种独立于进程运行状态的通信方式,写入者无需关心接收者是否在读取。
每种方法都有其优缺点,选择哪种取决于具体的应用场景和性能需求。理解这些通信方式有助于编写高效、可靠的多进程应用程序。