1 public interface ITcp:ITcpClientsController,IDisposable
2 {
3 void Initialize();
4 void Start();
5 void Stop(); // 釋放所有連接
6
7 int Port{ get ; set ;}
8 int ConnectionCount{ get ;} // 當(dāng)前連接的數(shù)量
9 int RecieveBuffSize{ get ; set ;}
10 int MaxMessageSize{ set ;} // 當(dāng)發(fā)現(xiàn)的消息長(zhǎng)度大于MaxMessageSize，將關(guān)閉對(duì)應(yīng)的連接
11
12 ITcpStreamDispatcherDispatcher{ set ;} // 支持依賴注入
13 IContractHelperContractHelper{ set ;}
14 IBufferPoolBufferPool{ set ;}
15 IEsbLoggerEsbLogger{ set ;} // 記錄運(yùn)行日志
16
17 event CbSimpleIntSomeOneConnected; // 上線,ConnectID
18 event CbSimpleIntConnectionCountChanged; // 在線人數(shù)變化
19
20 event CallBackDisconnectSomeOneDisConnected; // 掉線,ConnectID
21 event CallBackRespondServiceCommitted; // 用戶請(qǐng)求的服務(wù)的回復(fù)信息
22 event CallBackRespondServiceDirectCommitted; // 對(duì)應(yīng)ITcpClientsController.SendData，此時(shí)無法確定ServiceKey
23 }
24
25 public delegate void CallBackRespond( int connectID,NetMessagemsg);
26 public delegate void CallBackDisconnect( int connectID,DisconnectedCausecause);

public interface INet
{
void Initialize();
void Start();
void Stop();

int Port{ get ; set ;}
}

public interface IBufferPool
{
byte []RentBuffer( int minSize);
void GivebackBuffer( byte []buffer);
}

public interface ITcpClientsController
{
// 主動(dòng)給某個(gè)客戶同步發(fā)信息
void SendData( int ConnectID,NetMessagemsg);

// 主動(dòng)關(guān)閉連接
void DisposeOneConnection( int connectID,DisconnectedCausecause);
}