redis处理数据问题

我印象中Redis的众多数据类型中，并没有队列(Queue)的数据类型,Redis的数据类型有：string(字符串),Hash(哈希)，List(列表)，Set(集合)，有序集合(Sorted Set)。

如果你仅仅想生成订单号(OrderSn),可以提前生成好Sn号并入队，然后存储在Redis缓存里。

例如：

            // 伪代码

 

            Queue<string> snQueue = null // 订单号Sn队列

            string sn = Redis.Get("OrderSn")

            string curSn = string.Empty

            if(String.IsNullOrWhiteSpace(sn)){

                snQueue = new Queue<string>()

                for (int i = 0 i < 30000 i++) // 假定 双11，每秒3万订单

                {

                    // 提前分配好订单Sn号   入队

                    snQueue.Enqueue(DateTime.Now.ToString("yyyMMdd") + i)

                }

                curSn = snQueue.Dequeue() // 出队

                Redis.Set("OrderSn", JsonConvert.SerializeObject(snQueue))

            }

            else

            {

              snQueue=JsonConvert.DeserializeObject<Queue<string>>(sn)

              curSn = snQueue.Dequeue() // 出队

              Redis.Set("OrderSn", JsonConvert.SerializeObject(snQueue))// 重新放入Redis缓存

            }

添加空key可以到redis。最近把 AirNet 中的空气质量排行换成了用 Zset 实现，这篇笔记就来深入了解下 Zset 的底层实现原理。在通过 ZADD 命令添加第一个元素到空 key 时， Redis 会通过检查输入的第一个元素来决定使用何种编码。如果第一个元素符合以下条件的话， 就创建一个 REDIS_ENCODING_ZIPLIST 编码的 Zset：服务器属性server.zset_max_ziplist_entries 的值大于 0 (默认为 128 )。元素的 member 长度小于服务器属性 server.zset_max_ziplist_value 的值(默认为 64 )。所以，添加空key可以到redis。

使用消息中间件的时候，并非每次都需要非常专业的消息中间件，假如只有一个消息队列，只有一个消费者，那就没有必要去使用专业的消息中间件，这种情况可以直接使用 Redis 来做消息队列。

Redis 的消息队列不是特别专业，他没有很多高级特性，适用简单的场景，如果对于消息可靠性有着极高的追求，那么不适合使用 Redis 做消息队列。

Redis 做消息队列，使用它里边的 List 数据结构就可以实现，使用 lpush/rpush *** 作来实现入队，然后使用 lpop/rpop 来实现出队。

在客户端（例如 Java 端），我们会维护一个死循环来不停的从队列中读取消息，并处理，如果队列中有消息，则直

接获取到，如果没有消息，就会陷入死循环，直到下一次有消息进入，这种死循环会造成大量的资源浪费，这个时候，

可以使用之前讲的 blpop/brpop 。

blpop 阻塞式的d出，相当于 lpop 的阻塞版。

延迟队列可以通过 zset 来实现，因为 zset 中有一个 score，我们可以把时间作为 score，将 value 存到redis 中，然后通过轮询的方式，去不断的读取消息出来。

首先，如果消息是一个字符串，直接发送即可，如果是一个对象，则需要对对象进行序列化，这里我们

使用 JSON 来实现序列化和反序列化。

首先在项目中，添加 JSON 依赖：

接下来，构造一个消息对象：

接下来封装一个消息队列：

测试：

---