asp.net core 使用 Redis 和 Protobuf

Posted 2020-07-26 Leo_wlCnBlogs

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了asp.net core 使用 Redis 和 Protobuf相关的知识，希望对你有一定的参考价值。

asp.net core 使用 Redis 和 Protobuf

前言

上篇博文介绍了怎么样在 asp.net core 中使用中间件，以及如何自定义中间件。项目中刚好也用到了Redis，所以本篇就介绍下怎么样在 asp.net core 中使用 Redis 进行资源缓存和Session缓存。如果你觉得对你有帮助的话，不妨点个【推荐】。

Redis 介绍

下面是Redis官网的介绍：

Redis is an open source (BSD licensed), in-memory data structure store, used as database, cache and message broker. It supports data structures such as strings, hashes, lists, sets, sorted sets with range queries, bitmaps, hyperloglogs and geospatial indexes with radius queries. Redis has built-in replication, Lua scripting, LRU eviction, transactions and different levels of on-disk persistence, and provides high availability via Redis Sentinel and automatic partitioning with Redis Cluster.

Redis 是一个开源的（基于BSD许可），内存数据存储结构，常用作数据库，缓存，和消息队列。它支持如字符串、哈希表、列表、集合、排序集范围查询、位图、hyperloglogs半径和地理空间索引与查询。Redis内置主从连接，Lua脚本、LRU回收，事务和不同级别文件持久化，并提供了利用集群的主从切换和自动分区等来保证高可用性。

Redis的深入介绍我就直接开传送门了，不是本篇的重点，但是我给你们整理了一下，你们还是要感谢我滴：

redis 高可用部署及监控：http://blog.sina.com.cn/s/blog_75ad98f30101fwqj.html
redis 主从连接：http://www.tuicool.com/articles/fAnYFb
redis 事务: http://redisbook.readthedocs.io/en/latest/feature/transaction.html
redis 内存回收LRU：http://www.open-open.com/lib/view/open1427547789059.html
redis 数据持久化：http://qifuguang.me/2015/10/13/Redis%E6%8C%81%E4%B9%85%E5%8C%96/

以上知识学习完，使用和面试时应付Redis的提问应该不成问题了。

asp.net core session 介绍

session本身是一个很难解释的名词，在http中session代表服务器与浏览器的一次会话过程，这个过程可能一直，也可能间断的。

asp.net core中的session以中间件的方式提供给我们来使用。

下面来看一下使用方法：
首先，添加session的NuGet包Microsoft.AspNetCore.Http.Abstractions到项目中，在startup.cs文件的ConfigureServices(IServiceCollection services)函数中，使用app.UseSession()和app.UseCaching()来使用session.

//在使用session之前要注入cacheing，因为session依赖于cache进行存储
services.AddCaching();

services.AddSession();

添加了session之后就需要有存储session的地方，可以使用内存存储，也可以使用其他自定义存储，比如redis或者SQL Server等。

// 重要: session的注册必须在UseMvc之前，因为MVC里面要用 
app.UseSession();

app.UseMvc(routes =>
{
    routes.MapRoute(
        name: "default",
        template: "{controller}/{action}/{id?}",
        defaults: new { controller = "Home", action = "Index" });
});

Redis & Session 实例讲解

要在Session中使用Redis，只需要把services.AddCaching();换成services.AddDistributedRedisCache();就可以了，如下：

services.AddDistributedRedisCache(option => 
    {
    //redis 数据库连接字符串
        option.Configuration = Configuration.GetConnectionString("RedisConnection");
        
        //redis 实例名
        option.InstanceName = "master";
    }
);

Session的使用

在 asp.net core 的 MVC Controller 中，你可以HttpContext.Session来获取Session对象。

如果不是在 Controller 中需要使用 Session 的话，可以使用IHttpContextAccessor这个接口通过注入的方式来获取Session。

以下是在 Controller 中使用Session，需要引入Microsoft.AspNetCore.Http空间：

public class HomeController : Controller
{
    public IActionResult Index()
    { 
        HttpContext.Session.SetString("Test", "Ben Rules!");
        return View();
    }

    public IActionResult About()
    {
        ViewBag.Message = HttpContext.Session.GetString("Test");

        return View();
    }
}

以下是在除了 Controller 的其他地方使用 Session：

public class SomeOtherClass
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    private ISession _session => _httpContextAccessor.HttpContext.Session;

    public SomeOtherClass(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    public void TestSet()
    {
        _session.SetString("Test", "Ben Rules!");
    }

    public void TestGet()
    {
        var message = _session.GetString("Test");
    }
}

使用 Protobuf 给 Session添加扩展方法

默认情况下，我们只能存储byte[]到我们的Session当中，这让我们使用起来很不方便，在Microsoft.HttpCore.Extension中 Microsoft 给提供了一个SetString，SetInt32 和GetString，GetInt32的方法，但是在很多情况下，我们是需要使用Session来存储一个对象的，那么此时就需要给Session添加一个扩展方法。

为了追求效率和性能，我们选择Google的Protobuf序列化组件，而不使用Json.Net，在性能方面，Protobuf要比XML或者Json效率高很多。

在Nuget包中引入protobuf-net：

public static class SessionExtensions
{
        public static T Get<T>(this ISession session, string key) where T : class {
            byte[] byteArray = null;
            if (session.TryGetValue(key, out byteArray)) {
                using (var memoryStream = new MemoryStream(byteArray)) {
                    var obj = ProtoBuf.Serializer.Deserialize<T>(memoryStream);
                    return obj;
                }
            }
            return null;
        }

        public static void Set<T>(this ISession session, string key, T value) where T : class {
            try {
                using (var memoryStream = new MemoryStream()) {
                    ProtoBuf.Serializer.Serialize(memoryStream, value);
                    byte[] byteArray = memoryStream.ToArray();
                    session.Set(key, byteArray);
                }
            }
            catch (Exception) {
                throw;
            }
           
        }
}