与sider-redis C#客户端一起使用发布/订阅

Question

我正在使用Sider C#Redis客户端连接到运行在我的Windows7机器上的Redis服务器。https://github.com/chakrit/sider

我可以从我的C#应用程序中设置/获取/选择

我现在想使用发布/订阅功能，这样我的C#应用程序就可以通过事件方式（通过委托）了解redis客户端"密钥"的任何更改

我无法为此编写代码，因为没有关于如何使用sider客户端页面的示例。

我能写的只有这个：

var client = new RedisClient(address, 6379);
string[] keys = new string[1];
keys[0] = "key1ToMonitor";
IObservable<Message<string>> obb = client.Subscribe(keys);

我知道这看起来很蹩脚，但我不知道如何用lambda方式编写它，如果任何客户端更改redis服务器上所需的键，就会调用我的函数。

附言：我是新手，所以如果我的方法有缺陷，请纠正我。

编辑：在添加建议的更改时，我收到以下错误。

Error   7   Cannot convert lambda expression to type 'System.IObserver<Sider.Message<string>>' because it is not a delegate type    D:_WorkTestAppProgram.cs 90  27  TestApp

obb.subscribe签名看起来像这个

namespace System
{
    // Summary:
    //     Defines a provider for push-based notification.
    //
    // Type parameters:
    //   T:
    //     The object that provides notification information.This type parameter is
    //     covariant. That is, you can use either the type you specified or any type
    //     that is more derived. For more information about covariance and contravariance,
    //     see Covariance and Contravariance in Generics.
    public interface IObservable<out T>
    {
        // Summary:
        //     Notifies the provider that an observer is to receive notifications.
        //
        // Parameters:
        //   observer:
        //     The object that is to receive notifications.
        //
        // Returns:
        //     The observer's interface that enables resources to be disposed.
        IDisposable Subscribe(IObserver<T> observer);
    }
}

代码：

        var client = new RedisClient(address, 6379);
        string[] keys = new string[1];
        keys[0] = "key1ToMonitor";
        IObservable<Message<string>> obb = client.Subscribe(keys);
        obb.Subscribe(x => Debug.WriteLine(x.ToString()) ); // error : doesn't let me compile  

Answer 1

您需要订阅生成的实际可观察对象。类似这样的东西：

obb.Subscribe(x => Debug.WriteLine(x.ToString()));

不要忘记添加using System.Reactive.Linq;以获得将lambda转换为观察器所需的扩展。