gocommon/pkg/mq/rocketmq/producer.go

package rocketmq

import "git.shuncheng.lu/bigthing/gocommon/pkg/conf"

// Global 对象
var (
	_producer *rocketMqProducer
)

// 获取Consumer(程序启动后使用)
func GetProducer() Producer {
	//if _producer == nil {
	//	return nil, errors.New("rocket-mq producer is nil, please boot init rocket-mq producer")
	//}
	return _producer
}

// 初始化
func InitProducer() error {
	config, err := GetRocketMQConfig(ProducerMQ, conf.MustValue)
	if err != nil {
		return err
	}
	initLogger(config)
	con, err := newProducer(config.ToProducerConfig()...)
	if err != nil {
		return err
	}
	_producer = con
	return nil
}