redis作为消息队列的使用

1.生产者

使用循环模拟高并发操作

            RedisClient redisClient = new RedisClient("127.0.0.1", 6379);

            for(int i=0;i<10;i++)

            {

                string key = "map" + i;

                byte[] bytes= Encoding.UTF8.GetBytes(key);

                redisClient.RPush("MessageQuene", bytes);

            }

            redisClient.BgSave();

2.消费者

            RedisClient redisClient = new RedisClient("127.0.0.1", 6379);

            this.label1.Text = this.label1.Text + "," + System.Text.Encoding.Default.GetString(redisClient.LPop("MessageQuene"));

可以把消费者代码，写在windows服务中，定时处理