c# - 如何准备一个推送和弹出到 redis 队列的控制台应用程序？

Question

我需要准备一个包含 3 个按钮的控制台应用程序，一个用于将元素添加到 Redis 队列，一个用于从队列中弹出元素，一个用于显示队列中的元素。我是 C# 和 Redis 的新手。谁能帮我解决这个问题，或者给我一些资源。

我已经编写了与 Redis 数据库的连接，并且能够设置和获取变量。

using System;
using StackExchange.Redis;
namespace RedisConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            ConnectionMultiplexer redisCon = ConnectionMultiplexer.Connect("localhost");
            IDatabase db = redisCon.GetDatabase();
            //db.Lis
            db.StringSet("foo", "dog");
            string val = db.StringGet("foo");
            Console.WriteLine("output is {0}", val);
            Console.ReadKey(); 
        }
    }
}

Answer 1

像那样写一个 channel 订阅者

public class RedisHostingRunner : HostedService
{
    private readonly IServiceProvider _serviceProvider;
    IRedisSubscriber _subscriber;

    public RedisHostingRunner(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
        _subscriber = _serviceProvider.GetRequiredService<RedisSubscriber>();
    }

    protected override async Task ExecuteAsync(CancellationToken cancellationToken)
    {
        //while (!cancellationToken.IsCancellationRequested)
        //{
            _subscriber.SubScribeChannel();
            //await Task.Delay(TimeSpan.FromSeconds(60), cancellationToken);
        //}
    }

    public Task ShutdownAsync(CancellationToken cancellationToken = default)
    {
        return Task.CompletedTask;
    }
}

然后在您的订阅者中设置一个消息处理程序

    public void SubScribeChannel()
    {
        _logger.LogInformation("!SubScribeChannel started!!");

        string channelName = _config.ActiveChannelName;
        var pubSub = _connectionMultiplexer.GetSubscriber();
        try
        {
            pubSub.Subscribe(channelName, async (channel, message) => await MessageActionAsync(message, channel));
        }
        catch(Exception ex)
        {
            _logger.LogInformation(String.Format("!error: {0}", ex.Message));
        }
        Debug.WriteLine("EOF");
    }

在你的处理程序中做你的工作

    private async Task MessageActionAsync(RedisValue message, string channel)
    {
        try
        {
            Transformer t = new Transformer(_logger);
            _logger.LogInformation(String.Format("!SubScribeChannel message received on message!! channel: {0}, message: {1}", channel, message));
            string transformedMessage = Transformer.TransformJsonStringData2Message(message);
            List<Document> documents = Transformer.Deserialize<List<Document>>(transformedMessage);

            await MergeToMongoDb(documents, channel);
            _logger.LogInformation("!Merged");
        }
        catch (Exception ex)
        {
            _logger.LogInformation(String.Format("!error: {0}", ex.Message));
        }
    }