c#之redis發布訂閱

1、使用框架.NET Core3.1 創建控制台應用程序
2、導入包NuGet包StackExchange.Redis
3、添加配置信息

    <!--redis配置-->
    <add key="Data_redis" value="true"/>
    <add key="redis_IP" value="127.0.0.1"/>
    <add key="redis_Password" value="123"/>
    <add key="redis_Port" value="12345"/>
    <add key="redis_Passageway" value="8888"/>

4、根據配置信息創建連接

    string redis_IP = ConfigurationManager.AppSettings["redis_IP"];
    string redis_Port = ConfigurationManager.AppSettings["redis_Port"];
    string redis_Password = ConfigurationManager.AppSettings["redis_Password"];
    string redis_Passageway = ConfigurationManager.AppSettings["redis_Passageway"];

    ConfigurationOptions configOptions = new ConfigurationOptions
    {
        EndPoints = {
           { redis_IP,int.Parse(redis_Port) }
        },
        KeepAlive = 180,      //發送信息以保持sockets在線的間隔時間
        Password = redis_Password,   //密碼
        DefaultVersion = new Version("2.8.5"),   //Redis版本
        AllowAdmin = true     //啟用被認定為是有風險的一些命令
    };

    ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(configOptions);

5、獲取到指定服務器的發布/訂閱服務器連接

  ISubscriber sub = redis.GetSubscriber();

6、數據推送

   string msg = JsonConvert.SerializeObject(redisPushModel);
   sub.Publish(redis_Passageway, msg);//向頻道發送信息

7、客戶端訂閱

  sub.Subscribe(redis_Passageway, (channel, message) => {
      //輸出頻道redis_Passageway收到的消息
      Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " :" + message);
  });