分布式消息总线,基于.NET Socket Tcp的发布-订阅框架之离线支持,附代码下载

by 魏琼东 2014.8.21 11:24
一、分布式消息总线以及基于Socket的实现      在前面的分享一个分布式消息总线,基于.NET Socket Tcp的发布-订阅框架,附代码下载一文之中给大家分享和介绍了一个极其简单也非常容易上的基于.NET Socket Tcp 技术实现的分布消息总线,也是一个简单的发布订阅框架:     并且以案例的形式为大家演示了如何使用这个分布式消息总线架构发布订阅架构模式的应用程序,在得到各位同仁的反馈的同时,大家也非常想了解订阅者离线的情况,即支持离线构发布订阅框架。 二、离线架构      不同于订阅者、发布者都同时在线的情况,支持订阅者离线,架构将有所变化,如下图所示:      也会比原先的结构将更加复杂,其中需要处理以下两个关键点:      1)订阅者的持久化存储。      2)订阅者离线之后其所订阅消息的持久存储。 三、解决方案      为解决消息总线的离线支持机制,我们在Socket 框架之中增加了一个接口ISubscribeStorager: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Text; 5:  6: namespace EAS.Messages 7: { 8: /// <summary> 9: /// 消息订阅存储接口。 10: /// </summary> 11: public interface ISubscribeStorager 12: { 13: /// <summary> 14: /// 持久化订阅。 15: /// </summary> 16: /// <param name="subscriber">订阅者。</param> 17: /// <param name="topic">消息主题。</param> 18: void Subscribe(string subscriber, string topic); 19:  20: /// <summary> 21: /// 持久化退订。 22: /// </summary> 23: /// <param name="subscriber">订阅者。</param> 24: /// <param name="topic">消息主题。</param> 25: void Unsubscribe(string subscriber, string topic); 26:  27: /// <summary> 28: /// 装载订阅信息。 29: /// </summary> 30: /// <returns>系统之中的订阅清单。</returns> 31: List<SubscribeItem> LoadSubscribes(); 32:  33: /// <summary> 34: /// 写入消息。 35: /// </summary> 36: /// <param name="subscriber">订阅者。</param> 37: /// <param name="message">消息对象。</param> 38: void Write(string subscriber, QueueMessage message); 39:  40: /// <summary> 41: /// 读消息。 42: /// </summary> 43: /// <param name="subscriber">订阅者。</param> 44: /// <param name="message">消息对象。</param> 45: /// <returns>成功读取返回true,否则返回false。</returns> 46: bool Read(string subscriber, out QueueMessage message); 47: } 48: }      ISubscribeStorager共提供持久化订阅持久化消息存储共五个函数,其中:      LoadSubscribes:服务端初始化时读取所有的离线订阅关系,即那个订阅都订阅那那个主题。      Subscribe:持久化订阅者,当订阅才上线订阅消息时,持久化订阅关系,供离线检测之用。      Unsubscribe:持久化取消订阅,当订阅者退订消息时,从持久化订阅关系之中删除。      Write:当订阅者离线时,把订阅消息写入持久化存储。      Read:当离线订阅者上线时,从持久存储之中读取一条消息向其发送。      ISubscribeStorager:可以选择自己实现这个接口,以建立满足自己规则的离线存储机制,当然在AgileEAS.NET SOA 中间件之中提供了两种离线存储机制,存储于数据库和存储于MSMQ,下面向大家介绍一下这两种内置实现。 四、两种内置离线存储机制      在AgileEAS.NET SOA 中间件平台之中提供了两个ISubscribeStorager的实现,基于数据库的离线订阅存储实现EAS.Messages.DbSubscribeStorager和基于MSMQ的离线订阅存储实现EAS.Messages.MsmqSubscribeStorager。      EAS.Messages.DbSubscribeStorager:存储订阅关系在messageSubscribe.Config文件之中,消息存储在关系数据库SOA_SUBSCRIBEEVENTS表之中,使用前必须要建立相应的表结构,以下是SQL Server的DDL脚本: 1: CREATE TABLE [SOA_SUBSCRIBEEVENT]( 2: [GUID] [varchar](36) NOT NULL, 3: [SUBSCRIBER] [nvarchar](128) NOT NULL, 4: [TOPIC] [nvarchar](128) NOT NULL, 5: [BODY] [image] NULL, 6: [FCTIME] [datetime] NOT NULL, 7: CONSTRAINT [PK_SOA_SUBSCRIBEEVENT] PRIMARY KEY CLUSTERED 8: ( 9: [GUID] ASC 10: ) 11: )       目前理论上支持SQLServer 、Mysql、ORACLE、Sqlite四种数据库结构,具体建表脚本请自行参考相应资料书写,也可以使用AgileEAS.NET SOA中间件所提供的数据库初始化工具创建。       EAS.Messages.MsmqSubscribeStorager:存储订阅关系在messageSubscribe.Config文件之中,消息存储Msmq消息队列之中,使用之前请确保机器上安装了MSMQ消息对列。 五、关于自定义实现ISubscribeStorager      有兴趣的朋友可以自定义实现接口ISubscribeStorager,这样就可以按自己的规则进行存储,比如把离线消息存储到mongodb、Redis、或者直接存储在文件之中,或者其他更多的实现规则,在此就不一一介绍,如有相关兴趣,请联系作者,如确有必要需要给在家介绍一下如何实现,将会另开一文本介绍如何自定义实现ISubscribeStorager接口。 六、改进在线例子支持离线      还是跟上次一样,以案例为在家展示一下怎么进行离线消息,就不重新开始例子,对原有例子做一些改进,改进后例子如下:      其中在原有项目的基础上增加了:Demo.Subscriber1和Demo.Subscriber2项目,其项目配置代码、配置文件基本上同Demo.Subscriber一样,其中唯一的差别在于,Demo.Subscriber1和Demo.Subscriber2向服务器提交订阅的时候都增加一个另friendName参数,其使用IMessageBus接口的以下订阅函数: 1: /// <summary> 2: /// 订阅消息。 3: /// </summary> 4: /// <param name="subscriber">订阅者。</param> 5: /// <param name="friendName">订阅者名称,用于处理离线订阅。</param> 6: /// <param name="topic">主题。</param> 7: /// <param name="notifyHandler">订阅通知。</param> 8: void Subscribe(object subscriber,string friendName ,string topic, MessageNotifyHandler notifyHandler);                 Demo.Publisher项目为发布者代码。                 Demo.Subscriber项目为订阅者代码。                 Demo.Server项目为服务端代码。      Demo.Subscriber1项目之中,其Program.cs代码如下: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Windows.Forms; 5: using EAS.Messages; 6:  7: namespace Demo.Subscriber1 8: { 9: class Program 10: { 11: static void Main(string[] args) 12: { 13: var container = EAS.Objects.ContainerBuilder.BuilderDefault(); 14: var bus = container.GetComponentInstance("MessageBus") as IMessageBus; 15: System.Console.WriteLine("Subscriber1"); 16:  17: bus.Subscribe(new Program(), "Subscriber1", Demo.Messages.Topics.DEMO_TOPIC, MessageNotify); 18: System.Console.ReadLine(); 19: } 20:  21: static void MessageNotify(object m) 22: { 23: Demo.Messages.Message message = m as Demo.Messages.Message; 24: System.Console.WriteLine(string.Format("Subscribe:{0}", message.ID)); 25: } 26: } 27: }      其中bus.Subscribe(new Program(), "Subscriber1", Demo.Messages.Topics.DEMO_TOPIC, MessageNotify);在订阅消息的时候给了一个friendName为Subscriber1,Demo.Subscriber2与Demo.Subscriber1项目的唯一的差别就是此处为Subscriber2.      我们使用内置的EAS.Messages.DbSubscribeStorager,则不需要修改服务端的代码,只需要修改服务端的配置文件如下: 1: <?xml version="1.0" encoding="utf-8"?> 2: <configuration> 3: <configSections> 4: <section name="eas" type="EAS.ConfigHandler,EAS.MicroKernel" /> 5: </configSections> 6: <startup useLegacyV2RuntimeActivationPolicy="true"> 7: <supportedRuntime version="v4.0"/> 8: </startup> 9: <eas> 10: <objects> 11: <!--数据库连接--> 12: <object name="DbProvider" assembly="EAS.Data" type="EAS.Data.Access.SqlClientDbProvider" LifestyleType="Thread"> 13: <property name="ConnectionString" type="string" value="Data Source=.;Initial Catalog=eas_db;Integrated Security=SSPI;Connect Timeout=30" /> 14: </object> 15: <!--数据访问器--> 16: <object name="DataAccessor" assembly="EAS.Data" type="EAS.Data.Access.DataAccessor" LifestyleType="Thread"> 17: <property name="DbProvider" type="object" value="DbProvider"/> 18: <property name="Language" type="object" value="TSqlLanguage"/> 19: </object> 20: <!--ORM访问器--> 21: <object name="OrmAccessor" assembly="EAS.Data" type="EAS.Data.ORM.OrmAccessor" LifestyleType="Thread"> 22: <property name="DataAccessor" type="object" value="DataAccessor"/> 23: </object> 24: <!--查询语言--> 25: <object name="TSqlLanguage" assembly="EAS.Data" type="EAS.Data.Linq.TSqlLanguage" LifestyleType="Thread"/> 26: <!--消息持久化--> 27: <object name="SubscribeStorager" assembly="EAS.SOA.BootStrap" type="EAS.Messages.DbSubscribeStorager" LifestyleType="Singleton"/> 28: <!--日志管理--> 29: <object name="Logger" assembly="EAS.MicroKernel" type="EAS.Loggers.TextLogger" LifestyleType="Singleton"> 30: <property name="RootPath" type="string" value="G:\App.Work\Pub_Sub\Offline\Publish\logs" /> 31: </object> 32: </objects> 33: </eas> 34: </configuration>      在配置文件的IOC配置之中我们配置了消息存储对象以及其所依赖的数据库访问对象、Linq查询语言表达式,另外需要说明的是,我们需要把配置文件之中所涉及的EAS.Data.dll、EAS.SOA.BootStrap.dll复制到编译输出Publish,这两个文件可以从AgileEAS.NET SOA 中间件平台发布包之中寻找,本案例的下载压碎包之中会包括这两个文件。      有关于基于Msmq的配置,只需要修改配置文件如下: 1: <?xml version="1.0" encoding="utf-8"?> 2: <configuration> 3: <configSections> 4: <section name="eas" type="EAS.ConfigHandler,EAS.MicroKernel" /> 5: </configSections> 6: <startup useLegacyV2RuntimeActivationPolicy="true"> 7: <supportedRuntime version="v4.0"/> 8: </startup> 9: <eas> 10: <objects> 11: <!--消息持久化--> 12: <object name="SubscribeStorager" assembly="EAS.SOA.BootStrap" type="EAS.Messages.MsmqSubscribeStorager" LifestyleType="Singleton"/> 13: <!--日志管理--> 14: <object name="Logger" assembly="EAS.MicroKernel" type="EAS.Loggers.TextLogger" LifestyleType="Singleton"> 15: <property name="RootPath" type="string" value="G:\App.Work\Pub_Sub\Offline\Publish\logs" /> 16: </object> 17: </objects> 18: </eas> 19: </configuration>      到此为止,所有代码均已完成,是不是很简单,接下来,我们跑起来验证一下效果。 七、验证效果      我们在编译输入目录Publish下先启动Demo.Server.exe,再各启动Demo.Subscriber.exe、Demo.Subscriber1.exe、Demo.Subscriber2.exe,再启动一个Demo.Publisher.exe,在Demo.Publisher.exe控制台按回车键: 目前程序三个订阅者都是在线的,Demo.Publisher发布了三条消息,三个订阅者都收到了三条消息,那么我们关闭Demo.Subscriber2之后再由Demo.Publisher发布两条消息: 然后我们再启动Demo.Subscriber2,看是否还能收到其离线之后由Demo.Publisher发布的两条消息: OK,到此为止。 八、源代码下载      本程序的源代码已上传到服务器,请通过http://112.74.66.105/downloads/eas/Demo.Pub_Sub_Offline.rar进行下载,如果在开发过程之中想要了解更多有关Socket通信框架以及更多AgileEAS.NET SOA中间件平台的技术资源,请通过AgileEAS.NET SOA 网站:http://www.smarteas.net的最新下载栏目进行下载。   九、问题反馈      麻烦大家在通过视频进行学习的时候能及时把问题反馈给楼主,或者有什么需要改进的一些建议都请向楼主直接反馈,以下是联系方式: AgileEAS.NET SOA 网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com 楼主QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 120661978(AgileEAS.NET 平台交流)/上限1000人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

C# | ESB | Socket | 通信框架 | 消息中间件 | 中间件

零基础30分钟开启你的AgileEAS.NET SOA 中间件平台开发之旅

by 魏琼东 2014.4.25 11:20
接触AgileEAS.NET SOA 中间件平台(以下简称EAS.NET平台)有4个多月时间,经过试用认为可以把它作为一个开发的基础平台,开发团队可以把开发的重点放在需求的把控和项目的交付上,从而节省大量的时间,提高项目的开发、交付效率,降低对项目团队的深层技术要求,更重要的一点是EAS.NET平台的开发团队持续不断地维护和改进平台以及对反馈问题的快速反应,使我对平台的持续发展充满信心。

由于EAS.NET平台的资料比较多,需要花费较多的时间才能够初步了解平台并能够使用平台开始开发,所以,在此,我把学习EAS.NET平台的过程总结了一下,形成本篇短文,希望能够让初次接触EAS.NET平台的朋友能够用30分钟时间,跟着本文案例实际操作一遍,对EAS.NET平台有一个真实的体验,节省大家的时间,也算对EAS.NET平台的一点回报,希望有更多的人了解它的优势并真正用好它,为EAS.NET平台的使用者带来价值,也为EAS.NET平台的开发者带来效益,最终实现合作共赢的美好结局。 [更多...]

Tags:

.NET | C# | ESB | SOA | Socket | WCF | 三层架构 | 中间件 | 云计算 | 平台 | 应答 | 报表 | 权限 | 框架 | 模块 | 用户 | 负载均衡 | 通信框架

3小时搞定一个简单的MIS系统案例Northwind,有视频、有源代码下载、有真相

by 魏琼东 2014.4.14 14:09
一、瞎扯框架、架构      楼主自从1998年从C语言、MASM、Foxbase开始学计算机开始接触这个行当16年以来,2001年干第一份与程序、软件、然后是各种屌的东西开始,差不多干了13年了,这13年来,用过VF\VC\VB\C#搞过N多N多的项目,记得在2002年、2003年那个疯狂并且操蛋的年代,在整天VB代码与各种SQL、各种Bug、各种需求敲打、各种吐血的需求变更、各种大半夜还坐在医院的小板凳的加班与折磨之中,慢慢的学会去思考,他妈的这是为什么,写了程序那么的折磨人,从那时开始,就接触各种软件工程相关的东西,思考着是否可以发现能解决或者改变这种现关的东西,记得那个时间好像挺流行一本书,叫《银弹》,在那个年龄,也尝试对需求、变更进行控制和管理,但是在野蛮生长的中国软件业,用户这个上帝才是帮一位的,我们也尝试使用VB+COM/COM+进行加载和框架的提练,进行某些代码和架构级别的规范,试图使用那些技术去实现分布式架构的应用,以及通过插件机制去实现对需求的小范围控制,只是基于那些机制的先天不足和营养不良的环境,对项目与企业的现状改变不是多少。      在厌烦了VB开发之后,楼主也接触了Java,只是接触,没有做过多少开发,能大概看明白什么个意思,总体上来说,不是很喜欢基于Java开发,其中的原因第一是楼主在那个年代做的是CS类的MIS类应用,其实就是一直在做医疗行业的应用,Java做CS简直是弱爆了,再一个java IDE也直接太弱爆了,楼主是懒惰的一个人,不喜欢用记事本那种比较装的干法去写高深的代码。      2004年接触VS2003之后发现简直是找到了自己喜欢的东西了,VS2003配置.net1.1,也提供了简单的WebService和.NET Remoting技术,简直让以前在VB时候梦寐以求却难以搞定的机制就非常简单的实现了,.net所提供的反射机制可以实现很简单的插件开发,从那个时间起,楼主就写出了AgileEAS.NET SOA中间件平台的最初始版本,一个简单的winfrom插件平台。      从2004年到2014年,差不多快10年的时间,楼主也像所有的程序员一样,把AgileEAS.NET SOA当自己的宝贝一样的,升级、增加新的东西,早期关注各种IOC、各种AOP、各种ORM、各种通信等基础类的东西,2010年底专职从事咨询服务工具,为各种规模、各种业务的软件商提供框架定义、技术咨询服务、医疗行业业务咨询服务等服务。      也是自2011年之后对什么框架、什么架构、什么应用商店、各种云架构有了更简单的认识,整天没事扯架构、扯框架的人,或许压根就不知道什么是框架、什么是架构,架构、框架不是各种空泛的理论和各种看似华丽的词汇,架构或者框架、平台应该是一类能帮助开发人员、开发商提高效能的东西,好的框架一定是简单好用的,那怕是功能不是很强,也比较单一,但一定要好用,另外一个,框架或者架构一定要配合相应的工具,就比如.NET的种类库如果没有VS开发环境的配合,估计就是一堆废柴。      在很多人看来,能写框架、平台、架构的人都是牛人,实际上这是一个误导,写框架的人不一定是技术上的牛人,一个框架、平台、架构上没有什么多少高深的技术,比如做插件框架的,就一个简单的反射技术,相信一个C#程序员,用一周时间足够搞的很清楚了,再比如ORM框架,也没有什么高深的技术,动态拼接SQL加上动态反射创建实体,所以说从技术层面上来讲,写一个框架、类库不需要多少技术,因为这些东西都 是现成的并且可以你很容易找到。      但是一个好的框架或者平台,一定会有其配合很好的工具,比如对象建模工具、界面设计工具、文档生成工具、代码生成工具,以及相关的配置、管理、通信、监控工具,一个平台或者一个架构的生产力一方面体现在框架所提供的那引起基础类库所建立的规范,另一个很重要的原因是其配置工具所提供的快速开发能力是极其重要的,或者说一个框架是否能被应用的广泛,工具所带来的用处远远大于基础类库所提供的功能。      能写好一个优秀的框架并能提供大量、可用、好用的框架开发才不一定是技术上的牛人,但一定是对软件工程管理、企业软件生产组织模型或者某一业务领域的业务经验一定有其独到的理解,其框架之中所倾注的业务与软件工程管理经验才是框架作者最宝贵的财富,经验需要日积月累,可不是一天两天能练成的,不管在任何行业、经验都是非常值钱的东西。 二、3小时完成一个Northwind案例      在最近的一段时间之内,群里的好多朋友都希望我能给大家通过视频展示一下AgileEAS.NET SOA 中间件快速开发的相关技术,以便让更多的朋友学习和参考,但是一直忙于客户的各种项目、各种咨询服务以及家中的一些杂事,给大家拖了好久,拖的实在我都有点不好意思了,所以在上周做了一点准备,原本是想在原DrugShop的案例上进行,但是有朋友建议,在原项目基础上做,可以不一定让大家从头了解和从头开始学习、配置和如何从一个空白建立一个新的项目。      经过一些了解之后我们决定从SQLServer数据库所提供的案例Northwind基础上做一些简化和改动,为什么要使用Northwind案例呢,主要原因是其设计比较规范,了解和熟悉的人也非常的多,便于大于理解其业务需求。      楼主对Northwind做了一些简单的改进,主要是那方面的改进呢:        1)原来的Northwind主要重点再于客户和销售的管理,对采购入库业务处理的不是很好。        2)原来的Northwind对库存管理做的比较弱。        3)简化了原Northwind的客户、和销售管理,删除了对销售订单的区域等参数。        修改完成的Northwind主要提供了以下两大业务模型,采购入库业务:        销售订单业务:      Northwind的设计准备是前一天做好的,然后楼主通过YY为大家提供现场的快速开发培训,边讲角边做开发,从生成代码到第一个手工完成业务模块“商品分类”、“商品字典”、使用界面生成器生成了两个业务模块“员工管理”、“客户管理”,一直做到“采购入库”、“采购入库查询”、“库存查询”、“销售订单业务”一共8个模块,涉及数据查询、界面编辑、分层业务模型、输入字典、报表设计、检点控件挑战、输入焦点变色、文本输入验证等大量的工具、控件及相关技术,理论上已经完成了Northwind案例的所有业务,当然如果要完美的话可以增加“收支报表”、“销售订单查询”、以及界面的美化,界面验证的完善。      希望群里和各位朋友Northwind例没有完成的工具去做一做,把他做完,这一定是一个非常不错的项目模板,以下是几个做好的界面: 三、源代码、视频下载      在培训过程之中,楼主全程开启录相,录了大概。2.1G的高清视屏,目前已经全部上传在百度网盘和我们的服务器,源代码已经上传到我们的SVN服务器和下载服务器,请大家下载视频和源代码,视频时长4小时,请大家耐性观看。      视频下载地址,百度云:http://pan.baidu.com/s/1qW79ack      官网服务器:1.AgileEASNET SOA 5平台配置.avi                      2.AgileEAS.NET SOA 5元数据设计器.avi                      3.Northwind.WinForm案例.第1段.avi                      4.Northwind.WinForm案例.第2段.avi                      5.Northwind.WinForm案例.第3段.avi                      6.Northwind.WinForm案例.第4段.avi      源代码下载,源代码请通过AgileEAS.NET SOA 中间件平台官方网站下载,或者通过以下方式下载:      直接下载:AgileEAS.NET SOA  案例(Northwind)源码下载,http://112.74.66.105/downloads/eas/Northwind.rar。      SVN更新:https://112.74.66.105/svn/Northwind,登录用户:eas,密码eas. 四、问题反馈      麻烦大家在通过视频进行学习的时候能及时把问题反馈给楼主,或者有什么需要改进的一些建议都请向楼主直接反馈,以下是联系方式: AgileEAS.NET SOA 网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com 楼主QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 120661978(AgileEAS.NET 平台交流)/上限1000人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。      另外,楼主将会不定期的通过YY举办类似本次活动的培训,所以麻烦大家都关注一下YY频道:65011880,也可以加一下楼主YY号:537601972。

Tags:

SOA | ActiveX | AgileEAS.NET | 三层架构 | C# | AppServer | 角色 | 设计模式 | 通信框架 | 框架

拉风的应用程序服务器监控工具,随便掌握服务器动态,AgileEAS.NET SOA 中间件应用程序服务器监控工具集介绍

by 魏琼东 2013.12.19 21:55
一、前言      AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队,以达到节省开发成本、缩短开发时间,快速适应市场变化的目的。      AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践,通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系,以及提供了大量的实体、数据模型设计生成工具、代码生成工具,用于帮助中小软件开发商快速成长。      AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势,基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践,采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想,帮助软件企业实现“敏捷变化、快速适合”的目标,从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。 二、AgileEAS.NET SOA中间件的分布式结构      AgileEAS.NET SOA中间件平台吸吸引人的一个特色就是其分布式架构体系,其可以基于高层的WCF协议和底层的.NET Socket通信建设统一一致的分布式通信服务,如下图所示的分布式结构:        系统中所有的客户端业务处理请求都经由AppServer处理之后返回结果给客户端,这个一个极其经典的SOA架构的分布式结构。      当系统的业务运行量大到一台AppServer无法满足情况下,那么我们就要考虑纵向扩展或者横向扩展以满足系统性能和业务响应的问题,最常用的选择是横向扩展,使用负载均衡机制以确保业务请求由多台AppServer完成;以及对系统的可靠性要求很高的时候,因为只有一台AppServer如果AppServer宕机了,那么整个系统都无法运行。我们就必须的考虑整个系统的故障切换能力,以确定系统的高可用性,系统的架构就会衍生为以下结构:      可以对比发布,前面架构图之中的AppServer已经由一台NlbServer和多台AppServer组成的服务器组合替换,系统之中不再存在当AppServer宕机之后系统无法服务的问题,也解决了随着业务量增加动态扩容的问题。 三、AgileEAS.NET SOA平台服务监控工具      为了方便系统维护人员,我们为AgileEAS.NET SOA中间件平台应用程序服务AppServer和负载均衡服务NlbServer提供了强大的可视化远程监控工具,让系统维护人员可以方便的通过远程监控工作进行监控。      应用程序服务监控工具为EAS.SOA.Monitor.exe应用程序:      其主要提供以下监控参数:      服务器资源监控:服务器CPU、内存、磁盘读取、网络通信等重要的服务器资料的实时监控及历史监控曲线图,如上图。      Socket服务监控:监控AppServer的Socket通信服务参数的各种状态,包括并发连接数、数据发送和接收速度:      WCF服务监控:监控AppServer的WCF通信服务参数的各种状态,包括实时服务调用、最大并发、服务实例、累计服务调用次数等:      应用服务监控,监控AgileEAS.NET SOA服务的并发调用和累计调用:     负载均衡服务监控工具为EAS.NLB.Monitor.exe应用程序:      其提供的监控功能和监控参数同应用程序服务监控工作提供的类型,都提供了服务器资源监控、WCF服务监控、Socket通信监控,不一样的是负载均衡服务提供了对负载简单应用程序服务器的状态监控: 四、如何操作服务监控      不管是应用程序服务监控还是负载均衡服务监控,启动监控程序之前都需要使用监控客户端连接到用程序服务或者负载均衡服务。          初始的监控程序需要通过服务连接登录界面新建一个服务监控连接,弹出新建连接对话框:     监控连接参数主要由服务器的IP地址及所开放的端口决定,WCF或者Socket,应用程序服务监控工作提供WCF和Socket的连接,而负载均衡服务监控仅提供WCF形式的连接。     当创建好监控连接之后,下一次使用的时候就不需要再次配置监控连接信息了,只需要在服务连接下拉列表框中选择合适的的连接信息即可:     我们计划为监控程序提供一个动态的连接密钥或者证书验证机制,以便阻止非授权的监控连接请求,但是目前还没有启动连接密钥或者安全证书,在稍后的不久我们将会为大家提供这方面的功能。 五、联系我们      为完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET SOA中间件平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

高并发应用场景下的负载均衡与故障转移实践,AgileEAS.NET SOA 中间件负载均衡服务介绍与实例

by 魏琼东 2013.12.19 18:59
一、前言      AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队,以达到节省开发成本、缩短开发时间,快速适应市场变化的目的。      AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践,通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系,以及提供了大量的实体、数据模型设计生成工具、代码生成工具,用于帮助中小软件开发商快速成长。      AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势,基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践,采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想,帮助软件企业实现“敏捷变化、快速适合”的目标,从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。 二、关于AgileEAS.NET SOA中间件的分布式结构      AgileEAS.NET SOA中间件平台吸吸引人的一个特色就是其分布式架构体系,其可以基于高层的WCF协议和底层的.NET Socket通信建设统一一致的分布式通信服务,如下图所示的分布式结构:        系统中所有的客户端业务处理请求都经由AppServer处理之后返回结果给客户端,这个一个极其经典的SOA架构的分布式结构。      当系统的业务运行量大到一台AppServer无法满足情况下,那么我们就要考虑纵向扩展或者横向扩展以满足系统性能和业务响应的问题,最常用的选择是横向扩展,使用负载均衡机制以确保业务请求由多台AppServer完成;以及对系统的可靠性要求很高的时候,因为只有一台AppServer如果AppServer宕机了,那么整个系统都无法运行。我们就必须的考虑整个系统的故障切换能力,以确定系统的高可用性,系统的架构就会衍生为以下结构:      可以对比发布,前面架构图之中的AppServer已经由一台NlbServer和多台AppServer组成的服务器组合替换,系统之中不再存在当AppServer宕机之后系统无法服务的问题,也解决了随着业务量增加动态扩容的问题。 三、AgileEAS.NET SOA平台NLB支持      AgileEAS.NET SOA中间件平台的AppServer支持程序为EAS.SOA.Server.exe或EAS.SOA.Server.x64.exe,其中EAS.SOA.Server.exe为32位服务程序,EAS.SOA.Server.x64.exe为64位服务程序。      AppServer能在同一个进程之内同时支持Socket通信和WCF通信,即能同样的业务同步提供Socket和WCF通信方式,WCF通信提供http和net.tcp通道的访问,客户端应用使用何种通信方式由客户段程序决定。      AgileEAS.NET SOA中间件平台的在5.0版本之后增加了一个应用负载均衡服务程序EAS.NLB.Server,也同样提供了32位与64位的服务应用程序EAS.NLB.Server.exe或EAS.NLB.Server.x64.exe。      在AgileEAS.NET SOA中间件平台5.0版本之中为AppServer、NLB.Server提供了运行监控程序,NLB.Server的服务监控程序同时提供了NLB.Server的配置管理功能:      负载节点监控,会监控NLBServer后挂接的所有AppServer清单以及各个AppServer服务器的工作状态,是在线还是离线,在线的则能向客户端提供服务,如果离线了则表示不能向客户端提供服务了,在NLBServer负载过程之中,只会在在线的AppServr之间进行负载。 四、AgileEAS.NET NLBServer配置案例      在第三节我们已经对NLB做过一些简单的介绍,接下来我们以DrugShop案例环境为基础实例演示一下如何在应用环境之中启用NLBServer支持:      首先我们简单规划一下测试环境:      接下为我们一一配置,首先,我们参考AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二):配置WinClient分布式运行环境一文配置好一个AppServer实例AppServer1,端口号设置Socket:6706,Wcf-tcp:6707,Wcf-http:6708: 1: <appserver> 2: <channel> 3: <wcf enable="true"> 4: <config tcpPort="6707" httpPort="6708"/> 5: <serviceThrottling maxConcurrentCalls="128" maxConcurrentInstances="128" maxConcurrentSessions="256"/> 6: <wcfServices> 7: <wcfService key="Key" type="TValue"/> 8: </wcfServices> 9: </wcf> 10: <socket enable ="true"> 11: <config tcpPort="6706"/> 12: <serviceThrottling maxConcurrence="1024"/> 13: <socketServices> 14: <socketService key="IMSocketService" type="AgileIM.Service.IMSocketService,AgileIM.Service"/> 15: </socketServices> 16: </socket> 17: </channel> 18: <appServices> 19: <appService key="Key" type="TValue"/> 20: </appServices> 21: </appserver>      然后复制配置好的AppServer目录到其他地方建立AppSerer2,端口信息修改为Socket:6706,Wcf-tcp:6707,Wcf-http:6708: 1: <channel> 2: <wcf enable="true"> 3: <config tcpPort="6807" httpPort="6808"/> 4: <serviceThrottling maxConcurrentCalls="128" maxConcurrentInstances="128" maxConcurrentSessions="256"/> 5: <wcfServices> 6: <wcfService key="Key" type="TValue"/> 7: </wcfServices> 8: </wcf> 9: <socket enable ="true"> 10: <config tcpPort="6806"/> 11: <serviceThrottling maxConcurrence="1024"/> 12: <socketServices> 13: <socketService key="IMSocketService" type="AgileIM.Service.IMSocketService,AgileIM.Service"/> 14: </socketServices> 15: </socket> 16: </channel> 17: <appServices> 18: <appService key="Key" type="TValue"/> 19: </appServices> 20: appserver>      同样复制AppServer目录配置NlbServer,NlbServer服务目前没有配置工具,只能自己修改配置文件EAS.NLB.Server.exe.config或者EAS.NLB.Server.x64.exe.config: 1: <?xml version="1.0"?> 2: <configuration> 3: <configSections> 4: <section name="eas" type="EAS.ConfigHandler,EAS.MicroKernel"/> 5: </configSections> 6: <!--支持混合程序集--> 7: <startup useLegacyV2RuntimeActivationPolicy="true"> 8: <supportedRuntime version="v4.0"/> 9: </startup> 10: <eas> 11: <configurations> 12: <item name="Key" value="Value"/> 13: </configurations> 14: <nlbserver> 15: <config> 16: <keepAlive timeSpan="6" chnanel="WCF"/> 17: </config> 18: <channel> 19: <wcf enable="true"> 20: <config tcpPort="6607" httpPort="6608"/> 21: <serviceThrottling maxConcurrentCalls="128" maxConcurrentInstances="128" maxConcurrentSessions="256"/> 22: <wcfServices> 23: <wcfService key="Key" type="TValue"/> 24: </wcfServices> 25: </wcf> 26: <socket enable ="true"> 27: <config tcpPort="6606" gatewayStyle="NetPacket"/> 28: <serviceThrottling maxConcurrence="10000"/> 29: </socket> 30: </channel> 31: </nlbserver> 32: <objects> 33: <!--NLB日志记录--> 34: <object name="Logger" assembly="EAS.MicroKernel" type="EAS.Loggers.TextLogger" LifestyleType="Singleton"> 35: <property name="Path" type="string" value="..\logs" /> 36: </object> 37: </objects> 38: </eas> 39: <startup> 40: <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/> 41: </startup> 42: </configuration>      配置其端口号为6606,Wcf-tcp:6607,Wcf-http:6608,配置完成后参考AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二):配置WinClient分布式运行环境一文编写AppServer服务的安装、卸载和控制台启动脚本。      NLBServer的安装卸载和控制台启动脚本类似,都是由EAS.NLB.Server.exe -参数组成,只不过,EAS.NLB.Server只能支持在一台服务器安装一个实例,即同一台服务不充许像AppServer一样安装多个实现,以下是脚本示例: 1: @rem 安装NLB服务 2: EAS.NLB.Server.x64.exe -i 3:  4: @rem 卸载NLB服务 5: EAS.NLB.Server.x64.exe -u 6:  7: @rem 控制台启动NLB服务 8: EAS.NLB.Server.x64.exe -run 9: pause      OK,我们启动NLBServer和AppServer1、AppServer2:      接下来我们在客户端文件夹之中启动“负载均衡监控”程序EAS.NLB.Monitor.exe配置负载均衡服务的负载节点:     在服务连接之中选择新建连接,弹出新建连接对话框:     修改连接名为nlbServer,服务器为127.0.0.1,即连接本机nlbserver,实际情况之中请根据实际情况配置,端口号填入前面配置的NlbServer端口参数,我们此处选择以wcf-tcp连接,端口配置为6607,然后确定保存配置,并且进入“负载均衡监控”主界面:      “负载均衡监控”第一个界面为负载均衡服务器的CPU、内存、网络、磁盘等各种资源参数,供管理人员参考,我们切换到负载节点监控:      在空白区域右键打开快捷菜单点=>"添加节点":      根据AppServer参数添加负载节点信息,确定后保存负载节点信息,使用同样的方法添加AppSever2节点,完成后如下图:      也可以选择直接修改配置配置负载节点信息,负载节点信息存储在NlbServer工作目录中的“NLB.config”文件: 1: <?xml version="1.0" encoding="utf-16"?> 2: <NLB xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 3: <items> 4: <NlbWorkItem> 5: <host>127.0.0.1</host> 6: <wcfChannel> 7: <HttpPort>6708</HttpPort> 8: <TcpPort>6707</TcpPort> 9: </wcfChannel> 10: <socketChannel> 11: <TcpPort>6706</TcpPort> 12: </socketChannel> 13: <enabled>true</enabled> 14: <runing>true</runing> 15: </NlbWorkItem> 16: <NlbWorkItem> 17: <host>127.0.0.1</host> 18: <wcfChannel> 19: <HttpPort>6808</HttpPort> 20: <TcpPort>6807</TcpPort> 21: </wcfChannel> 22: <socketChannel> 23: <TcpPort>6806</TcpPort> 24: </socketChannel> 25: <enabled>true</enabled> 26: <runing>false</runing> 27: </NlbWorkItem> 28: </items> 29: </NLB>      OK,现在已经完成了对负载均衡的配置,接下来我们配置客户端程序“DrugShop.Main.exe”的连接信息,可以选择由配置工具生成,也可以选择手工书写,定义为SOA分布式环境下wcf-tcp连接,连接端口为127.0.0.1:6607(NLBServer),配置文件如下: 1: <?xml version="1.0" encoding="utf-8"?> 2: <configuration> 3: <configSections> 4: <section name="eas" type="EAS.ConfigHandler,EAS.MicroKernel" /> 5: </configSections> 6: <!--SQLite运行必需--> 7: <startup useLegacyV2RuntimeActivationPolicy="true"> 8: <supportedRuntime version="v4.0"/> 9: </startup> 10: <eas> 11: <configurations> 12: <item name="Key" value="Value" /> 13: </configurations> 14: <objects> 15: <!--分布式通信组件。--> 16: <object name="ServiceBridger" assembly="EAS.Distributed" type="EAS.Distributed.ServiceBridger" LifestyleType="Thread" > 17: <property name="ServiceName" type="string" value="EAS.RMI.Service" /> 18: </object> 19: <object name="DataAccessor" assembly="EAS.Distributed" type="EAS.Distributed.DataAccessor" LifestyleType="Thread" > 20: <property name="ServiceBridger" type="object" value="ServiceBridger" /> 21: </object> 22: <object name="OrmAccessor" assembly="EAS.Distributed" type="EAS.Distributed.OrmAccessor" LifestyleType="Thread" > 23: <property name="ServiceBridger" type="object" value="ServiceBridger" /> 24: <property name="DataAccessor" type="object" value="DataAccessor" /> 25: </object> 26: <!--日志管理--> 27: <object name="Logger" assembly="EAS.MicroKernel" type="EAS.Loggers.TextLogger" LifestyleType="Singleton" /> 28: <!--资源--> 29: <object name="EAS.Explorer.Resource" assembly="DrugShop.Res" type="DrugShop.Res.Resources" LifestyleType="Singleton" /> 30: </objects> 31: <services> 32: <service name="EAS.RMI.Service" service-type="WcfService" singleton="true" url="net.tcp://127.0.0.1:6607/eas/services/EAS.RMIService" /> 33: </services> 34: </eas> 35: </configuration>      OK,客户端程序配置完成。 五、测试验证      启动DrugShop.Main.exe,可以选择启动多个客户端程序实例,可以看到以控制台运行的两个服务实例都有不同程序的请求响应:      我们可以看到,客户端的业务请求被NLBServer进行了有效的负载,当我们随便停止其他任务一个AppServer,我们可以通过“负载均衡监控”程序看到其处于离线状态:      在实际项目之中可以是某一台AppServer宕机了或者人为的进行某种维护升级活动,在这个时间,所有的客户端程序的所有业务操作都是可以的,从这一点我们可以看出,AppServer被NLBServer进行了有效的故障转移,有效的提高了系统的高可用性。      如果所有的AppServer都离线了,即所有AppServer都宕机了,如下图:      那么这个时间,系统就不能提供任务的服务了,当我们在客户端执行任何操作都会报错:      当我们恢复负载之中的任务一个节点之后,系统则可以向使用者提供全部的业务服务。 六、联系我们      为完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET SOA中间件平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

SOA | ESB | 云计算 | 中间件 | 平台 | .NET | 分布式 | 通信框架 | 消息中间件 | 框架 | NLB | AppServer | 应用程序服务 | 三层架构 | 负载均衡

犀利的报表系统,AgileEAS.NET SOA中间件平台GReport使用指南

by 魏琼东 2013.12.18 17:43
一、前言      AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队,以达到节省开发成本、缩短开发时间,快速适应市场变化的目的。      AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践,通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系,以及提供了大量的实体、数据模型设计生成工具、代码生成工具,用于帮助中小软件开发商快速成长。      AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势,基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践,采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想,帮助软件企业实现“敏捷变化、快速适合”的目标,从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。 二、关于GReport、Grid++报表系统      AgileEAS.NET SOA中间件平台目前集成两套优秀的报表系统,一套是开源的fyireporting报表系统3.96版本,其始于2007年AgileEAS.NET SOA中间件平台3.0版本之时就集成入平台的一套报表系统,其快速方便的条带式报表非常适合用于MIS系统的报表展示,我们在fyireporting基础上做了大是的汉化、改动并且与AgileEAS.NET SOA中间件平台进行紧密的集成。      但是对于市场在国内的大多数软件企业都会遇到客户的很多近似于变态的报表需求,fyireporting有也其不足的地方,其在处理中国式的票据、和一个特殊报表时无能无为,之后我们考虑集成一套更好的中国式报表系统,在和几家行业医疗供应商合作的两个年头之中,我们集成广州锐浪的Grid++报表系统并与AgileEAS.NET SOA中间件进行融合,称之为GReport。      AgileEAS.NET SOA中间件平台的报表管理体系并设计为集中式的报表管理、设计与报表浏览、打印相协调的可集中管理的报表体系,极大的简化和方便报表的开发、部署和管理。      在AgileEAS.NET中间件平台之中提供了一个用于管理、和设计GRport的功能模块“GR报表”:      系统之中的所有报表都是可管理的,当在系统的任何一个客户端修改了报表定义之后,不需要重新部署程序,即可让报表的修改通过所有的使用者。即时生效。      在GR报表模块之中,直接双击选中的报表即可进行报表设计界面,进行报表的设计:      GR报表的设计器界面是基于Grid++报表所提供的设计器控件实现的,其使用方法同Grid++原始的报表设计工作,具体的使用方法请参考Grid++官方帮助。      本设计器与官方的原生设计器之间的差别主要是新建报表与原生不同,原生的报表系统只能基于数据库连接和SQL语句创建报表,而本设计器提供了除通过书写SQL创建报表(不用提供连接信息,以当前连接为准)之外还提供了基于AgileEAS.NET SOA中间件平台的ORM实体创建报表:        数据报表即为基于SQL语句创建报表,对象报表基于ORM实体对象创建报表:      当基于实体创建报表时确定报表对应的实体对象之后,系统会自动的从ORM定义信息之中读出实体的属性定义信息并且自动的转换为报表的数据列。 三、GReport组件      AgileEAS.NET SOA中间件平台为开发人员提供了三个有关于GReport报表的控件,包括打印预览对话框、报表数据显示控件、报表打印控件,这三个控件都由EAS.GReport.Controls.dll程序集承载,使用这三个组件之前都需要先引用EAS.GReport.Controls.dll程序集或者把这三个组件加载到Visual Studio的工具箱之中。      打印预览对话框: EAS.GReport.Controls.PrintViewDialog,用于打开一个新的窗口并且预览打印报表。      报表查询显示控件: EAS.GReport.Controls.GDisplayViewer,以查询模式显示报表及报表数据的一个控件。      报表预览显示控件: EAS.GReport.Controls.GPrintViewer,以打印模式显示报表及报表数据的一个控件。      以上三个控件都提供相同的报表API: 1: // 2: // 摘要: 3: // 报表ID。 4: [DesignerSerializationVisibility(DesignerSerializationVisibility.Hidden)] 5: [Browsable(false)] 6: public Guid ReportID { get; set; }      属性ReportID:其意思为报表ID,其取值为GR报表模块之中设计好的报表ID号,用于实现与系统报表管理的绑定。 1: // 2: // 摘要: 3: // 数据源对象。 4: [DesignerSerializationVisibility(DesignerSerializationVisibility.Hidden)] 5: [Browsable(false)] 6: public object DataObject { get; set; }      属性DataObject:其意义为报表的数据对象,即控件要显示或者打印的数据源,DataObject的值必须为DataTable或者为ORM实体的List<T>集合。      程序之中调用报表的流程即为设计这两个属性即可,首先设计ReportID为要显示、打印的报表ID,然后向控件设置报表的显示数据源DataObject即可完成对报表系统的调用。 四、报表开发实例      我们下面以DrugShop案例之中的药品字典模块的字打印实例如何进行GReport报表开发:      首先我们需要在GR报表模块之中增加一个名称为“药品字典明细报表”的报表项目。      报表名称必须要填写并且不能重名,别名可以选择填写,缓存间隔默认为15分种,最小1分种,自由设定,原则上在系统开发测试阶段设小一些,在稳定运行阶段设大一些。      其他参数,如“报表模块,把报表做为独立模块发布”、查询语句、查询参数可以不去理会,这些参数为动态报表提供,关于动态报表我们会在后面的文章之中进行专门的介绍。      然后我们点“确定”按钮保存报表进行下一步的报表设计工作。      双击我们刚才添加的“药品字典明细报表”进入报表设计界面,我们可以看到这是一个空报表:      选择“文件”菜单之中的“新建”=》“对象报表”:        切换到数据定义Tab页,进行实体类型的选择:      我们浏览选择程序集DrugShop.Entitties.dll,然后在对象下拉列表框中选择DrugShop.Entitties.PIn,即药品入库ORM对象,我们基于DrugShop.Entitties.PIn创建报表,点击“确定”完成报表的新建。      系统会自动的更具新建导向生成一个初始报表,如果需要对报表的显示、格式进行调用,请参考Grid++设计手册进行学习。      修改完成之后,点击“保存”图标、或者“文件=》保存”菜单项保存报表的格式定义,这样就完成了报表的定义。      接下来我们需要把刚才定义、设计好的报表挂在程序之中,使用Visual Studio 打开DrugShop解决方案,打开DrugShop.WinUI项目之中的药品字典模块DrugDictList.cs:      双击“打印”按钮写以下打印代码: 1: private void tsbPrint_Click(object sender, EventArgs e) 2: { 3: if (this.dictList != null) 4: { 5: EAS.GReport.Controls.PrintViewDialog ViewDialog = new EAS.GReport.Controls.PrintViewDialog(); 6: ViewDialog.ReportID = new Guid("F29C4C91-0791-4116-BE26-3A2A88F30A2A"); 7: ViewDialog.DataObject = this.dictList; 8: ViewDialog.StartPosition = System.Windows.Forms.FormStartPosition.CenterScreen; 9: ViewDialog.WindowState = System.Windows.Forms.FormWindowState.Maximized; 10: ViewDialog.ShowDialog(); 11: } 12: }      这样我们就完成了对报表的调用,另外,在DrugShop案例之中,药品入库查询和药品销售查询两个模块之中分别使用了GReport报表,请大家在开发过程之中参考。 五、执行验证      我们编译并且启动DrugShop.Main.exe,使用0001密码sa登录,打开药品字典功能,来试一下是报表是否正常:      OK,使用正常,没有任何问题。      DrugShop案例之中同步提供了本例子的字典定义和使用代码,请大家通过AgileEAS.NET SOA中间件官方网站的最新下载栏目进行下载。 六、联系我们      为完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET SOA中间件平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

.NET | AgileEAS.NET | C# | ORM | SOA | Socket | 分布式 | 企业服务总线 | 企业应用架构 | 框架 | 消息中间件 | 通信框架 | 报表 | BI

如何使用DotNetBar制作漂亮的WinFrom界面,同步学习如何自定义AgileEAS.NET SOA中间件平台WinClient主界面

by 魏琼东 2013.12.17 18:11
一、前言      AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队,以达到节省开发成本、缩短开发时间,快速适应市场变化的目的。      AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践,通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系,以及提供了大量的实体、数据模型设计生成工具、代码生成工具,用于帮助中小软件开发商快速成长。      AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势,基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践,采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想,帮助软件企业实现“敏捷变化、快速适合”的目标,从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。 二、关于WinClient的外挂资源体系介绍      最初版本的AgileEAS.NET SOA中间件平台的运行容器/外壳是没有界面替换体系,最初只是提供了替换关键部分的图片、文字的功能,随着AgileEAS.NET SOA中间件被众多的客户应用到各行各业之后,我们从客户的应用反馈之中进行了大量的重构,其中运行容器也越来越开放,从最初令开放替换部分图片到慢慢开放可以自由修改其他的导航栏、Banner、状态栏、菜单、登录界面、关于界面,发生了很大的变化,同步我们也提供了Desktop、MDI、Dockable等多种界面风格,可以说客户有更我的选择了。      随着更多软件企业或组织加入应用AgileEAS.NET SOA中间件行业,有许多的客户已经不能满足于在这几种风格之中进行选择,希望能给自己最大的自定义空间和范围,提供了更换主界面的需求,我们积极的响应这种需求,并且提出了相关的解决方案,并且在2012年AgileEAS.NET SOA 5.0版本的时间向大家提供。      主界面替换被某一些我们服务于的客户所使用,但是对于广大的关心AgileEAS.NET SOA中间件的朋友来说,并不能得到我们细致并且一对一的服务,因为我们还没有变此部分内容给大家做过介绍和在公开的案例之中提供,所以对于社区之中的很多朋友来说,还能灵活的应用本部分内容。      下图是一个典型的AgileEAS.NET SOA中间件平台WinClient容器的主界面:      其中包含以下组成部分:      主菜单:界面最上部的主菜单,系统、视图和帮助。      导航菜单:通过菜单之中的菜单项可以打开指点的功能模块。      导航栏:同系统导航菜单、以树形或者其他形式展示。      状态栏:显示系统的一些状态信息,如操作消息、当前登录信息等。      内容区:除以上项目外的界面空白区域为业务工作区,即模块插件的工作区域,新打开的模块在经区域显示和工作。      启始页:特指工作区之中第一个打开的模块,当系统登录完成之后会自动打开一个模块,此模块称为起始页模块。 三、IResource接口      AgileEAS.NET SOA 中间件平台为了应用对运行容器的各个部分进行自定义和扩展,提供了一个资源接口IResource: 1: using System; 2:  3: namespace EAS.Explorer 4: { 5: /// <summary> 6: /// 运行容器的外壳资源。 7: /// </summary> 8: public interface IResource 9: { 10: /// <summary> 11: /// 获取应用系统的图标,用于替换主界面的图标。 12: /// </summary> 13: System.Drawing.Icon GetMainIcon(); 14:  15: /// <summary> 16: /// 获取默认的模块图标,用于简约、经典风格的Tab页图标显示,也用于Desktop模式的桌面图标显示。 17: /// </summary> 18: System.Drawing.Image GetModuleIcon(); 19:  20: /// <summary> 21: /// 获取桌面背景图像,用于Desktop模式的桌面模块。 22: /// </summary> 23: System.Drawing.Image GetDesktopImage(); 24:  25: /// <summary> 26: /// 获取应用系统的导航控件,用于替换平台的导航控件。 27: /// </summary> 28: /// <returns>WinForm/WPF用户控件。</returns> 29: object GetNavigationControl(); 30:  31: /// <summary> 32: /// 获取应用系统的Banner控件,用于替换平台的Banner条。 33: /// </summary> 34: /// <returns>WinForm/WPF用户控件。</returns> 35: object GetBannerControl(); 36:  37: /// <summary> 38: /// 获取应用系统的Bottom控件,用于替换平台的状态栏。 39: /// </summary> 40: /// <returns>WinForm/WPF用户控件。</returns> 41: object GetBottomControl(); 42:  43: /// <summary> 44: /// 获取WinForm/WPF容器的关于对话框,用于替换平台的关于对话框。 45: /// </summary> 46: /// <returns>WinForm/WPF窗体。</returns> 47: object GetAboutForm(); 48:  49: /// <summary> 50: /// 获取WinForm/WPF容器的主界面,用于替换平台的主界面。 51: /// </summary> 52: /// <returns>WinForm/WPF窗体。</returns> 53: object GetMainShell(); 54:  55: /// <summary> 56: /// 获取WinForm/WPF/Silverlight容器的登录对话框,用于替换平台的登录对话框。 57: /// </summary> 58: /// <returns>WinForm/WPF/Silverlight窗体。</returns> 59: ILoginForm GetLoginForm(); 60:  61: /// <summary> 62: /// 获取WinForm/WPF容器的起始页/初始模块,用于替换平台的起始页。 63: /// </summary> 64: /// <returns>WinForm/WPF用户控件。</returns> 65: object GetStartModule(); 66:  67: /// <summary> 68: /// 获取系统的名称,显示在运行环境的导航栏。 69: /// </summary> 70: /// <returns>应用系统名称。</returns> 71: string GetApplicationName(); 72:  73: /// <summary> 74: /// 获取系统的标题,显示在运行环境的主窗口之上。 75: /// </summary> 76: /// <returns>应用系统名称。</returns> 77: string GetApplicationTitle(); 78:  79: /// <summary> 80: /// 是否显示主菜单。 81: /// </summary> 82: bool DisplayMainMenu 83: { 84: get; 85: } 86:  87: /// <summary> 88: /// 是否显示导航工具条。 89: /// </summary> 90: bool DisplayNavigationTool 91: { 92: get; 93: } 94: } 95: }      实现AgileEAS.NET SOA 平台的资源替换即是实现IResource接口的过程,在我们DrugShop、SmartERP案例之中都有对应的实现项目DrugShop.Res和SmartERP.Res。      当然,光实现IResource还不购,还需要修改系统的配置文件,以便让资源生效: 1: <;!--资源--> 2: <object name="EAS.Explorer.Resource" assembly="DrugShop.Res" type="DrugShop.Res.Resources" LifestyleType="Singleton"/>      需要注意的是在EAS.Explorer.dll程序集之中还定义了以下两个接口,INavigation接口: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Text; 5: using System.Text.RegularExpressions; 6: 7: namespace EAS.Explorer 8: { 9: /// <;summary> 10: /// 导航控件接口。 11: /// <;/summary> 12: public interface INavigation 13: { 14: /// <;summary> 15: /// 初始化导航。 16: /// <;/summary> 17: /// <;param name="m_GroupList">导航清单。</param> 18: /// <;param name="m_ModuleList">模块清单。</param> 19: void Initialize(IList<;INavigateGroup> m_GroupList, IList<INavigateModule> m_ModuleList); 20: } 21: }      ILoginForm接口: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Text; 5:  6: namespace EAS.Explorer 7: { 8: /// <;summary> 9: /// 定义登记对话框接口,用于实现自定义登录。 10: /// <;/summary> 11: public interface ILoginForm 12: { 13: /// <;summary> 14: /// 是否已经通过登录验证。 15: /// <;/summary> 16: bool Passed { get; } 17: } 18: }      自定义的导航控件必须实现INavigation接口,以便于平台实现导航的初始化,方法Initialize由平台调用,传入当前系统登录人员所具有权限的模块清单及相关的导航清单。      自定我的登录界面必须实现ILoginForm,以便于系统判定登录界面是否完成了登录验证。 四、IMainShell接口和自定义主界面      第三节在介绍IResource接口的时候我们会发现其他有一个GetMainShell()方法,其用于获取资源实现之中的主界面定义,系统主界面必须是一个Form并且要实现IMainShell接口: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Text; 5:  6: namespace EAS.Explorer 7: { 8: /// <;summary> 9: /// 定义主界面接口,用于实现自定义主界面。 10: /// <;/summary> 11: public interface IMainShell 12: { 13: /// <;summary> 14: /// 初始化主界面,根据平台传入的模块清单和相关的导航分组初始化主界面。 15: /// <;/summary> 16: /// <;param name="m_GroupList">导航清单。</param> 17: /// <;param name="m_ModuleList">模块清单。</param> 18: void InitializeShell(IList<;INavigateGroup> m_GroupList, IList<INavigateModule> m_ModuleList); 19:  20: /// <;summary> 21: /// 加载/打开指定模块,响应系统的模块打开操作。 22: /// <;/summary> 23: /// <;param name="module">模块实例。</param> 24: void OpenModule(object module); 25: 26: /// <summary> 27: /// 关闭当前模块(活动的模块)。 28: /// <;/summary> 29: void CloseModule(); 30: 31: /// <summary> 32: /// 关闭指定模块。 33: /// <;/summary> 34: /// <;param name="module">模块实例。</param> 35: void CloseModule(object module); 36: 37: /// <summary> 38: /// 切换导航,展开、隐藏导航,主界面没有导航的隐藏、展开需求可以不处理。 39: /// <;/summary> 40: void SwitchNavigation(); 41: 42: /// <summary> 43: /// 当前活动插件/模块。 44: /// <;/summary> 45: object ActiveAddIn 46: { 47: get; 48: } 49:  50: /// <;summary> 51: /// 已打开的插件/模块集合。 52: /// <;/summary> 53: List<;object> AddIns 54: { 55: get; 56: } 57: } 58: }      其中InitializeShell方法:用于平台传入当前系统登录人员所具有权限的模块清单及相关的导航清单,由自定义界面实现界面的初始化。      OpenModule方法:用于实现对模块的打开,平台传入要打开的模块,由主界面进行处理,实现主界面对模块的动态加载。      CloseModule方法:用于关闭已经打开的模块,并对界面进行清理。      SwitchNavigation方法:切换导航,展开、隐藏导航,主界面没有导航的隐藏、展开需求可以不处理。      ActiveAddIn属性:向平台返回当前的活动模块。      AddIns属性:向平台返回已加载的模块清单。 四、自定义界面实例      近期 有朋友建议使用devcomponents或者DotNetBar为大家演示一下如何自定义平台的主体界面,参考了网有对devcomponents和DotNetBar相关的资料之后我们选择了较为轻量级的DotNetBar为大家演示如何替换系统的主界面。      我们使用DotNetBar所提供的一些控件实现了以下三种风格的主体界面:      第一种是Win7/Ribbon风格的主界面RibbonShell,如下图所示:      其对应代码为DrugShop案例之中的DrugShop.Res项目之中的RibbonShell.cs程序文件。      第二种为类似Visual Studio界面风格的DockableShell,其效果如下:      其对应代码为DrugShop案例之中的DrugShop.Res项目之中的DockableShell.cs程序文件。      第三种为不包含导航栏的简单MDI界面风格的TabShell,其效果如下:      其对应代码为DrugShop案例之中的DrugShop.Res项目之中的TabShell.cs程序文件。 五、关于代码      以上介绍了三种风格的自定义主界面的例子,例子不多,也不复杂,或许也不能满足所有人的美观度需求和功能需求,其目的在于抛砖引用,希望借此文让更多的开发者加入到我们的行列之中来,做出更加美观大方的界面。      关于以上三种风格自定义界面代码,我们已经合并到DrugShop案例和SmartEPR案例之中,请大家在AgileEAS.NET SOA中间件官方网站的最新下载栏目进行下载。      在启动自定义界面的过程之中切记要修改资源项目之中IResource的实现代码之中的GetMainShell方法代码: 1: public object GetMainShell() 2: { 3: return new RibbonShell(); //Ribbon风格自定义界面。 4: //return new DockableShell(); //Dockable风格自定义界面。 5: //return new TabShell(); //TabMdi风格自定义界面。 6: //return null; //使用AgileEAS.NET SOA平台自带界面。 7: }      本文所使用的是DotNetBar115版本,有关于DotNetBar115请通过http://112.74.66.105/downloads/DotNetBar115.rar下载。 六、联系我们      为完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET SOA中间件平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

.NET | ActiveX | ESB | ORM | SOA | SAAS | 中间件 | 框架 | 消息中间件 | 通信框架

AgileEAS.NET SOA 中间件平台.Net Socket通信框架-完整应用例子-在线聊天室系统-下载配置

by 魏琼东 2013.10.12 11:58
一、AgileEAS.NET SOA中间件Socket/Tcp框架介绍      在文章AgileEAS.NET SOA 中间件平台Socket/Tcp通信框架介绍一文之中我们对AgileEAS.NET SOA中间Socket/Tcp框架进行了总体的介绍,我们知道 AgileEAS.NET SOA中间件Socket/Tcp框架是一套Socket通信的消息中间件: 二、简单的服务器客户段消息应答      在文章AgileEAS.NET SOA 中间件平台Socket/Tcp通信框架-简单例子-实现简单的服务端客户端消息应答中我们实现了一个简单的客户端消息请求==>服务端应答的简单的Socket应用。 三、完整的应用-实现完整的聊天室      本文我们将实现一个多人聊天室的应用,类似于早年的网络聊天室或者当年的QQ网络聊天室或者游戏里面的聊天功能,聊到室主界面如下:      聊天室支持公聊和私聊频道,理论上可以支持几百甚至几千人,具体上限没有经过测试,在这个案例之中,大家将会掌握基于AgileEAS.NET SOA中间件Socket/Tcp框架的比较复杂的消息定义及消息处理及消息协调,同时还会掌握如何管理服务端的链接、聊天室用户在线状态、消息的多目标转发等功能。      本案例的可执行客户端程序和服务端已经在我们的服务器上为大家部署了一套,大家可以下载客户段http://112.74.66.105/downloads/eas/examples/chat.client.rar体验,下载客户端压缩包之后解压缩,注册一个账号就可以使用这个账号登录我们为大家搭建的聊天室服务端。 三、下载源代码编译配置运行      本案例源代码请通AgileEAS.NET SOA中间件官方网站的最新下载中的栏目进行下载或者从SVN中获取最新版本的源代码: 下载或者SVN-OUT得到代码之后我们来看一下代码文建构: 一级目录 二级目录 说明 Code   程序源代码   Entities 实体(ORM)代码   BLL.Contracts 业务契约定义代码   BLL.Host 数据实现代码   Messages Socket通信消息定义   Services Socket服务定义   ChatRoom 客户段程序代码   UserManage 注册用户管理代码 db   用户数据库文件,Sqlite数据库 Documents   文档,用户模型文档 Publish   引用程序集及编译输出            然后用VS2010或者VS2012打开Code目录之中的ChatRoom解决方案进行编译,编译写成之后我们开始进行配置。      打开Publish目录之中的EAS.SOA.Server.exe.config进行服务端配置:      其中最重要的配置就是配置服务端sqlite数据库文件的路径,以及端口号,当然端口号是可以不用修改的,配置完成之后我们启动Publish目录之中的soaserver.start.bat指指理文件来启动聊天室服务端:      启动聊天室服务端的本质是启动AgileEAS.NET SOA 中间件SOA服务,在SOA服务之中我们集成了Socket插件服务系统,我们的聊天室做为一个SOA的Socket插件服务被进行加载和处理,需要说明的是如果你的运行环境是Win7或者Win2008操作系统,需要以管理员权限运行启动脚本: 接下来我们配置客户段,打开ChatingRoom.MainClient.exe.config文件,修改以下地方:     这样我们变完成了聊天室客户端的配置,运行ChatingRoom.MainClient.exe程序启动客户端的登录窗口:     点用户注册注册一个新用户:     注册成功之后使用这个用户登录聊天室:      到时为止,聊天室案例的配置过程到此完成! 四、源代码学习      要学习和研究本案例的源代码,请参考:      1.AgileEAS.NET SOA 中间件平台Socket/Tcp通信框架介绍      2.AgileEAS.NET SOA 中间件平台Socket/Tcp通信框架-简单例子-实现简单的服务端客户端消息应答      在之后的文章之中我们将会对本案例源代码进行分析。 五、特别感谢      感谢团队成员计文忻同学为大家编写了本案例的第一版本,之后我在通信和界面上做了一些小的调整,也感谢王涛同学为本应用案例提供了Banner图片和一些界面美工建议,也感谢在此案例进行测试和提出建议的客户和小伙伴们。 六、联系我们      为了完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台了开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 120661978(AgileEAS.NET 平台交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

.NET | AgileEAS.NET | C# | SOA | Socket | 中间件 | 应答 | 框架 | 消息中间件 | 通信框架 | 聊天室

AgileEAS.NET SOA 中间件平台.Net Socket通信框架-简单例子-实现简单的服务端客户端消息应答

by 魏琼东 2013.10.11 20:07
一、AgileEAS.NET SOA中间件Socket/Tcp框架介绍      在文章AgileEAS.NET SOA 中间件平台Socket/Tcp通信框架介绍一文之中我们对AgileEAS.NET SOA中间Socket/Tcp框架进行了总体的介绍,我们知道 AgileEAS.NET SOA中间件Socket/Tcp框架是一套Socket通信的消息中间件: 二、简单例子-实现简单的服务器客户段消息应答      我们接下来实现一个简单的例子,例子的场景非常的简单,客户端向服务端发送一个请求消息,服务段收到消息之后显示消息内容,并对客户端发送一个应答消息,客户端收到应答消息之后显示这个应答消息,对于本例子,我们使用WinForm应用来实现。 三、一步一步实现      首先我们下载AgileEAS.NET SOA 中间件最新版本5.0/5.1,下载地址:http://www.smarteas.net/page/EAS_NET_Downloads.aspx。      首先我们打开VS2010或者VS2010创建一个类为项目Socket.Demo.Messages:      删除默认的Class1.cs,引用AgileEAS.NET SOA 中间件的EAS.MicroKernel.dll程序集文件,然后添加一个类请求消息类RequestMessage: 1: [Serializable] 2: [Message("14DB99D2-190C-48E9-879A-EA833247F24A", "请求消息")] 3: public class RequestMessage:IMessage 4: { 5: /// <summary> 6: /// 消息内容。 7: /// </summary> 8: public string Content 9: { 10: get; 11: set; 12: } 13:  14: public void Load(EAS.IO.BufferReader reader) 15: { 16: this.Content = reader.ReadString(); 17: } 18:  19: public void WriteTo(EAS.IO.BufferWriter writer) 20: { 21: writer.Write(this.Content); 22: } 23: }      以上代码我们定义了一个请求消息,消息ID为"14DB99D2-190C-48E9-879A-EA833247F24A",Load方法实现从消息读取器之中读出消息内容,WriteTo方法实现把消息内容写入消息编写器,转换为字节流供通信引擎进行收发,接下来我们再增加一个应答消息类ResponseMessage: 1: [Serializable] 2: [Message("D94C51C4-8423-4BF6-A011-184265BBA62C", "应答消息")] 3: public class ResponseMessage : RequestMessage, IMessage 4: { 5: }     在本例子之中应答消息与请求消息其内容没有本质的区别,都是文本通信,所以就直接继承了RequestMessage,变更了MessageID和消息说明。 到此为止,我们已经完成了请求消息与应答消息的定义Socket.Demo.Messages项目结构下:    接下来我们来实现服务端程序,向解决方案添加一个Socket.Demo.Server的Windows窗体应用程序:    同样,我们要引用AgileEAS.NET SOA 中间件的EAS.MicroKernel.dll程序集文件,并且还要引用Socket.Demo.Messages项目,然后重命名Form1为MainForm,并做以下界面布局:    接下来我们向服务端加载请求消息的处理器RequestMessageHandler,用于服务端收到请求消息之后的处理动作: 1: class RequestMessageHandler:AbstractMessageHandler<RequestMessage> 2: { 3: public override void Process(NetSession context, uint instanceId, RequestMessage message) 4: { 5: //1.显示消息。 6: MainForm.Instance.ShowMessage(message); 7:  8: //2.向客户端回复一条应当消息。 9: string content = string.Format("{0}已收到,OK!", message.Content); 10: ResponseMessage responseMessage = new ResponseMessage { Content = content }; 11: context.Reply(responseMessage); 12: } 13: }      然后我们实现MainForm窗体的功能代码: 1: using System; 2: using System.Collections.Generic; 3: using System.ComponentModel; 4: using System.Data; 5: using System.Drawing; 6: using System.Linq; 7: using System.Text; 8: using System.Windows.Forms; 9: using EAS.Sockets; 10: using Socket.Demo.Messages; 11:  12: namespace Socket.Demo.Server 13: { 14: public partial class MainForm : Form 15: { 16: public static MainForm Instance = null; 17: private SocketServer m_SocketServer = null; 18:  19: public MainForm() 20: { 21: InitializeComponent(); 22: Instance = this; 23:  24: //实例化对象。 25: this.m_SocketServer = new SocketServer(); 26:  27: //端口号为6610 28: this.m_SocketServer.Port = 6610; 29:  30: //注册消息处理器。 31: this.m_SocketServer.AddHander<RequestMessage>(new RequestMessageHandler()); 32:  33: this.m_SocketServer.ServerStarted += new EventHandler(m_SocketServer_ServerStarted); 34: this.m_SocketServer.ServerStopped+=new EventHandler(m_SocketServer_ServerStopped); 35: } 36:  37: void m_SocketServer_ServerStarted(object sender, EventArgs e) 38: { 39: this.btnStart.Enabled = false; 40: this.btnStop.Enabled = true; 41: } 42:  43: void m_SocketServer_ServerStopped(object sender, EventArgs e) 44: { 45: this.btnStart.Enabled = true; 46: this.btnStop.Enabled = false; 47: } 48:  49: internal void ShowMessage(Messages.RequestMessage message) 50: { 51: Action UI = () => 52: { 53: this.tbMessage.AppendText(message.Content); 54: this.tbMessage.AppendText("\r\n"); 55: this.tbMessage.ScrollToCaret(); 56: }; 57:  58: this.Invoke(UI); 59: } 60:  61: private void btnStart_Click(object sender, EventArgs e) 62: { 63: if (this.m_SocketServer.ServerState == ServerState.Stoped) 64: { 65: this.m_SocketServer.StartServer(); 66: } 67: } 68:  69: private void btnStop_Click(object sender, EventArgs e) 70: { 71: if (this.m_SocketServer.ServerState != ServerState.Stoped) 72: { 73: this.m_SocketServer.StopServer(); 74: } 75: } 76: } 77: }      其中代码this.m_SocketServer.AddHander<RequestMessage>(new RequestMessageHandler());完成向服务器注册请求消息的处理器对象,internal void ShowMessage(Messages.RequestMessage message)方法用于显示服务器收到的请求消息。     接下来我们来实现客户端程序,向解决方案添加一个Socket.Demo.Client的Windows窗体应用程序,同前面一样样,我们要引用AgileEAS.NET SOA 中间件的EAS.MicroKernel.dll程序集文件,并且还要引用Socket.Demo.Messages项目,然后重命名Form1为MainForm,并做以下界面布局:     接下来我们向客户端加载应答消息的处理器ResponseMessageHandler,用于客户端收到应答消息之后的处理动作: 1: using System; 2: using System.Collections.Generic; 3: using System.Linq; 4: using System.Text; 5: using EAS.Sockets.Messages; 6: using Socket.Demo.Messages; 7: using EAS.Sockets; 8:  9: namespace Socket.Demo.Client 10: { 11: class ResponseMessageHandler : AbstractMessageHandler<ResponseMessage> 12: { 13: public override void Process(NetSession context, uint instanceId, ResponseMessage message) 14: { 15: //1.显示消息。 16: MainForm.Instance.ShowMessage(message); 17: } 18: } 19: }          然后我们实现MainForm窗体的功能代码: 1: using System; 2: using System.Collections.Generic; 3: using System.ComponentModel; 4: using System.Data; 5: using System.Drawing; 6: using System.Linq; 7: using System.Text; 8: using System.Windows.Forms; 9: using EAS.Sockets; 10: using Socket.Demo.Messages; 11:  12: namespace Socket.Demo.Client 13: { 14: public partial class MainForm : Form 15: { 16: public static MainForm Instance = null; 17: SocketClient m_SocketClient; 18:  19: public MainForm() 20: { 21: InitializeComponent(); 22: Instance = this; 23: this.m_SocketClient = new SocketClient(); 24: this.m_SocketClient.IPAddress = "127.0.0.1"; 25: this.m_SocketClient.Port = 6610; 26: this.m_SocketClient.AddHander<ResponseMessage>(new ResponseMessageHandler()); 27:  28: this.m_SocketClient.Connected += new EventHandler(m_SocketClient_Connected); 29: this.m_SocketClient.Closed += new EventHandler(m_SocketClient_Closed); 30: } 31:  32: void m_SocketClient_Connected(object sender, EventArgs e) 33: { 34: this.btnConnect.Enabled = false; 35: this.btnClose.Enabled = true; 36: this.btnSend.Enabled = false; 37: } 38:  39: void m_SocketClient_Closed(object sender, EventArgs e) 40: { 41: this.btnConnect.Enabled = true; 42: this.btnClose.Enabled = false; 43: this.btnSend.Enabled = true; 44: } 45:  46: internal void ShowMessage(ResponseMessage message) 47: { 48: Action UI = () => 49: { 50: this.tbMessage.AppendText(message.Content); 51: this.tbMessage.AppendText("\r\n"); 52: this.tbMessage.ScrollToCaret(); 53: }; 54:  55: this.Invoke(UI); 56: } 57:  58: private void btnConnect_Click(object sender, EventArgs e) 59: { 60: if (this.m_SocketClient.ClientState == ClientState.Closed) 61: { 62: this.m_SocketClient.Connect(); 63: } 64: } 65:  66: private void btnClose_Click(object sender, EventArgs e) 67: { 68: if (this.m_SocketClient.ClientState != ClientState.Closed) 69: { 70: this.m_SocketClient.Connect(); 71: } 72: } 73:  74: private void btnSend_Click(object sender, EventArgs e) 75: { 76: if (this.tbSend.Text.Trim().Length == 0) 77: { 78: MessageBox.Show("不能发空消息"); 79: return; 80: } 81:  82: if (this.m_SocketClient.ClientState != ClientState.Closed) 83: { 84: RequestMessage rm = new RequestMessage(); 85: rm.Content = this.tbSend.Text.Trim(); 86: this.m_SocketClient.Send(rm); 87: } 88: } 89: } 90: }         OK,这个简单的例子我们已经开发完成了,接下来,我们来编译、测试一下这个例子! 四、运行测试      首先我们启动服务端程序、启动服务器,然后启动客户段并连接服务器,从客户段向服务器发送消息,服务端会显示客户端发送的消息会向客户端发送一个应答消息。 五、本例源代码下载      本文例子源代码请通过http://112.74.66.105/downloads/eas/examples/Socket.Demo.rar进行下载,有关于AgileEAS.NET SOA 中间件平台请通过AgilleEAS.NET SOA 中站件平台官方网站的最新下载页面下载。 六、联系我们      为了完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台了开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 120661978(AgileEAS.NET 平台交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

AgileEAS.NET | Socket | 中间件 | 企业应用架构 | 分布式 | 框架 | 消息中间件 | 通信框架 | C# | .NET | 请求 | 应答

AgileEAS.NET SOA 中间件平台.Net Socket通信框架-介绍

by 魏琼东 2013.10.11 16:11
一、前言      AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队,以达到节省开发成本、缩短开发时间,快速适应市场变化的目的。      AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践,通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系,以及提供了大量的实体、数据模型设计生成工具、代码生成工具,用于帮助中小软件开发商快速成长。      AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势,基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践,采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想,帮助软件企业实现“敏捷变化、快速适合”的目标,从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。 二、关于Socket/Tcp框架的需求      在AgileEAS.NET SOA 中间件平台在大量客户的使用过程之中,有的客户提出了一些基于“消息推”、和应用系统事件通知的需求,比如在“医院信息系统”、“电子病历系统‘、”区域公共卫生平台“、等系统之中就提供了这样的需求,比如当大夫为病人开立了医嘱之后、需要在相关护理人员即时提示,之前大家都使用数据库刷新,数据库的压力都比较大,所以迫切的提出了这样的需求。      另外一个原因是AgileEAS.NET SOA 中间件平台之前一直使用WCF、WS、Romotinig通信做为SOA分布式架构的通信基础,我们在考虑WS、WCF的某些协议并不能提供给我们非常高效的通信,所以我们也需要有一套直接基于Socket/TCP的通信体系用于支撑我们的SOA分布式服务业务体系。 三、AgileEAS.NET SOA 中间件Socket/Tcp框架结构      AgileEAS.NET SOA中间件需要的Socket/Tcp框架严格意思是需要的基于Socket的通信消息中件间,其所提供的功能本质是对消息的处理,所以其所提供的API有三大类、Socket框架本身、消息框架及消息处理框架,以下是AgileEAS.NET SOA中间件的Socket/Tcp的应用框架结构:      各上图我们可以看到AgileEAS.NET SOA中间件需要的Socket/Tcp框架实现了这么一件有意思的事,把原生的Socekt基于数据流的流式通信模式转换为基于消息的消息通信模式,让开发人员多复杂的系统Socket通信和数据流处理之中解放出来,转而关心高层通信消息的设计和消息处理的业务设计与实现。 三、AgileEAS.NET SOA 中间件Socket/Tcp框架重要的接口和类      AgileEAS.NET SOA中间件需要的Socket/Tcp框架严格意思是需要的基于Socket的通信消息中件间,其所提供的功能本质是对消息的处理,所以其所提供的API有三大类、Socket框架本身、消息框架及消息处理框架,以下是AgileEAS.NET SOA中间件的Socket/Tcp的应用框架结构:      其中ISocketCient接口为客户段功能封装,其定义大体如下: 1: /// <summary> 2: /// Tcp客户端接口。 3: /// </summary> 4: public interface ISocketClient : ISocketEngine 5: { 6: /// <summary> 7: /// 客户端状态。 8: /// </summary> 9: ClientState ClientState 10: { 11: get; 12: } 13:  14: /// <summary> 15: /// 连接Tcp服务器。 16: /// </summary> 17: bool Connect(); 18:  19: /// <summary> 20: /// 关闭与服务器的连接。 21: /// </summary> 22: void Close(); 23:  24: /// <summary> 25: /// 发送消息。 26: /// </summary> 27: /// <param name="message">消息。</param> 28: void Send(IMessage message); 29:  30: /// <summary> 31: /// 调用消息,用于服务器/客户端应用中的请示==》响应消息的应用。 32: /// </summary> 33: /// <param name="request">请示消息。</param> 34: /// <returns>服务器返回的响应消息。</returns> 35: IMessage Invoke(IMessage request); 36:  37: /// <summary> 38: /// 异步调用消息,用于服务器/客户端应用中的请示==》响应消息的应用。 39: /// </summary> 40: /// <param name="request">请示消息。</param> 41: /// <returns>包含响应消息的异步任务。</returns> 42: NetInvokeTask BeginInvoke(IMessage request); 43:  44: /// <summary> 45: /// 服务器发生错误时触发。 46: /// </summary> 47: event ErrorEventHandler Error; 48:  49: /// <summary> 50: /// 连接服务器后触发。 51: /// </summary> 52: event EventHandler Connected; 53:  54: /// <summary> 55: /// 断开服务器连接后触发。 56: /// </summary> 57: event EventHandler Closed; 58: }      其是最重要方法为void Send(IMessage message)方法,即发送一个消息到服务器,这个方法也是对使用者开放的最重要方法,在这里发送的不是字节流,而是一个实现了IMessage接口的消息对象,当服户段接收到IMessage对象之后会调用与其对应的消息处理器(IMessageHandler)对象进行消息处理,反之客户段收到IMessage也会调用与其相关的消息处理器(IMessageHandler)对象进行处理。      ISocketServer、ISocketServerBase接口: 1: /// <summary> 2: /// Socket服务器基类接口。 3: /// </summary> 4: public interface ISocketServerBase : ISocketEngine 5: { 6: /// <summary> 7: /// 客户端会话集合。 8: /// </summary> 9: IList<NetSession> Sessions 10: { 11: get; 12: } 13:  14: /// <summary> 15: /// 注册了一个新会话后发生。 16: /// </summary> 17: event NetSessionEventHandler SessionStarted; 18:  19: /// <summary> 20: /// 某一个会话结束后发生。 21: /// </summary> 22: event NetSessionEventHandler SessionAbandoned; 23:  24: /// <summary> 25: /// 发送消息。 26: /// </summary> 27: /// <param name="target">消息接收方ID(会话ID)。</param> 28: /// <param name="message">消息。</param> 29: void Send(Guid target, IMessage message); 30:  31: /// <summary> 32: /// 发送网络消息。 33: /// </summary> 34: /// <param name="target">消息接收方ID(会话ID)。</param> 35: /// <param name="netMessage">网络消息。</param> 36: void Send(Guid target, NetMessage netMessage); 37:  38: /// <summary> 39: /// 发送网络报文(仅网关模式有效)。 40: /// </summary> 41: /// <param name="target">消息接收方ID(会话ID)。</param> 42: /// <param name="netPacket">网络报文。</param> 43: void Send(Guid target, NetPacket netPacket); 44:  45: /// <summary> 46: /// 发送网络数据(仅网关模式有效)。 47: /// </summary> 48: /// <param name="target">消息接收方ID(会话ID)。</param> 49: /// <param name="buffer">网络数据。</param> 50: void Send(Guid target, byte[] buffer); 51: } 1: /// <summary> 2: /// Socket服务器接口。 3: /// </summary> 4: public interface ISocketServer : ISocketServerBase 5: { 6: /// <summary> 7: /// 客户端连接数。 8: /// </summary> 9: int ClientCount 10: { 11: get; 12: } 13:  14: /// <summary> 15: /// 服务器状态。 16: /// </summary> 17: ServerState ServerState 18: { 19: get; 20: } 21:  22: /// <summary> 23: /// 开始Tcp服务器。 24: /// </summary> 25: void StartServer(); 26:  27: /// <summary> 28: /// 停止Tcp服务器。 29: /// </summary> 30: void StopServer(); 31:  32: /// <summary> 33: /// 关闭指定客户的连接。 34: /// </summary> 35: /// <param name="client">客户Guid。</param> 36: void AbandonSession(System.Guid client); 37:  38: /// <summary> 39: /// 服务器发生错误时触发。 40: /// </summary> 41: event ServerErrorEventHandler ServerError; 42:  43: /// <summary> 44: /// 服务器启动后触发。 45: /// </summary> 46: event System.EventHandler ServerStarted; 47:  48: /// <summary> 49: /// 服务器停止后触发。 50: /// </summary> 51: event System.EventHandler ServerStopped; 52: }      这两个接口定义了SocketServer的一些行为和属性,其中最重要的方法还是void Send(Guid target, IMessage message),实现向某个特定客户段连接发送应用消息,别外定义了一个IList<NetSession> Sessions属性,表示目前连接到此SocketServer的所有客户端会话信息。      NetSession表示服务器的一个客户段连接会话,包括连接上下文信息和连接的Socket通信对象,当某个SocketClient发送给SocketServer的信息都会被与其应对的NetSession进行处理,NetSession定义两个重要的方法public void Reply(uint requestID, IMessage message)和public void Abandon(),其中Reply表示向客户端回复一个消息,Abandon表示服务器强制中止此会话。      在整个Socket/tcp框架之中进行通信的最基本单元都是IMessage,那么SocketClient、SocketServer接收到IMessage如何处理呢,答案是由与之配对的IMessageHandler进行处理,所以SocketClient、SocketServer都实现了一个基础接口ISocketEngine: 1: /// <summary> 2: /// Socket引擎,Socket网络通信基础类。 3: /// </summary> 4: public interface ISocketEngine : IDisposable 5: { 6: /// <summary> 7: /// 通信引擎的全局唯一标识符号。 8: /// </summary> 9: System.Guid Guid 10: { 11: get; 12: } 13:  14: /// <summary> 15: /// IP地址和端口号。 16: /// </summary> 17: IPEndPoint IPEndPoint 18: { 19: get; 20: set; 21: } 22:  23: /// <summary> 24: /// IP地址。 25: /// </summary> 26: string IPAddress 27: { 28: get; 29: set; 30: } 31:  32: /// <summary> 33: /// 端口号。 34: /// </summary> 35: int Port 36: { 37: get; 38: set; 39: } 40:  41: /// <summary> 42: /// 报文最大长度。 43: /// </summary> 44: int MessageMaxSize 45: { 46: get; 47: } 48:  49: /// <summary> 50: /// 注册消息处理器。 51: /// </summary> 52: /// <typeparam name="T">消息类型。</typeparam> 53: /// <param name="hander">消息处理器。</param> 54: void AddHander<T>(IMessageHandler<T> hander) where T : IMessage; 55:  56: /// <summary> 57: /// 通过Socket发送数据之后触发。 58: /// </summary> 59: event SocketDataHandler SocketDataSend; 60:  61: /// <summary> 62: /// 通过Socket接收数据之后触发。 63: /// </summary> 64: event SocketDataHandler SocketDataReceived; 65:  66: /// <summary> 67: /// 发送报文完成之后触发。 68: /// </summary> 69: event PacketHandler PacketSend; 70:  71: /// <summary> 72: /// 报文接收完成之后触发。 73: /// </summary> 74: event PacketHandler PacketReceived; 75:  76: /// <summary> 77: /// 载送完一个NetMessage之后触发。 78: /// </summary> 79: event NetMessageHandler NetMessageSend; 80:  81: /// <summary> 82: /// 接收完一个NetMessage之后触发。 83: /// </summary> 84: event NetMessageHandler NetMessageReceived; 85:  86: /// <summary> 87: /// 消息发送完成之后触发。 88: /// </summary> 89: event MessageHandler MessageSend; 90:  91: /// <summary> 92: /// 接收消息完成之后触发。 93: /// </summary> 94: event MessageHandler MessageReceived; 95: }      其中方法void AddHander<T>(IMessageHandler<T> hander) where T : IMessage实现对消息处理器的注册,以便收到IMessage之后选择合适的处理器进行处理。 四、消息和消息处理器      从以上的介绍我们可以明确的知道AgileEAS.NET SOA中间件Socket/Tcp框架是的一个基于消息对象的消息通信框架,那么其最核心的业务就是定义消息及消息的处理思路,我们称之为消息及消息处理器结构:      其中IMessage接口为Socket/Tcp框架中最重要的接口,所有高层的应用消息都需要实现本接口: 1: /// <summary> 2: /// 消息接口定义。 3: /// </summary> 4: /// <remarks> 5: /// 这里所说的消息是指业务处理的最小单元,而不是传输于网络之间的网络消息。 6: /// </remarks> 7: public interface IMessage 8: { 9: /// <summary> 10: /// 从指定的 MessageReader加载消息对象。 11: /// </summary> 12: /// <param name="reader">消息读取器。</param> 13: void Load(BufferReader reader); 14:  15: /// <summary> 16: /// 将消息对象保存到指定的MessageWriter。 17: /// </summary> 18: /// <param name="writer">消息编写器。</param> 19: void WriteTo(BufferWriter writer); 20: }      其中Load和WriteTo实现IMessage消息对象实例与字节流之间进行相互转换,Load消息用于从字节流之中读取并实例化消息、WriteTo把消息转换为流写入消息流之中,在应用开发过程之中必须实现这两个方法并且在消息类上打上MessageAttribute标记: 1: /// <summary> 2: /// 消息ID属性。 3: /// </summary> 4: /// <remarks> 5: /// 标记网络消息,确定其唯一的ID。 6: /// </remarks> 7: [AttributeUsage(AttributeTargets.Class)] 8: public class MessageAttribute : Attribute 9: { 10: /// <summary> 11: /// 初始化MessageAttribute对象实例。 12: /// </summary> 13: /// <param name="messageID">消息ID。</param> 14: public MessageAttribute(string messageID) 15: :this(messageID,string.Empty) 16: { 17:  18: } 19:  20: /// <summary> 21: /// 初始化MessageAttribute对象实例。 22: /// </summary> 23: /// <param name="messageID">消息ID。</param> 24: /// <param name="description">消息说明。</param> 25: public MessageAttribute(string messageID, string description) 26: { 27: this.MessageID = new Guid(messageID); 28: this.Description = description; 29: } 30:  31: /// <summary> 32: /// 消息ID。 33: /// </summary> 34: public Guid MessageID 35: { 36: get; 37: set; 38: } 39:  40: /// <summary> 41: /// 消息说明。 42: /// </summary> 43: public string Description 44: { 45: get; 46: set; 47: } 48: }      MessageAttribute标记用于向已实现IMessage接口的具体消息的消息ID与消息说明,即向Socket通信框架声音本消息的唯一性之用,其中MessageID为一个GUID对象,GUID对象理论上是唯一的,我们可以表示消息的唯一性,以下是一个具体的消息例子: 1: /// <summary> 2: /// 用户登录消息。 3: /// </summary> 4: [Message("F42433DF-2D4D-4514-9523-2FE911E63CAA", "登录消息")] 5: [Serializable] 6: public class LoginMessage : IMessage 7: { 8: /// <summary> 9: /// 用户名。 10: /// </summary> 11: public string LoginID 12: { 13: get; 14: set; 15: } 16:  17: /// <summary> 18: /// 密码。 19: /// </summary> 20: public string PassWord 21: { 22: get; 23: set; 24: } 25:  26: #region IMessage 成员 27:  28: /// <summary> 29: /// 30: /// </summary> 31: /// <param name="reader"></param> 32: public void Load(EAS.IO.BufferReader reader) 33: { 34: LoginID = reader.ReadString(); 35: PassWord = reader.ReadString(); 36: } 37:  38: /// <summary> 39: /// 40: /// </summary> 41: /// <param name="writer"></param> 42: public void WriteTo(EAS.IO.BufferWriter writer) 43: { 44: writer.Write(LoginID); 45: writer.Write(PassWord); 46: } 47:  48: #endregion 49: }      以上是一个具体消息的例子,其表明消息ID为“F42433DF-2D4D-4514-9523-2FE911E63CAA”,其作用是登录消息,用于实现类似登录业务。 五、可靠的消息中间件      AgileEAS.NET SOA中间件Socket/Tcp框架是一个可靠的消息中间件,在设计过程之初就选择了完成端口模型进行开发,以保证服务的高并发和吞吐量,在底层消息通信上,我们选择了不超过8K的可变大小通信报文,比如当一个高层的IMeesage只有512字节内容的时候,会取转成一个一个远小于8K的报文进行发送,如果一个高层IMeesage为66K时,会被分解成为9条消息报文进行通信,前8条消息报文长度为8K,最后一条不满足8K,接收文收到这9条报文后组合并转换为IMeesage对象之后交由消息处理器IMeeesgaHandler进行处理。      在进行消息报文收发过程之中,经过长期测试、验证、设计和选择了高性能的防粘包设计,避免应用开发者头疼的消息粘包问题。 六、AgileEAS.NET SOA中间件需要的Socket/Tcp框架下载      AgileEAS.NET SOA中间件Socket/Tcp框架包含在AgileEAS.NET SOA中间件平台之中,具体定义在EAS.MicroKernel.dll程序集之中,要使用AgileEAS.NET SOA中间件Socket/Tcp框架进行基于Socket的通信开发,请通过AgilleEAS.NET SOA 中站件平台官方网站的最新下载页面下载。 七、联系我们      为了完善、改进和推广AgileEAS.NET而成立了敏捷软件工程实验室,是一家研究、推广和发展新技术,并致力于提供具有自主知识产权的业务基础平台软件,以及基于业务基础平台了开发的管理软件的专业软件提供商。主要业务是为客户提供软件企业研发管理解决方案、企业管理软件开发,以及相关的技术支持,管理及技术咨询与培训业务。      AgileEAS.NET平台自2004年秋呱呱落地一来,我就一直在逐步完善和改进,也被应用于保险、医疗、电子商务、房地产、铁路、教育等多个应用,但一直都是以我个人在推广,2010年因为我辞职休息,我就想到把AgileEAS.NET推向市场,让更多的人使用。      我的技术团队成员都是合作多年的老朋友,因为这个平台是免费的,所以也没有什么收入,都是由程序员的那种理想与信念坚持,在此我感谢一起奋斗的朋友。 团队网站:http://www.agilelab.cn, AgileEAS.NET网站:http://www.smarteas.net 官方博客:http://eastjade.cnblogs.com QQ:47920381,AgileEAS.NET QQ群:113723486(AgileEAS SOA 平台)/上限1000人 199463175(AgileEAS SOA 交流)/上限1000人 120661978(AgileEAS.NET 平台交流)/上限1000人 212867943(AgileEAS.NET研究)/上限500人 147168308(AgileEAS.NET应用)/上限500人 172060626(深度AgileEAS.NET平台)/上限500人 116773358(AgileEAS.NET 平台)/上限500人 125643764(AgileEAS.NET探讨)/上限500人 193486983(AgileEAS.NET 平台)/上限500人 邮件:james@agilelab.cn,mail.james@qq.com, 电话:18629261335。

Tags:

AgileEAS.NET | SAAS | SOA | 中间件 | 企业应用架构 | 分布式 | 框架 | Socket | 消息中间件 | 通信框架

最新评论

声明

本博所有网友评论不代表本博立场,版权归其作者所有。

© Copyright 2011