首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Go-micro兔子mq插件-优先发布消息

Go-micro兔子mq插件-优先发布消息
EN

Stack Overflow用户
提问于 2020-03-12 11:11:00
回答 2查看 410关注 0票数 1

因为支持RabbitMQ版本3.5.0优先级队列- https://www.rabbitmq.com/priority.html

如果在队列创建过程中传递了x优先级参数,则可以声明队列。

我可以成功地声明一个具有优先级支持的队列。

代码语言:javascript
复制
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),
        ),
    )

但是,如何发布指定优先级的消息呢?

代码语言:javascript
复制
    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上下文中指定其他选项。我是否在寻找正确的方向,如果是的话,你能帮我一点吗?

编辑:我能够在不引起任何编译时错误的情况下执行以下操作。但是,优先级仍然被忽略,消息以通常的方式出现。

代码语言:javascript
复制
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)
}
EN

回答 2

Stack Overflow用户

发布于 2020-03-12 14:05:12

试着做这样的事:

代码语言:javascript
复制
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“

票数 0
EN

Stack Overflow用户

发布于 2021-04-16 09:58:29

代码语言:javascript
复制
var brokerOpts broker.PublishOptions
rabbitmq.Priority(uint8(10))(&brokerOpts)

event.Publish(ctx, payload, client.PublishContext(brokerOpts.Context))
票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/60652897

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档