Go RabbitMQ 协程使用 conn.Channel() 报错：channel/connection is not open 解决方法

这个错误通常是因为在使用协程时，可能会发生竞态条件，导致连接未打开就尝试打开通道。

为了解决这个问题，可以使用锁来确保在打开通道之前连接已经打开。以下是示例代码：

import threading

lock = threading.Lock()

def create_channel(conn):
    with lock:
        if not conn.is_open:
            conn.connect()
        return conn.channel()

在这个示例中，我们使用了一个锁来确保连接在打开通道之前已经打开。如果连接未打开，我们就先打开连接，然后再打开通道。

你可以根据自己的需要修改这个代码，并根据你的具体情况选择适当的锁来解决竞态条件问题。