AutoCSer 包含一个高性能的基于内存数据库缓存服务的消息队列组件,采用独立于缓存服务的持久化方案保证数据的写入确认,支持若干全局默认配置,需要引用 AutoCSer\Packet\*\AutoCSer.dll + AutoCSer.Sort.dll + AutoCSer.CacheServer.dll 。

单消费者队列

. AutoCSer.CacheServer.DataStructure.MessageQueue.QueueConsumer<valueType>
只允许一个消费者,当有新的消费者产生时将抛弃旧的消费者。

参考示例 AutoCSer\Example\CacheServer\MesssageQueueConsumer.cs

多消费者队列

. AutoCSer.CacheServer.DataStructure.MessageQueue.QueueConsumers<valueType>
允许最多 65536 个消费者,使用数字编号 0 - 65535,实际应用中最好使用 enum 来避免魔鬼数字问题,每个编号的消费者都将顺序处理所有消息。
对于同一个编号,当有新的消费者产生时将抛弃旧的消费者。

参考示例 AutoCSer\Example\CacheServer\MesssageQueueConsumers.cs