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应用程序。

目录
相关文章
|
消息中间件 Linux C++
c++ linux通过实现独立进程之间的通信和传递字符串 demo
的进程间通信机制,适用于父子进程之间的数据传输。希望本文能帮助您更好地理解和应用Linux管道,提升开发效率。 在实际开发中,除了管道,还可以根据具体需求选择消息队列、共享内存、套接字等其他进程间通信方
366 16
|
消息中间件 存储 网络协议
从零开始掌握进程间通信:管道、信号、消息队列、共享内存大揭秘
本文详细介绍了进程间通信(IPC)的六种主要方式:管道、信号、消息队列、共享内存、信号量和套接字。每种方式都有其特点和适用场景,如管道适用于父子进程间的通信,消息队列能传递结构化数据,共享内存提供高速数据交换,信号量用于同步控制,套接字支持跨网络通信。通过对比和分析,帮助读者理解并选择合适的IPC机制,以提高系统性能和可靠性。
2017 14
|
消息中间件 Linux
Linux:进程间通信(共享内存详细讲解以及小项目使用和相关指令、消息队列、信号量)
通过上述讲解和代码示例,您可以理解和实现Linux系统中的进程间通信机制,包括共享内存、消息队列和信号量。这些机制在实际开发中非常重要,能够提高系统的并发处理能力和数据通信效率。希望本文能为您的学习和开发提供实用的指导和帮助。
975 20
|
Linux
【Linux】System V信号量详解以及semget()、semctl()和semop()函数讲解
System V信号量的概念及其在Linux中的使用,包括 `semget()`、`semctl()`和 `semop()`函数的具体使用方法。通过实际代码示例,演示了如何创建、初始化和使用信号量进行进程间同步。掌握这些知识,可以有效解决多进程编程中的同步问题,提高程序的可靠性和稳定性。
924 19
|
消息中间件 存储 监控
消息队列通信的优缺点
【10月更文挑战第29天】消息队列通信具有诸多优点,如解耦性强、异步通信、缓冲削峰等,能够有效地提高系统的灵活性、可扩展性和稳定性。但同时也存在一些缺点,如系统复杂性增加、性能开销、数据一致性挑战和实时性受限等。在实际应用中,需要根据具体的业务需求和场景,权衡其优缺点,合理地选择和使用消息队列通信机制,以实现系统的高效运行和优化。
|
消息中间件 存储 Kafka
MQ 消息队列核心原理,12 条最全面总结!
本文总结了消息队列的12个核心原理,涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
|
消息中间件
手撸MQ消息队列——循环数组
队列是一种常用的数据结构,类似于栈,但采用先进先出(FIFO)的原则。生活中常见的排队场景就是队列的应用实例。在数据结构中,队列通常用数组实现,包括入队(队尾插入元素)和出队(队头移除元素)两种基本操作。本文介绍了如何用数组实现队列,包括定义数组长度、维护队头和队尾下标(front 和 tail),并通过取模运算解决下标越界问题。此外,还讨论了队列的空与满状态判断,以及并发和等待机制的实现。通过示例代码展示了队列的基本操作及优化方法,确保多线程环境下的正确性和高效性。
330 0
手撸MQ消息队列——循环数组
|
消息中间件 Java Kafka
MQ 消息队列 比较
MQ 消息队列 比较
167 0
|
消息中间件 存储 缓存
一个用过消息队列的人,竟不知为何要用 MQ?
一个用过消息队列的人,竟不知为何要用 MQ?
555 1
|
消息中间件 C语言 RocketMQ
消息队列 MQ操作报错合集之出现"Connection reset by peer"的错误,该如何处理
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
下一篇
开通oss服务