基于surging跨網(wǎng)關跨語言進行緩存降級的問題小結

更新時間：2024年05月06日 09:02:27 作者：fanly11

surging是一款開源的微服務引擎,包含了rpc服務治理,中間件,以及多種外部協(xié)議來解決各個行業(yè)的業(yè)務問題,這篇文章主要介紹了如何基于surging跨網(wǎng)關跨語言進行緩存降級,需要的朋友可以參考下

概述

surging是一款開源的微服務引擎，包含了rpc服務治理，中間件，以及多種外部協(xié)議來解決各個行業(yè)的業(yè)務問題，在日益發(fā)展的今天，業(yè)務的需求也更加復雜，單一語言也未必能抗下所有，所以在多語言行業(yè)解決方案優(yōu)勢情況下，那么就需要多語言的協(xié)同研發(fā)，而對于協(xié)同研發(fā)環(huán)境下，統(tǒng)一配置的網(wǎng)關，多語言訪問調用必然會涉及到需要數(shù)據(jù)緩存的問題，那么怎么做到跨網(wǎng)關跨語言緩存降級呢？那么將在此篇文章中進行講解。

如何創(chuàng)建攔截器

繼承IInterceptor ，創(chuàng)建攔截，如下代碼所示

public class LogProviderInterceptor : IInterceptor
    {
        public async Task Intercept(IInvocation invocation)
        { 
            await invocation.Proceed();
            var result = invocation.ReturnValue;
        }
    }

服務引擎針對于IInterceptor 擴展了CacheInterceptor用來做緩存攔截，如以下代碼所示

public class CacheProviderInterceptor : CacheInterceptor
    {
        public override async Task Intercept(ICacheInvocation invocation)
        { 
        }
}

如何使用緩存攔截器

通過設置特性Metadatas.ServiceCacheIntercept配置緩存攔截，如以下代碼所示

[Metadatas.ServiceCacheIntercept(Metadatas.CachingMethod.Get, Key = "GetUser_{0}_{1}", L2Key = "GetUser_{0}_{1}",EnableL2Cache =true, CacheSectionType = "ddlCache", Mode = Metadatas.CacheTargetType.Redis, Time = 480)]

在處理業(yè)務的修改，刪除方法時候，需要移除依賴的緩存，那么可以設置CorrespondingKeys，如以下代碼所示

[Metadatas.ServiceCacheIntercept(CachingMethod.Remove, "GetUser_id_{0}", "GetUserName_name_{0}", CacheSectionType = SectionType.ddlCache, Mode = CacheTargetType.Redis)]

如何設置緩存Key

1.比如緩存設置為GetUserById_{0}, 傳遞的參數(shù)是int 類型，值為2199 ，那么產(chǎn)生的key就是GetUserById_2199.

2.比如緩存設置為GetUser_{0}_{1},傳遞的參數(shù)是UserModel類型，傳遞為new UserModel{ UserId=2199,Name="Fanly" }值，那么產(chǎn)生的Key就是GetUser_fanly_2199. 標識CacheKeyAttribute特性以生成緩存key, 并且設置SortIndex排序依次生成。

public class UserModel
    {
       [CacheKey(1)]
        public int UserId { get; set; }
        [CacheKey(2)]
        public string Name { get; set; }
        public int Age { get; set; }
    }

創(chuàng)建攔截模塊

通過以下代碼，把攔截器注入到服務引擎中

public class IntercepteModule : SystemModule
   {
       public override void Initialize(CPlatformContainer serviceProvider)
       {
           base.Initialize(serviceProvider);
       }
       /// <summary>
       /// Inject dependent third-party components
       /// </summary>
       /// <param name="builder"></param>
       protected override void RegisterBuilder(ContainerBuilderWrapper builder)
       {
           base.RegisterBuilder(builder);
           builder.AddClientIntercepted(typeof(CacheProviderInterceptor),typeof(LogProviderInterceptor));
       }
   }

如何跨語言調用中開啟緩存攔截降級

在surging 是調用分為二種

1.基于接口創(chuàng)建代理調用，可以作為同一語言的互相調用，性能上比第二種基于routepath要快，但是具有高耦合性

var userProxy = ServiceLocator.GetService<IServiceProxyFactory>().CreateProxy<IUserService>("User");

2.基于routepath調用，可以作為跨語言調用，性能上比第一種基于接口創(chuàng)建代理要慢，但是具有低耦合性

Dictionary<string, object> model = new Dictionary<string, object>();
  model.Add("name", name);
  string path = "api/hello/say";
   string result =await _serviceProxyProvider.Invoke<object>(model, path, null);

而在服務調用下，因為業(yè)務模型參數(shù)在基于routepath調用情況，做不到模型參數(shù)解析，只能支持單一參數(shù)和無參數(shù)的緩存攔截調用，而基于接口創(chuàng)建代理調用是可以支持業(yè)務模型緩存調用的，在以下特征情況下就需要在Metadatas.ServiceCacheIntercept特性下開啟EnableStageCache，代碼如下

[Metadatas.ServiceCacheIntercept(Metadatas.CachingMethod.Get, Key = "GetDictionary", L2Key = "GetDictionary", EnableL2Cache = true, CacheSectionType = "ddlCache", Mode = Metadatas.CacheTargetType.Redis, Time = 480, EnableStageCache = true)]

通過以上的代碼，運行后，在注冊中心注冊的服務路由下可以看到攔截器元數(shù)據(jù)，這樣在其它語言通過元數(shù)據(jù)可以構造服務消費者的緩存攔截降級。

以下是基于二種調用的緩存結果存儲redis中

如何處理緩存K/V 中Value 過大

緩存中間件Redis是一種高性能的內存數(shù)據(jù)庫，用于存儲鍵值對的數(shù)據(jù)結構。當value的大小超過一定限制時，一般超過10K就會影響查詢的性能。這時候使用一二級緩存來解決，一級緩存用redis 存儲標記，標記緩存是否失效，二級緩存用本地緩存存儲，當標記失效不存在后，會遠程調用服務，返回結果添加一級緩存標記，返回結果添加到二級緩存。

提示：大家可以按照自己的業(yè)務需求，研發(fā)緩存攔截，不一定非要使用CacheProviderInterceptor，按照CacheProviderInterceptor一二級緩存進行構建研發(fā)