class EchoHandler : Handler
{public override Object Read(IHandlerContext context, Object message){var session = context.Session;var pk = message as Packet;session.WriteLog("收到：{0}", pk.ToStr());// 把收到的数据发回去
        session.Send(pk);return null;}
}

// 实例化服务端，指定端口，同时在Tcp/Udp/IPv4/IPv6上监听
var svr = new NetServer
{Port = 1234,Log = XTrace.Log
};
svr.Add<EchoHandler>();
svr.Start();

static void TestClient()
{var uri = new NetUri("tcp://127.0.0.1:1234");//var uri = new NetUri("tcp://net.newlifex.com:1234");var client = uri.CreateRemote();client.Log = XTrace.Log;client.Received += (s, e) =>{XTrace.WriteLine("收到：{0}", e.Packet.ToStr());};client.Open();// 定时显示性能数据_timer = new TimerX(ShowStat, client, 100, 1000);// 循环发送数据for (var i = 0; i < 5; i++){//Thread.Sleep(1000);var str = "你好" + (i + 1);client.Send(str);}//client.Dispose();
}

static void TestServer()
{// 实例化服务端，指定端口，同时在Tcp/Udp/IPv4/IPv6上监听var svr = new NetServer{Port = 1234,Log = XTrace.Log};//svr.Add(new LengthFieldCodec { Size = 4 });svr.Add<StandardCodec>();svr.Add<EchoHandler>();// 打开原始数据日志var ns = svr.Server;ns.LogSend = true;ns.LogReceive = true;svr.Start();_server = svr;// 定时显示性能数据_timer = new TimerX(ShowStat, svr, 100, 1000);
}

static void TestClient()
{var uri = new NetUri("tcp://127.0.0.1:1234");//var uri = new NetUri("tcp://net.newlifex.com:1234");var client = uri.CreateRemote();client.Log = XTrace.Log;client.Received += (s, e) =>{var pk = e.Message as Packet;XTrace.WriteLine("收到：{0}", pk.ToStr());};//client.Add(new LengthFieldCodec { Size = 4 });client.Add<StandardCodec>();// 打开原始数据日志var ns = client;ns.LogSend = true;ns.LogReceive = true;client.Open();// 定时显示性能数据_timer = new TimerX(ShowStat, client, 100, 1000);// 循环发送数据for (var i = 0; i < 5; i++){var str = "你好" + (i + 1);var pk = new Packet(str.GetBytes());client.SendAsync(pk);}
}