因为支持RabbitMQ版本3.5.0优先级队列- https://www.rabbitmq.com/priority.html
如果在队列创建过程中传递了x优先级参数,则可以声明队列。
我可以成功地声明一个具有优先级支持的队列。
brkrSub := broker.NewSubscribeOptions(
broker.DisableAutoAck(),
rabbitmq.QueueArguments(map[string]interface{}{"x-max-priority": 10}),
)
service.Server().Subscribe(
service.Server().NewSubscriber(
"mytopic",
h.Handle,
server.SubscriberQueue("mytopic.hello"),
server.SubscriberContext(brkrSub.Context),
),
)但是,如何发布指定优先级的消息呢?
body := &message.MyTestMessage{
Message: fmt.Sprintf("Message number %d", counter),
}
msg := client.NewMessage(
topic,
body,
// TODO: Priority
)
if err := client.Publish(ctx, msg); err != nil {
fmt.Printf("Cannot publish message: ", err.Error())
return
}我找不到像MessageOption或PublishOption那样直接传递优先级的方法,但是,似乎有一种方法可以在client.Publish上下文中指定其他选项。我是否在寻找正确的方向,如果是的话,你能帮我一点吗?
编辑:我能够在不引起任何编译时错误的情况下执行以下操作。但是,优先级仍然被忽略,消息以通常的方式出现。
func setPriority(ctx context.Context, priority int) client.PublishOption {
return func(o *client.PublishOptions) {
o.Context = context.WithValue(ctx, "priority", priority)
}
}
func publish(ctx context.Context, priority int, counter int) {
//body := fmt.Sprintf("hello, I am a message %d", counter)
body := &message.MyTestMessage{
Message: fmt.Sprintf("Message number %d", counter),
}
msg := client.NewMessage(
topic,
body,
)
if err := client.Publish(ctx, msg, setPriority(ctx, priority)); err != nil {
fmt.Printf("Cannot publish message: ", err.Error())
return
}
fmt.Printf("Published message %d to %s \n", counter, topic)
}发布于 2020-03-12 14:05:12
试着做这样的事:
func publishMessageToChan(queue *amqp.Queue, channel *amqp.Channel, messageToQueue string) error {
return channel.Publish(
"<exchange>", // exchange
"<queue>", // routing key
false, // mandatory
false, // immediate
amqp.Publishing{
Timestamp: time.Now(),
ContentType: "text/plain",
Body: []byte(messageToQueue),
Priority: 0, // <-- Priority here < 0 to 9>
})
}图书馆"github.com/streadway/amqp“
发布于 2021-04-16 09:58:29
var brokerOpts broker.PublishOptions
rabbitmq.Priority(uint8(10))(&brokerOpts)
event.Publish(ctx, payload, client.PublishContext(brokerOpts.Context))https://stackoverflow.com/questions/60652897
复制相似问题