话说小菜过做已近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:
[ServiceContract]
public interface IView {
[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:
public class View: ApplicationService, IView {
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();
return job.ID;
}
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的封装：
class Program
{
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 need
process = 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我们照着改就可以了，你先写吧。
就这样小菜心想，我已经写的这么好了的接口，为什么大家不喜欢用不喜欢听呢。下班之后小菜一直不思其解，于是拨通了同校大两级也是做开发的学长”老鸟“的电话，简单介绍了事情的经过之后，老鸟呵呵一笑说：“小菜， 你的想法不错，可是就是因为你提供的东西反而太多了，大师不是只懂加法也要会做减法，搭架子要有所为有所不为”。
未完待续。。。