Beetle简单构建TCP服务

使用Beetle构建TCP服务应用是件非常简单的事情,它并不需要你去关注Socket细节,如果你想用Socket编写高性能的TCP服务,那你要关注的东西非常多,异步数据处理,大量连接下的线程管理和连接断相关资源处理等等复杂的事情;使用Beetle那以上的事情完全都可以不用关心,因为Beetle都已经帮你处理好.而你需要做的只需要简单的定义相关对象和绑定相关处理事件即可. 以下是通过Beetle实现一个简单的TCP服务

配置

<configSections>
<section name="beetle" type="Beetle.ConfigSection, Beetle"/>
</configSections>
<beetle Connections="1000"
Pools="1"
SocketSendThreads="1"
SocketReceiveThreads="1"
SocketThreadSleep="1"
WorkThreads="1"
WorkThreadSleep="1"
SendBufferSize="2048"
ReceiveBufferSize="2048"
PackageMaxSize="8196"
StringEncodingSize="512"
ChannelMaxQueueData="0"
ExecutionContext="False"
TimeOut="30"
Statistics="False"/>

Beetle.TcpUtils.Setup("beetle");//初始化组件

现实TCP服务端

class Program:Beetle.ServerBase
{
protected override void OnConnected(object sender, Beetle.ChannelEventArgs e)
{
base.OnConnected(sender, e);
C.WriteLine("{0} connected!", e.Channel.EndPoint);
}
protected override void OnDisposed(object sender, Beetle.ChannelDisposedEventArgs e)
{
base.OnDisposed(sender, e);
C.WriteLine("{0} disposed!", e.Channel.EndPoint);
}
protected override void OnError(object sender, Beetle.ChannelErrorEventArgs e)
{
base.OnError(sender, e);
C.WriteLine("{0} Error {1}!", e.Channel.EndPoint,e.Exception.Message);
}
protected override void OnReceive(object sender, Beetle.ChannelReceiveEventArgs e)
{
string value = e.Channel.Coding.GetString(e.Data.Array, e.Data.Offset, e.Data.Count);
C.WriteLine(value);
Beetle.StringMessage msg = new Beetle.StringMessage();
msg.Value = value;
e.Channel.Send(msg);
}

}

Program server = new Program();
server.Open(9321);
C.WriteLine("Server started @9321");

连接到服务端进行数据处理

//连接到指定IP的端口服务
channel = Beetle.TcpServer.CreateClient(txtIPAddress.Text, 9321);
//绑定数据流接收事件
channel.DataReceive = OnReceive;
//连接断开事件
channel.ChannelDisposed += OnDisposed;
//开始接收数据
channel.BeginReceive();

Beetle.StringMessage msg = new Beetle.StringMessage();
msg.Value = richTextBox1.Text;
channel.Send(msg);

运行效果

总结