TcpService 是 TCP 系服务器基类,但是不参与实际的数据交互,实际的数据交互由 SocketClient 完成,所以 TcpService 的功能只是配置、激活、管理、注销、
重建 SocketClient 类实例,所以在 TcpService 中,须指定其 SocketClient 派生的泛型类型,然后必须实现 HandleReceivedData 方法,该方法指示如何处理已接收数据或经过适配器转换的对象。
所以具体创建过程如下。
TcpService service = new TcpService();
service.Connecting += (client, e) =>{};//有客户端正在连接
service.Connected += (client, e) =>{};//有客户端连接
service.Disconnected += (client, e) =>{};//有客户端断开连接
service.Received += (client, byteBlock ,requestInfo) =>
{
//从客户端收到信息
string mes = Encoding.UTF8.GetString(byteBlock.Buffer, 0, byteBlock.Len);
Console.WriteLine($"已从{client.Name}接收到信息:{mes}");//Name即IP+Port
};
//声明配置
var config = new TcpServiceConfig();
config.ListenIPHosts = new IPHost[] { new IPHost("127.0.0.1:7789"), new IPHost(7790) };//同时监听两个地址
//载入配置
service.Setup(config);
service.Start();
TcpClient 是 TCP 客户端的基类,为抽象类,不可创建实例,须通过继承实现 HandleReceivedData 方法,该方法指示如何处理接收到的数据。
SimpleTcpClient tcpClient = new SimpleTcpClient();
tcpClient.Connected += (client, e) =>{};//成功连接到服务器
tcpClient.Disconnected += (client, e) =>{};//从服务器断开连接,当连接不成功时不会触发。
tcpClient.Received += (client, byteBlock ,requestInfo) =>
{
//从服务器收到信息
string mes = Encoding.UTF8.GetString(byteBlock.Buffer, 0, byteBlock.Len);
Console.WriteLine($"接收到信息:{mes}");
};
//载入配置
tcpClient.Setup("127.0.0.1:7789");
tcpClient.Connect();
tcpClient.Send(Encoding.UTF8.GetBytes("RRQM"));
客户端 服务端发送都是封装了 send 方法,TcpClient 和 TcpService 已经内置了多种发送方法,直接调用就可以发送。如果发送失败,则会立即抛出异常。
service.Send(“”);
最后大家如果喜欢我的文章,还麻烦给个关注, 希望 net 生态圈越来越好!