Linux中的System V通信标准--共享内存、消息队列以及信号量

简介: 希望本文能帮助您更好地理解和应用System V IPC机制,构建高效的Linux应用程序。

Linux中的System V通信标准——共享内存、消息队列以及信号量

在Linux系统中,System V IPC(Inter-Process Communication)提供了一系列进程间通信的机制,包括共享内存、消息队列和信号量。这些机制在系统中发挥了重要作用,帮助进程之间进行数据交换和同步。本文将详细介绍这些机制的概念、使用方法以及应用场景。

一、共享内存

1.1 概念

共享内存(Shared Memory)是最快的一种进程间通信方式,它允许多个进程直接访问同一块内存区域,从而实现高效的数据交换。共享内存由内核管理,每个进程可以将共享内存段映射到自身的地址空间。

1.2 使用方法

创建和附加共享内存

创建或获取一个共享内存段:

#include <sys/ipc.h>
#include <sys/shm.h>

int shm_id = shmget(key_t key, size_t size, int shmflg);
​

附加共享内存段到进程的地址空间:

void *shmaddr = shmat(int shm_id, const void *shmaddr, int shmflg);
​

数据读写

共享内存的读写操作直接通过指针进行,如同普通内存操作。

分离和删除共享内存

分离共享内存段:

int shmdt(const void *shmaddr);
​

删除共享内存段:

int shmctl(int shm_id, IPC_RMID, NULL);
​

1.3 示例代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/shm.h>

int main() {
    key_t key = ftok("shmfile", 65);
    int shm_id = shmget(key, 1024, 0666|IPC_CREAT);
    char *str = (char*) shmat(shm_id, (void*)0, 0);

    printf("写入数据到共享内存\n");
    strcpy(str, "Hello, World!");

    printf("数据: %s\n", str);
    shmdt(str);
    shmctl(shm_id, IPC_RMID, NULL);
    return 0;
}
​

二、消息队列

2.1 概念

消息队列(Message Queue)是一种以消息为单位的进程间通信机制,允许一个或多个进程以有序的方式发送和接收消息。消息队列在内核中维护,进程通过消息队列标识符进行操作。

2.2 使用方法

创建和获取消息队列

创建或获取一个消息队列:

#include <sys/ipc.h>
#include <sys/msg.h>

int msg_id = msgget(key_t key, int msgflg);
​

发送消息

int msgsnd(int msg_id, const void *msgp, size_t msgsz, int msgflg);
​

接收消息

ssize_t msgrcv(int msg_id, void *msgp, size_t msgsz, long msgtyp, int msgflg);
​

删除消息队列

int msgctl(int msg_id, IPC_RMID, NULL);
​

2.3 示例代码

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

struct msg_buffer {
    long msg_type;
    char msg_text[100];
};

int main() {
    key_t key = ftok("msgfile", 65);
    int msg_id = msgget(key, 0666 | IPC_CREAT);
    struct msg_buffer message;

    message.msg_type = 1;
    strcpy(message.msg_text, "Hello, World!");
    msgsnd(msg_id, &message, sizeof(message), 0);

    printf("消息发送: %s\n", message.msg_text);

    msgrcv(msg_id, &message, sizeof(message), 1, 0);
    printf("消息接收: %s\n", message.msg_text);

    msgctl(msg_id, IPC_RMID, NULL);
    return 0;
}
​

三、信号量

3.1 概念

信号量(Semaphore)是一种用于同步进程操作的机制,可以控制多个进程对共享资源的访问。信号量可以是单个信号量(用于简单的互斥)或信号量集合(用于复杂的同步)。

3.2 使用方法

创建和获取信号量

创建或获取一个信号量集:

#include <sys/ipc.h>
#include <sys/sem.h>

int sem_id = semget(key_t key, int num_sems, int semflg);
​

初始化信号量

int semctl(int sem_id, int semnum, SETVAL, union semun arg);
​

操作信号量

信号量操作包括P操作(等待)和V操作(信号),通常使用 semop函数进行操作。

struct sembuf {
    unsigned short sem_num;
    short sem_op;
    short sem_flg;
};

int semop(int sem_id, struct sembuf *sops, size_t nsops);
​

3.3 示例代码

#include <stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/types.h>

union semun {
    int val;
    struct semid_ds *buf;
    unsigned short *array;
};

void sem_wait(int sem_id) {
    struct sembuf sem_op;
    sem_op.sem_num = 0;
    sem_op.sem_op = -1;
    sem_op.sem_flg = 0;
    semop(sem_id, &sem_op, 1);
}

void sem_signal(int sem_id) {
    struct sembuf sem_op;
    sem_op.sem_num = 0;
    sem_op.sem_op = 1;
    sem_op.sem_flg = 0;
    semop(sem_id, &sem_op, 1);
}

int main() {
    key_t key = ftok("semfile", 65);
    int sem_id = semget(key, 1, 0666 | IPC_CREAT);
    union semun sem_union;
    sem_union.val = 1;
    semctl(sem_id, 0, SETVAL, sem_union);

    if (fork() == 0) {
        sem_wait(sem_id);
        printf("子进程正在使用共享资源\n");
        sleep(2);
        printf("子进程释放共享资源\n");
        sem_signal(sem_id);
    } else {
        sem_wait(sem_id);
        printf("父进程正在使用共享资源\n");
        sleep(2);
        printf("父进程释放共享资源\n");
        sem_signal(sem_id);
    }

    semctl(sem_id, 0, IPC_RMID, sem_union);
    return 0;
}
​

四、总结

本文详细介绍了Linux中的System V通信标准,包括共享内存、消息队列和信号量。共享内存提供了最快的进程间通信方式,消息队列以消息为单位进行通信,信号量用于控制和同步进程对共享资源的访问。这些机制各有优劣,适用于不同的场景。在实际开发中,合理选择和使用这些机制,可以提高系统的性能和可靠性。

希望本文能帮助您更好地理解和应用System V IPC机制,构建高效的Linux应用程序。

目录
相关文章
|
2月前
|
消息中间件 存储 网络协议
从零开始掌握进程间通信:管道、信号、消息队列、共享内存大揭秘
本文详细介绍了进程间通信(IPC)的六种主要方式:管道、信号、消息队列、共享内存、信号量和套接字。每种方式都有其特点和适用场景,如管道适用于父子进程间的通信,消息队列能传递结构化数据,共享内存提供高速数据交换,信号量用于同步控制,套接字支持跨网络通信。通过对比和分析,帮助读者理解并选择合适的IPC机制,以提高系统性能和可靠性。
301 14
|
2月前
|
消息中间件 Linux
Linux:进程间通信(共享内存详细讲解以及小项目使用和相关指令、消息队列、信号量)
通过上述讲解和代码示例,您可以理解和实现Linux系统中的进程间通信机制,包括共享内存、消息队列和信号量。这些机制在实际开发中非常重要,能够提高系统的并发处理能力和数据通信效率。希望本文能为您的学习和开发提供实用的指导和帮助。
207 20
|
3月前
|
Linux
【Linux】System V信号量详解以及semget()、semctl()和semop()函数讲解
System V信号量的概念及其在Linux中的使用,包括 `semget()`、`semctl()`和 `semop()`函数的具体使用方法。通过实际代码示例,演示了如何创建、初始化和使用信号量进行进程间同步。掌握这些知识,可以有效解决多进程编程中的同步问题,提高程序的可靠性和稳定性。
139 19
|
4月前
|
消息中间件 存储 监控
消息队列通信的优缺点
【10月更文挑战第29天】消息队列通信具有诸多优点,如解耦性强、异步通信、缓冲削峰等,能够有效地提高系统的灵活性、可扩展性和稳定性。但同时也存在一些缺点,如系统复杂性增加、性能开销、数据一致性挑战和实时性受限等。在实际应用中,需要根据具体的业务需求和场景,权衡其优缺点,合理地选择和使用消息队列通信机制,以实现系统的高效运行和优化。
|
15天前
|
存储 缓存 算法
JVM简介—1.Java内存区域
本文详细介绍了Java虚拟机运行时数据区的各个方面,包括其定义、类型(如程序计数器、Java虚拟机栈、本地方法栈、Java堆、方法区和直接内存)及其作用。文中还探讨了各版本内存区域的变化、直接内存的使用、从线程角度分析Java内存区域、堆与栈的区别、对象创建步骤、对象内存布局及访问定位,并通过实例说明了常见内存溢出问题的原因和表现形式。这些内容帮助开发者深入理解Java内存管理机制,优化应用程序性能并解决潜在的内存问题。
107 29
JVM简介—1.Java内存区域
|
12天前
|
消息中间件 Java 应用服务中间件
JVM实战—2.JVM内存设置与对象分配流转
本文详细介绍了JVM内存管理的相关知识,包括:JVM内存划分原理、对象分配与流转、线上系统JVM内存设置、JVM参数优化、问题汇总。
JVM实战—2.JVM内存设置与对象分配流转
|
14天前
|
缓存 监控 算法
JVM简介—2.垃圾回收器和内存分配策略
本文介绍了Java垃圾回收机制的多个方面,包括垃圾回收概述、对象存活判断、引用类型介绍、垃圾收集算法、垃圾收集器设计、具体垃圾回收器详情、Stop The World现象、内存分配与回收策略、新生代配置演示、内存泄漏和溢出问题以及JDK提供的相关工具。
JVM简介—2.垃圾回收器和内存分配策略
|
4月前
|
缓存 Prometheus 监控
Elasticsearch集群JVM调优设置合适的堆内存大小
Elasticsearch集群JVM调优设置合适的堆内存大小
856 1
|
1月前
|
存储 算法 Java
JVM: 内存、类与垃圾
分代收集算法将内存分为新生代和老年代,分别使用不同的垃圾回收算法。新生代对象使用复制算法,老年代对象使用标记-清除或标记-整理算法。
27 6
|
3月前
|
存储 监控 算法
深入探索Java虚拟机(JVM)的内存管理机制
本文旨在为读者提供对Java虚拟机(JVM)内存管理机制的深入理解。通过详细解析JVM的内存结构、垃圾回收算法以及性能优化策略,本文不仅揭示了Java程序高效运行背后的原理,还为开发者提供了优化应用程序性能的实用技巧。不同于常规摘要仅概述文章大意,本文摘要将简要介绍JVM内存管理的关键点,为读者提供一个清晰的学习路线图。