PulseRPC.Infrastructure.Etcd 1.1.9

PulseRPC

基于现代 .NET 平台的高性能 RPC 框架，支持 TCP 和 KCP 传输协议，面向 Unity 游戏和微服务架构设计。

项目仍在积极开发中，部分接口可能发生变化。完整、可运行的用法优先参考 docs/index.md、samples/ChatApp、samples/JwtAuthentication 与 samples/HubFactoryExample。

🚀 核心特性

• 多传输协议：TCP（可靠）与 KCP（低延迟）传输实现
• 集群发现：IDiscoveryProvider / IClusterMembership 抽象，提供静态成员以及 Consul、Etcd、Kubernetes 后端
• 客户端负载均衡：连接级随机、轮询和最少连接；加权轮询与一致性哈希仍为实验枚举值，选择时会明确抛出 NotSupportedException
• 健康检查与故障转移：客户端连接健康检查与服务端 IPulseServiceHealthCheck 支持
• 连接管理：连接生命周期管理，支持自动重连
• 代码生成：基于 Source Generator 的客户端/服务端代理，客户端避免使用反射（兼容 Unity）
• 多节点 Actor / Gateway：内置节点 TCP 数据面、wire v2 claims 与 lease fencing、Redis CAS + TTL 租约及严格授权路由（部署边界见专项指南）
• 高性能序列化：优先使用 MemoryPack
• 可观测性基础：服务端包含消息引擎监控与分布式追踪集成点；当前未发布独立 PulseRPC.Monitoring / PulseRPC.Tracing 包

📦 项目结构

PulseRPC/
├── src/                          # 核心源代码
│   ├── PulseRPC.Abstractions/    # 抽象接口和基础类型
│   ├── PulseRPC.Client/          # 客户端实现
│   ├── PulseRPC.Server/          # 服务端实现
│   ├── PulseRPC.Client.Unity/    # Unity 客户端支持
│   ├── PulseRPC.Shared/          # 共享组件（压缩、网络缓冲池等）
│   ├── PulseRPC.Infrastructure/  # 核心基础设施实现
│   └── PulseRPC.Infrastructure.*/# 特定基础设施实现（Consul、Etcd、K8s 等）
├── perf/                         # 性能测试和基准测试
│   ├── BenchmarkApp/             # 系统级性能基准测试框架
│   ├── Microbenchmark/           # 方法级微基准测试
│   └── SourceGeneratorPerf/      # 源生成器性能测试
├── samples/                      # 示例应用（见 samples/README.md）
├── tests/                        # 单元测试和集成测试
└── docs/                         # 中文项目文档

🛠️ 环境要求

• .NET 10 SDK（版本以 global.json 为准）
• Visual Studio 2022 或 JetBrains Rider（推荐）
• Unity 2022.3 LTS（用于 Unity 集成，客户端兼容 netstandard2.1）

⚡ 快速开始

构建和测试

# 恢复依赖（使用集中化包管理）
dotnet restore

# 构建整个解决方案
dotnet build

# 运行所有测试
dotnet test

# 构建发布版本
dotnet build -c Release

服务端

以下示例基于 samples/ChatApp，演示如何注册并启动服务端：

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using PulseRPC.Server;
using PulseRPC.Server.Extensions;
using PulseRPC.Shared;

var host = Host.CreateDefaultBuilder(args)
    .ConfigureServices(services =>
    {
        // 注册 PulseRPC 服务端及传输通道
        services.AddPulseServer(options =>
        {
            options.Transports = new()
            {
                new TransportChannelConfiguration
                {
                    Name = "TCP",
                    Type = TransportType.TCP,
                    Port = 7000,
                    IsDefault = true
                }
            };
        });

        // 注册业务服务（服务实现 IPulseHub / IPulseService）
        services.AddPulseService<ChatRoomService>();
    })
    .Build();

var server = host.Services.GetRequiredService<IPulseServer>();
await server.StartAsync();

客户端

using Microsoft.Extensions.Logging;
using PulseRPC.Client;
using PulseRPC.Client.Configuration;

// 通过 Builder 配置并创建客户端
var client = new PulseClientBuilder()
    .AddConnection(ConnectionConfig.Tcp(name: "ChatServer", host: "127.0.0.1", port: 7000).ToDescriptor())
    .WithLogging(LoggerFactory.Create(b => b.AddConsole()))
    .Build();

await client.InitializeAsync();

// 通过 Source Generator 生成的代理调用远程服务
// （代理与扩展方法由 PulseRPC.Client.SourceGenerator 生成）

await client.StopAsync();

更完整的端到端示例（服务契约定义、代理调用、认证、Unity 集成等）请参阅 docs/index.md 与 samples/ 目录。

📊 性能基准测试

perf/BenchmarkApp 提供端到端的性能基准测试框架，支持延迟、吞吐量、流式传输等场景，并可导出 HTML/JSON/CSV 报告。使用方法请参阅 perf/BenchmarkApp/README.md。

📖 文档

所有面向用户的文档均位于 docs/ 目录，入口见 文档索引：

• 快速开始
• 客户端和服务端使用指南
• Unity 客户端教程
• 架构总览
• Actor 模型
• 集群与路由
• 经 Gateway 调用 Actor
• 参考手册
• 示例项目
• 变更日志

历史设计、阶段总结和旧路线图已归档到 docs/archive/。

🧪 示例项目

项目包含多个示例，完整清单见 samples/README.md，其中包括：

• ChatApp - 基于服务隔离架构的实时聊天/游戏示例（含 Unity 客户端）
• JwtAuthentication - JWT 身份验证集成示例
• HubFactoryExample - 当前 Hub 工厂用法
• GameApp / DistributedGameApp - 历史游戏架构参考，不作为当前可运行模板

🔧 开发约定

• 启用 nullable reference types（Nullable 警告视为错误）
• 使用 PublicAPI.Shipped.txt 和 PublicAPI.Unshipped.txt 进行 API 兼容性管理
• 遵循异步编程模式，使用 CancellationToken
• 客户端实现避免使用反射，通过 Source Generator 进行代码生成
• 集中化包管理：Directory.Packages.props、Directory.Build.props、global.json

🤝 贡献指南

欢迎社区贡献！

1. Fork 本仓库
2. 创建特性分支 (git checkout -b feature/AmazingFeature)
3. 提交更改 (git commit -m 'Add some AmazingFeature')
4. 推送到分支 (git push origin feature/AmazingFeature)
5. 开启 Pull Request

📄 许可证

本项目采用 MIT 许可证。

🏆 致谢

感谢所有贡献者和社区成员的支持！

特别感谢：

• MemoryPack 提供高性能序列化
• Microsoft 提供 .NET 平台
• Unity Technologies 提供游戏引擎支持

⭐ 如果这个项目对你有帮助，请给我们一个星标！