标签: rabbitmq

RabbitMQ有任何消息优先级的概念吗？我有一个问题是一些更重要的消息由于在队列中排在它之前的不太重要的消息而变慢.我希望优先级高的优先级移动到队列的前面.

我知道我可以使用两个队列"快速"队列和"慢"队列来近似这个,但这似乎是一个黑客.

有没有人知道使用RabbitMQ更好的解决方案？

Web Dynos可以处理HTTP请求

当Web Dynos处理它们时,Worker Dynos可以处理它的作业.

但我不知道如何让Web Dynos和Worker Dynos相互沟通.

例如,我想通过Web Dynos接收HTTP请求

,发送给工人Dynos

,处理作业并将结果发送回Web Dynos

,在Web上显示结果.

在Node.js中这可能吗？(使用RabbitMQ或Kue等)？

我在Heroku文档中找不到一个例子

或者我应该在Web Dynos中实现所有代码并仅扩展Web Dynos吗？

是否有可能通过RabbitMQ发送消息有一些延迟？例如,我希望在30分钟后使客户端会话到期,并且我发送一条消息,该消息将在30分钟后处理.

与直接在RabbitMQ上构建相比,构建在MassTransit之上的好处是什么？

我相信MassTransit提供的一个好处是'类型'交换(通过接口/类型发布订阅),因此消息的内容是结构化的,与普通RabbitMQ交换相比,其中消息的内容是非结构化文本/ blob.

MassTransit还提供哪些其他好处？

我正在尝试创建一个订阅多个队列的消费者,然后在消息到达时处理它们.

问题是当第一个队列中已经存在某些数据时,它会占用第一个队列,而不会消耗第二个队列.但是,当第一个队列为空时,它会转到下一个队列,然后同时消耗这两个队列.

我首先实现了线程,但是想要避开它,当pika库为我做的时候没有太多的复杂性.以下是我的代码:

import pika

mq_connection = pika.BlockingConnection(pika.ConnectionParameters('x.x.x.x'))
mq_channel = mq_connection.channel()
mq_channel.basic_qos(prefetch_count=1)


def callback(ch, method, properties, body):
    print body
    mq_channel.basic_ack(delivery_tag=method.delivery_tag)

mq_channel.basic_consume(callback, queue='queue1', consumer_tag="ctag1.0")
mq_channel.basic_consume(callback, queue='queue2', consumer_tag="ctag2.0")
mq_channel.start_consuming()

我的开发环境中有成千上万条未包装的消息,我无法重启.
有没有办法删除(清除)所有邮件,即使它们未被确认？

我已经阅读了RabbitMQ提供的入门指南,甚至为stormed-amqp贡献了第六个例子,所以我对AMQP有了一些了解.

但是,该指南并不全面,可以避免身份验证和授权等问题.

我们正在设计一个多租户系统,它将在RPC类型的情况下使用RabbitMQ.RPC的这种实现可能有什么不同之处在于远程过程实际上是系统上的其他租户程序.

基本上,我想隔离数据总线,其中包括以下断言:

1. 我们的服务器不会将数据传送到错误的租户程序(这很容易处理并且相关但不受质疑).
2. 租户程序无法从不属于他们的队列中读取数据.
3. 租户程序无法写入不属于他们的队列.

这个问题严格关于RabbitMQ安全性.我知道RabbitMQ支持SSL,它提供端到端加密,我知道RabbitMQ支持用户名/密码验证.我不知道这些内容是否适用于私有化队列使用(也称为ACL),即连接可能是加密的,用户可能已经过验证,但用户可以从所有队列读取/写入.

有人可以在这个更高级的主题上启发我吗？我相信RabbitMQ可以支持这种系统但不完全正面.我知道RabbitMQ中有些东西我不知道,例如什么是虚拟主机,他们会在这种情况下帮助吗？我只是没有看到当前知识中的解决方案仅限于路由密钥,队列名称和交换.

使用NServiceBus比使用RabbitMQ的.net驱动程序有什么好处(假设我们可以用AMQP替换MSMQ).NSB是否提供AMQP中无法直接提供的任何其他功能或抽象.

您是否有任何指示如何确定订阅问题何时发生,以便重新连接？

我的服务使用RabbitMQ.Client.MessagePatterns.Subscription进行订阅.一段时间后,我的客户端默默地停止接收消息.我怀疑网络问题,因为我的VPN连接不是最可靠的.

我已经通过文档阅读了一段时间,寻找一个关键,以找出这个订阅何时可能由于网络问题而没有太多运气而被打破.我已经尝试检查连接和通道是否仍然打开,但似乎总是报告它仍处于打开状态.

它确实处理的消息工作得很好,并被确认回队列,所以我不认为这是"ack"的问题.

我确信我一定只是错过了一些简单的东西,但我还没有找到它.

public void Run(string brokerUri, Action<byte[]> handler)
{
    log.Debug("Connecting to broker: {0}".Fill(brokerUri));
    ConnectionFactory factory = new ConnectionFactory { Uri = brokerUri };

    using (IConnection connection = factory.CreateConnection())
    {
        using (IModel channel = connection.CreateModel())
        {
            channel.QueueDeclare(queueName, true, false, false, null);

            using (Subscription subscription = new Subscription(channel, queueName, false))
            {
                while (!Cancelled)
                {
                    BasicDeliverEventArgs args;

                    if (!channel.IsOpen)
                    {
                        log.Error("The channel is no longer open, but we are still trying to process messages.");
                        throw new InvalidOperationException("Channel is closed.");
                    } …

我正在尝试使用厨师聚集兔子

这是我的错误.我关闭了第二个节点上的所有兔子.

rabbitmqctl join_cluster --ram rabbit@ip-10-158-xxx-xxx

Error: mnesia_unexpectedly_running

那么......交易是什么？我从http://agiletesting.blogspot.com/2010/05/rabbitmq-clustering-in-ubuntu.html尝试了这个,这是删除/ var/lib/rabbitmq/mnesia.不行.在什么服务器上运行它不会运行？所有？

谢谢