以下是一个简单的Linux RDMA客户端和服务端的代码示例：
RDMA服务端代码（server.cpp）：
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <infiniband/verbs.h>
#define PORT_NUM 1
#define BUFFER_SIZE 4096
int main() {
struct ibv_device** dev_list;
struct ibv_device* ib_dev;
struct ibv_context* context;
struct ibv_pd* pd;
struct ibv_mr* mr;
struct ibv_cq* cq;
struct ibv_qp_init_attr qp_attr = {};
int num_devices, err;
// 获取可用的IB设备列表
dev_list = ibv_get_device_list(&num_devices);
if (num_devices == 0) {
printf("No RDMA devices found.\n");
return -1;
}
// 打开第一个设备
ib_dev = dev_list[0];
// 创建上下文句柄
context = ibv_open_device(ib_dev);
// 创建完成队列（CQ）
cq = ibv_create_cq(context, 1, NULL, NULL, 0);
// 分配保护域（Protection Domain）
pd = ibv_alloc_pd(context);
// 注册内存区域
char buffer[BUFFER_SIZE] = "Hello, RDMA!";
mr = ibv_reg_mr(pd, buffer, sizeof(buffer), IBV_ACCESS_LOCAL_WRITE | IBV_ACCESS_REMOTE_READ | IBV_ACCESS_REMOTE_WRITE);
// 创建QP初始化属性
qp_attr.send_cq = cq;
qp_attr.recv_cq = cq;
qp_attr.qp_type = IBV_QPT_RC; // Reliable Connection
qp_attr.cap.max_send_wr = 1; // 发送工作请求的最大数量
qp_attr.cap.max_recv_wr = 1; // 接收工作请求的最大数量
qp_attr.cap.max_send_sge = 1; // 每个发送工作请求中的scatter/gather元素的最大数量
qp_attr.cap.max_recv_sge = 1; // 每个接收工作请求中的scatter/gather元素的最大数量
// 创建QP（Queue Pair）
struct ibv_qp* qp = ibv_create_qp(pd, &qp_attr);
printf("Server is ready to accept connections.\n");
return 0;
}
RDMA客户端代码（client.cpp）：
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <infiniband/verbs.h>
#define PORT_NUM 1
int main() {
struct ibv_device** dev_list;
struct ibv_device* ib_dev;
struct ibv_context* context;
struct ibv_pd* pd;
struct ibv_mr* mr;
struct ibv_cq* cq;
struct ibv_qp_init_attr qp_attr = {};
int num_devices, err;
// 获取可用的IB设备列表
dev_list = ibv_get_device_list(&num_devices);
if (num_devices == 0) {
printf("No RDMA devices found.\n");
return -1;
}
// 打开第一个设备
ib_dev = dev_list[0];
// 创建上下文句柄
context = ibv_open_device(ib_dev);
// 创建完成队列（CQ）
cq = ibv_create_cq(context, 1, NULL, NULL, 0);
// 分配保护域（Protection Domain）
pd = ibv_alloc_pd(context);
// 注册内存区域
char buffer[BUFFER_SIZE];
mr = ibv_reg_mr(pd, buffer, sizeof(buffer), IBV_ACCESS_LOCAL_WRITE | IBV_ACCESS_REMOTE_READ | IBV_ACCESS_REMOTE_WRITE);
// 创建QP初始化属性
qp_attr.send_cq = cq;
qp_attr.recv_cq = cq;
qp_attr.qp_type = IBV_QPT_RC; // Reliable Connection
qp_attr.cap.max_send_wr = 1; // 发送工作请求的最大数量
qp_attr.cap.max_recv_wr = 1; // 接收工作请求的最大数量
qp_attr.cap.max_send_sge = 1; // 每个发送工作请求中的scatter/gather元素的最大数量
qp_attr.cap.max_recv_sge = 1; // 每个接收工作请求中的scatter/gather元素的最大数量
// 创建QP（Queue Pair）
struct ibv_qp* qp = ibv_create_qp(pd, &qp_attr);
printf("Client is ready to connect to the server.\n");
return 0;
}
请注意，这只是一个简单的示例，仅展示了RDMA客户端和服务端代码框架。要实现完整的RDMA通信，还需要添加适当的连接建立、数据传输等逻辑，并处理错误和异常情况。在编写RDMA代码时，请确保您已经熟悉RDMA编程模型和相关API。
内容由零声教学AI助手提供，问题来源于学员提问
![/// \brief parse endpoint.
/// \param[in] endpoint S3 endpoints to parse.
/// \param[out] host Endpoint host.
/// \param[out] port Endpoint port.
/// \return -1 means parsing failed, return 0 means parsing to host only, return 1 means parsing to h...](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162233565655357.png)
