loks666/go-wxhelper
1
0
Fork 0
forked from lxh/go-wxhelper
Code Pull Requests Activity

Merge pull request 'hotfix' (#33) from hotfix into main

Browse Source 
Reviewed-on: lxh/go-wxhelper#33
This commit is contained in:
李寻欢 2024-03-22 23:07:45 +08:00
commit 22c7d3683b
3 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
config.yaml
View File

@ -37,6 +37,8 @@ task:
# MQ配置 # MQ配置
mq: mq:
# 是否启用
enable: false
# RabbitMQ配置 # RabbitMQ配置
rabbitmq: rabbitmq:
host: 10.0.0.247 host: 10.0.0.247

1
config/mq.go
View File

@ -5,6 +5,7 @@ import "fmt"
// mq // mq
// @description: MQ配置 // @description: MQ配置
type mq struct { type mq struct {
Enable bool `json:"enable" yaml:"enable"` // 是否启用
RabbitMQ rabbitMq `json:"rabbitmq" yaml:"rabbitmq"` // RabbitMQ配置 RabbitMQ rabbitMq `json:"rabbitmq" yaml:"rabbitmq"` // RabbitMQ配置
} }

4
mq/rabbitmq.go
View File

@ -16,6 +16,10 @@ const exchangeName = "wechat-message"
// Init // Init
// @description: 初始化MQ // @description: 初始化MQ
func Init() { func Init() {
if !config.Conf.Mq.Enable {
log.Println("未启用MQ")
return
}
// 读取MQ连接配置 // 读取MQ连接配置
mqUrl := config.Conf.Mq.RabbitMQ.GetURL() mqUrl := config.Conf.Mq.RabbitMQ.GetURL()
if mqUrl == "" { if mqUrl == "" {