.NET 使用 redis

Redis 的发布订阅功能

redis 配置

Redis配置讲解（操作完记得重启Redis服务）

允许远程访问

1.修改两个配置文件:redis.windows.conf 和 redis.windows-service.conf
2.注释掉 bind 127.0.0.1
3.关闭保护模式 protected-mode no

密码

1.修改两个配置文件:redis.windows.conf 和 redis.windows-service.conf
2.开启 requirepass yourPassword

ASP.NET Core 使用redis

1. 安装StackChange.Redis nuget包
2. 连接字符串等数据库连接信息放在appsettings 中
3. 编写数据库访问工具类
4. startup注册服务

这里是手动解析配置信息，可以通过softjson自动解析

        public void ConfigureServices(IServiceCollection services)        {            var section = Configuration.GetSection("Redis:Default");            string _connectionString = section.GetSection("Connection").Value;            string _instanceName = section.GetSection("InstanceName").Value;            int _defaultDB = int.Parse(section.GetSection("DefaultDB").Value ?? "0");            services.AddSingleton(new RedisHelper(_connectionString, _instanceName, _defaultDB));            services.AddControllers();        }

5. controller 中调用

ASP.NET CORE 中使用redis缓存

安装nuget 包

• StackExchange.Redis.Extensions.Core
• StackExchange.Redis.Extensions.AspNetCore
• StackExchange.Redis.Extensions.Newtonsoft

appsettings配置文件添加

"Redis": {  "Password": "123456",  "AllowAdmin": true,  "Ssl": false,  "ConnectTimeout": 6000,  "ConnectRetry": 2,  "Database": 0,  "Hosts": [    {      "Host": "127.0.0.1",      "Port": "6379"    }  ]  }

startup 注册服务

public void ConfigureServices(IServiceCollection services){    var redisConfiguration = Configuration.GetSection("Redis").Get<RedisConfiguration>();    services.AddControllersWithViews();    services.AddStackExchangeRedisExtensions<NewtonsoftSerializer>(redisConfiguration);}

服务注入

        private readonly RedisCacheClient _redisCacheClient;        public TestController(IRedis redisCacheClient)        {            _redisCacheClient = redisCacheClient;        }

使用

        public async Task<IActionResult> Index4()        {            var productdata = await _redisCacheClient.Db0.GetAsync<Product>("Product");            return View();        }

.net 中 redis 的发布订阅

主要使用代码：订阅

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