使用RabbitMQ在公共交通中竞争消费者

Question

我已经使用MassTransit实现了一个简单的发布者/消费者集合,我想让消费者从同一个队列中读取消息.但是,当我运行它时,我看到很大一部分消息被发送到错误队列而不是被消耗.从我所见过的讨论(SO,论坛),这应该是非常简单的RabbitMQ(只是指向相同的队列),但它不起作用.是否应该设置其他配置？

这是我的发布者

public class YourMessage { public string Text { get; set; } }
public class Program
{
    public static void Main()
    {
        Console.WriteLine("Publisher");
        Bus.Initialize(sbc =>
        {
            sbc.UseRabbitMqRouting();
            sbc.ReceiveFrom("rabbitmq://localhost/test_queue");
        });
        var x = Console.Read();
        for (var i = 0; i <= 1000; i++)
        {
            Console.WriteLine("Message Number " + i);
            Bus.Instance.Publish(new YourMessage { "Message Number " + i });
        }
    }
}

而我的消费者

public class YourMessage { public string Text { get; set; } }
public class Program
{
    public static void Main()
    {
        Console.WriteLine("Consumer");
        Bus.Initialize(sbc =>
        {
            sbc.UseRabbitMqRouting();
            sbc.ReceiveFrom("rabbitmq://localhost/test_queue");
            sbc.Subscribe(subs =>
            {
                var del = new Action<IConsumeContext<YourMessage>,YourMessage>((context, msg) =>
                {
                    Console.WriteLine(msg.Text);
                });
                subs.Handler<YourMessage>(del);
            });
        });
        while (true) { }
    }
}

Answer 1

接收者/消费者和发布者不能在同一队列中.如果您希望竞争消费者有多个消费者实例针对同一队列运行.

我们有文档,但是这部分目前还没有,所以我理解你的困惑:http://readthedocs.org/docs/masstransit/en/latest/configuration/gotchas.html#how-to-setup-a-competing-consumer如果你成功了,那么文档的帮助就会很棒.