XRPC - 高性能分布式RPC框架

XRPC 是一个基于 Go 语言开发的高性能、企业级分布式 RPC 框架，提供了完整的微服务开发解决方案。

🌟 核心特性

🔧 核心功能

高性能消息传输：基于高效的消息队列机制实现RPC调用
并发安全：全面的并发安全保护，支持高并发场景
分布式追踪：内置OpenTelemetry兼容的分布式追踪系统
性能监控：丰富的性能指标收集和监控功能
多协议支持：支持HTTP、gRPC、WebSocket等多种协议

🛡️ 安全特性

TLS加密：完整的TLS支持，确保传输安全
身份认证：支持JWT、API Key、HMAC等多种认证方式
访问控制：IP白名单/黑名单、流量限制
CORS支持：完善的跨域资源共享配置
CSRF防护：内置CSRF攻击防护机制

📊 可观测性

分布式追踪：完整的请求链路追踪
指标监控：计数器、仪表盘、直方图等监控指标
健康检查：HTTP、TCP、gRPC多种健康检查机制
实时仪表板：提供Web界面的实时监控面板

⚖️ 高可用特性

负载均衡：轮询、加权轮询、最少连接、一致性哈希算法
服务发现：自动服务注册与发现机制
故障转移：智能故障检测和自动恢复
熔断器：防雪崩的熔断保护机制

🔌 中间件生态

认证中间件：多种认证策略支持
限流中间件：令牌桶、滑动窗口等限流算法
缓存中间件：LRU、LFU、FIFO等多种缓存策略
安全中间件：综合安全检查和防护

🚀 快速开始

安装


go get github.com/darkit/xrpc

基础使用


package main

import (
    "context"
    "log"
    
    "github.com/darkit/xrpc"
)

func main() {
    // 创建XRPC实例
    rpcServer := xrpc.NewXRPC()
    
    // 配置选项
    opts := &xrpc.Options{
        EnableTracing:    true,
        EnableMetrics:    true,
        MetricsInterval: 10,
    }
    rpcServer.SetOptions(opts)
    
    // 注册服务方法
    rpcServer.RegisterMethod("hello", func(ctx context.Context, args []interface{}) (interface{}, error) {
        if len(args) > 0 {
            name := args[0].(string)
            return "Hello, " + name, nil
        }
        return "Hello, World!", nil
    })
    
    // 启动服务器
    if err := rpcServer.Serve(":8080"); err != nil {
        log.Fatal(err)
    }
}

客户端调用


package main

import (
    "context"
    "fmt"
    "log"
    
    "github.com/darkit/xrpc"
)

func main() {
    // 创建客户端
    client := xrpc.NewXRPC()
    
    // 连接服务器
    if err := client.Connect("localhost:8080"); err != nil {
        log.Fatal(err)
    }
    defer client.Close()
    
    // 调用远程方法
    result, err := client.Call(context.Background(), "hello", []interface{}{"World"})
    if err != nil {
        log.Fatal(err)
    }
    
    fmt.Println(result) // 输出: Hello, World
}

📚 高级功能

1. 安全配置


// 创建安全管理器
securityConfig := &xrpc.SecurityConfig{
    EnableTLS:       true,
    CertFile:        "/path/to/cert.pem",
    KeyFile:         "/path/to/key.pem",
    EnableAuth:      true,
    AuthType:        "jwt",
    SecretKey:       "your-secret-key",
    EnableRateLimit: true,
    RateLimitPerIP:  100,
}

securityManager, err := xrpc.NewSecurityManager(securityConfig)
if err != nil {
    log.Fatal(err)
}

// 应用安全配置
rpcServer.SetSecurityManager(securityManager)

2. 负载均衡配置


// 创建负载均衡器
lbConfig := &xrpc.LoadBalancerConfig{
    Algorithm: "round_robin", // round_robin, weighted_round_robin, least_connections, consistent_hash
    HealthCheckInterval: 30 * time.Second,
    MaxRetries: 3,
}

loadBalancer := xrpc.NewLoadBalancer(lbConfig)

// 添加服务节点
nodes := []*xrpc.ServiceNode{
    {ID: "node1", Address: "192.168.1.10", Port: 8080, Weight: 100},
    {ID: "node2", Address: "192.168.1.11", Port: 8080, Weight: 100},
    {ID: "node3", Address: "192.168.1.12", Port: 8080, Weight: 50},
}

loadBalancer.UpdateNodes("my-service", nodes)

3. 健康检查配置


// 创建健康监控器
healthConfig := &xrpc.HealthMonitorConfig{
    DefaultInterval: 30 * time.Second,
    DefaultTimeout:  5 * time.Second,
    MaxWorkers:      10,
    EnableMetrics:   true,
}

healthMonitor := xrpc.NewHealthMonitor(healthConfig)

// 添加健康检查目标
target := &xrpc.HealthTarget{
    ID:       "service-node-1",
    Type:     "http",
    Address:  "192.168.1.10",
    Port:     8080,
    Path:     "/health",
    Interval: 15 * time.Second,
    Timeout:  3 * time.Second,
}

healthMonitor.AddTarget(target)

4. 分布式追踪配置


// 创建追踪器配置
tracerConfig := &xrpc.TracerConfig{
    ServiceName:    "my-rpc-service",
    ServiceVersion: "1.0.0",
    ExporterType:   "jaeger", // jaeger, console, file
    ExporterConfig: map[string]string{
        "endpoint": "http://jaeger:14268/api/traces",
    },
    SamplingRate: 1.0, // 100% 采样
}

tracer := xrpc.NewTracer(tracerConfig)
rpcServer.SetTracer(tracer)

5. 中间件使用


// 认证中间件
authConfig := &xrpc.AuthConfig{
    Type:      "jwt",
    SecretKey: "your-secret-key",
    TokenTTL:  time.Hour,
}
authMiddleware := xrpc.NewAuthMiddleware(authConfig)

// 限流中间件
rateLimitConfig := &xrpc.RateLimitConfig{
    Algorithm:    "token_bucket",
    Rate:         100,
    BurstSize:    200,
    WindowSize:   time.Minute,
}
rateLimitMiddleware := xrpc.NewRateLimitMiddleware(rateLimitConfig)

// 缓存中间件
cacheConfig := &xrpc.CacheConfig{
    Algorithm:  "lru",
    MaxSize:    1000,
    DefaultTTL: 10 * time.Minute,
}
cacheMiddleware := xrpc.NewCacheMiddleware(cacheConfig)

// 注册中间件
rpcServer.Use(authMiddleware)
rpcServer.Use(rateLimitMiddleware)
rpcServer.Use(cacheMiddleware)

🔧 开发者工具

XRPC 提供了完整的开发者工具链，提升开发效率：

代码生成器


# 编译工具
cd cmd/xrpc && go build -o ../../bin/xrpc

# 生成RPC客户端代码
./bin/xrpc generate -input service.go -output client.go -format client

# 生成服务端代码
./bin/xrpc generate -input service.go -output server.go -format server

# 生成接口定义
./bin/xrpc generate -input service.go -output interface.go -format interface

调试工具


# 编译调试工具
cd cmd/xrpc-debug && go build -o ../../bin/xrpc-debug

# 调试RPC连接
./bin/xrpc-debug -target localhost:8080 -method ping

# 性能测试
./bin/xrpc-debug -target localhost:8080 -method hello -concurrent 100 -requests 1000

代码格式化


# 编译格式化工具
cd cmd/xrpc-fmt && go build -o ../../bin/xrpc-fmt

# 格式化代码
./bin/xrpc-fmt -input service.go -output formatted.go

文档生成器


# 编译文档生成器
cd cmd/xrpc-docs && go build -o ../../bin/xrpc-docs

# 生成文档
./bin/xrpc-docs -input service.go -output docs/ -format html

🏗️ 架构设计


┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐
│   客户端应用     │    │   负载均衡器     │    │   服务端应用     │
│                │    │                │    │                │
│  ┌───────────┐  │    │  ┌───────────┐  │    │  ┌───────────┐  │
│  │ RPC Client│──┼────┼──│LoadBalancer│──┼────┼──│RPC Server │  │
│  └───────────┘  │    │  └───────────┘  │    │  └───────────┘  │
│                │    │                │    │                │
└─────────────────┘    └─────────────────┘    └─────────────────┘
         │                       │                       │
         └───────────────────────┼───────────────────────┘
                                │
                    ┌─────────────────┐
                    │   基础设施层     │
                    │                │
                    │ ┌─────┐ ┌─────┐ │
                    │ │追踪│ │监控│ │
                    │ └─────┘ └─────┘ │
                    │ ┌─────┐ ┌─────┐ │
                    │ │缓存│ │安全│ │
                    │ └─────┘ └─────┘ │
                    └─────────────────┘