Asp.net Core中使用Redis 来保存Session, 读取配置文件

今天无意看到Asp.net Core中使用Session ，首先要使用Session就必须添加Microsoft.AspNetCore.Session包，默认Session是只能存去字节，所以如果你想存取string的，那么还的引入Microsoft.AspNetCore.Http.Extensions包，那么在Startup.cs的ConfigureServices方法里面添加 services.AddSession(); （在 services.AddMvc()之前），在Configure方法添加 app.UseSession(); （ app.UseMvc()之前）这样就可以使用Session了，默认Session是字节方式，这里我们使用json来序列化对象：

 public static class SessionExtensions

    {

        public static void Set(this ISession session, string key, object value)

        {

            session.SetString(key, JsonConvert.SerializeObject(value));

        }

        public static T Get<T>(this ISession session, string key)

        {

            var value = session.GetString(key);

            return value == null ? default(T) : JsonConvert.DeserializeObject<T>(value);

        }

    }

使用方式：

var city = new City { ID = 1, CountryCode = "123", Name = "city", District = "District test", Population = " Population test" };
HttpContext.Session.Set("city", city);
var c2 = HttpContext.Session.Get<City>("city");

如何保存到Redis中了？

首先需要添加对应的包Microsoft.Extensions.Caching.Redis，再调用AddDistributedRedisCache如下：

    public void ConfigureServices(IServiceCollection services)

        {

           // string mysqlConnectiong = Configuration.GetConnectionString("MySQL");

            string redisConnectiong = Configuration.GetConnectionString("Redis");

            services.AddSession();

            services.AddDistributedRedisCache(option=>option.Configuration=redisConnectiong);

            services.AddMvc();

        }

配置如下：

{

  "Logging": {

    "IncludeScopes": false,

    "LogLevel": {

      "Default": "Warning"

    }

  },

  "ConnectionStrings": {

    "MySQL": "server=localhost;port=3306;uid=root;pwd=;database=word;charset=utf8;max pool size=1000;",

    "Redis": "127.0.0.1:6379,abortConnect=false,connectRetry=3,connectTimeout=3000,defaultDatabase=1,syncTimeout=3000,version=3.2.1,responseTimeout=3000"

  }

}

这样Session就可以保存到Redis了。

缓存的使用也很简单

IDistributedCache Cache;

        public ValuesController(IDistributedCache cache) {

            Cache = cache;

        }

 Cache.SetString("test", "Gavin");

            var vc = Cache.GetString("test");

我们在项目类库如何读配置文件

public class ConfigurationManager

    {

        /*

         Microsoft.Extensions.Options.ConfigurationExtensions

         Microsoft.Extensions.Configuration.Abstractions

         Microsoft.AspNetCore.Http.Extensions
         Microsoft.Extensions.DependencyInjection

             */

        static IConfiguration Configuration;

        static ConfigurationManager()

        {

            var baseDir = AppContext.BaseDirectory;

             Configuration = new ConfigurationBuilder()

                .SetBasePath(baseDir)

                .Add(new JsonConfigurationSource { Path = "appsettings.json", Optional = false, ReloadOnChange = true })

                .Build();

        }

        public static T GetAppSettings<T>(string key) where T : class, new()

        {

            var appconfig = new ServiceCollection()

                .AddOptions()

                .Configure<T>( Configuration.GetSection(key))

                .BuildServiceProvider()

                .GetService<IOptions<T>>()

                .Value;

            return appconfig;

        }

    }

 public class ConnectionStrings

    {

        public string MySQL { set; get; }

        public string Redis { set; get; }

    }

单独访问Redis：

public class CityService

    {

        /*

         * StackExchange.Redis

         */

        static IDatabase redis;

        static object lobject = new object();

        public CityService()

        {

            if (redis == null)

            {

                lock (lobject)

                {

                    if (redis == null)

                    {

                        var connection = ConfigurationManager.GetAppSettings<ConnectionStrings>("ConnectionStrings");

                        ConnectionMultiplexer connectionMultiplexer = ConnectionMultiplexer.Connect(connection.Redis);

                        redis = connectionMultiplexer.GetDatabase();

                    }

                }

            }

        }

        public IDatabase Redis { get { return redis; } }

    }

读取MySql

  public List<City> TestDB()

        {

            /*MySql.Data*/

            List<City> list = new List<City>();

            using (MySqlConnection con = new MySqlConnection(MySqlConnectionStr))

            {

                MySqlCommand cmd = new MySqlCommand("SELECT ID, NAME,CountryCode, District, Population FROM city ;", con);

                con.Open();

                using (MySqlDataReader reader = cmd.ExecuteReader())

                {

                    while (reader.Read())

                    {

                        list.Add(new City

                        {

                            ID = reader.GetInt32("ID"),

                            Name = reader.GetString("NAME"),

                            CountryCode = reader.GetString("CountryCode"),

                            District = reader.GetString("District"),

                            Population = reader.GetString("Population")

                        });

                    }

                }

            }

            return list;

        }

参考 ASP.NET Core实现类库项目读取配置文件

ASP.NET Core实现强类型Configuration读取配置数据

4.3 可配置的分布式缓存（上）

Asp.net Core 使用Redis存储Session

巴特西

Asp.net Core中使用Redis 来保存Session, 读取配置文件

最新文章

热门文章