using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Threading.Tasks; namespace NetFrame { public class ServerStart { Socket server;maxClient;//最大客户端连接数 Semaphore acceptClients; UserTokenPool pool; public LengthEncode LE; public LengthDecode LD; public encode encode; public decode decode; 消息处理中心，由外部应用传入 AbsHandlerCenter center; 初始化通信监听 ServerStart(int max) { //实例化监听对象 server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //设定服务器最大连接人数 maxClient = max; } public void Start(int port) { //创建连接池 pool = new UserTokenPool(maxClient); //连接信号量 acceptClients = new Semaphore(maxClient, maxClient); for (int i = 0; i < maxClient; i++) { UserToken token = new UserToken(); //初始化token信息 token.receiveSAEA.Completed += new EventHandler<SocketAsyncEventArgs>(IO_Comleted); token.sendSAEA.Completed += new EventHandler<SocketAsyncEventArgs>(IO_Comleted); token.LD = LD; token.LE = LE; token.encode = encode; token.decode = decode; token.sendProcess = ProcessSend; token.closeProcess = ClientClose; token.center = center; pool.push(token); } //监听当前服务器网卡所有可用IP地址的port端口 { server.Bind(new IPEndPoint(IPAddress.Any, port)); //置于监听状态 server.Listen(10); StartAccept(null); } catch (Exception e) { Console.WriteLine(e.Message); } } 开始客户端连接监听 StartAccept(SocketAsyncEventArgs e) { (e == null) { e = new SocketAsyncEventArgs(); e.Completed += new EventHandler<SocketAsyncEventArgs>(Accept_Comleted); } else { e.AcceptSocket = null; } //信号量-1 acceptClients.WaitOne(); bool result= server.AcceptAsync(e); (!result) { ProcessAccept(e); } } public void ProcessAccept(SocketAsyncEventArgs e) { //从连接对象池取出连接对象 供新用户使用 UserToken token = pool.pop(); token.conn = e.AcceptSocket; //TODO 通知应用层 有客户端连接 center.ClientConnect(token); //开启消息到达监听 StartReceive(token); //释放当前异步对象 StartAccept(e); } public void Accept_Comleted(object sender, SocketAsyncEventArgs e) { ProcessAccept(e); } public void StartReceive(UserToken token) { try { result = token.conn.ReceiveAsync(token.receiveSAEA); (!result) { ProcessReceive(token.receiveSAEA); } } catch (Exception e) { Console.WriteLine(e.Message); } } public void IO_Comleted(object sender, SocketAsyncEventArgs e) { if (e.LastOperation == SocketAsyncOperation.Receive) { ProcessReceive(e); } else { ProcessSend(e); } } public void ProcessReceive(SocketAsyncEventArgs e) { UserToken token= e.UserToken as UserToken; (token.receiveSAEA.BytesTransferred > 0 && token.receiveSAEA.SocketError == SocketError.Success) { byte[] message = new byte[token.receiveSAEA.BytesTransferred]; //将网络消息拷贝到自定义数组 Buffer.BlockCopy(token.receiveSAEA.Buffer, 0, message, 0, token.receiveSAEA.BytesTransferred); //处理接收到的消息 token.receive(message); StartReceive(token); } else { if (token.receiveSAEA.SocketError != SocketError.Success) { ClientClose(token, token.receiveSAEA.SocketError.ToString()); } else { ClientClose(token, ); } } } public void ProcessSend(SocketAsyncEventArgs e) { UserToken token = e.UserToken as UserToken; if (e.SocketError != SocketError.Success) { ClientClose(token, e.SocketError.ToString()); } else { //消息发送成功，回调成功 token.writed(); } } 客户端断开连接 ClientClose(UserToken token,string error) { if (token.conn != null) { lock (token) { //通知应用层面 客户端断开连接了 center.ClientClose(token, error); token.Close(); //加回一个信号量，供其它用户使用 pool.push(token); acceptClients.Release(); } } } } }

　　至此，服务器的通信底层已经搭建完毕，可以进一步进行具体的游戏逻辑玩法开发了。

　　逻辑处理主要分层架构如下：