IRedisClient redis = RedisServiceConfig.Default.GetClient();
const string channels = "Channel-1";
//发布
redis.PublishMessage(channels, "Leon Test");
//订阅
IRedisSubscription sub = redis.CreateSubscription();
//接受到消息时的委托
sub.OnMessage = (channelStr, msg) =>
{
Console.WriteLine("OnMessage的channel=" + channelStr + ",msg:" + msg);
if (msg.Equals("unsub"))
{
sub.UnSubscribeFromChannels(channelStr);
}
};
sub.OnSubscribe = channelStr =>
{
Console.WriteLine("OnSubscribe的channel=" + channelStr);
};
sub.OnUnSubscribe = channelStr =>
{
Console.WriteLine("OnUnSubscribe的channel=" + channelStr + ",订阅取消成功!");
};
sub.SubscribeToChannels(channels);
参考
https://blog.csdn.net/qq_34609268/article/details/85091165
