摘要： Delphi-Cross-Socket：跨平台高性能网络通信框架 项目概述 Delphi-Cross-Socket 是一个基于 Pascal/Delphi 的跨平台、高性能网络通信...

Delphi-Cross-Socket：跨平台高性能网络通信框架

项目概述

Delphi-Cross-Socket 是一个基于 Pascal/Delphi 的跨平台、高性能网络通信框架，由开发者 winddriver 创建并维护。该项目旨在为 Delphi 开发者提供一个现代化、高效的网络编程解决方案，支持 Windows、Linux、macOS 和 Android 等多个平台。

核心特性

1. 跨平台支持

• 支持 Windows（IOCP）、Linux（epoll）、macOS（kqueue）和 Android
• 统一的 API 接口，无需为不同平台编写特定代码
• 自动选择最优的 I/O 多路复用机制

2. 高性能架构

• 基于事件驱动的异步 I/O 模型
• 零拷贝技术减少内存复制开销
• 连接池和内存池优化资源管理
• 支持高并发连接处理

3. 协议支持

• TCP/UDP 协议支持
• WebSocket 协议支持
• SSL/TLS 安全通信
• 自定义协议扩展能力

4. 易用性设计

• 简洁的 API 设计
• 丰富的示例代码
• 详细的文档说明
• 活跃的社区支持

安装与配置

环境要求

• Delphi 10.3+ 或 Lazarus 2.0+
• 支持跨平台编译环境

安装步骤

1. 克隆项目到本地：

git clone https://github.com/winddriver/Delphi-Cross-Socket.git

1. 将项目目录添加到 Delphi 的库路径中

2. 在项目中引用必要的单元文件

使用示例

示例 1：创建 TCP 服务器

program TcpServerExample;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  Net.CrossSocket,
  Net.CrossServer;

var
  Server: ICrossServer;
  
procedure OnConnected(AConnection: ICrossConnection);
begin
  Writeln('客户端连接: ', AConnection.PeerAddr);
end;

procedure OnDisconnected(AConnection: ICrossConnection);
begin
  Writeln('客户端断开: ', AConnection.PeerAddr);
end;

procedure OnReceived(AConnection: ICrossConnection; ABuf: Pointer; ALen: Integer);
var
  sData: string;
begin
  // 接收数据
  SetString(sData, PAnsiChar(ABuf), ALen);
  Writeln('收到数据: ', sData);
  
  // 回显数据
  AConnection.SendBuf(ABuf, ALen);
end;

begin
  try
    // 创建服务器实例
    Server := TCrossServer.Create;
    
    // 设置事件回调
    Server.OnConnected := OnConnected;
    Server.OnDisconnected := OnDisconnected;
    Server.OnReceived := OnReceived;
    
    // 启动服务器监听 8080 端口
    if Server.Start('0.0.0.0', 8080) then
    begin
      Writeln('服务器启动成功，监听端口: 8080');
      Writeln('按 Enter 键退出...');
      Readln;
    end
    else
      Writeln('服务器启动失败');
      
  except
    on E: Exception do
      Writeln('错误: ', E.Message);
  end;
end.

示例 2：创建 TCP 客户端

program TcpClientExample;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  Net.CrossSocket,
  Net.CrossClient;

var
  Client: ICrossClient;
  Connected: Boolean;

procedure OnConnected(AConnection: ICrossConnection);
begin
  Connected := True;
  Writeln('已连接到服务器');
  
  // 连接成功后发送数据
  AConnection.Send('Hello Server!');
end;

procedure OnDisconnected(AConnection: ICrossConnection);
begin
  Connected := False;
  Writeln('与服务器断开连接');
end;

procedure OnReceived(AConnection: ICrossConnection; ABuf: Pointer; ALen: Integer);
var
  sData: string;
begin
  SetString(sData, PAnsiChar(ABuf), ALen);
  Writeln('收到服务器响应: ', sData);
end;

begin
  Connected := False;
  
  try
    // 创建客户端实例
    Client := TCrossClient.Create;
    
    // 设置事件回调
    Client.OnConnected := OnConnected;
    Client.OnDisconnected := OnDisconnected;
    Client.OnReceived := OnReceived;
    
    // 连接到服务器
    Writeln('正在连接到服务器...');
    Client.Connect('127.0.0.1', 8080);
    
    // 等待连接
    while not Connected do
      Sleep(100);
    
    // 保持运行
    Writeln('按 Enter 键退出...');
    Readln;
    
  except
    on E: Exception do
      Writeln('错误: ', E.Message);
  end;
end.

示例 3：WebSocket 服务器

program WebSocketServerExample;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  Net.CrossSocket,
  Net.CrossWebSocketServer;

var
  WSServer: ICrossWebSocketServer;

procedure OnWebSocketConnected(AConnection: ICrossWebSocketConnection);
begin
  Writeln('WebSocket 客户端连接: ', AConnection.PeerAddr);
end;

procedure OnWebSocketDisconnected(AConnection: ICrossWebSocketConnection);
begin
  Writeln('WebSocket 客户端断开: ', AConnection.PeerAddr);
end;

procedure OnWebSocketReceived(AConnection: ICrossWebSocketConnection;
  ADataType: TWsMessageType; ABuf: Pointer; ALen: Integer);
var
  sData: string;
begin
  case ADataType of
    wsText, wsBinary:
    begin
      SetString(sData, PAnsiChar(ABuf), ALen);
      Writeln('收到 WebSocket 消息: ', sData);
      
      // 广播消息给所有连接的客户端
      WSServer.BroadcastText('收到消息: ' + sData);
    end;
  end;
end;

begin
  try
    // 创建 WebSocket 服务器
    WSServer := TCrossWebSocketServer.Create;
    
    // 设置事件回调
    WSServer.OnConnected := OnWebSocketConnected;
    WSServer.OnDisconnected := OnWebSocketDisconnected;
    WSServer.OnReceived := OnWebSocketReceived;
    
    // 启动服务器
    if WSServer.Start('0.0.0.0', 8081) then
    begin
      Writeln('WebSocket 服务器启动成功，监听端口: 8081');
      Writeln('按 Enter 键退出...');
      Readln;
    end
    else
      Writeln('服务器启动失败');
      
  except
    on E: Exception do
      Writeln('错误: ', E.Message);
  end;
end.

高级功能

SSL/TLS 支持

// 启用 SSL/TLS 加密通信
Server.SSL := True;
Server.CertFile := 'server.crt';
Server.KeyFile := 'server.key';

性能调优

// 配置工作线程数
Server.IOThreads := 4;

// 设置连接超时
Server.ConnectTimeout := 5000; // 5秒

// 启用心跳检测
Server.KeepAlive := True;
Server.KeepAliveInterval := 30000; // 30秒

项目优势

1. 性能卓越：采用高效的 I/O 模型，能够处理数万并发连接
2. 资源友好：内存占用低，CPU 利用率高
3. 稳定可靠：经过大量实际项目验证，稳定性有保障
4. 易于扩展：模块化设计，方便添加新功能和新协议
5. 社区活跃：持续更新维护，问题响应及时

适用场景

• 游戏服务器开发
• 实时通信应用
• IoT 设备通信
• API 服务器
• 消息推送系统
• 分布式系统通信

总结

Delphi-Cross-Socket 为 Pascal/Delphi 开发者提供了一个现代化、高性能的网络编程框架，填补了 Delphi 在跨平台网络编程领域的空白。无论是开发简单的客户端/服务器应用，还是构建复杂的分布式系统，这个框架都能提供强大的支持。其简洁的 API 设计和丰富的功能特性，使得网络编程变得更加简单高效。

对于需要跨平台网络通信解决方案的 Delphi 开发者来说，Delphi-Cross-Socket 是一个值得尝试的优秀选择。项目持续更新，社区活跃，是 Delphi 生态中不可多得的网络编程利器。

项目地址：https://github.com/winddriver/Delphi-Cross-Socket