小菜白话搭架子一:有所为,有所不为 – Turbo Zhang
话说小菜过做已近3年,虽出身PHP后项目大多涉及.net,系统也做得比较繁杂,从常见的CMS,企业OA,ERP,也涉及到电商系统的开发定制,爬虫,工具不一而足,其中web系统居多。
由于表现良好,时常会被经理叫去:“小菜,人是需要成长的啊,不如下个项目你负责吧,锻炼一下吧。”可是小菜对这种负责的职位是相当的不感冒,小菜只想快乐的编码,小菜的最终成为soho一族陪着美女环游世界。都知道事情一涉及到管理,负责就不那么纯洁了。并且小菜一直认为:将帅无能,累死三军。于是小菜每次都以“更对编码感兴趣” 为由拒绝。然而小菜知道丑媳妇早晚要见公婆,时间久了,这一步总是要过的,于是小菜也每每在项目之前,之后尝试以自己的理解,去搭一个架子,以备将来负责时不时之需。
于是“小菜白话搭架子”系列便出现了,会结合一些项目进行分析与记录,促进成长,水平有限,不喜勿喷哦。
闲话少绪,小菜给大家道一下整个的项目背景。
背景:此项目是为欧美某信息服务公司A加工其世界范围内所合作的的“信息提供商”提供的信息。也就是为A设计开发一个数据处理管道使用其不同的合作商,使不同合作商的数据最终为A所用。
由于小菜公司与A公司长久合作关系,大部分的合作商数据处理工具以开发完成,目前小菜们所要做的架子主要是将这些工具组合在一起,使开发过程减少人工干扰,减少人工成本。同时可适用于未来的需求扩展。
开发完成的Tool,及步骤:
- DownloadTool:从信息提供商下载数据。
- Diff:为数据提供商本身数据去重。
- Caculate:整合新版本数据与库中数据,生成新数据。
- View:生成用户可用数据。
- Backup:数据备份。
因为小菜认为做开发解决方案一定要在技术选型之前,如果先做技术选型的话,可能会我们的思考产生束缚,
小菜第一次获取以上信息时,由于这么多的Tool,将来还可能扩展,本能的想到了一个模型,就是ToolBox。
这样的话,将来那些新开发的Tool或已有的Tool之间就不需要产生本质的结合,将来我们就需要将他们扔进一个叫做“Toolbox”的文件夹中,MainServer会检索这个文件夹,将新增的Tool加载进系统运行程序集,有些类似于插件开发。由于经理对于Wcf有个人的青睐,要求使用wcf做选型的分布式信息架构,说实话小菜不喜欢wcf,因为小菜一直认为这又是微软的一个学院派产品,配置麻烦也不酷。不过用就用吧。
于是小菜认为,既然头脑中有了模型,技术有了选型,开始最喜欢的代码吧:
小菜的结构与分层大概是这样的:
小菜为每一个Tool都做了一个接口,MainServer和Tool之间通过wcf进行通信,mainserver通过检测Tool的心跳获知其生活状态,Tool内有一个线程定时回调方法去Mainserver查找有没有分配自己的Task,Tool获取Task之后执行,返回给客户端:
代码如下:
server.contract:
[OperationContract]
Int32 CreateWork(UpstreamViewsWF work, Int32
? seriesID);[OperationContract]
Boolean TryTakeWork(
out GeneralWork<UpstreamViewsWF> work);[OperationContract]
void UpdateWork(GeneralWork<UpstreamViewsWF> work);[OperationContract]
void DeleteWork(Int32 id);[OperationContract]
void ReportProcess(WorkProgress progress);[OperationContract]
void ReportCompletion(GeneralWork<UpstreamViewsWF> work);}
service:
private Logger _logger;
private IGeneralJobRepository _generalRepo;
private IJobStatusHistoryRepository _historyRepo; public ViewsService(
IRepositoryContext context,
IGeneralJobRepository generalJobRepo,
IJobStatusHistoryRepository historyRepo)
: base(context) {
_generalRepo = generalJobRepo;
_historyRepo = historyRepo;
_logger = LogManager.GetCurrentClassLogger();
} public Int32 CreateWork(Views work, Int32? seriesID) {
_logger.Info(String.Empty);
GeneralJob job = new GeneralJob {
Category = (Byte)WorkCategory.Views,
Status = (Byte)WorkStatus.Created,
}; if (seriesID.HasValue && seriesID.Value > 0) {
job.SeriesID = seriesID.Value;
}
work.TypeName
= WorkCategory.Views.ToString();job.VARS
= JsonConvert.SerializeObject(work);try {
Context.BeginTrans();
_generalRepo.Create(job);
_historyRepo.Create(CreateJobStatus(job));
Context.Commit();
}
catch (Exception ex) {
_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);
}
} public GeneralWork<Views> RetriveWork(int id) {
_logger.Info(String.Empty);
try {
GeneralJob job = _generalRepo.RetriveByKey(id);
return job.Map<Views>();
} catch (Exception ex) {
_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);}
}
public void UpdateWork(GeneralWork<Views> work) {_logger.Info(String.Empty);
try {GeneralJob job
= _generalRepo.RetriveByKey(work.ID); if (job.Status != (Byte)WorkStatus.Created) {Exception ex
= new Exception(“Only new work could be modified“);}
work.VARS.TypeName
= WorkCategory.UpstreamViewsWF.ToString();job.SeriesID
= work.SeriesID;job.VARS
= JsonConvert.SerializeObject(work.VARS);Context.BeginTrans();
_generalRepo.Update(job);
_historyRepo.Create(CreateJobStatus(job));
Context.Commit();
}
catch (Exception ex) {_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);}
}
public void DeleteWork(Int32 id) {_logger.Info(String.Empty);
try {GeneralJob job
= _generalRepo.RetriveByKey(id); if (job.Status != (Byte)WorkStatus.Created) {Exception ex
= new Exception(“Only new work could be modified“);}
job.Status
= (Byte)WorkStatus.Abandoned;Context.BeginTrans();
_generalRepo.Delete(job);
_historyRepo.Create(CreateJobStatus(job));
Context.Commit();
}
catch (Exception ex) {_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);}
}
public void ReportProcess(WorkProgress progress) {_logger.Info(String.Empty);
}
public void ReportCompletion(GeneralWork<Views> work) {_logger.Info(String.Empty);
try {GeneralJob job1
= work.Map<Views>();job1.Status
= (Byte)WorkStatus.Finished;Context.BeginTrans();
_generalRepo.Update(job1);
_historyRepo.Create(CreateJobStatus(job1));
Context.Commit();
}
catch (Exception ex) {_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);}
}
public GeneralWork<Views>[] ReadWorkQueue(int currentPage, int itemsPerPage, WorkStatus? status, string key, outPageClause pageClause) {_logger.Info(String.Empty);
try {List
<Expression<Func<GeneralJob, Boolean>>> filters = new List<Expression<Func<GeneralJob, bool>>>();filters.Add(e
=> e.Category == (Byte)WorkCategory.UpstreamViewsWF); if (status.HasValue) {filters.Add(e
=> e.Status == (Byte)status);}
if (!String.IsNullOrWhiteSpace(key)) {filters.Add(e
=> e.VARS.Contains(key.Trim()));}
PageClause
<GeneralJob> jobs = _generalRepo.RetriveAll(currentPage, itemsPerPage, true, p
=> p.ID, filters.ToArray());pageClause
= new PageClause(jobs); return jobs.Map<UpstreamViewsWF>().ToArray();}
catch (Exception ex) {_logger.ErrorException(String.Empty, ex);
throw FaultData.CreateFaultException(ex);}
}
}
对Tool的封装:
{
static lWork<View> currentWork; private readonly static string exePath = Path.Combine( AppDomain.CurrentDomain.BaseDirectory, “app.exe“ ); static void Main( string[] args ) {Trace.Listeners.Add(
new ConsoleTraceListener() ); try { if( TryTakeWork() ) {Trace.WriteLine(
“Take a work“ );Work();
ProcessWork();
ReportCompletion();
}
}
catch( Exception ex ) {Console.WriteLine( ex );
}
}
static void Work() { using( ServiceFactory factory = new ServiceFactory() ) { try {ISeriesWorkService service
= factory.CreateChanel<ISeriesWorkService>();SeriesWork seriesWork
= service.RetriveWork( currentWork.SeriesID );currentWork.VARS.TypeName
= ConfigurationManager.AppSettings[ “TypeName“ ];Trace.WriteLine(
“TypeName:“ + currentWork.VARS.TypeName );currentWork.VARS.Code
= seriesWork.egion;Trace.WriteLine(
“Code:“ + Code );CopyHelper.CopyDir( Path.GetFullPath(
@”….Application“ ), AppDomain.CurrentDomain.BaseDirectory );}
catch( Exception ex ) {Console.WriteLine( ex );
}
}
}
static Boolean TakeWork() {Trace.WriteLine(
“TryTakeWork“ ); using( ServiceFactory factory = new ServiceFactory() ) {IUpstreamViewsWFService service
= factory.CreateChanel<IUpstreamViewsWFService>(); return service.TakeWork( out currentWork );}
}
static void ProcessWork() {Trace.WriteLine(
“ProcessWork…“ );Process process
= null; try {ProcessStartInfo info
= new ProcessStartInfo();info.CreateNoWindow
= false;info.FileName
= exePath; //as u needprocess
= Process.Start( info );process.EnableRaisingEvents
= true;process.WaitForExit();
Trace.WriteLine(
“ProcessWork succeed“ );}
catch( Exception EX ) {Trace.WriteLine(
“Exception:“ + EX ); if( process != null ) {process.Kill();
}
}
}
static void ReportCompletion() {Trace.WriteLine(
“ReportCompletion“ ); using( ServiceFactory factory = new ServiceFactory() ) {IView service
= factory.CreateChanel<IView>();service.ReportCompletion( currentWork );
}
}
}
话说一天过去了,小菜把基本的功能完成了,小菜想反正也有时间于是小菜把他知道的东西都用上了IOC(unit),Log4,Orm(ef)。慢慢的小菜开始将接口丰富了越来越多的功能,最后小菜对经理说了自己的想法,说了用的技术,经理说好”下午部署上吧“,小菜心想我的接口已经有了很丰富的功能,我还提供了很多其他功能的接口,肯定没问题于是小菜欣然的答应了。然而新的挑战就这样悄然的反生了。
他找到每个Tool的开发人员讲解自己的接口怎样用,能做什么,需要与MainServer以怎样的方式进行通信,不同异常机制信息的提供的不同。小菜发现他对每一开发者讲解的时候,大家更多的是关心自己的Tool应该更少的关注Mainserver,同时大家也更多的是忙于自己的事情,没有多少时间去协同维护你的接口,大家的一致决定是你先写一个Tool对接Mainserver的Demo我们照着改就可以了,你先写吧。
就这样小菜心想,我已经写的这么好了的接口,为什么大家不喜欢用不喜欢听呢。下班之后小菜一直不思其解,于是拨通了同校大两级也是做开发的学长”老鸟“的电话,简单介绍了事情的经过之后,老鸟呵呵一笑说:“小菜, 你的想法不错,可是就是因为你提供的东西反而太多了,大师不是只懂加法也要会做减法,搭架子要有所为有所不为”。
未完待续。。。
本文链接:http://www.cnblogs.com/xiguain/p/3498646.html,转载请注明。