消息队列 NewLife.MQ

NewLife.MQ 是一个消息队列组件，可提供广播和集群两大消费模式。

public static async Task Main2()
{
    var host = new MQHost();
    host.Log = XTrace.Log;
    host.Tip = true;

    host.Subscribe("aaa", "ttt", null, OnMessage);
    host.Subscribe("bbb", "ttt", "t1||t2", OnMessage);
    host.Subscribe("ccc", "ttt", "t1||t3", OnMessage, 111);
    host.Subscribe("ccc", "ttt", "t1||t3", OnMessage, 222);

    var tags = "t1,t2,t3,t4".Split(",");
    for (int i = 0; i < 1000; i++)
    {
        Console.WriteLine();
        host.Send("大石头", "ttt", tags[Rand.Next(tags.Length)], Rand.NextString(16));
        Thread.Sleep(1000);
    }
}

static async Task OnMessage(Subscriber sb, Message m)
{
    await Task.Delay(Rand.Next(200));
    XTrace.WriteLine("{0}=>{3} [{1}]: {2} {4}", m.Sender, m.Tag, m.Content, sb.Host.User, sb.User);
}

主要术语：

• MQHost 消息队列主机，管理多主题的订阅和发布
• Topic 主题队列，每个主题有一个队列用于缓冲保存消息，同时记录多个消费者
• Consumer 消费者，发布到主题的消息，会广播给各个消费者。多个订阅者构成消费者集群，消息只推送给其中一个订阅者。
• Subscriber 订阅者，使用相同消费者标识的不同来源，视为不同订阅者，比如同一个消费者账号的不同网络连接。