C#はredisでメッセージキューを実現する.net core

1007 ワード

nugetにCSRedisCoreコンポーネントをインストールする
using CSRedis;
using System;

namespace ConsoleAppTestRedisQueue
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionStr = "192.168.31.42:6380,password=pisenmaster,defaultDatabase=5,poolsize=50,ssl=false,writeBuffer=10240";
            var redisClient = new CSRedisClient(connectionStr);
            //redisClient.Set("K100", "   ",30);  
            for (int i = 0; i < 10; i++)
            {
                //    
                redisClient.LPush("K200", "   " + i);
            }
          
            //    ,  
            while (true)
            {
                string value = redisClient.RPopLPush("K200", "K200_destination");
                if (value != null)
                {
                    Console.WriteLine("      :"+value);
                }
            }
            Console.ReadKey();
        }
    }
}