.net core怎样行使Redis宣布订阅

Redis是一本机能很是强劲的内存数据库，它一样平常是作为缓存来行使，可是他不只仅可以用来作为缓存，好比闻名的漫衍式框架dubbo就可以用Redis来做处事注册中心。接下来先容一下.net core 行使Redis的宣布/订阅成果。

Redis 宣布订阅

Redis 宣布订阅(pub/sub)是一种动静通讯模式：发送者(pub)发送动静，订阅者(sub)吸取动静。
Redis 客户端可以订阅恣意数目的通道。

下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 ―― client2 、 client5 和 client1 之间的相关：

当有新动静通过 PUBLISH 呼吁发送给频道 channel1 时， 这个动静就会被发送给订阅它的三个客户端：

行使Redis呼吁

起首，通过subscribe redismessage呼吁使两个客户端订阅redismessage通道：

然后再打开一个Redis客户端，行使呼吁publish redismessage "动静内容"宣布动静

行使.net core 实现

这里我选择的毗连驱动为 StackExchange.Redis，这里必要留意的是 ServiceStack.Redis毗连驱动已经逐渐贸易化，4.0及以上版本都具有限定，以是选择的免费且好用的StackExchange.Redis，行使nuget安装即可。

成立订阅客户端

//建设毗连
using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("127.0.0.1:6379"))
{
  ISubscriber sub = redis.GetSubscriber();

  //订阅名为 messages 的通道

  sub.Subscribe("messages",(channel,message) => {

    //输出收到的动静
    Console.WriteLine($"[{DateTime.Now:HH:mm:ss}] {message}");
  });
  Console.WriteLine("已订阅 messages");
  Console.ReadKey();
}

成立宣布客户端

//建设毗连
using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("127.0.0.1:6379"))
{
  ISubscriber sub = redis.GetSubscriber();

  Console.WriteLine("请输入恣意字符，输入exit退出");

  string input;

  do
  {
    input = Console.ReadLine();
    sub.Publish("messages",input);
  } while (input != "exit");
}

下面运行了一个宣布客户端，两个订阅客户端：

Demo下载

以上就是本文的所有内容，但愿对各人的进修有所辅佐，也但愿各人多多支持编程小能力。

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!