.NET 使用 redis

人类群星闪耀时 发表于 2022/07/04 10:20:55 2022/07/04
【摘要】 .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();

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

}
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区),文章链接,文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:cloudbbs@huaweicloud.com进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。