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

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

2017-11-20 473

一、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：

 
[Serializable] 
[Message("14DB99D2-190C-48E9-879A-EA833247F24A", "请求消息")] 
public class RequestMessage:IMessage 
{ 
    /// <summary> 
    /// 消息内容。 
    /// </summary> 
    public string Content 
    { 
        get; 
        set; 
    } 
   
    public void Load(EAS.IO.BufferReader reader) 
    { 
        this.Content = reader.ReadString();    
    } 
   
    public void WriteTo(EAS.IO.BufferWriter writer) 
    { 
        writer.Write(this.Content); 
    } 
} 
  

以上代码我们定义了一个请求消息，消息ID为"14DB99D2-190C-48E9-879A-EA833247F24A"，Load方法实现从消息读取器之中读出消息内容，WriteTo方法实现把消息内容写入消息编写器，转换为字节流供通信引擎进行收发，接下来我们再增加一个应答消息类ResponseMessage:

 
[Serializable] 
[Message("D94C51C4-8423-4BF6-A011-184265BBA62C", "应答消息")] 
public class ResponseMessage : RequestMessage, IMessage 
{ 
} 
  

在本例子之中应答消息与请求消息其内容没有本质的区别，都是文本通信，所以就直接继承了RequestMessage，变更了MessageID和消息说明。

到此为止，我们已经完成了请求消息与应答消息的定义Socket.Demo.Messages项目结构下：

接下来我们来实现服务端程序，向解决方案添加一个Socket.Demo.Server的Windows窗体应用程序：

同样，我们要引用AgileEAS.NET SOA 中间件的EAS.MicroKernel.dll程序集文件，并且还要引用Socket.Demo.Messages项目，然后重命名Form1为MainForm，并做以下界面布局：

接下来我们向服务端加载请求消息的处理器RequestMessageHandler，用于服务端收到请求消息之后的处理动作：

 
class RequestMessageHandler:AbstractMessageHandler<RequestMessage> 
{ 
    public override void Process(NetSession context, uint instanceId, RequestMessage message) 
    { 
        //1.显示消息。 
        MainForm.Instance.ShowMessage(message); 
   
        //2.向客户端回复一条应当消息。 
        string content = string.Format("{0}已收到，OK！", message.Content); 
        ResponseMessage responseMessage = new ResponseMessage { Content = content }; 
        context.Reply(responseMessage); 
    } 
} 
  

然后我们实现MainForm窗体的功能代码：

 
using System; 
using System.Collections.Generic; 
using System.ComponentModel; 
using System.Data; 
using System.Drawing; 
using System.Linq; 
using System.Text; 
using System.Windows.Forms; 
using EAS.Sockets; 
using Socket.Demo.Messages; 
   
namespace Socket.Demo.Server 
{ 
    public partial class MainForm : Form 
    { 
        public static MainForm Instance = null; 
        private SocketServer m_SocketServer = null; 
   
        public MainForm() 
        { 
            InitializeComponent(); 
            Instance = this; 
   
            //实例化对象。 
            this.m_SocketServer = new SocketServer(); 
   
            //端口号为6610 
            this.m_SocketServer.Port = 6610; 
   
            //注册消息处理器。 
            this.m_SocketServer.AddHander<RequestMessage>(new RequestMessageHandler()); 
   
            this.m_SocketServer.ServerStarted += new EventHandler(m_SocketServer_ServerStarted); 
            this.m_SocketServer.ServerStopped+=new EventHandler(m_SocketServer_ServerStopped); 
        } 
   
        void m_SocketServer_ServerStarted(object sender, EventArgs e) 
        { 
            this.btnStart.Enabled = false; 
            this.btnStop.Enabled = true; 
        } 
   
        void m_SocketServer_ServerStopped(object sender, EventArgs e) 
        { 
            this.btnStart.Enabled = true; 
            this.btnStop.Enabled = false; 
        } 
   
        internal void ShowMessage(Messages.RequestMessage message) 
        { 
            Action UI = () => 
                { 
                    this.tbMessage.AppendText(message.Content); 
                    this.tbMessage.AppendText("\r\n"); 
                    this.tbMessage.ScrollToCaret(); 
                }; 
   
            this.Invoke(UI); 
        } 
   
        private void btnStart_Click(object sender, EventArgs e) 
        { 
            if (this.m_SocketServer.ServerState == ServerState.Stoped) 
            { 
                this.m_SocketServer.StartServer(); 
            } 
        } 
   
        private void btnStop_Click(object sender, EventArgs e) 
        { 
            if (this.m_SocketServer.ServerState != ServerState.Stoped) 
            { 
                this.m_SocketServer.StopServer(); 
            } 
        } 
    } 
} 
  

其中代码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，用于客户端收到应答消息之后的处理动作：

 
using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using EAS.Sockets.Messages; 
using Socket.Demo.Messages; 
using EAS.Sockets; 
   
namespace Socket.Demo.Client 
{ 
    class ResponseMessageHandler : AbstractMessageHandler<ResponseMessage> 
    { 
        public override void Process(NetSession context, uint instanceId, ResponseMessage message) 
        { 
            //1.显示消息。 
            MainForm.Instance.ShowMessage(message); 
        } 
    } 
} 
  

然后我们实现MainForm窗体的功能代码：

 
using System; 
using System.Collections.Generic; 
using System.ComponentModel; 
using System.Data; 
using System.Drawing; 
using System.Linq; 
using System.Text; 
using System.Windows.Forms; 
using EAS.Sockets; 
using Socket.Demo.Messages; 
   
namespace Socket.Demo.Client 
{ 
    public partial class MainForm : Form 
    { 
        public static MainForm Instance = null; 
        SocketClient m_SocketClient; 
   
        public MainForm() 
        { 
            InitializeComponent(); 
            Instance = this; 
            this.m_SocketClient = new SocketClient(); 
            this.m_SocketClient.IPAddress = "127.0.0.1"; 
            this.m_SocketClient.Port = 6610; 
            this.m_SocketClient.AddHander<ResponseMessage>(new ResponseMessageHandler()); 
   
            this.m_SocketClient.Connected += new EventHandler(m_SocketClient_Connected); 
            this.m_SocketClient.Closed += new EventHandler(m_SocketClient_Closed); 
        } 
   
        void m_SocketClient_Connected(object sender, EventArgs e) 
        { 
            this.btnConnect.Enabled = false; 
            this.btnClose.Enabled = true; 
            this.btnSend.Enabled = false; 
        } 
   
        void m_SocketClient_Closed(object sender, EventArgs e) 
        { 
            this.btnConnect.Enabled = true; 
            this.btnClose.Enabled = false; 
            this.btnSend.Enabled = true; 
        } 
   
        internal void ShowMessage(ResponseMessage message) 
        { 
            Action UI = () => 
            { 
                this.tbMessage.AppendText(message.Content); 
                this.tbMessage.AppendText("\r\n"); 
                this.tbMessage.ScrollToCaret(); 
            }; 
   
            this.Invoke(UI); 
        } 
   
        private void btnConnect_Click(object sender, EventArgs e) 
        { 
            if (this.m_SocketClient.ClientState == ClientState.Closed) 
            { 
                this.m_SocketClient.Connect(); 
            } 
        } 
   
        private void btnClose_Click(object sender, EventArgs e) 
        { 
            if (this.m_SocketClient.ClientState != ClientState.Closed) 
            { 
                this.m_SocketClient.Connect(); 
            } 
        } 
   
        private void btnSend_Click(object sender, EventArgs e) 
        { 
            if (this.tbSend.Text.Trim().Length == 0) 
            { 
                MessageBox.Show("不能发空消息"); 
                return; 
            } 
   
            if (this.m_SocketClient.ClientState != ClientState.Closed) 
            { 
                RequestMessage rm = new RequestMessage(); 
                rm.Content = this.tbSend.Text.Trim(); 
                this.m_SocketClient.Send(rm); 
            } 
        } 
    } 
} 
  

OK，这个简单的例子我们已经开发完成了，接下来，我们来编译、测试一下这个例子！

四、运行测试

首先我们启动服务端程序、启动服务器，然后启动客户段并连接服务器，从客户段向服务器发送消息，服务端会显示客户端发送的消息会向客户端发送一个应答消息。

五、本例源代码下载

本文例子源代码请通过http://42.121.30.77/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。

作者：魏琼东
出处：http://www.cnblogs.com/eastjade
关于作者：有13年的软件从业经历，专注于中小软件企业软件开发过程研究，通过在技术与管理帮助中小软件企业实现技术层面开源节流的目的。熟悉需求分析、企业架构、项目管理。现主要从事基于AgileEAS.NET平台的技术咨询工作，主要服务于医疗卫生、铁路、电信、物流、物联网、制造、零售等行业。如有问题或建议，请多多赐教！
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，如有问题，可以通过mail.james@qq.com 联系我，也可以加入QQ群:113723486、199463175、116773358、116773358、212867943、147168308、59827496、193486983、15118502和大家共同讨论，非常感谢。

本文转自魏琼东博客园博客，原文链接：http://www.cnblogs.com/eastjade/p/3371631.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/376242

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Hadoop概念学习系列之常见的分布式文件系统（二十六）

常见的分布式文件系统有， GFS、HDFS、Lustre 、Ceph 、GridFS 、mogileFS、TFS、FastDFS等。各自适用于不同的领域。它们都不是系统级的分布式文件系统，而是应用级的分布式文件存储服务。 Google学术论文，这是众多分布式文件系统的起源 ================================== Google File System（大规模分散文件系统） MapReduce （大规模分散FrameWork） BigTable（大规模分散数据库） Chubby（分散锁服务）一般你搜索Google_三大论文中文版(Bigtable、 GFS、 Google MapReduce)就有了。做个中文版下载源：http://dl.iteye.com/topics/download/38db9a29-3e17-3dce-bc93-df9286081126 做个原版地址链接： http://labs.google.com/papers/gfs.html http://labs.google.com/papers/bigtable.html http...

2017-11-21

558

一、前言 AgileEAS.NET SOA 中间件平台是一款基于基于敏捷并行开发思想和Microsoft .Net构件(组件)开发技术而构建的一个快速开发应用平台。用于帮助中小型软件企业建立一条适合市场快速变化的开发团队，以达到节省开发成本、缩短开发时间，快速适应市场变化的目的。 AgileEAS.NET SOA中间件平台提供了敏捷快速开发软件工程的最佳实践，通过提供大量的基础支撑功能如IOC、ORM、SOA、分布式体系及敏捷并发开发方法所支撑的插件开发体系，以及提供了大量的实体、数据模型设计生成工具、代码生成工具，用于帮助中小软件开发商快速成长。 AgileEAS.NET平台充分把握目前软件行业快速发展的新趋势，基于敏捷并行开发、快速适应市场这样淳朴的软件工程实践，采用业界广泛使用的Microsoft .Net构件(组件)开发技术实践了这种开发思想，帮助软件企业实现“敏捷变化、快速适合”的目标，从而帮助软件企业在激烈的市场竞争中赢得先机并获得更高的回报。二、AgileEAS.NET SOA 中间件平台5.1反馈在2013年早些时候，我们向大家发布了AgileEAS.NET...

2017-11-21

587

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。