AgileEAS.NET SOA 中间件平台.Net Socket通信框架-简单例子-实现简单的服务端客户端消息应答
2013-10-16 10:20
876 查看
一、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。
相关文章推荐
- AgileEAS.NET SOA 中间件平台.Net Socket通信框架-简单例子-实现简单的服务端客户端消息应答 推荐
- AgileEAS.NET SOA 中间件平台.Net Socket通信框架-完整应用例子-在线聊天室系统-下载配置
- AgileEAS.NET SOA 中间件平台.Net Socket通信框架-完整应用例子-在线聊天室系统-代码解析
- AgileEAS.NET SOA 中间件平台.Net Socket通信框架-介绍
- AgileEAS.NET SOA 中间件平台.Net Socket通信框架-介绍
- AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(三):配置ActiveXForm运行环境
- 重写AgileEAS.NET SOA 中间件平台账号密码的加密算法
- AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(一):下载平台并基于直连环境运行
- AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(四):开源的Silverlight运行容器的编译、配置
- .net平台 基于 XMPP协议的即时消息服务端简单实现
- .net平台 基于 XMPP协议的即时消息服务端简单实现
- AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二):配置WinClient分布式运行环境
- AgileEAS.NET SOA 中间件平台工作流系统介绍
- AgileEAS.NET SOA平台多帐套的实现
- AgileEAS.NET SOA中间件平台/敏捷软件开发平台
- AgileEAS.NET SOA 中间件平台 5.2 发布说明-包含Silverlight及报表系统的开源代码下载
- AgileEAS.NET SOA 中间件平台工作流系统介绍
- AgileEAS.NET SOA中间件平台简易入门
- AgileEAS.NET SOA 中间件平台工作流系统介绍
- AgileEAS.NET SOA中间件平台更新日志 2015-04-28