在 Go 中使用 RabbitMQ 消费消息时，可以通过设置消费者的优先级来决定消费者处理消息的顺序。具体实现方法如下：
- 在创建队列时，设置队列的最大优先级（x-max-priority），例如：
args := make(amqp.Table)
args["x-max-priority"] = 10 // 设置队列最大优先级为 10
_, err := ch.QueueDeclare(
"queue-name", // 队列名字
true, // 是否持久化
false, // 是否自动删除
false, // 是否独占模式
false, // 是否等待连接关闭后自动删除
args, // 队列参数
)
- 发布消息时，指定消息的优先级（priority），例如：
msg := amqp.Publishing{
Body: []byte("hello"),
Priority: 5, // 设置消息优先级为 5
}
err = ch.Publish(
"", // exchange 名称，此处为空字符串表示使用默认交换机
"queue-name",// routing key 或 queue name，根据情况填写
false, // 是否必须路由到一个匹配的队列中，false 表示不强制要求，默认值为 true。
// 如果没有找到匹配的队列，则会将该消息返回给生产者。
// 生产者可以选择重新发布该消息或抛弃该消息。
// 注意：如果此处填写了 routing key，则不能将 mandatory 设为 false。
false,
msg,
)
- 创建消费者时，设置消费者的优先级（priority），例如：
msgs, err := ch.Consume(
"queue-name", // 队列名字
"", // 消费者标识符，为空字符串表示由 RabbitMQ 自动生成一个唯一标识符
false, // 是否将 auto-ack 设置为 true，如果设置为 true，则消息会在被接收到的时候自动确认。否则需要手动调用 Ack 方法进行确认。
false, // 是否独占模式，true 表示只有当前连接可以使用该队列，false 表示多个连接可以使用同一个队列。
false, // 是否等待连接关闭后自动删除队列
false, // 其他属性
amqp.Table{
"x-priority": 5, // 设置消费者优先级为 5
},
)
通过上述步骤，就可以实现 RabbitMQ 消息优先级的设置和使用了。
