Redis 隊列操作

 class Program
    {
        //版本2：使用Redis的客戶端管理器（對象池）
        public static IRedisClientsManager redisClientManager = new PooledRedisClientManager(new string[]
        {
            //如果是Redis集群則配置多個{IP地址:端口號}即可
            //例如: "10.0.0.1:6379","10.0.0.2:6379","10.0.0.3:6379"
            "127.0.0.1:6379"
        });

        //從池中獲取Redis客戶端實例
        public static IRedisClient redisClient = redisClientManager.GetClient();



        static void Main(string[] args)
        {
            RedisClient client = new RedisClient("127.0.0.1", 6379);

            for (int i = 0; i < 1000; i++)
            {
                //將異常信息入隊
                redisClient.EnqueueItemOnList("ExceptionLog", i.ToString());
                //  var query = client.Increment("zizeng", 3);

                Console.WriteLine("進入隊列的值:" + i.ToString());
            }

            while (true)
            {

                if (redisClient.GetListCount("ExceptionLog") > 0)
                {
                    //從隊列中出隊，獲取異常對象
                    string errorMsg = redisClient.DequeueItemFromList("ExceptionLog");
                    Console.WriteLine("取出的隊列:" + errorMsg);
                }
            }

            Console.ReadKey();
        }
    }