## 消息队列 NewLife.MQ NewLife.MQ 是一个消息队列组件，可提供广播和集群两大消费模式。 ```csharp 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` 订阅者，使用相同消费者标识的不同来源，视为不同订阅者，比如同一个消费者账号的不同网络连接。