关闭资源

rabbitmq.go

@@ -31,6 +31,7 @@ func (r *rabbitmq) Publish(exchangeName, msg string, delay ...int64) error {
 	if err != nil {
 		return err
 	}
+	defer ch.Close()
 	header := amqp.Table{}
 	if len(delay) > 0 && delay[0] > 0 {
 		header["x-delay"] = delay[0] * 1000