rabbitmqutil

type BasePool[T any] struct {
	Pool *sync.Pool
	//用于创建新对象的函数
	NewFunc func() *T
	Mtx     sync.Mutex
	Cap     int
}

type MessageAttribute struct {
	//消息要投入的交换机名称
	ExchangeName string
	//路由键
	RouteKey string
	//消息ID
	MsgID string
	//消息类型
	MsgType string
	//载荷
	Payload []byte
	//创建时间
	CreateAt time.Time
}

type NewFuncCallBack[T any] = func() *T

type Option = func(r *RabbitMqClientManager)

type PoolOption[T any] = func(c *BasePool[T])

type RabbitMqClient struct {
	Channel        *amqp091.Channel // 非协程安全
	CheckHandler   on_check_handler //处理消息前的检查回调函数
	MessageHandler on_message_handler
	//当ack成功后触发的回调函数
	OnAckedHandler on_acked_handler
	//由客户端管理器注入
	Config *RabbitmqConfig
}

type RabbitMqClientManager struct {
	// 内部是协程安全的
	Conn *amqp091.Connection
	// 连接异常时触发的用户自定义回调
	ExceptionHandler on_exception_handler_t
	// Channel池
	Pool *BasePool[RabbitMqClient]
	// 外部传入的处理路由失败的return回调
	OnReturnHandler on_return_handler
	//消息触发时调用的回调函数
	OnMessageHandler on_message_handler
	//ack成功后触发的回调函数
	OnAckedHandler on_acked_handler
	//调用MessageHandler前触发的回调函数
	CheckHandler on_check_handler
	//rabbitmq客户端配置信息
	Config *RabbitmqConfig
	Locker sync.Mutex
	//是否健康
	IsHealthy atomic.Bool
	//重连次数,默认3次
	RetryCounts int
	Logger      RabbitmqLogger
}

type RabbitmqConfig struct {
	Address             string
	User                string
	AccessKey           string
	VirtualHostName     string
	NormalExchangeName  string
	NormalQueueName     string
	NormalQueueRouteKey string
	DieExchangeName     string
	DieQueueName        string
	DieQueueRouteKey    string
	MessageTTL          int64
	ConsumerName        string
	MaxClientCnts       int
}

type RabbitmqLogger interface {
	Debug(expand *map[string]any, format string)
	Info(expand *map[string]any, format string)
	Error(expand *map[string]any, format string)
}