在Linux下通过Socket实现本机进程间通信

简介: 这些代码块提供了一个基本的IPC通信模型,可以用作更复杂应用程序的基础。要根据特定需求扩展这些代码,您可能需要考虑错误处理、多线程或多进程并发处理、以及消息编码策略。

在Linux环境下实现本机进程间通信(IPC),socket是一种灵活的通信方式。Socket允许在同一台机器上的进程或不同机器间的进程通信。此处我们专注于本机进程间通信。

本机进程间通信通常使用UNIX Domain Sockets,该方式相比网络套接字提供了更高的数据传输效率和安全性,因为它不会将数据通过网络接口发送。

以下是使用C语言在Linux操作系统上通过UNIX Domain Sockets进行进程间通信的示例代码。这个示例将包括一个服务器进程和一个客户端进程。

服务器端:

  1. 创建一个套接字: 使用 socket()函数,指定 AF_UNIX作为协议族。
  2. 绑定套接字: 使用 bind()函数将套接字绑定到文件系统中的名称(地址)。
  3. 监听连接: 使用 listen()函数使服务器套接字监听连接。
  4. 接受连接: 使用 accept()函数等待客户端的连接请求。
  5. 读写数据: 使用 read()write()函数与客户端交换数据。
  6. 关闭连接: 使用 close()函数结束连接。
// Server code
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <stdio.h>
#include <unistd.h>

int main() {
    int server_sock, client_sock, len;
    struct sockaddr_un server_addr;
    char buf[100];

    // 创建套接字
    server_sock = socket(AF_UNIX, SOCK_STREAM, 0);
    server_addr.sun_family = AF_UNIX;
    strcpy(server_addr.sun_path, "socketfile");

    // 绑定
    bind(server_sock, (struct sockaddr *)&server_addr, sizeof(server_addr));

    // 监听
    listen(server_sock, 5);

    // 接受连接
    client_sock = accept(server_sock, NULL, NULL);

    // 从client读取数据
    read(client_sock, buf, sizeof(buf));

    // 这里可以处理数据

    // 向client写入数据
    write(client_sock, buf, sizeof(buf));

    // 关闭套接字
    close(client_sock);
    close(server_sock);

    // 删除socket文件
    unlink(server_addr.sun_path);

    return 0;
}
​

客户端:

  1. 创建一个套接字: 使用 socket()函数.
  2. 连接到服务器: 使用 connect()函数连接到服务器。
  3. 读写数据: 使用 write()read()函数与服务器交换数据。
  4. 关闭套接字: 使用 close()函数。
// Client code
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <stdio.h>
#include <unistd.h>

int main() {
    int client_sock;
    struct sockaddr_un server_addr;
    char buf[100];

    // 创建套接字
    client_sock = socket(AF_UNIX, SOCK_STREAM, 0);

    // 指定服务器地址
    server_addr.sun_family = AF_UNIX;
    strcpy(server_addr.sun_path, "socketfile");

    // 连接到服务器
    connect(client_sock, (struct sockaddr *)&server_addr, sizeof(server_addr));

    // 向服务器发送数据
    write(client_sock, "Hello, World!", 13);

    // 读取服务器响应
    read(client_sock, buf, sizeof(buf));

    // 关闭套接字
    close(client_sock);

    return 0;
}
​

步骤:

  1. 编译代码: 使用 gcc -o server server.cgcc -o client client.c来编译上述两个C文件。
  2. 运行服务器: 在一个终端窗口中运行编译好的服务器程序。
  3. 运行客户端: 在另一个终端窗口中运行客户端程序,这时它会发送消息给服务器,并收到回复。

这些代码块提供了一个基本的IPC通信模型,可以用作更复杂应用程序的基础。要根据特定需求扩展这些代码,您可能需要考虑错误处理、多线程或多进程并发处理、以及消息编码策略。

目录
相关文章
|
22天前
|
Linux Docker 索引
安装Docker及其基本操作命令概览
了解和运用这些基本命令,能够帮助用户更好地管理Docker容器和镜像,从而有效地使用Docker进行开发和部署。
208 15
|
22天前
|
关系型数据库 MySQL 数据管理
MySQL数据库基本操作包括增加、删除、更新和查询
值得注意的是,虽然上述操作看起来直观易懂,但实际情况中可能会遇到数据类型、索引、性能优化和事务处理等高级话题。因此,数据库管理员或开发人员在对数据库进行操作时,应具备深入的理解和丰富的实践经验。
309 18
|
19天前
|
SQL 分布式计算 大数据
【跨国数仓迁移最佳实践8】MaxCompute Streaming Insert:大数据数据流写业务迁移的实践与突破
本系列文章将围绕东南亚头部科技集团的真实迁移历程展开,逐步拆解 BigQuery 迁移至 MaxCompute 过程中的关键挑战与技术创新。本篇为第八篇,MaxCompute Streaming Insert:大数据数据流写业务迁移的实践与突破。 注:客户背景为东南亚头部科技集团,文中用 GoTerra 表示。
243 39
|
安全 JavaScript Docker
Agent Skills技术协议与开源实现,让大模型拥有“即插即用”技能
Anthropic推出Agent Skills协议,通过模块化技能封装提升大模型智能体的专业能力。ModelScope开源项目MS-Agent已实现该协议,支持技能的动态加载、自主执行与安全沙箱运行,推动智能体能力的可组合与可扩展发展。
469 28
|
19天前
|
SQL 分布式计算 DataWorks
【跨国数仓迁移最佳实践7】基于 MaxCompute 多租的大数据平台架构
本系列文章将围绕东南亚头部科技集团的真实迁移历程展开,逐步拆解 BigQuery 迁移至 MaxCompute 过程中的关键挑战与技术创新。本篇为第七篇,基于MaxCompute 多租的大数据平台架构。 注:客户背景为东南亚头部科技集团,文中用 GoTerra 表示。
179 27
|
22天前
|
机器学习/深度学习 运维 监控
当系统开始“自愈”:聊聊大数据与AIOps的真正魔力
当系统开始“自愈”:聊聊大数据与AIOps的真正魔力
138 10