|
@@ -18,7 +18,7 @@ namespace ET.Server
|
|
|
var session = new AsyncTcpSession();
|
|
|
self.Session = session;
|
|
|
session.NoDelay = true;
|
|
|
- session.ReceiveBufferSize = 1024;
|
|
|
+ session.ReceiveBufferSize = 10* 1024;
|
|
|
|
|
|
session.Connected += new EventHandler(OnSessionConnected);
|
|
|
session.Error += new EventHandler<ErrorEventArgs>(OnSessionError);
|
|
@@ -60,10 +60,23 @@ namespace ET.Server
|
|
|
|
|
|
private static void OnSessionDataReceived(object sender, DataEventArgs e)
|
|
|
{
|
|
|
- var buff = e.Data;
|
|
|
var len = e.Length;
|
|
|
- Log.Debug("receive fast stream data");
|
|
|
+ Log.Debug($"receive fast stream data: len({len})");
|
|
|
Log.Debug("======================================");
|
|
|
+ var buff = ByteBuffer.Allocate(len, true);
|
|
|
+ var keylen = buff.ReadShort();
|
|
|
+ var vallen = buff.ReadInt();
|
|
|
+ if(keylen + vallen > len)
|
|
|
+ {
|
|
|
+ Log.Debug("unknow content");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ var key = buff.ReadString(keylen);
|
|
|
+ var val = buff.ReadString(vallen);
|
|
|
+ Log.Debug($"{key} = {val}");
|
|
|
+ }
|
|
|
+ Log.Debug("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^");
|
|
|
}
|
|
|
|
|
|
private static void OnSessionError(object sender, ErrorEventArgs e)
|