求助（附代码）:rabbitmq:Exception (504) Reason: "channel/connection is not open"

这是测试生产者 **代码** ``` func Send(queueName string, msg interface{}) error { if ch == nil { if err := InitRabbitmq(Url); err != nil { log.Println(err) return err } } _, err := ch.QueueDeclarePassive(queueName, true, false, false, true, nil) if err != nil { q, err = ch.QueueDeclare(queueName, true, false, false, false, nil) if err != nil { log.Println(err) return err } } data, err := json.Marshal(msg) if err != nil { return err } count++ log.Println(q, count) err = ch.Publish(queueName, q.Name, false, false, amqp.Publishing{ ContentType: "application/json", Body: data, }) if err != nil { log.Println(err) return err } return nil } ``` ``` func InitRabbitmq(url string) error { var ( err error ) conn, err = amqp.Dial(url) if err != nil { log.Println("Failed to connect to RabbitMq") return err } ch, err = conn.Channel() if err != nil { defer conn.Close() log.Println("Failed to open a channel") return err } mqsync.Lock() defer mqsync.Unlock() q, err = ch.QueueDeclare("hello_world", true, false, false, false, nil) if err != nil { log.Println("Failed to declare queue:", err.Error()) return err } log.Println("rabbitmq init ok!") return nil } ``` ``` var Url = `amqp://guest:guest@0.0.0.0:5672/` func main(){ log.SetFlags(log.Lshortfile) err := InitRabbitmq(Url) if err != nil { log.Println(err) } go func(){ data :=map[string]interface{}{ "1":hello, } for { err := Send(data) if err != nil { log.Println(err) } time.Sleep(1 * time.Second) } } go func(){ data :=map[string]interface{}{ "2":world, } for { err := Send(data) if err != nil { log.Println(err) } time.Sleep(1 * time.Second) } } select {} } ``` **问题：**  **错误信息**  **分析** >测试发现不是消费者好着，通过再次启动此程序发现 询问还有其他问题影响吗？