Linux操作系统是一种开源的操作系统，被广泛应用于各种 服务器 和嵌入式设备中。在企业应用中，消息队列是一种常见的进程间通信方式，很多企业系统都是基于消息队列实现各个模块之间的数据传输和协调。Linux系统提供了一种称为msgrcv的函数用于进程间消息队列的idc.com/xtywjcwz/35035.html" target="_blank">接收和处理。本文将着重介绍。
一、消息队列的概念
消息队列是一种进程间通信方式，它是消息的链表，存放在内核中。消息队列中的每个消息都有一个消息类型和消息体。消息类型用于标识消息的用途，消息体则是真正的数据部分。
消息队列是多个进程共享的一种数据结构，通过消息队列，发送方可以把消息发送到消息队列中，接收方则从消息队列中读取消息并进行处理。在使用消息队列时，发送方和接收方可以是同一个进程，也可以是不同的进程。
二、msgrcv函数的实现
在Linux系统中，进程间通信的方式有多种，比如信号、管道、共享内存等。消息队列是其中一种较为高效的方式。在Linux系统中，进程通过定义特定的消息类型和消息内容，将消息发送到消息队列中，而通过msgrcv函数则可以从消息队列中读取并处理消息。
在Linux系统中，msgrcv函数是一个系统调用函数，其完整定义如下：
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msg);
函数各参数含义如下：
msqid：消息队列的标识符，它是通过msgget函数创建消息队列后返回的一个值。
msgp：消息的接收缓冲区指针。调用msgrcv函数后，内核将消息从消息队列中读取到该缓冲区中。
msgsz：接收缓冲区的大小，msgsz应该至少等于消息长度。
msgtyp：指定所读取消息的消息类型。其值为0时，可以读取消息队列中的之一条消息；否则，值为msgtyp的消息将被读取。
msg：消息的接收方式。它可以取以下值：
– IPC_NOWT：如果消息队列中没有符合要求的消息，则返回-1，并将errno设置为ENOMSG。
– MSG_NOERROR：如果消息长度超过msgsz，则被截断。
– MSG_EXCEPT：读取类型为msgtyp以外所有类型的消息，而不是读取类型为msgtyp的消息。
– MSG_COPY：读取类型为msgtyp的消息时，内核将消息从消息队列中移除，并将其复制到msgp中，而不是返回一个指向缓冲区的指针。
三、msgrcv函数的使用
使用msgrcv函数可以很方便地从消息队列中读取并处理消息。下面是一个示例程序，通过msgrcv函数从消息队列中读取消息并输出消息体的内容。
创建消息队列及发送消息：
#define MSG_KEY 0x12345678
struct msgbuf {
long mtype;
char mtext[256];
// 创建消息队列
msgid = msgget(MSG_KEY, IPC_CREAT | 0666);
if (msgid == -1) {
perror(“msgget”);
exit(EXIT_FLURE);
// 发送消息
message.mtype = 1;
snprintf(message.mtext, 256, “Hello, world!”);
if (msgsnd(msgid, &message, sizeof(message), 0) == -1) {
perror(“msgsnd”);
exit(EXIT_FLURE);
上述程序使用msgget函数创建了一个消息队列，并通过msgsnd函数向消息队列中发送了一条消息。
下面是使用msgrcv函数读取消息的示例程序：
#define MSG_KEY 0x12345678
struct msgbuf {
long mtype;
char mtext[256];
// 连接消息队列
msgid = msgget(MSG_KEY, 0666);
if (msgid == -1) {
perror(“msgget”);
exit(EXIT_FLURE);
// 从队列中读取消息
if (msgrcv(msgid, &message, sizeof(message), 1, 0) == -1) {
perror(“msgrcv”);
exit(EXIT_FLURE);
printf(“Received message: %s\n”, message.mtext);
上述程序使用msgget函数打开消息队列，并通过msgrcv函数从消息队列中读取了一条消息，并输出消息内容。
四、消息队列的应用场景
消息队列广泛应用于各种企业系统中，例如电商系统、银行系统、物流系统等。下面简要介绍消息队列在这些系统中的应用场景。
1. 电商系统
在电商系统中，消息队列可以用于记录日志信息，并对于不同类型的操作建立不同的消息类型，例如订单、库存、日志等。消息队列中的每条消息可以包含订单编号、日志信息、库存信息等，并通过消息队列传递给其他模块进行处理。
2. 银行系统
在银行系统中，消息队列可以用于处理交易信息，例如客户向银行申请贷款、转账等操作。对于每个交易，银行会对其进行处理并返回相应的结果，所有的交易信息都可以通过消息队列进行传递，提高交易处理的速度和效率。
3. 物流系统
在物流系统中，消息队列可以用于处理订单信息、运输信息等。例如，每个订单都会有一个唯一的订单号，订单信息会通过消息队列传递给相应的快递员，快递员在途中需要不断更新订单的状态，例如已发货、已派送等。所有这些状态信息都可以通过消息队列进行交换和传递。
五、
相关问题拓展阅读：
如何在linux下看消息队列是否存在
#include types.h>
#include msg.h>
#include ipc.h>
void msg_show_attr(int msg_id, struct msqid_ds msg_info)
int ret = -1;
ret = msgctl(msg_id, IPC_STAT, &msg_info);
if( -1 == ret)
printf(获消息信息失败\n);
printf(\n);
printf(现队列字节数：%d\n,msg_info.msg_cbytes);
printf(队列消息数：%d\n,msg_info.msg_qnum);
printf(队列字节数：%d\n,msg_info.msg_qbytes);
printf(发送消息进程pid：%d\n,msg_info.msg_lspid);
printf(接收消息进程pid：%d\n,msg_info.msg_lrpid);
printf(发送消息间：%s,ctime(&(msg_info.msg_stime)));
printf(接收消息间：%s,ctime(&(msg_info.msg_rtime)));
printf(变化间：%s,ctime(&(msg_info.msg_ctime)));
printf(消息UID：%d\n,msg_info.msg_perm.uid);
printf(消息GID：%d\n,msg_info.msg_perm.gid);
int main(void)
int ret = -1;
int msg_flags, msg_id;
struct msgmbuf{
char mtext;
struct msqid_ds msg_info;
struct msgmbuf msg_mbuf;
int msg_sflags,msg_rflags;
char *msgpath = /ipc/msg/;
key = ftok(msgpath,’a’);
if(key != -1)
printf(功建立KEY\n);
printf(建立KEY失败\n);
msg_flags = IPC_CREAT;
msg_id = msgget(key, msg_flags|0666);
if( -1 == msg_id)
printf(消息建立失败\n);
msg_show_attr(msg_id, msg_info);
msg_sflags = IPC_NOWAIT;
msg_mbuf.mtype = 10;
memcpy(msg_mbuf.mtext,测试消息,sizeof(测试消息));
ret = msgsnd(msg_id, &msg_mbuf, sizeof(测试消息), msg_sflags);
if( -1 == ret)
printf(发送消息失败\n);
msg_show_attr(msg_id, msg_info);
msg_rflags = IPC_NOWAIT|MSG_NOERROR;
ret = msgrcv(msg_id, &msg_mbuf, 10,10,msg_rfla
共享内存示例代码：
#include sem.h>
#include ipc.h>
typedef int sem_t;
union semun {
struct semid_ds *buf;
unsigned short *array;
sem_t CreateSem(key_t key, int value)
union semun sem;
sem_t semid;
sem.val = value;
semid = semget(key,value,IPC_CREAT|0666);
if (-1 == semid)
printf(create semaphore error\n);
semctl(semid,0,SETVAL,sem);
return semid;
struct sembuf{
ushort sem_num;
short sem_op;
short sem_;
void SetvalueSem(sem_t semid, int value)
union semun sem;
sem.val = value;
semctl(semid,0,SETVAL,sem);
int GetvalueSem(sem_t semid)
union semun sem;
return semctl(semid,0,GETVAL,sem);
return sem.val;
void DestroySem(sem_t semid)
union semun sem;
sem.val = 0;
semctl(semid,0,IPC_RMID,sem);
int Sem_P(sem_t semid)
struct sembuf sops={0,+1,IPC_NOWAIT};
return (semop(semid,&sops,1));
int Sem_V(sem_t semid)
struct sembuf sops={0,-1,IPC_NOWAIT};
return (semop(semid,&sops,1));
static char msg=共享内存\n;
int main(void)
int semid,shmid;
char i,*shms,*shmc;
struct semid_ds buf;
int value = 0;
char buffer;
key = ftok(/ipc/sem/,’a’);
shmid = shmget(key,1024,IPC_CREAT|0604);
semid = CreateSem(key,1);
/* 父进程 */
/* 建立共享内存 */
shms = (char *)shmat(shmid,0,0);
memcpy(shms, msg, strlen(msg)+1);
sleep(10);
Sem_P(semid);
shmdt(shms);
DestroySem(semid);
else if(p == 0)
shmc = (char *)shmat(shmid,0,0);
Sem_V(semid);
printf(共享内存值:%s\n,shmc);
linux消息队列msgrcv的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于linux消息队列msgrcv,Linux下的消息队列msgrcv实现及应用,如何在linux下看消息队列是否存在的信息别忘了在本站进行查找喔。
香港服务器首选树叶云，2H2G首月10元开通。树叶云（shuyeidc.com）提供简单好用，价格厚道的香港/美国云服务器和独立服务器。IDC+ISP+ICP资质。ARIN和APNIC会员。成熟技术团队15年行业经验。
如何在 Linux 下检测内存泄漏
内存泄漏指由于疏忽或错误造成程序未能释放已经不再使用的内存的情况。 内存泄漏并非指内存在物理上的消失，而是应用程序分配某段内存后，由于设计错误，失去了对该段内存的控制，因而造成了内存的浪费。 可以使用相应的软件测试工具对软件进行检测。 1. ccmalloc－Linux和Solaris下对C和C++程序的简单的使用内存泄漏和malloc调试库。 2. Dmalloc－Debug Malloc Library.3. Electric Fence－Linux分发版中由Bruce Perens编写的malloc()调试库。 4. Leaky－Linux下检测内存泄漏的程序。 5. LeakTracer－Linux、Solaris和HP-UX下跟踪和分析C++程序中的内存泄漏。 6. MEMWATCH－由Johan Lindh编写，是一个开放源代码C语言内存错误检测工具，主要是通过gcc的precessor来进行。 7. Valgrind－Debugging and profiling Linux programs, aiming at programs written in C and C++.8. KCachegrind－A visualization tool for the profiling data generated by Cachegrind and Calltree.9. Leak Monitor－一个Firefox扩展，能找出跟Firefox相关的泄漏类型。 10. IE Leak Detector (Drip/IE Sieve)－Drip和IE Sieve leak detectors帮助网页开发员提升动态网页性能通过报告可避免的因为IE局限的内存泄漏。 11. Windows Leaks Detector－探测任何Win32应用程序中的任何资源泄漏(内存，句柄等)，基于Win API调用钩子。 12. SAP Memory Analyzer－是一款开源的JAVA内存分析软件，可用于辅助查找JAVA程序的内存泄漏，能容易找到大块内存并验证谁在一直占用它，它是基于Eclipse RCP(Rich Client Platform)，可以下载RCP的独立版本或者Eclipse的插件。 13. DTrace－即动态跟踪Dynamic Tracing，是一款开源软件，能在Unix类似平台运行，用户能够动态检测操作系统内核和用户进程，以更精确地掌握系统的资源使用状况，提高系统性能，减少支持成本，并进行有效的调节。 14. IBM Rational PurifyPlus－帮助开发人员查明C/C++、托管、Java和VB6代码中的性能和可靠性错误。 PurifyPlus 将内存错误和泄漏检测、应用程序性能描述、代码覆盖分析等功能组合在一个单一、完整的工具包中。 15. Parasoft Insure++－针对C/C++应用的运行时错误自动检测工具，它能够自动监测C/C++程序，发现其中存在着的内存破坏、内存泄漏、指针错误和I/O等错误。 并通过使用一系列独特的技术（SCI技术和变异测试等），彻底的检查和测试我们的代码，精确定位错误的准确位置并给出详细的诊断信息。 能作为Microsoft Visual C++的一个插件运行。 16. Compuware DevPartner for Visual C++ BoundsChecker Suite－为C++开发者设计的运行错误检测和调试工具软件。 作为Microsoft Visual Studio和C++ 6.0的一个插件运行。 17. Electric Software GlowCode－包括内存泄漏检查，code profiler，函数调用跟踪等功能。 给C++和开发者提供完整的错误诊断，和运行时性能分析工具包。 18. Compuware DevPartner Java Edition－包含Java内存检测,代码覆盖率测试,代码性能测试,线程死锁,分布式应用等几大功能模块。 19. Quest JProbe－分析Java的内存泄漏。 20. ej-technologies JProfiler－一个全功能的Java剖析工具，专用于分析J2SE和J2EE应用程序。 它把CPU、执行绪和内存的剖析组合在一个强大的应用中。 JProfiler可提供许多IDE整合和应用服务器整合用途。 JProfiler直觉式的GUI让你可以找到效能瓶颈、抓出内存泄漏、并解决执行绪的问题。 4.3.2注册码：A-G666#F-1olm9mv1i5uuly#. BEA JRockit－用来诊断Java内存泄漏并指出根本原因，专门针对Intel平台并得到优化，能在Intel硬件上获得最高的性能。 22. SciTech Software AB Memory Profiler－找到内存泄漏并优化内存使用针对C#，，或其它程序。 23. YourKit & Java Profiler－业界领先的Java和程序性能分析工具。 24. AutomatedQA AQTime－AutomatedQA的获奖产品performance profiling和memory debugging工具集的下一代替换产品，支持Microsoft, Borland, Intel, Compaq 和 GNU编译器。 可以为和Windows程序生成全面细致的报告，从而帮助您轻松隔离并排除代码中含有的性能问题和内存/资源泄露问题。 支持 1.0,1.1,2.0,3.0和Windows 32/64位应用程序。 25. JavaScript Memory Leak Detector－微软全球产品开发欧洲团队(Global Product Development- Europe team, GPDE) 发布的一款调试工具，用来探测JavaScript代码中的内存泄漏，运行为IE系列的一个插件。
linux进程间通信的方式？
# 管道( pipe )：管道是一种半双工的通信方式，数据只能单向流动，而且只能在具有亲缘关系的进程间使用。 进程的亲缘关系通常是指父子进程关系。 # 有名管道 (named pipe) ： 有名管道也是半双工的通信方式，但是它允许无亲缘关系进程间的通信。 # 信号量( semophore ) ： 信号量是一个计数器，可以用来控制多个进程对共享资源的访问。 它常作为一种锁机制，防止某进程正在访问共享资源时，其他进程也访问该资源。 因此，主要作为进程间以及同一进程内不同线程之间的同步手段。 # 消息队列( message queue ) ： 消息队列是由消息的链表，存放在内核中并由消息队列标识符标识。 消息队列克服了信号传递信息少、管道只能承载无格式字节流以及缓冲区大小受限等缺点。 # 信号 ( sinal ) ： 信号是一种比较复杂的通信方式，用于通知接收进程某个事件已经发生。 # 共享内存( shared memory ) ：共享内存就是映射一段能被其他进程所访问的内存，这段共享内存由一个进程创建，但多个进程都可以访问。 共享内存是最快的 IPC 方式，它是针对其他进程间通信方式运行效率低而专门设计的。 它往往与其他通信机制，如信号两，配合使用，来实现进程间的同步和通信。 # 套接字( socket ) ： 套解口也是一种进程间通信机制，与其他通信机制不同的是，它可用于不同及其间的进程通信。
如何利用linux系统去破解软件的应用？
使用Linux操作系统，装完系统后就是装各种常用软件了。 Linux系统集成了很多软件，可是对于一些习惯了的windows文件兼容性不太好，所以还是要下一些比较全面的软件或代替或补充。 Linux下安装软件感觉很复杂，一种软件包就有一种安装方法，不象windows找到就万事大吉了，而且不少软件都要很复杂的编译、配置，感觉头很大，这几天我唯一的工作就是不停的下载、安装。 虽然开源是件很诱惑的事，可是感觉没有windows的标准化的确大大削弱了linux的市场。 把这几天用过的一些安装方法总结一下吧，以备日后。 一、rpm包 是Redhat提供的一种已经编译过的包封的安装装格式。 一般使用rpm命令直接执行安装，比较简单。 常用的格式是： rpm -ivh <文件名> (-i是安装，-v是校验，-h是显示安装进度) 卸载同样也是一条命令就完成了： rpm -e <软件名> 这里的软件名跟rpm包的文件名不一样，通常不包括软件版本号，可以通过rpm命令先查看已安装的rpm软件包，再卸载列表中的软件。 二、deb包 它是Debain Linux提供的一种已经编译过的包封的安装装格式。 安装方法跟rpm 类似。 dpkg -i dpkg -e <软件名> 三、tar包 这种安装包是Unix下tar工具的压缩包，有时经过2次会在后面加上2、等扩展名。 这种包多数都提供源代码，开放性最好(可以选择甚至修改模块，也不局限于某个发行版本)但安装和卸载也最多问题。 一般安装tar包的步骤如下： 1：解压压缩包——tar -xvzf 压缩包名 或者 tar -xvzf 压缩包名(-z是调用gzip解压，-x是解压，-v是校验，-f是显示文件结果，-y是调用bzip2解压) 2：配置安装选项——./configure，一般用prefix参数配置安装路径，其他的参数也很有用。 3：编译安装文件——make。 4：安装——make install 5：清除安装产生的临时文件——make clean 有些软件不完全遵循这个步骤，（比如luma qq解压后直接./lumaqq就能运行，有点象windows的绿色软件）如果英文过关最好是阅读压缩包里的intall文件或者readme文件。 一般来说，安装后的可执行文件会存放在/usr/local/bin目录下，但也不是唯一的，还是要仔细阅读这两个文件。 卸载tar包可以进入安装目录执行make uninstall ，如果软件不提供uninstall，就必须手动rm -rf删除了，如果文件分散地安装在系统的多个目录中，除非安装时记住了所有路径，否则就很难清除干净了。 四、安装脚本 目前有些软件提供安装和卸载的SHELL脚本，只要运行甚至可以直接从网站下载软件一并安装到本地，同时运行就卸载该软件。 一些常用软件的安装和配置方法 linux找到一个适用的、完整的应用软件版本至关重要，这点我深有体会，我要安装的东西不多，但这几天就不停的各种版本来尝试，有些还会引起软件冲突，有些安装了发现没有传说中的功能又得下插件什么的。 linux的发行版本又多，各种体会和经验都是因人而异了。
发表评论