拆开配置文件

config/config.go

@@ -1,428 +1,140 @@
 package config
 
 import (
-	"fmt"
-	"os"
-	"path/filepath"
 	"sync"
 
-	"gopkg.in/yaml.v2"
+	"git.x2erp.com/qdy/go-base/config/subconfigs"
 )
 
-// ==================== 配置结构体定义 ====================
-
-// Config 应用配置
-type Config struct {
-	Database DBConfig       `yaml:"database"`
-	Redis    RedisConfig    `yaml:"redis"`
-	Doris    DorisConfig    `yaml:"doris"`
-	RabbitMQ RabbitMQConfig `yaml:"rabbitmq"`
-	Auth     Auth           `yaml:"auth"`
-	Service  Service        `yaml:"service"`
-	HTTP     HTTPConfig     `yaml:"http"`
-	Micro    MicroConfig    `yaml:"micro"` // Go Micro配置
-}
-
-// ==================== 各个组件的配置结构 ====================
-
-// RabbitMQConfig RabbitMQ配置
-type RabbitMQConfig struct {
-	Host                 string `yaml:"host"`
-	Port                 int    `yaml:"port"`
-	Username             string `yaml:"username"`
-	Password             string `yaml:"password"`
-	Vhost                string `yaml:"vhost"`
-	UseTLS               bool   `yaml:"use_tls"`
-	CACert               string `yaml:"ca_cert"`
-	CertFile             string `yaml:"cert_file"`
-	KeyFile              string `yaml:"key_file"`
-	MaxOpenChannels      int    `yaml:"max_open_channels"`
-	ReconnectDelay       int    `yaml:"reconnect_delay"`
-	MaxReconnectAttempts int    `yaml:"max_reconnect_attempts"`
-	Heartbeat            int    `yaml:"heartbeat"`
-	ChannelSize          int    `yaml:"channel_size"`
-	DefaultExchange      string `yaml:"default_exchange"`
-	DefaultQueue         string `yaml:"default_queue"`
-	AutoAck              bool   `yaml:"auto_ack"`
-	Mandatory            bool   `yaml:"mandatory"`
-	Immediate            bool   `yaml:"immediate"`
-	PrefetchCount        int    `yaml:"prefetch_count"`
-	PrefetchSize         int    `yaml:"prefetch_size"`
-	Global               bool   `yaml:"global"`
-	PublisherConfirms    bool   `yaml:"publisher_confirms"`
-	ConfirmTimeout       int    `yaml:"confirm_timeout"`
-}
-
-// HTTPConfig HTTP客户端配置
-type HTTPConfig struct {
-	Timeout             int  `yaml:"timeout"`
-	MaxIdleConns        int  `yaml:"max_idle_conns"`
-	MaxIdleConnsPerHost int  `yaml:"max_idle_conns_per_host"`
-	IdleConnTimeout     int  `yaml:"idle_conn_timeout"`
-	MaxConnsPerHost     int  `yaml:"max_conns_per_host"`
-	DisableCompression  bool `yaml:"disable_compression"`
-	DisableKeepAlives   bool `yaml:"disable_keep_alives"`
-}
-
-// DBConfig 数据库配置
-type DBConfig struct {
-	Type            string `yaml:"type"`
-	Host            string `yaml:"host"`
-	Port            int    `yaml:"port"`
-	Username        string `yaml:"username"`
-	Password        string `yaml:"password"`
-	Database        string `yaml:"database"`
-	MaxOpenConns    int    `yaml:"max_open_conns"`
-	MaxIdleConns    int    `yaml:"max_idle_conns"`
-	ConnMaxLifetime int    `yaml:"conn_max_lifetime"`
-}
-
-// RedisConfig Redis配置
-type RedisConfig struct {
-	Host         string `yaml:"host"`
-	Port         int    `yaml:"port"`
-	Password     string `yaml:"password"`
-	DB           int    `yaml:"db"`
-	PoolSize     int    `yaml:"pool_size"`
-	DialTimeout  int    `yaml:"dial_timeout"`
-	ReadTimeout  int    `yaml:"read_timeout"`
-	WriteTimeout int    `yaml:"write_timeout"`
-	IdleTimeout  int    `yaml:"idle_timeout"`
-	MaxConnAge   int    `yaml:"max_conn_age"`
-}
-
-// DorisConfig Doris配置
-type DorisConfig struct {
-	FEHost            string `yaml:"fe_host"`
-	FEPort            int    `yaml:"fe_port"`
-	FEUsername        string `yaml:"fe_username"`
-	FEPassword        string `yaml:"fe_password"`
-	MySQLHost         string `yaml:"mysql_host"`
-	MySQLPort         int    `yaml:"mysql_port"`
-	MaxOpenConns      int    `yaml:"max_open_conns"`
-	MaxIdleConns      int    `yaml:"max_idle_conns"`
-	ConnMaxLifetime   int    `yaml:"conn_max_lifetime"`
-	StreamLoadTimeout int    `yaml:"stream_load_timeout"`
-	BatchSize         int    `yaml:"batch_size"`
-}
-
-// Auth 认证配置
-type Auth struct {
-	Token string `yaml:"token"`
-}
-
-// Service 微服务配置
-type Service struct {
-	ServiceName    string `yaml:"service_name"`
-	ServiceVersion string `yaml:"service_version"`
-	ServiceTag     string `yaml:"service_tags"`
-	Port           int    `yaml:"port"`
-	ReadTimeout    int    `yaml:"read_timeout"`
-	WriteTimeout   int    `yaml:"write_timeout"`
-	IdleTimeout    int    `yaml:"idle_timeout"`
-	TrustedProxies string `yaml:"trusted_proxies"`
-}
-
-// MicroConfig Go Micro微服务配置
-type MicroConfig struct {
-	RegistryAddress string `yaml:"registry_address"`
-	RegistryType    string `yaml:"registry_type"`
-	RegistryTimeout int    `yaml:"registry_timeout"`
-	LBStrategy      string `yaml:"lb_strategy"`
-	LBCacheTTL      int    `yaml:"lb_cache_ttl"`
-	LBRetries       int    `yaml:"lb_retries"`
-	ClientTimeout   int    `yaml:"client_timeout"`
-	ClientPoolSize  int    `yaml:"client_pool_size"`
-	MaxRetries      int    `yaml:"max_retries"`
-	CircuitEnabled  bool   `yaml:"circuit_enabled"`
-	CircuitTimeout  int    `yaml:"circuit_timeout"`
-	ErrorThreshold  int    `yaml:"error_threshold"`
-	SleepWindow     int    `yaml:"sleep_window"`
-	HealthPath      string `yaml:"health_path"`
-	HealthInterval  int    `yaml:"health_interval"`
-	HealthTimeout   int    `yaml:"health_timeout"`
-	LogLevel        string `yaml:"log_level"`
-	EnableDebug     bool   `yaml:"enable_debug"`
-	MetricsEnabled  bool   `yaml:"metrics_enabled"`
-	MetricsAddress  string `yaml:"metrics_address"`
-	TracerEnabled   bool   `yaml:"tracer_enabled"`
-	TracerAddress   string `yaml:"tracer_address"`
-}
-
-// ==================== 配置接口定义 ====================
-
-// IConfig 配置接口
+// IConfig 主配置接口
 type IConfig interface {
-	GetDatabase() DBConfig
-	GetRedis() RedisConfig
-	GetDoris() DorisConfig
-	GetRabbitMQ() RabbitMQConfig
-	GetAuth() Auth
-	GetService() Service
-	GetHTTP() HTTPConfig
-	GetMicro() MicroConfig
-
+	GetDatabase() *subconfigs.DatabaseConfig
+	GetRedis() *subconfigs.RedisConfig
+	GetDoris() *subconfigs.DorisConfig
+	GetRabbitMQ() *subconfigs.RabbitMQConfig
+	GetAuth() *subconfigs.AuthConfig
+	GetService() *subconfigs.ServiceConfig
+	GetHTTP() *subconfigs.HTTPConfig
+	GetMicro() *subconfigs.MicroConfig
+	GetLog() *subconfigs.LogConfig
+	GetInitError() error
 	IsDatabaseConfigured() bool
-	IsRedisConfigured() bool
 	IsDorisConfigured() bool
-	IsRabbitMQConfigured() bool
-	IsHTTPConfigured() bool
-	IsAuthConfigured() bool
-	IsMicroConfigured() bool
-}
-
-// configWrapper 配置包装器
-type configWrapper struct {
-	config *Config
-}
-
-// ==================== 接口实现 ====================
-
-func (cw *configWrapper) GetDatabase() DBConfig {
-	return cw.config.Database
-}
-
-func (cw *configWrapper) GetRedis() RedisConfig {
-	return cw.config.Redis
-}
-
-func (cw *configWrapper) GetDoris() DorisConfig {
-	return cw.config.Doris
-}
-
-func (cw *configWrapper) GetRabbitMQ() RabbitMQConfig {
-	return cw.config.RabbitMQ
+	IsRedisConfigured() bool
 }
 
-func (cw *configWrapper) GetAuth() Auth {
-	return cw.config.Auth
+// Config 主配置结构体 - 访问门面
+type Config struct {
+	initError error // 初始化错误
 }
 
-func (cw *configWrapper) GetService() Service {
-	return cw.config.Service
+// 实现IConfig接口 - 从注册表获取配置
+func (c *Config) GetDatabase() *subconfigs.DatabaseConfig {
+	if config := subconfigs.GetRegisteredConfig("database"); config != nil {
+		return config.(*subconfigs.DatabaseConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) GetHTTP() HTTPConfig {
-	return cw.config.HTTP
+func (c *Config) GetRedis() *subconfigs.RedisConfig {
+	if config := subconfigs.GetRegisteredConfig("redis"); config != nil {
+		return config.(*subconfigs.RedisConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) GetMicro() MicroConfig {
-	return cw.config.Micro
+func (c *Config) GetDoris() *subconfigs.DorisConfig {
+	if config := subconfigs.GetRegisteredConfig("doris"); config != nil {
+		return config.(*subconfigs.DorisConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsDatabaseConfigured() bool {
-	db := cw.config.Database
-	return db.Type != "" &&
-		db.Host != "" &&
-		db.Port > 0 &&
-		db.Username != "" &&
-		db.Database != ""
+func (c *Config) GetRabbitMQ() *subconfigs.RabbitMQConfig {
+	if config := subconfigs.GetRegisteredConfig("rabbitmq"); config != nil {
+		return config.(*subconfigs.RabbitMQConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsRedisConfigured() bool {
-	redis := cw.config.Redis
-	return redis.Host != "" && redis.Port > 0
+func (c *Config) GetAuth() *subconfigs.AuthConfig {
+	if config := subconfigs.GetRegisteredConfig("auth"); config != nil {
+		return config.(*subconfigs.AuthConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsDorisConfigured() bool {
-	doris := cw.config.Doris
-	return doris.FEHost != "" && doris.FEPort > 0
+func (c *Config) GetService() *subconfigs.ServiceConfig {
+	if config := subconfigs.GetRegisteredConfig("service"); config != nil {
+		return config.(*subconfigs.ServiceConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsRabbitMQConfigured() bool {
-	rabbit := cw.config.RabbitMQ
-	return rabbit.Host != "" && rabbit.Port > 0
+func (c *Config) GetHTTP() *subconfigs.HTTPConfig {
+	if config := subconfigs.GetRegisteredConfig("http"); config != nil {
+		return config.(*subconfigs.HTTPConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsHTTPConfigured() bool {
-	httpCfg := cw.config.HTTP
-	return httpCfg.Timeout > 0
+func (c *Config) GetMicro() *subconfigs.MicroConfig {
+	if config := subconfigs.GetRegisteredConfig("micro"); config != nil {
+		return config.(*subconfigs.MicroConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsAuthConfigured() bool {
-	return cw.config.Auth.Token != ""
+func (c *Config) GetLog() *subconfigs.LogConfig {
+	if config := subconfigs.GetRegisteredConfig("log"); config != nil {
+		return config.(*subconfigs.LogConfig)
+	}
+	return nil
 }
 
-func (cw *configWrapper) IsMicroConfigured() bool {
-	micro := cw.config.Micro
-	return micro.RegistryAddress != ""
+func (c *Config) GetInitError() error {
+	return c.initError
 }
 
-// ==================== 单例和全局变量 ====================
-
 var (
-	instance IConfig
-	once     sync.Once
-	initErr  error
+	cfgInstance *Config
+	once        sync.Once
 )
 
-// GetConfig 获取配置单例实例
+// GetConfig 获取主配置（单例模式）
 func GetConfig() IConfig {
 	once.Do(func() {
-		config, err := loadConfig()
-		if err != nil {
-			initErr = err
-			instance = &configWrapper{config: &Config{}}
-			return
-		}
-		instance = &configWrapper{config: config}
+		cfgInstance = &Config{}
+		cfgInstance.initError = LoadConfig() // 加载配置到注册表
 	})
-	return instance
+	return cfgInstance
 }
 
-// GetInitError 获取初始化错误（如果有）
+// GetInitError 包级函数 - 兼容现有代码调用
 func GetInitError() error {
-	return initErr
+	return cfgInstance.GetInitError()
 }
 
-// ==================== 配置文件加载 ====================
-
-// loadConfig 加载配置文件（整合所有默认值）
-func loadConfig() (*Config, error) {
-	configFile, err := findConfigFile()
-	if err != nil {
-		return nil, err
-	}
-
-	fmt.Printf("✅ Using config file: %s\n", configFile)
-
-	// 创建带默认值的配置
-	config := &Config{
-		Service: Service{
-			ServiceName:    "myService",
-			Port:           8080,
-			ReadTimeout:    30,
-			WriteTimeout:   30,
-			IdleTimeout:    60,
-			TrustedProxies: "",
-		},
-		Redis: RedisConfig{
-			Port:         6379,
-			DB:           0,
-			PoolSize:     10,
-			DialTimeout:  5,
-			ReadTimeout:  3,
-			WriteTimeout: 3,
-			IdleTimeout:  300,
-			MaxConnAge:   0,
-		},
-		Doris: DorisConfig{
-			FEPort:            8030,
-			MySQLPort:         9030,
-			MaxOpenConns:      20,
-			MaxIdleConns:      10,
-			ConnMaxLifetime:   3600,
-			StreamLoadTimeout: 30,
-			BatchSize:         1000,
-		},
-		HTTP: HTTPConfig{
-			Timeout:             30,
-			MaxIdleConns:        100,
-			MaxIdleConnsPerHost: 10,
-			IdleConnTimeout:     90,
-			MaxConnsPerHost:     0,
-			DisableCompression:  false,
-			DisableKeepAlives:   false,
-		},
-		RabbitMQ: RabbitMQConfig{
-			Port:                 5672,
-			Username:             "guest",
-			Password:             "guest",
-			Vhost:                "/",
-			UseTLS:               false,
-			MaxOpenChannels:      10,
-			ReconnectDelay:       5000,
-			MaxReconnectAttempts: 10,
-			Heartbeat:            30,
-			ChannelSize:          100,
-			DefaultExchange:      "amq.direct",
-			DefaultQueue:         "",
-			AutoAck:              false,
-			Mandatory:            false,
-			Immediate:            false,
-			PrefetchCount:        1,
-			PrefetchSize:         0,
-			Global:               false,
-			PublisherConfirms:    false,
-			ConfirmTimeout:       30,
-		},
-		Micro: MicroConfig{
-			RegistryAddress: "localhost:8500",
-			RegistryType:    "consul",
-			RegistryTimeout: 10,
-			LBStrategy:      "roundrobin",
-			LBCacheTTL:      30,
-			LBRetries:       3,
-			ClientTimeout:   30,
-			ClientPoolSize:  100,
-			MaxRetries:      3,
-			CircuitEnabled:  true,
-			CircuitTimeout:  60,
-			ErrorThreshold:  5,
-			SleepWindow:     5000,
-			HealthPath:      "/health",
-			HealthInterval:  10,
-			HealthTimeout:   5,
-			LogLevel:        "info",
-			EnableDebug:     false,
-			MetricsEnabled:  true,
-			MetricsAddress:  ":9090",
-			TracerEnabled:   false,
-			TracerAddress:   "localhost:6831",
-		},
-	}
-
-	// 读取并解析配置文件
-	data, err := os.ReadFile(configFile)
-	if err != nil {
-		return nil, fmt.Errorf("failed to read config file %s: %v", configFile, err)
-	}
-
-	err = yaml.Unmarshal(data, &config)
-	if err != nil {
-		return nil, fmt.Errorf("failed to parse config file: %v", err)
-	}
-
-	return config, nil
+// GetConfigWithError 新方法 - 同时获取配置和错误
+func GetConfigWithError() (IConfig, error) {
+	cfg := GetConfig()
+	return cfg, cfg.GetInitError()
 }
 
-// findConfigFile 查找配置文件路径
-func findConfigFile() (string, error) {
-	// 1. 可执行文件同目录
-	exePath, err := os.Executable()
-	if err == nil {
-		exeDir := filepath.Dir(exePath)
-		configFile := filepath.Join(exeDir, "db.yaml")
-		if _, err := os.Stat(configFile); err == nil {
-			return configFile, nil
-		}
-	}
-
-	// 2. 环境变量指定路径
-	envConfigPath := os.Getenv("DB_CONFIG_PATH")
-	if envConfigPath != "" {
-		if _, err := os.Stat(envConfigPath); err == nil {
-			return envConfigPath, nil
-		}
-		return "", fmt.Errorf("DB_CONFIG_PATH file not found: %s", envConfigPath)
-	}
+// 实现 IConfig 接口的 IsDatabaseConfigured 方法
+func (c *Config) IsDatabaseConfigured() bool {
 
-	// 3. 未找到配置文件
-	exeDir := "unknown"
-	if exePath, err := os.Executable(); err == nil {
-		exeDir = filepath.Dir(exePath)
-	}
+	return c.GetDatabase().IsConfigured()
+}
 
-	return "", fmt.Errorf(`no configuration file found!
+// 实现 IConfig 接口的 IsDorisConfigured 方法
+func (c *Config) IsDorisConfigured() bool {
 
-Tried locations:
-1. Executable directory: %s/db.yaml
-2. Environment variable: DB_CONFIG_PATH
+	return c.GetDoris().IsConfigured()
+}
 
-Solutions:
-- Place db.yaml in the same directory as the executable  
-- Or set DB_CONFIG_PATH environment variable to config file path
+// 实现 IConfig 接口的 IsDorisConfigured 方法
+func (c *Config) IsRedisConfigured() bool {
 
-Example:
-  export DB_CONFIG_PATH=/path/to/your/db.yaml`, exeDir)
+	return c.GetRedis().IsConfigured()
 }

config/loader.go

@@ -0,0 +1,94 @@
+package config
+
+import (
+	"fmt"
+	"os"
+	"path/filepath"
+
+	"git.x2erp.com/qdy/go-base/config/subconfigs"
+	"gopkg.in/yaml.v2"
+)
+
+// LoadConfig 加载配置到注册表
+func LoadConfig() error {
+	// 1. 设置所有注册配置的默认值
+	for _, config := range subconfigs.GetAllConfigs() {
+		config.SetDefaults()
+	}
+
+	// 2. 查找配置文件
+	configFile, err := findConfigFile()
+	if err != nil {
+		return err
+	}
+
+	// 3. 读取文件
+	data, err := os.ReadFile(configFile)
+	if err != nil {
+		return fmt.Errorf("read config file error: %v", err)
+	}
+
+	// 4. 解析为map
+	var rawConfig map[string]interface{}
+	err = yaml.Unmarshal(data, &rawConfig)
+	if err != nil {
+		return fmt.Errorf("parse yaml error: %v", err)
+	}
+
+	// 5. 循环注册表，为每个配置加载数据
+	for name, config := range subconfigs.GetAllConfigs() {
+		if configData, ok := rawConfig[name].(map[interface{}]interface{}); ok {
+			// 转换为 map[string]interface{}
+			strMap := convertMap(configData)
+			if err := config.Load(strMap); err != nil {
+				return fmt.Errorf("load config %s error: %v", name, err)
+			}
+		}
+	}
+
+	// // 6. 验证所有配置
+	// for name, config := range subconfigs.GetAllConfigs() {
+	// 	if err := config.Validate(); err != nil {
+	// 		return fmt.Errorf("validate config %s error: %v", name, err)
+	// 	}
+	// }
+
+	return nil
+}
+
+// convertMap 转换map类型
+func convertMap(input map[interface{}]interface{}) map[string]interface{} {
+	output := make(map[string]interface{})
+	for k, v := range input {
+		if strKey, ok := k.(string); ok {
+			output[strKey] = v
+		}
+	}
+	return output
+}
+
+// findConfigFile 查找配置文件
+func findConfigFile() (string, error) {
+	exePath, _ := os.Executable()
+	exeDir := filepath.Dir(exePath)
+
+	possiblePaths := []string{
+		filepath.Join(exeDir, "db.yaml"),
+		filepath.Join(exeDir, "config", "db.yaml"),
+		"db.yaml",
+		"config/db.yaml",
+		os.Getenv("DB_CONFIG_PATH"),
+	}
+
+	for _, path := range possiblePaths {
+		if path == "" {
+			continue
+		}
+		if _, err := os.Stat(path); err == nil {
+			fmt.Printf("✅ Using config file: %s\n", path)
+			return path, nil
+		}
+	}
+
+	return "", fmt.Errorf("no configuration file found")
+}

config/subconfigs/auth_config.go

@@ -0,0 +1,28 @@
+package subconfigs
+
+// AuthConfig 认证配置
+type AuthConfig struct {
+	BaseConfig
+	Token string `yaml:"token"`
+}
+
+func NewAuthConfig() *AuthConfig {
+	return &AuthConfig{}
+}
+
+func (c *AuthConfig) SetDefaults() {
+	// 默认不设置token
+}
+
+func (c *AuthConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *AuthConfig) Validate() error {
+	// token 可以为空，有些环境不需要认证
+	return nil
+}
+
+func (c *AuthConfig) IsConfigured() bool {
+	return c.Token != ""
+}

config/subconfigs/base.go

@@ -0,0 +1,30 @@
+package subconfigs
+
+import (
+	"gopkg.in/yaml.v2"
+)
+
+// BaseConfig 基础配置（所有子配置继承）
+type BaseConfig struct{}
+
+// LoadFromYAML 从YAML数据加载
+func (b *BaseConfig) LoadFromYAML(data map[string]interface{}, target interface{}) error {
+	// 转换为yaml字节
+	yamlBytes, err := yaml.Marshal(data)
+	if err != nil {
+		return err
+	}
+
+	// 解析到目标结构体
+	return yaml.Unmarshal(yamlBytes, target)
+}
+
+// GetRegisteredConfig 获取注册的配置实例（避免名称冲突）
+func GetRegisteredConfig(name string) ConfigLoader {
+	return registry[name]
+}
+
+// GetAllRegisteredConfigs 获取所有注册的配置
+func GetAllRegisteredConfigs() map[string]ConfigLoader {
+	return registry
+}

config/subconfigs/database_config.go

@@ -0,0 +1,54 @@
+package subconfigs
+
+import "fmt"
+
+// DatabaseConfig 数据库配置
+type DatabaseConfig struct {
+	BaseConfig
+	Type            string `yaml:"type"`
+	Host            string `yaml:"host"`
+	Port            int    `yaml:"port"`
+	Username        string `yaml:"username"`
+	Password        string `yaml:"password"`
+	Database        string `yaml:"database"`
+	MaxOpenConns    int    `yaml:"max_open_conns"`
+	MaxIdleConns    int    `yaml:"max_idle_conns"`
+	ConnMaxLifetime int    `yaml:"conn_max_lifetime"`
+}
+
+// NewDatabaseConfig 创建数据库配置实例
+func NewDatabaseConfig() *DatabaseConfig {
+	return &DatabaseConfig{}
+}
+
+// SetDefaults 设置默认值
+func (c *DatabaseConfig) SetDefaults() {
+	c.Type = "mysql"
+	c.Port = 3306
+	c.MaxOpenConns = 100
+	c.MaxIdleConns = 20
+	c.ConnMaxLifetime = 3600
+}
+
+// Load 从yaml数据加载
+func (c *DatabaseConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+// Validate 验证配置
+func (c *DatabaseConfig) Validate() error {
+	if c.Type == "" {
+		return fmt.Errorf("database type is required")
+	}
+	return nil
+}
+
+// IsConfigured 判断是否已配置
+func (c *DatabaseConfig) IsConfigured() bool {
+	return c.Host != "" && c.Port > 0 && c.Username != "" && c.Database != ""
+}
+
+// 自动注册
+func init() {
+	Register("database", &DatabaseConfig{})
+}

config/subconfigs/doris_config.go

@@ -0,0 +1,53 @@
+package subconfigs
+
+import "fmt"
+
+// DorisConfig Doris配置
+type DorisConfig struct {
+	BaseConfig
+	FEHost            string `yaml:"fe_host"`
+	FEPort            int    `yaml:"fe_port"`
+	FEUsername        string `yaml:"fe_username"`
+	FEPassword        string `yaml:"fe_password"`
+	MySQLHost         string `yaml:"mysql_host"`
+	MySQLPort         int    `yaml:"mysql_port"`
+	MaxOpenConns      int    `yaml:"max_open_conns"`
+	MaxIdleConns      int    `yaml:"max_idle_conns"`
+	ConnMaxLifetime   int    `yaml:"conn_max_lifetime"`
+	StreamLoadTimeout int    `yaml:"stream_load_timeout"`
+	BatchSize         int    `yaml:"batch_size"`
+}
+
+func NewDorisConfig() *DorisConfig {
+	return &DorisConfig{}
+}
+
+func (c *DorisConfig) SetDefaults() {
+	c.FEPort = 8030
+	c.MySQLPort = 9030
+	c.MaxOpenConns = 20
+	c.MaxIdleConns = 10
+	c.ConnMaxLifetime = 3600
+	c.StreamLoadTimeout = 30
+	c.BatchSize = 1000
+}
+
+func (c *DorisConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *DorisConfig) Validate() error {
+	if c.FEHost == "" && c.MySQLHost == "" {
+		return fmt.Errorf("at least one of fe_host or mysql_host must be configured")
+	}
+	return nil
+}
+
+func (c *DorisConfig) IsConfigured() bool {
+	return c.FEHost != "" || c.MySQLHost != ""
+}
+
+// 自动注册
+func init() {
+	Register("doris", &DorisConfig{})
+}

config/subconfigs/http_config.go

@@ -0,0 +1,46 @@
+package subconfigs
+
+import "fmt"
+
+// HTTPConfig HTTP客户端配置
+type HTTPConfig struct {
+	BaseConfig
+	Timeout             int  `yaml:"timeout"`
+	MaxIdleConns        int  `yaml:"max_idle_conns"`
+	MaxIdleConnsPerHost int  `yaml:"max_idle_conns_per_host"`
+	IdleConnTimeout     int  `yaml:"idle_conn_timeout"`
+	MaxConnsPerHost     int  `yaml:"max_conns_per_host"`
+	DisableCompression  bool `yaml:"disable_compression"`
+	DisableKeepAlives   bool `yaml:"disable_keep_alives"`
+}
+
+func NewHTTPConfig() *HTTPConfig {
+	return &HTTPConfig{}
+}
+
+func (c *HTTPConfig) SetDefaults() {
+	c.Timeout = 30
+	c.MaxIdleConns = 100
+	c.MaxIdleConnsPerHost = 10
+	c.IdleConnTimeout = 90
+}
+
+func (c *HTTPConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *HTTPConfig) Validate() error {
+	if c.Timeout <= 0 {
+		return fmt.Errorf("http timeout must be positive")
+	}
+	return nil
+}
+
+func (c *HTTPConfig) IsConfigured() bool {
+	return c.Timeout > 0
+}
+
+// 自动注册
+func init() {
+	Register("http", &HTTPConfig{})
+}

config/subconfigs/log_config.go

@@ -0,0 +1,71 @@
+package subconfigs
+
+import (
+	"fmt"
+	"strings"
+)
+
+// LogConfig 日志配置
+type LogConfig struct {
+	BaseConfig
+	Level      string `yaml:"level"`
+	Output     string `yaml:"output"`
+	FilePath   string `yaml:"file_path"`
+	MaxSize    int    `yaml:"max_size"`
+	MaxBackups int    `yaml:"max_backups"`
+	MaxAge     int    `yaml:"max_age"`
+	Compress   bool   `yaml:"compress"`
+	ESEnabled  bool   `yaml:"es_enabled"`
+	ESPath     string `yaml:"es_path"`
+	JSONFormat bool   `yaml:"json_format"`
+}
+
+// NewLogConfig 创建日志配置实例
+func NewLogConfig() *LogConfig {
+	return &LogConfig{}
+}
+
+// SetDefaults 设置默认值
+func (c *LogConfig) SetDefaults() {
+	c.Level = "info"
+	c.Output = "both"
+	c.FilePath = "logs/service.log"
+	c.MaxSize = 100
+	c.MaxBackups = 3
+	c.MaxAge = 30
+	c.Compress = true
+	c.ESEnabled = true
+	c.ESPath = "logs/es-service.log"
+	c.JSONFormat = true
+}
+
+// Load 从yaml数据加载
+func (c *LogConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+// Validate 验证配置
+func (c *LogConfig) Validate() error {
+	// 验证日志级别
+	validLevels := map[string]bool{
+		"debug": true, "info": true, "warn": true, "error": true,
+	}
+	if !validLevels[strings.ToLower(c.Level)] {
+		return fmt.Errorf("invalid log level: %s", c.Level)
+	}
+
+	// 验证输出类型
+	validOutputs := map[string]bool{
+		"console": true, "file": true, "both": true,
+	}
+	if !validOutputs[c.Output] {
+		return fmt.Errorf("invalid log output: %s", c.Output)
+	}
+
+	return nil
+}
+
+// 自动注册
+func init() {
+	Register("log", &LogConfig{})
+}

config/subconfigs/micro_config.go

@@ -0,0 +1,77 @@
+package subconfigs
+
+import "fmt"
+
+// MicroConfig Go Micro微服务配置
+type MicroConfig struct {
+	BaseConfig
+	RegistryAddress string `yaml:"registry_address"`
+	RegistryType    string `yaml:"registry_type"`
+	RegistryTimeout int    `yaml:"registry_timeout"`
+	LBStrategy      string `yaml:"lb_strategy"`
+	LBCacheTTL      int    `yaml:"lb_cache_ttl"`
+	LBRetries       int    `yaml:"lb_retries"`
+	ClientTimeout   int    `yaml:"client_timeout"`
+	ClientPoolSize  int    `yaml:"client_pool_size"`
+	MaxRetries      int    `yaml:"max_retries"`
+	CircuitEnabled  bool   `yaml:"circuit_enabled"`
+	CircuitTimeout  int    `yaml:"circuit_timeout"`
+	ErrorThreshold  int    `yaml:"error_threshold"`
+	SleepWindow     int    `yaml:"sleep_window"`
+	HealthPath      string `yaml:"health_path"`
+	HealthInterval  int    `yaml:"health_interval"`
+	HealthTimeout   int    `yaml:"health_timeout"`
+	LogLevel        string `yaml:"log_level"`
+	EnableDebug     bool   `yaml:"enable_debug"`
+	MetricsEnabled  bool   `yaml:"metrics_enabled"`
+	MetricsAddress  string `yaml:"metrics_address"`
+	TracerEnabled   bool   `yaml:"tracer_enabled"`
+	TracerAddress   string `yaml:"tracer_address"`
+}
+
+func NewMicroConfig() *MicroConfig {
+	return &MicroConfig{}
+}
+
+func (c *MicroConfig) SetDefaults() {
+	c.RegistryAddress = "localhost:8500"
+	c.RegistryType = "consul"
+	c.RegistryTimeout = 10
+	c.LBStrategy = "roundrobin"
+	c.LBCacheTTL = 30
+	c.LBRetries = 3
+	c.ClientTimeout = 30
+	c.ClientPoolSize = 100
+	c.MaxRetries = 3
+	c.CircuitEnabled = true
+	c.CircuitTimeout = 60
+	c.ErrorThreshold = 5
+	c.SleepWindow = 5000
+	c.HealthPath = "/health"
+	c.HealthInterval = 10
+	c.HealthTimeout = 5
+	c.LogLevel = "info"
+	c.EnableDebug = false
+	c.MetricsEnabled = true
+	c.MetricsAddress = ":9090"
+}
+
+func (c *MicroConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *MicroConfig) Validate() error {
+	if c.RegistryAddress == "" {
+		return fmt.Errorf("registry address is required")
+	}
+	return nil
+}
+
+func (c *MicroConfig) IsConfigured() bool {
+	return c.RegistryAddress != ""
+}
+
+// 自动注册
+func init() {
+	Register("micro", &MicroConfig{})
+}

config/subconfigs/rabbitmq_config.go

@@ -0,0 +1,74 @@
+package subconfigs
+
+import "fmt"
+
+// RabbitMQConfig RabbitMQ配置
+type RabbitMQConfig struct {
+	BaseConfig
+	Host                 string `yaml:"host"`
+	Port                 int    `yaml:"port"`
+	Username             string `yaml:"username"`
+	Password             string `yaml:"password"`
+	Vhost                string `yaml:"vhost"`
+	UseTLS               bool   `yaml:"use_tls"`
+	CACert               string `yaml:"ca_cert"`
+	CertFile             string `yaml:"cert_file"`
+	KeyFile              string `yaml:"key_file"`
+	MaxOpenChannels      int    `yaml:"max_open_channels"`
+	ReconnectDelay       int    `yaml:"reconnect_delay"`
+	MaxReconnectAttempts int    `yaml:"max_reconnect_attempts"`
+	Heartbeat            int    `yaml:"heartbeat"`
+	ChannelSize          int    `yaml:"channel_size"`
+	DefaultExchange      string `yaml:"default_exchange"`
+	DefaultQueue         string `yaml:"default_queue"`
+	AutoAck              bool   `yaml:"auto_ack"`
+	Mandatory            bool   `yaml:"mandatory"`
+	Immediate            bool   `yaml:"immediate"`
+	PrefetchCount        int    `yaml:"prefetch_count"`
+	PrefetchSize         int    `yaml:"prefetch_size"`
+	Global               bool   `yaml:"global"`
+	PublisherConfirms    bool   `yaml:"publisher_confirms"`
+	ConfirmTimeout       int    `yaml:"confirm_timeout"`
+}
+
+func NewRabbitMQConfig() *RabbitMQConfig {
+	return &RabbitMQConfig{}
+}
+
+func (c *RabbitMQConfig) SetDefaults() {
+	c.Port = 5672
+	c.Username = "guest"
+	c.Password = "guest"
+	c.Vhost = "/"
+	c.MaxOpenChannels = 10
+	c.ReconnectDelay = 5000
+	c.MaxReconnectAttempts = 10
+	c.Heartbeat = 30
+	c.ChannelSize = 100
+	c.DefaultExchange = "amq.direct"
+	c.PrefetchCount = 1
+	c.ConfirmTimeout = 30
+}
+
+func (c *RabbitMQConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *RabbitMQConfig) Validate() error {
+	if c.Host == "" {
+		return fmt.Errorf("rabbitmq host is required")
+	}
+	if c.Port <= 0 {
+		return fmt.Errorf("invalid rabbitmq port: %d", c.Port)
+	}
+	return nil
+}
+
+func (c *RabbitMQConfig) IsConfigured() bool {
+	return c.Host != ""
+}
+
+// 自动注册
+func init() {
+	Register("rabbitmq", &RabbitMQConfig{})
+}

config/subconfigs/redis_config.go

@@ -0,0 +1,52 @@
+package subconfigs
+
+import "fmt"
+
+// RedisConfig Redis配置
+type RedisConfig struct {
+	BaseConfig
+	Host         string `yaml:"host"`
+	Port         int    `yaml:"port"`
+	Password     string `yaml:"password"`
+	DB           int    `yaml:"db"`
+	PoolSize     int    `yaml:"pool_size"`
+	DialTimeout  int    `yaml:"dial_timeout"`
+	ReadTimeout  int    `yaml:"read_timeout"`
+	WriteTimeout int    `yaml:"write_timeout"`
+	IdleTimeout  int    `yaml:"idle_timeout"`
+	MaxConnAge   int    `yaml:"max_conn_age"`
+}
+
+func NewRedisConfig() *RedisConfig {
+	return &RedisConfig{}
+}
+
+func (c *RedisConfig) SetDefaults() {
+	c.Port = 6379
+	c.DB = 0
+	c.PoolSize = 10
+	c.DialTimeout = 5
+	c.ReadTimeout = 3
+	c.WriteTimeout = 3
+	c.IdleTimeout = 300
+}
+
+func (c *RedisConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *RedisConfig) Validate() error {
+	if c.Host == "" {
+		return fmt.Errorf("redis host is required")
+	}
+	return nil
+}
+
+func (c *RedisConfig) IsConfigured() bool {
+	return c.Host != ""
+}
+
+// 自动注册
+func init() {
+	Register("redis", &RedisConfig{})
+}

config/subconfigs/register.go

@@ -0,0 +1,26 @@
+package subconfigs
+
+// ConfigLoader 配置加载接口
+type ConfigLoader interface {
+	SetDefaults()
+	Load(data map[string]interface{}) error
+	//Validate() error
+}
+
+// 全局注册表 - 存储配置实例（单例）
+var registry = make(map[string]ConfigLoader)
+
+// Register 注册配置实例
+func Register(name string, config ConfigLoader) {
+	registry[name] = config
+}
+
+// GetConfig 获取配置实例
+func GetConfig(name string) ConfigLoader {
+	return registry[name]
+}
+
+// GetAllConfigs 获取所有配置
+func GetAllConfigs() map[string]ConfigLoader {
+	return registry
+}

config/subconfigs/service_config.go

@@ -0,0 +1,48 @@
+package subconfigs
+
+import "fmt"
+
+// ServiceConfig 微服务配置
+type ServiceConfig struct {
+	BaseConfig
+	ServiceName    string `yaml:"service_name"`
+	ServiceVersion string `yaml:"service_version"`
+	ServiceTag     string `yaml:"service_tags"`
+	Port           int    `yaml:"port"`
+	ReadTimeout    int    `yaml:"read_timeout"`
+	WriteTimeout   int    `yaml:"write_timeout"`
+	IdleTimeout    int    `yaml:"idle_timeout"`
+	TrustedProxies string `yaml:"trusted_proxies"`
+	InstanceName   string `yaml:"instance-name"`
+}
+
+func NewServiceConfig() *ServiceConfig {
+	return &ServiceConfig{}
+}
+
+func (c *ServiceConfig) SetDefaults() {
+	c.ServiceName = "myService"
+	c.Port = 8080
+	c.ReadTimeout = 30
+	c.WriteTimeout = 30
+	c.IdleTimeout = 60
+}
+
+func (c *ServiceConfig) Load(data map[string]interface{}) error {
+	return c.LoadFromYAML(data, c)
+}
+
+func (c *ServiceConfig) Validate() error {
+	if c.ServiceName == "" {
+		return fmt.Errorf("service name is required")
+	}
+	if c.Port <= 0 || c.Port > 65535 {
+		return fmt.Errorf("invalid port: %d", c.Port)
+	}
+	return nil
+}
+
+// 自动注册
+func init() {
+	Register("service", &ServiceConfig{})
+}

gct.sh

@@ -1,82 +1,14 @@
 #!/bin/bash
 
-# 脚本用法：./git-commit-and-tag.sh "你的提交描述" "版本号"
-
-# 检查参数数量
-if [ $# -ne 2 ]; then
-    echo "错误: 脚本需要2个参数。"
-    echo "用法: $0 \"提交描述\" \"版本号\""
-    echo "示例: $0 \"修复了登录问题\" \"v1.2.3\""
-    exit 1
-fi
-
-# 分配参数
-COMMIT_MESSAGE="$1"
-VERSION_TAG="$2"
-
-# 检查当前目录是否为Git仓库
-if ! git rev-parse --git-dir > /dev/null 2>&1; then
-    echo "错误: 当前目录不是一个Git仓库。"
-    exit 1
-fi
-
-echo "开始处理提交和版本标签..."
-echo "提交描述: $COMMIT_MESSAGE"
-echo "版本标签: $VERSION_TAG"
-
-# 检查是否有未提交的更改
-if [ -n "$(git status --porcelain)" ]; then
-    echo "检测到未提交的更改，正在提交..."
-    
-    # 添加所有更改到暂存区
-    git add .
-    
-    # 进行提交
-    git commit -m "$COMMIT_MESSAGE"
-    if [ $? -ne 0 ]; then
-        echo "错误: 提交失败。"
-        exit 1
-    fi
-    echo "✅ 更改已提交"
-else
-    echo "提示: 没有未提交的更改，跳过提交步骤"
-    
-    # 检查是否有未提交的commit但未推送
-    LOCAL_COMMITS=$(git log @{u}..HEAD --oneline 2>/dev/null | wc -l)
-    if [ $LOCAL_COMMITS -eq 0 ]; then
-        echo "错误: 没有需要推送的提交。"
-        exit 1
-    else
-        echo "检测到 $LOCAL_COMMITS 个本地提交等待推送"
-    fi
-fi
-
-# 检查标签是否已存在
-#if git rev-parse "$VERSION_TAG" >/dev/null 2>&1; then
- #   echo "错误: 标签 '$VERSION_TAG' 已经存在。"
-  #  exit 1
-#fi
-
-# 创建标签
-#git tag "$VERSION_TAG"
-#if [ $? -ne 0 ]; then
-#    echo "错误: 创建标签失败。"
-#    exit 1
-#fi
-#echo "✅ 标签 '$VERSION_TAG' 已创建"
-
-# 推送到远程仓库并推送标签
-echo "正在推送到远程仓库..."
-git push
-if [ $? -ne 0 ]; then
-    echo "错误: 推送提交失败。"
-    exit 1
-fi
-
-#git push origin "$VERSION_TAG"
-#if [ $? -ne 0 ]; then
-#    echo "错误: 推送标签失败。"
-#    exit 1
-#fi
-
-#echo "✅ 完成！提交已推送，版本标签 $VERSION_TAG 已创建并推送。"
+# 使用命令行参数，如果没有提供则使用默认值
+COMMIT_MSG="${1:-初始提交}"
+TAG_VERSION="${2:-v0.1.0}"
+
+echo "提交信息: $COMMIT_MSG"
+echo "标签版本: $TAG_VERSION"
+
+git add .
+git commit -m "$COMMIT_MSG"
+git push -u origin master
+git tag -s "$TAG_VERSION"
+git push origin "$TAG_VERSION"

go.mod

@@ -33,6 +33,7 @@ require (
 	github.com/pjbgf/sha1cd v0.5.0 // indirect
 	github.com/skeema/knownhosts v1.3.2 // indirect
 	github.com/stretchr/objx v0.5.2 // indirect
+	go.uber.org/multierr v1.10.0 // indirect
 )
 
 require (
@@ -61,6 +62,7 @@ require (
 	github.com/urfave/cli/v2 v2.27.7 // indirect
 	github.com/xanzy/ssh-agent v0.3.3 // indirect
 	github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 // indirect
+	go.uber.org/zap v1.27.1
 	golang.org/x/crypto v0.45.0 // indirect
 	golang.org/x/mod v0.30.0 // indirect
 	golang.org/x/net v0.47.0 // indirect
@@ -69,6 +71,7 @@ require (
 	golang.org/x/text v0.31.0 // indirect
 	golang.org/x/tools v0.39.0 // indirect
 	google.golang.org/protobuf v1.36.10 // indirect
+	gopkg.in/natefinch/lumberjack.v2 v2.2.1
 	gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 // indirect
 	gopkg.in/warnings.v0 v0.1.2 // indirect
 )

go.sum

@@ -186,6 +186,10 @@ github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 h1:FnBeRrxr7OU4VvAz
 github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342/go.mod h1:Ohn+xnUBiLI6FVj/9LpzZWtj1/D6lUovWYBkxHVV3aM=
 go-micro.dev/v4 v4.11.0 h1:DZ2xcr0pnZJDlp6MJiCLhw4tXRxLw9xrJlPT91kubr0=
 go-micro.dev/v4 v4.11.0/go.mod h1:eE/tD53n3KbVrzrWxKLxdkGw45Fg1qaNLWjpJMvIUF4=
+go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
+go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.27.1 h1:08RqriUEv8+ArZRYSTXy1LeBScaMpVSTBhCeaZYfMYc=
+go.uber.org/zap v1.27.1/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190923035154-9ee001bba392/go.mod h1:/lpIB1dKB+9EgE3H3cr1v9wB50oz8l4C4h62xy7jSTY=
@@ -246,6 +250,8 @@ gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
+gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST95x9zc=
+gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
 gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
 gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
 gopkg.in/warnings.v0 v0.1.2 h1:wFXVbFY8DY5/xOe1ECiWdKCzZlxgshcYVNkBHstARME=

types/types.go

@@ -18,17 +18,22 @@ type ExchangeRequest struct {
 
 // QueueRequest 创建队列的请求
 type QueueRequest struct {
-	ChannelName string            `json:"channel_name"`
-	QueueName   string            `json:"queue_name"`
-	Durable     bool              `json:"durable"`
-	Exclusive   bool              `json:"exclusive"`
-	AutoDelete  bool              `json:"auto_delete"`
-	NoWait      bool              `json:"no_wait"`
-	Arguments   map[string]string `json:"arguments"`
+	ChannelName  string `json:"channel_name"`
+	QueueName    string `json:"queue_name"`
+	Durable      bool   `json:"durable"`
+	Exclusive    bool   `json:"exclusive"`
+	AutoDelete   bool   `json:"auto_delete"`
+	NoWait       bool   `json:"no_wait"`
+	Url          string `json:"url"`
+	Concurrency  int    `json:"Concurrency"`
+	ExchangeName string `json:"exchange_name"`
+	RoutingKey   string `json:"routing_key"`
+
+	Arguments map[string]string `json:"arguments"`
 }
 
 // BindRequest 绑定队列的请求
-type BindRequest struct {
+type QueueBindRequest struct {
 	ChannelName  string            `json:"channel_name"`
 	QueueName    string            `json:"queue_name"`
 	ExchangeName string            `json:"exchange_name"`