backend

Backend 模块

概述

Backend 模块负责管理各代理服务的后端实例配置。包括 MySQL、SSH、Redis、MongoDB 等多种后端的连接信息和连接池管理。

职责

• ✅ 后端实例管理（CRUD）
• ✅ 后端健康检查
• ✅ 连接池配置管理
• ✅ 负载均衡策略支持
• ✅ 实例分组（同一服务的多个实例）

数据模型

backend_instances 表（通用表）

CREATE TABLE backend_instances (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    backend_id VARCHAR(64) NOT NULL UNIQUE COMMENT '实例ID',
    service_name VARCHAR(64) NOT NULL COMMENT '服务名 (rds, ssh, redis)',
    instance_name VARCHAR(255) NOT NULL COMMENT '实例名称',
    type VARCHAR(32) NOT NULL COMMENT '类型 (master, slave, replica, replica_set)',
    host VARCHAR(255) NOT NULL COMMENT '主机地址',
    port INT NOT NULL COMMENT '端口号',
    enabled BOOLEAN DEFAULT TRUE COMMENT '是否启用',
    weight INT DEFAULT 1 COMMENT '负载均衡权重',
    max_pool_size INT DEFAULT 20 COMMENT '连接池大小',
    health_check_interval INT DEFAULT 30 COMMENT '健康检查间隔(秒)',
    healthy BOOLEAN DEFAULT TRUE COMMENT '当前是否健康',
    description VARCHAR(255) COMMENT '实例描述',
    metadata JSON COMMENT '扩展元数据(服务特定配置)',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    INDEX idx_service_name (service_name),
    INDEX idx_backend_id (backend_id),
    INDEX idx_enabled (enabled),
    INDEX idx_type (type)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='代理后端实例表';

实例类型说明

接口设计

核心接口

type Service interface {
    // 查询
    GetBackend(context.Context, *GetBackendRequest) (*Backend, error)
    SearchBackend(context.Context, *SearchBackendRequest) (*types.Set[*Backend], error)
    
    // 管理
    CreateBackend(context.Context, *CreateBackendRequest) (*Backend, error)
    UpdateBackend(context.Context, *UpdateBackendRequest) (*Backend, error)
    DeleteBackend(context.Context, *DeleteBackendRequest) error
    
    // 健康检查
    HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResult, error)
    GetHealthStatus(context.Context, *GetHealthStatusRequest) (*HealthStatus, error)
    
    // 连接池
    GetPoolStats(context.Context, *GetPoolStatsRequest) (*PoolStats, error)
}

Backend 模型

type Backend struct {
    Id              int64             `json:"id"`
    BackendId       string            `json:"backend_id"`
    ServiceName     string            `json:"service_name"`
    InstanceName    string            `json:"instance_name"`
    Type            string            `json:"type"`
    Host            string            `json:"host"`
    Port            int               `json:"port"`
    Enabled         bool              `json:"enabled"`
    Weight          int               `json:"weight"`
    MaxPoolSize     int               `json:"max_pool_size"`
    HealthCheckInterval int           `json:"health_check_interval"`
    Healthy         bool              `json:"healthy"`
    Description     string            `json:"description"`
    Metadata        map[string]interface{} `json:"metadata"`
    CreatedAt       time.Time         `json:"created_at"`
    UpdatedAt       time.Time         `json:"updated_at"`
}

使用场景

场景 1: 注册 MySQL 主从实例

req := &CreateBackendRequest{
    ServiceName:    "rds",
    InstanceName:   "business_db_master",
    BackendId:      "mysql-biz-master",
    Type:          "master",
    Host:          "10.0.0.1",
    Port:          3306,
    MaxPoolSize:   20,
    Weight:        1,
}

backend, _ := backendService.CreateBackend(ctx, req)

场景 2: 健康检查

result, _ := backendService.HealthCheck(ctx, &HealthCheckRequest{
    BackendId: "mysql-biz-master",
})

if !result.Healthy {
    // 自动切换到从库
}

场景 3: 查询连接池统计

stats, _ := backendService.GetPoolStats(ctx, &GetPoolStatsRequest{
    BackendId: "mysql-biz-master",
})

fmt.Printf("活跃连接: %d, 空闲连接: %d\n", stats.ActiveConn, stats.IdleConn)

API 端点

# 实例管理
GET    /api/mproxy/backends              # 列表
GET    /api/mproxy/backends/:backend_id  # 详情
POST   /api/mproxy/backends              # 创建
PUT    /api/mproxy/backends/:backend_id  # 更新
DELETE /api/mproxy/backends/:backend_id  # 删除

# 健康检查
POST   /api/mproxy/backends/:backend_id/health-check
GET    /api/mproxy/backends/:backend_id/health-status

# 连接池
GET    /api/mproxy/backends/:backend_id/pool-stats

文件结构

backend/
├── README.md           # 本文档
├── interface.go        # 接口定义
├── impl/
│   ├── impl.go        # 实现
│   └── healthcheck.go # 健康检查逻辑
├── model.go           # 数据模型
└── api.go             # HTTP API

后续增强

• 自动故障转移
• 连接池动态调整
• 实例分组管理
• 性能指标收集