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);
  });

c#之redis发布订阅

上一篇:windows 环境中,编译器里面快捷键 Ctrl+Space 没反应


下一篇:C# webservices接口生成的wsdl文件中有soap12,导致调用接口返回的结果不对