ubuntu进程如何共享 - 问答

在Ubuntu系统中，进程间可以通过多种方式实现数据共享。以下是一些常见的方法：

1. 管道（Pipes）

管道是一种半双工的通信方式，通常用于父子进程之间。

# 创建一个命名管道
mkfifo my_pipe

# 写入进程
echo "Hello from writer" > my_pipe &

# 读取进程
cat my_pipe

2. 命名管道（Named Pipes）

命名管道是一种特殊的文件，可以在不相关的进程之间进行通信。

# 创建一个命名管道
mkfifo my_pipe

# 写入进程
echo "Hello from writer" > my_pipe &

# 读取进程
cat my_pipe

3. 消息队列（Message Queues）

消息队列是一种允许进程发送和接收消息的机制。

# 安装消息队列库
sudo apt-get install librt-dev

# 编写代码使用消息队列

4. 共享内存（Shared Memory）

共享内存是一种高效的进程间通信方式，允许多个进程访问同一块内存区域。

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

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

    strcpy(str, "Hello from shared memory");
    printf("String in shared memory = %s\n", str);

    shmdt(str);
    shmctl(shmid, IPC_RMID, NULL);
    return 0;
}

5. 信号量（Semaphores）

信号量用于进程同步，防止多个进程同时访问共享资源。

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

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

int main() {
    key_t key = ftok("semfile", 65);
    int semid = semget(key, 1, 0666|IPC_CREAT);

    union semun arg;
    arg.val = 1;
    semctl(semid, 0, SETVAL, arg);

    // 使用信号量进行同步
    struct sembuf sb = {0, -1, SEM_UNDO};
    semop(semid, &sb, 1);

    // 访问共享资源

    sb.sem_op = 1;
    semop(semid, &sb, 1);

    semctl(semid, 0, IPC_RMID, arg);
    return 0;
}

6. 套接字（Sockets）

套接字是一种通用的进程间通信机制，支持本地和网络通信。

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

int main() {
    int server_fd, new_socket;
    struct sockaddr_in address;
    int opt = 1;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};

    // 创建套接字文件描述符
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    // 绑定套接字到端口
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(8080);

    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(server_fd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    // 接受连接
    if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
        perror("accept");
        exit(EXIT_FAILURE);
    }

    // 读取数据
    read(new_socket, buffer, 1024);
    printf("Message from client: %s\n", buffer);

    // 发送数据
    send(new_socket, "Hello from server", 17, 0);
    printf("Hello message sent\n");

    close(new_socket);
    close(server_fd);
    return 0;
}

这些方法各有优缺点，选择哪种方法取决于具体的应用场景和需求。

0 赞

0 踩