NetPs.Tcp 1.0.30829

简介

NetPs.TCP基于NetPs.Socket，对TCP数据数据传输提供便捷。

其中将服务端、客户端 分开进行实现TcpServer类与TcpClient类。

增加了TcpClient 的分支 TcpRepeaterClient 优化转发类，在此基础上提供了StartMirror(url)方法。

该库支持提前预热来加快首次运行速度，可以通过调用方法进行使用 NetPs.Socket.Eggs.Food.Heating();

How To Use?

• TcpServer

  当 "0.0.0.0:0" 中端口为 "0" 值时，会生成可使用的端口，你可以通过server.Address、server.IPEndPoint 查看。

  你可以通过的两种快捷方式创建该实例。

1. parament

var server = new TcpServer((server, client) =>
{
  // Accept new client
  // 转发到192.168.1.1，并且会将接收后的数据转发回请求端
  client.StartMirror("192.168.1.1:443");
});
server.Run("0.0.0.0:7070", () =>  Environment.Exit(0));

2. interface

class Server : ITcpServerConfig, IDisposable
{
    private TcpServer serv;
    public Server()
    {
        this.serv = new TcpServer(this);
    }

    public string BandAddress => "0.0.0.0:0";

    public bool TcpAccept(TcpServer server, TcpClient client) { 
        //this.serv.StartReceive(this); //需要手动开启接收
        tcp.StartMirror("192.168.1.1:443");
        return true;
    }
    public void TcpConfigure(TcpCore core) { }

    public void TcpReceive(byte[] data, TcpClient tcp) {}
    
    public void Dispose()
    {
        this.serv.Dispose();
    }
}

• TcpClient

var client = new TcpClient();
client.ReceivedObservable.Subscribe(data => {
  // received byte[] data
});
client.ConnectedObservable.Subscribe(_ => client.Rx.StartReceive());
client.Connect("127.0.0.1:12345");
client.Transport(new byte[] {1,2,3});

• TcpRepeaterClient

// A, B之间转发数据
var A = new TcpClient();
var B = new TcpClient();
var repeater_client1 = new TcpRepeaterClient(B, B.Tx);
var repeater_client2 = new TcpRepeaterClient(A, A.Tx);

repeater_client1.Disposables.Add(repeater_client1.ConnectedObservable.Subscribe(_ =>
{
    repeater_client1.Rx.StartReceive();
    repeater_client2.Rx.StartReceive();
}));

Tests

./ethr -c 127.0.0.1 -port 8000 -t pi -d 5m

-----------------------------------------------------------------------------------------
TCP connect statistics for [127.0.0.1]:8000:
  Sent = 300, Received = 300, Lost = 0
-----------------------------------------------------------------------------------------
      Avg       Min       50%       90%       95%       99%     99.9%    99.99%       Max
305.793us 146.100us 256.200us 496.900us 548.300us 735.000us 756.800us 756.800us 871.400us
-----------------------------------------------------------------------------------------
Ethr done, duration: 5m0s.

./ethr -c 127.0.0.1 -port 8000 -t c -n 0 -p tcp -d 5s

Using destination: 127.0.0.1, ip: 127.0.0.1, port: 8000
- - - - - - - - - - - - - - - - - -
Protocol    Interval      Conn/s
  TCP      050-051 sec    20.13K
  TCP      051-052 sec    21.27K
  TCP      052-053 sec    21.30K
  TCP      053-054 sec    20.16K
  TCP      054-055 sec    20.56K
  TCP      055-056 sec    21.07K
  TCP      056-057 sec       21K
  TCP      057-058 sec    20.89K
  TCP      058-059 sec    20.23K
  TCP      059-060 sec    20.56K
Ethr done, duration: 1m0s.

<u>NetPs以实现现有网络协议库为目标，为数据交互提供基础支撑。</u>