为何Go语言中RabbitMQ的PublishWithContext无法正常工作？

先排查代码中的显性问题 #

你的代码逻辑和官方教程一致，但几个关键问题会直接导致报错：

1. 缺失关键步骤的错误检查
   你提到“已处理错误”但代码中未体现，amqp.Dial、conn.Channel()、ch.QueueDeclare这三步只要有一步失败（比如RabbitMQ未启动、端口错误、凭据无效），后续调用ch.PublishWithContext都会因为连接/通道异常报错。必须在每一步后立刻检查错误：

   conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
   if err != nil {
       return nil, fmt.Errorf("connect to rabbitmq failed: %w", err)
   }
   
   ch, err := conn.Channel()
   if err != nil {
       conn.Close() // 连接成功后需清理资源
       return nil, fmt.Errorf("open channel failed: %w", err)
   }
   
   q, err := ch.QueueDeclare(
       "hello", // name
       false,   // durable
       false,   // delete when unused
       false,   // exclusive
       false,   // no-wait
       nil,     // arguments
   )
   if err != nil {
       ch.Close()
       conn.Close()
       return nil, fmt.Errorf("declare queue failed: %w", err)
   }
   

2. 未捕获并返回PublishWithContext的具体错误
   你需要明确返回或打印该方法的错误信息，才能定位具体问题（比如连接断开、通道关闭、超时等）：

   err = ch.PublishWithContext(
       ctx,    // context
       "",     // exchange
       q.Name, // routing key
       false,  // mandatory
       false,  // immediate
       amqp.Publishing{
           ContentType: "text/plain",
           Body:        []byte(body),
       })
   if err != nil {
       ch.Close()
       conn.Close()
       return nil, fmt.Errorf("publish message failed: %w", err)
   }
   

3. 资源泄漏问题
   你的RabbitMQ结构体没有保存连接和通道实例，后续无法关闭资源，可能导致连接堆积引发RabbitMQ侧错误。建议修改结构体：

   type RabbitMQ struct {
       Conn  *amqp.Connection
       Ch    *amqp.Channel
       Queue amqp.Queue
   }
   
   // 初始化时赋值
   return &RabbitMQ{Conn: conn, Ch: ch, Queue: q}, nil
   

Go 1.19版本兼容性说明 #

你使用的amqp091-go库完全支持Go 1.18及以上版本，Go 1.19不是报错的直接原因。但需确保依赖安装正确，执行go mod tidy拉取最新兼容版本，避免依赖冲突。

后续排查步骤 #

• 确认本地RabbitMQ服务正在localhost:5672端口运行，guest/guest凭据有效。
• 查看RabbitMQ日志文件，检查是否有连接拒绝、权限错误等服务端日志。
• 补全错误处理后，运行程序查看具体错误信息，再针对性解决。

内容的提问来源于stack exchange，提问作者rc07jnr