sns社区架构设计案例分享(二)

时间:2022-02-28 09:52:53

源码下载地址:http://www.jinhusns.com/Products/Download/?type=xcj

五、 架构使用说明 > 缓存 > 使用说明 >


(一)基础类库介绍

sns社区架构设计案例分享(二)

  1. ICacheService:缓存服务接口,供缓存的存取的调用;

ICacheService方法说明:

方法名称

成员修饰

说明

备注

Add(多个参数):void +1重载

public static

加入缓存项

Set(多个参数):void +1重载

public static

添加或更新缓存

如果无对应缓存项则创建,否则更新

Remove(stringcacheKey):void

public static

移除缓存

MarkDeletion(多个参数):void

public static

标识为删除

Clear():void

public static

清空缓存

Get(string cacheKey):object

public static

从缓存获取

Get<T>(string cacheKey): T

public static

从缓存获取

GetFromFirstLevel(stringcacheKey): object

public static

从一层缓存获取

分布式缓存情况下从分布式缓存获取

GetFromFirstLevel<T>(string cacheKey) : T

public static

从一层缓存获取

分布式缓存情况下从分布式缓存获取

1)         提供Tunynet.Caching.DefaultCacheService作为ICacheService的默认实现;

  1. CacheSettingAttribute:用于在实体标注缓存相关的设置;

CacheSettingAttribute属性说明:

属性名称

成员修饰

说明

备注

EnableCache: bool

public

是否启用缓存

仅允许在构造器设置属性

ExpirationPolicy :

EntityCacheExpirationPolicies

public

实体缓存(实体正文缓存)过期策略

PropertyNameOfBody : string

public

实体正文缓存对应的属性名称(如果不需单独存储实体正文缓存,则不要设置该属性)

PropertyNamesOfArea : string

public

缓存分区的属性名称(可以设置多个,用逗号分隔)

  1. RealTimeCacheHelper:主要功能是递增缓存版本号(一般无需开发人员干涉)和辅助获取缓存CacheKey;

RealTimeCacheHelper方法说明:

方法名称

成员修饰

说明

备注

GetGlobalVersion():long

public

列表缓存全局version

GetEntityVersion(objectprimaryKey): long

public

获取Entity的缓存版本

GetAreaVersion(多个参数): long

public

获取列表缓存区域version

GetCacheKeyOfEntity(object primaryKey): string

public

获取实体的cacheKey

GetListCacheKeyPrefix(多个参数): string

public

获取列表缓存CacheKey的前缀(例如:abe3ds2sa90:8:)

IncreaseEntityCacheVersion(object entityID): void

public

递增实体缓存(仅更新实体时需要递增)

IncreaseListCacheVersion(IEntity entity): void

public

递增列表缓存version(仅增加、删除实体时需要递增)

IncreaseAreaVersion(多个参数): void +2重载

public

递增列表缓存区域version

(二)缓存时间过期类型

1.          预设以下几种过期时间(在Tunynet.Caching.CachingExpirationTypes定义);

缓存期限类型

描述

备注

Invariable

永久不变的

 

Stable

稳定数据

例如: Resources.xml、Area、Application

RelativelyStable

相对稳定

例如: 权限配置、审核配置、敏感词、表情、站点类别、资讯版块、资讯版块集合

UsualSingleObject

常用的单个对象

例如: 用户、群组、类别、标签、博客Section、相册Section、论坛版块、活动

UsualObjectCollection

常用的对象集合

例如: 用户的朋友

SingleObject

单个对象

例如: 博文、帖子

ObjectCollection

对象集合

例如: 用于分页的私信数据

  1. 目前实际使用的都是绝对过期时间(例如:5分钟过期);
  2. 尽量不要在使用缓存时直接设置具体过期时间;
  3. 可以配置过期时间因子(cacheExpirationFactor),用于统一调配预设过期时间类型对应的具体时间;

(三)缓存配置说明

缓存服务通过DI容器进行注册,例如:

//注册缓存

containerBuilder.Register(c => new DefaultCacheService(new RuntimeMemoryCache(), 1.0F)).As<ICacheService>().SingleInstance();

  1. 可以使用不同的构造函数实例化DefaultCacheService以支持分布式缓存,或者设置缓存过期时间因子(会整体影响预置的缓存过期时间);
  2. 为性能考虑,必须注册成单例;

3.          如果自行实现ICacheService,同样在此注册替换掉DefaultCacheService;

(四)缓存开发注意事项

  1. 在分布式缓存情况下,如需更新缓存必须显式调用更新操作(ICacheService.Set()),因为web服务器与缓存服务器可能位于不同的服务器,而非分布式缓存情况下可以利用引用类型的特征直接更新从缓存获取的数据,而无需显示调用缓存更新操作(ICacheService.Set());
  2. 所有可能需要分布式缓存的数据必须支持序列化/反序列化:

1)         需缓存的实体必须标注[Serializable];

2)         特殊数据类型必须验证是否支持序列化/反序列化,例如从Dictionary<T key,T value>派生的类型无法直接序列化;

3.         不要在使用Repository.GetTopEntities(inttopNumber, CachingExpirationTypescachingExpirationTypes, Func<string>getCacheKey, Func<PetaPoco.Sql>generateSql)设置CacheKey时与topNumber相关,因为不管topNumber值是多少,实际都会最多获取SecondaryMaxRecords条数据并缓存起来。即不同的topNumber可以共用一份缓存,用于提升缓存使用率,进而提升性能。

(五)实体的缓存标注

使用CacheSettingAttribute在实体上进行标注,使大部分缓存工作得以在Repository自动处理。

  1. 可以通过ExpirationPolicy设置实体的缓存策略(目前主要与缓存失效时间有关);
  2. 可以通过PropertyNameOfBody设置实体正文缓存对应的属性名称;
  3. 可以通过PropertyNamesOfArea设置列表分区缓存相关的属性,可以设置多个分区(即多个属性,用英文逗号分隔);
[CacheSetting(true, ExpirationPolicy = EntityCacheExpirationPolicies.Normal, PropertyNamesOfArea = "UserId,CategoryId", PropertyNameOfBody = "Body")]

[Serializable]

publicclassDiscussQuestion : IEntity

{

……

}

(六)使用实体正文缓存

当实体正文可能很大时,为了提升运行效率并减少分布式缓存时的网络流量将实体正文缓存单独存储,并且不在实体缓存中存储该部分内容。使用实体正文缓存,需要遵循以下步骤:

  1. 使用CacheSettingAttribute的PropertyNameOfBody在实体中进行标注,可以参见上一节的代码示例;
  2. 在自行派生的Repository编写实体正文的获取方法,例如:

/// <summary>

///获取DiscussQuestion内容

/// </summary>

public string GetBody(long questionId)

{

string cacheKey = RealTimeCacheHelper.GetCacheKeyOfEntityBody(questionId);

string body = cacheService.Get<string>(cacheKey);

if (body == null)

{

DiscussQuestion question = Database.SingleOrDefault<DiscussQuestion>(questionId);

body = question != null ? question.Body : string.Empty;

cacheService.Add(cacheKey, body, CachingExpirationType.SingleObject);

}

return body;

}

(七)列表缓存使用

列表缓存的主要工作是CacheKey的获取。

  1. 1.          使用无版本的列表缓存

StringBuilder cacheKey = new StringBuilder(CacheSetting.GetListCacheKeyPrefix(CacheVersionTypes.None));

cacheKey.AppendFormat("Ranking:sb-{0}", (int)sortBy);

return cacheKey.ToString();

  1. 2.          使用有版本的列表缓存

1)         可以通过RealTimeCacheHelper的以下方法获取列表缓存CacheKey前缀,直接使用第一个方法是最简便的方式;

public string GetListCacheKeyPrefix(CacheVersionType cacheVersionType, string areaCachePropertyName, object areaCachePropertyValue);

2)         在使用查询条件类并且需要即时性缓存时,可以使查询条件类实现IListCacheSetting,例如:

///<summary>

/// DiscussQuestion查询条件封装

///</summary>

public class DiscussQuestionQuery : IListCacheSetting

{

public DiscussQuestionQuery(CacheVersionTypes cacheVersionType)

{

this.cacheVersionType = cacheVersionType;

}

……

#region IListCacheSetting 成员

Private CacheVersionTypes cacheVersionType = CacheVersionTypes.None;

///<summary>

///列表缓存版本设置

///</summary>

CacheVersionTypesIListCacheSetting.CacheVersionType

{

get { return cacheVersionType; }

}

private string areaCachePropertyName = null;

///<summary>

///缓存分区字段名称

///</summary>

public string AreaCachePropertyName

{

get { return areaCachePropertyName; }

set { areaCachePropertyName = value; }

}

private object areaCachePropertyValue = null;

///<summary>

///缓存分区字段值

///</summary>

public object AreaCachePropertyValue

{

get { return areaCachePropertyValue; }

set { areaCachePropertyValue = value; }

}

#endregion

}

3)         可以自行定义的Repository使用以下代码获取CacheKey:

StringBuilder cacheKey = new StringBuilder(RealTimeCacheHelper.GetListCacheKeyPrefix(query));

if (query.UserId.HasValue)

cacheKey.AppendFormat("UserID-{0}:", query.UserId.Value);

cacheKey.AppendFormat("sb-{0}:", (int)query.SortBy);

return cacheKey.ToString();

4)         在Service中使用以下代码构造DiscussQuestionQuery:

/// <summary>

/// 获取我创建的问题

/// </summary>

public PagingDataSet<DiscussQuestion> GetMyQuestions(long userId, int pageIndex)

{

DiscussQuestionQuery query = new DiscussQuestionQuery(CacheVersionType.AreaVersion);

query.AreaCachePropertyName = "UserId";

query.AreaCachePropertyValue = userId;

query.UserId = userId;

return questionRepository.GetQuestions(query, QuestionPageSize, pageIndex);

}

(八)如何使用实体以外的属性作为分区

使用实体以外的属性作为分区时,无法依靠Repository自动维护对应分区缓存版本,需要通过代码自行控制。

  1. 自行编写代码递增分区缓存版本,例如:

/// <summary>

/// 把用户加入到一组角色中

/// </summary>

public void AddUserToRoles(int userID, List<int> roleIDs)

{

var sql_delete = PetaPoco.Sql.Builder.Append("DELETE FROM tn_UsersInRoles where UserID=@0", userID);

List<PetaPoco.Sql> sql_inserts = new List<PetaPoco.Sql>();

foreach (var roleID in roleIDs)

{

var sql_insert = PetaPoco.Sql.Builder.Append("INSERT INTO tn_UsersInRoles (UserID,RoleID) VALUES (@0,@1)", userID, roleID);

sql_inserts.Add(sql_insert);

}

using (var scope = Database.GetTransaction())

{

Database.Execute(sql_delete);

Database.Execute(sql_inserts);

scope.Complete();

}

//递增缓存分区版本号(UserID)

RealTimeCacheHelper.IncreaseAreaVersion("UserID", userID);

}

  1. 借助RealTimeCacheHelper.GetListCacheKeyPrefix()获得CacheKey,例如:

/// <summary>

///获取用户的角色

/// </summary>

public IEnumerable<Role> GetRolesOfUser(int userID)

{

string cacheKey = RealTimeCacheHelper.GetListCacheKeyPrefix(CacheVersionTypes.AreaVersion, "UserID", userID);

IEnumerable<Role> roles = CacheService.Get<IEnumerable<Role>>(cacheKey);

if (roles == null)

{

var sql = PetaPoco.Sql.Builder

.Select("RoleID")

.From("tn_UsersInRoles")

.Where("UserID = @0", userID);

IList<object> roleIDs = Database.FetchFirstColumn(sql);

RoleRepository roleRepository = new RoleRepository();

roles = roleRepository.PopulateEntitiesByPrimaryKeys(roleIDs);

CacheService.Add(cacheKey, roles, CachingExpirationTypes.UsualObjectCollection);

}

return roles;

}

http://www.jinhusns.com/Products/Curriculum/?type=xcj

sns社区架构设计案例分享(二)的更多相关文章

  1. sns社区架构设计案例分享

    今天看了个社区,了解了一下该产品的架构设计,做一下分享. 内容来源:http://www.jinhusns.com/Document/FrameworkDocument/?type=cc 一. 架构使 ...

  2. web架构设计经验分享(转)

    本人作为一位web工程师,着眼最多之处莫过于 性能与架构,本次幸得参与sd2.0大会,得以与同行广泛交流,于此二方面,有些心得,不敢独享,与众博友分享,本文是这次参会与众同撩交流的心得,有兴趣者可以查 ...

  3. 一套海量在线用户的移动端IM架构设计实践分享&lpar;含详细图文&rpar;&lpar;转&rpar;

    1.写在前面 1.1.引言 如果在没有太多经验可借鉴的情况下,要设计一套完整可用的移动端IM架构,难度是相当大的.原因在于,IM系统(尤其是移动端IM系统)是多种技术和领域知识的横向应用综合体:网络编 ...

  4. SOA架构设计经验分享—架构、职责、数据一致性

    阅读目录: 1.背景介绍 2.SOA的架构层次 2.1.应用服务(原子服务) 2.2.组合服务 2.3.业务服务(编排服务) 3.SOA化的重构 3.1.保留服务空间,为了将来服务的组合 4.运用DD ...

  5. &lbrack;转&rsqb;SOA架构设计经验分享&mdash&semi;架构、职责、数据一致性

    阅读目录: 1.背景介绍 2.SOA的架构层次 2.1.应用服务(原子服务) 2.2.组合服务 2.3.业务服务(编排服务) 3.SOA化的重构 3.1.保留服务空间,为了将来服务的组合 4.运用DD ...

  6. 【转】SOA架构设计经验分享—架构、职责、数据一致性

      1.背景介绍       最近一段时间都在做系统分析和设计工作,面对的业务是典型的重量级企业应用方向.突然发现很多以往觉得很简单的问题变得没有想象的那么容易,最大的问题就 是职责如何分配.论系统架 ...

  7. 新年春节EDM邮件内容设计案例分享

    春节自古以来都是中国最重要的节日.随着中国的发展,中国的春节在世界上都已受到越来越多人的关注,有许多国家和地区都将春节定为法定假日.与此同时,许多品牌营销商也选择在这个时候为中国客户发送马年新年邮件, ...

  8. SOA架构设计案例分析

    转载自:https://www.jdon.com/soa.html 首先Martin Fowler提出SOA歧义Service Oriented Ambiguity,认为"什么是SOA&qu ...

  9. EDM设计案例分享:6款引人入胜的夏日邮件营销模板分享

    夏日酷暑,清凉如风.在这个假期,旅游行业.酒店.服饰等都推出不少的假期活动,吸引游者的到来.假日期间,让我们看看一些旅游业.品牌服装店和酒店是怎么做好电子邮件广告的.在此,Focussend精心为大家 ...

随机推荐

  1. &lbrack;DFNews&rsqb; Touch ID不是神话,指模依旧能搞定。

    扫描制作翻模,使用含石墨硅胶压膜,前者复制指纹纹路,后者欺骗活体检测.

  2. 使用X-UA-Compatible来设置IE8&sol;IE9兼容模式

    文件兼容性用于定义让IE如何编译你的网页.此文件解释文件兼容性,如何指定你网站的文件兼容性模式以及如何判断一个网页该使用的文件模式. 前言 为了帮助确保你的网页在所有未来的IE版本都有一致的外观,IE ...

  3. 8、NFC技术:让Android自动打开网页

    创建封装Uri的NdefRecord  public  NdefRecord  createUri(String  uriString);  public  NdefRecord  cre ...

  4. Geometric Shapes - POJ 3449(多边形相交)

    题目大意:给一些几何图形的编号,求出来这些图形都和那些相交.   分析:输入的正方形对角线上的两个点,所以需要求出来另外两个点,公式是: x2:=(x1+x3+y3-y1)/2; y2:=(y1+y3 ...

  5. 网易云课堂&lowbar;程序设计入门-C语言&lowbar;第五周:函数&lowbar;1分解质因数

    1 分解质因数(5分) 题目内容: 每个非素数(合数)都可以写成几个素数(也可称为质数)相乘的形式,这几个素数就都叫做这个合数的质因数.比如,6可以被分解为2x3,而24可以被分解为2x2x2x3. ...

  6. ubuntu系统下设置静态IP

    改动 /etc/network/interfaces文件 加入下面内容 # The loopback network interface auto lo eth0 iface lo inet loop ...

  7. Tomcat&lpar;五&rpar;:nginx&sol;httpd &plus; tomcat及负载均衡tomcat

    */ .hljs { display: block; overflow-x: auto; padding: 0.5em; color: #333; background: #f8f8f8; } .hl ...

  8. Java高并发系列 — AQS

    只懂volatile和CAS是不是可以无视concurrent包了呢,发现一个好链接,继续死磕,第一日: 首先,我承认很多时候要去看源码才能更好搞懂一些事,但如果站在巨人肩膀上呢?有了大概思想源码看还 ...

  9. 【坑】tableView cell默认选中

    在tableView展示的过程时候,如果想一开始就有一些cell默认被选中,不能在cellForRowAtIndexPath中cell.selected=YES, 必须在willDisplayCell ...

  10. django的模板语言中一些之前没有用过的小点

    1.模板语言中的for循环的最后一个的表示方式 {% for auther in auther_list %} {% if forloop.last %} {# 这里的意思是for循环的最后一个的意思 ...