brpc支持基于memfd的共享内存通信机制

flowchart LR
    subgraph bottom["Server写共享内存"]
        B2[buffer]
        Q2[ioQueue]
    end
    subgraph top["Client写共享内存"]
        B1[buffer]
        Q1[ioQueue]
    end
    C[Client]
    S[Server]

    C -->|1、写请求| B1
    C -->|2、IO事件入队| Q1
    C -->|3、uds事件通知| S
    S --->|4、IO事件出队| Q1
    S -->|5、读请求| B1
    S -->|6、写应答| B2
    S --->|7、IO事件入队| Q2
    S -->|8、uds事件通知| C
    C -->|9、IO事件出队| Q2
    C -->|10、读应答| B2

sequenceDiagram
    participant client as client
    participant bw1 as bthread-worker
    participant bw2 as bthread-worker
    participant server as server

   server->>server: 启动服务端<br/>设置UDS地址+Socket共享内存模式<br/>初始化服务端写共享内存文件
   server->>bw2:监听连接
   client->>client: 启动客户端<br/>设置UDS地址+Socket共享内存模式<br/>初始化客户端写共享内存文件
   client->>bw1:
   client->>client: 发起RPC调用<br/>IoBuf从共享内存获取block<br/>写入请求数据
   client->>bw2: 发起UDS连接
   bw2->>bw2:接收连接<br/>创建IoQueue共享内存文件
   bw2->>bw1:发送server端写fd给客户端
   bw1->>bw1:映射共享内存fd<br/>创建本端IoQueue共享内存
   bw1->>bw2: 发送client端写fd给服务端
   bw2->>bw2: 接收fd，完成客户端共享内存映射<br/>连接建立成功
   bw1->>bw1: 发送请求<br/>获取共享内存偏移+大小<br/>IoQueue入队
   bw1->>bw2:UDS通知服务端
   bw2->>bw2:bthread-worker IoQueue出队<br/>从共享内存读取消息
   bw2->>bw2:构造应答<br/>IoBuf从共享内存获取block写入数据<br/>IoQueue入队
   bw2->>bw1:UDS通知客户端
   bw1->>bw1: IoQueue出队<br/>从共享内存读取应答

Client Process (连接 N 个 Server)
├── Client Send Buffer SHM (1 个, 进程级, 所有连接共享)
├── Server Send Buffer SHM (N 个, 服务端创建)
├── Connection 1 (→ Server A)
│   ├── Request IoQueue SHM (客户端创建)
│   └── Reply IoQueue SHM   (服务端创建)
├── Connection 2 (→ Server B)
│   ├── Request IoQueue SHM (客户端创建)
│   └── Reply IoQueue SHM   (服务端创建)
└── ...
Server Process (被 M 个 Client 连接)
├── Server Send Buffer SHM (1 个, 进程级, 所有连接共享)
├── Client Send Buffer SHM (M 个, 客户端创建)
├── Connection 1 (← Client A)
│   ├── Request IoQueue SHM (客户端创建)
│   └── Reply Queue SHM   (服务端创建)
├── Connection 2 (← Client B)
│   ├── Request IoQueue SHM (客户端创建)
│   └── Reply IoQueue SHM   (服务端创建)
└── ...

// Server 端
 	 brpc::Server server;
 	 brpc::ServerOptions options;
 	 options.socket_mode = brpc::SOCKET_MODE_MEMFD;  // 关键配置
 	 server.Start("unix:shmsocket", &options);

 	 // Client 端
 	 brpc::Channel channel;
 	 brpc::ChannelOptions options;
 	 options.socket_mode = brpc::SOCKET_MODE_MEMFD;  // 关键配置
 	 channel.Init("unix:shmsocket", &options);