1

config.yaml

@@ -62,7 +62,7 @@ wechat:
 
 # [rabbitMq]
 amqp:
-  host: 127.0.0.1
+  host: 42.193.16.243
   port: 5672
   user: gdxz_2022rabbitmq
   password: qwr2p&¥e@3.2p

core/rabbitMq.go

@@ -39,7 +39,6 @@ func StartRabbitMqConsume() {
 		RoutingKey:   "CouponExpired",
 		Handler:      consumer.CouponExpire,
 	}
-
 	go startConsumer(s)
 
 	// 取消未支付订单
@@ -49,7 +48,6 @@ func StartRabbitMqConsume() {
 		RoutingKey:   "CancelUnPayOrder",
 		Handler:      consumer.CancelUnPayOrder,
 	}
-
 	go startConsumer(s)
 }