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

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

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


(一)基础类库介绍

  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 [email protected]", 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

时间: 03-22

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

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

本人作为一位web工程师,着眼最多之处莫过于 性能与架构,本次幸得参与sd2.0大会,得以与同行广泛交流,于此二方面,有些心得,不敢独享,与众博友分享,本文是这次参会与众同撩交流的心得,有兴趣者可以查看视频 架构设计的几个心得: 一,不要过设计:never over design 这是一个常常被提及的话题,但是只要想想你的架构里有多少功能是根本没有用到,或者最后废弃的,就能明白其重要性了,初涉架构设计,往往倾向于设计大而化一的架构,希望设计出具有无比扩展性,能适应一切需求的增加架构,web开发领

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

阅读目录: 1.背景介绍 2.SOA的架构层次 2.1.应用服务(原子服务) 2.2.组合服务 2.3.业务服务(编排服务) 3.SOA化的重构 3.1.保留服务空间,为了将来服务的组合 4.运用DDD+GRASP进行分析和设计(防止主观的判断导致错误的假设) 5.SOA分布式下的数据一致性 5.1.分布式事务(基于DTC的分布式事务) 5.2.事务补偿(提供正向或反向的操作来让数据在业务上是一致的) 5.3.异步EDA(基于异步事件流来实现柔性的分布式事务) 6.总结 1.背景介绍 最近一段时

[转]SOA架构设计经验分享&mdash;架构、职责、数据一致性

阅读目录: 1.背景介绍 2.SOA的架构层次 2.1.应用服务(原子服务) 2.2.组合服务 2.3.业务服务(编排服务) 3.SOA化的重构 3.1.保留服务空间,为了将来服务的组合 4.运用DDD+GRASP进行分析和设计(防止主观的判断导致错误的假设) 5.SOA分布式下的数据一致性 5.1.分布式事务(基于DTC的分布式事务) 5.2.事务补偿(提供正向或反向的操作来让数据在业务上是一致的) 5.3.异步EDA(基于异步事件流来实现柔性的分布式事务) 6.总结 1.背景介绍 最近一段时

Linux系统运维与架构设计

一 本章概览 介绍Linux系统运维与架构设计的方方面面 二 Linux基础入门 认识计算机核心硬件和服务器 Linux发展历史.系统组成.应用领域以及发行版 搭建运维环境:VMWareWorkStation.SecureCRT的使用 Linux系统的基本使用 Shell入门以及命令概述 三 Linux系统管理 文件目录管理 用户管理 权限管理 VIM编辑器的使用 文档压缩打包 程序包管理 网络管理 文件系统管理 内存管理 系统管理(监控.环境变量) 安全管理(selinux,iptables)

海尔电商峰值系统架构设计最佳实践

多数电商平台都会经历相似的过程,流量和业绩每年以几倍至十几倍的速度增长,每年都要接受几次大规模.全方位的系统检阅,例如双11.周年庆等购物狂欢节,期间流量和订单可能是日常的十几倍甚至几十倍,产生的峰值对平台形成极其强烈的冲击,对电商平台的架构带来巨大的考验.因此,对电商平台的规划和架构工作不仅要高瞻远瞩,而且要细致入微,否则将导致平台无法满足高速增长的业务发展,细微处的失误也可能造成严重后果,不仅影响业务指标的实现,还可能导致对系统进行重新架构,劳时费力又伤钱. 从2012年开始,海尔进入了网络

NET架构设计、框架设计系列文章总结

NET架构设计.框架设计系列文章总结 从事.NET开发到现在已经有七个年头了.慢慢的可能会很少写.NET文章了.不知不觉竟然走了这么多年,热爱.NET热爱c#.突然想对这一路的经历进行一个总结. 是时候开始下一阶段的旅途,希望这些文章可以在发挥点价值作用. 架构设计: ElasticSearch大数据分布式弹性搜索引擎使用 (推荐) DDD实施经验分享-价值导向.从上往下进行(圈内第一个吃螃蟹DDD实施方案)(推荐) 软件工程-思考项目开发那些事(一)(推荐) SOA架构设计经验分享-架构.职责

ENode框架Conference案例分析系列之 - 架构设计

Conference架构概述 先贴一下Conference案例的在线地址,UI因为完全拿了微软的实现,所以都是英文的,以后我有空再改为中文的. Conference后台会议管理:http://www.enode.me/conference Conference前台预定座位:http://www.enode.me/registration ENode论坛开源案例:http://www.enode.me/post ENode开源项目地址:https://github.com/tangxuehua/e

架构设计实践二:需求分析

1.1 三个问题 掌握好需求分析,需要掌握三个问题的解决方式. 需求如何获得?需求开发=愿景分析+需求分析 如何判断需求全不全?功能.质量.约束三类需求 如何从需求转换为设计?功能.质量.约束对架构产生不同的影响. 1.2 软件研发与交付过程总图 其中概念化阶段一般都要完成愿景分析.风险评估.可行性分析及项目进度和成本的粗略估算,输出<愿景与范围文档>:需求分析阶段则完成需求捕获.需求分析,得到<软件需求规格说明书>,一个关键的思路是需求捕获与需求分析是迭代着进行的,完成需求捕获之

架构设计分享之权限系统(看图说话)

前面一篇文章<最近架构随想>,我提到架构设计的一些构想,其实也是对之前项目经验的一些归纳及总结.今天我们就以权限系统作为切入点,谈一谈怎么设计权限系统以及怎么做到系统具有以下特性: Organized:如果系统组织比较好,可以起到事半功倍的效果. Encapsulated:对功能,结构,数据进行有效的封装,会使系统维护变得更加容易. Reusable:对常用功能以及组件进行有效的封装,可以使系统变得结构清晰且方便维护. Extensible:在设计系统的时候,如果很好的遵守OO的设计理念(OO