C#はredisでメッセージキューを実現する.net core
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();
}
}
}