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