游戏服务器开发 (服务器创建篇) - 纳金网

class ServerStart
{
private static Socket server;//服务器监听对象
public static void start(int port)
{
//创建监听对象
server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//绑定监听端口
server.Bind(new IPEndPoint(IPAddress.Any, port));
server.Listen(20);
//开启异步连接监听
server.BeginAccept(AcceptCallBack, server);
Console.WriteLine("server start");
while (true) { }
}
public static void stop()
{
server.Dispose();
server.Close();
}
private static void AcceptCallBack(IAsyncResult ar)
{
Console.WriteLine("有客户端连接");
try
{
Socket listener = (Socket)ar.AsyncState;
//获取连接过来的连接信息
Socket client = listener.EndAccept(ar);
//创建自定义连接信息
Session session = new Session();
session.socket = client;
//开始异步监听客户端消息
client.BeginReceive(session.message, 0, session.message.Length, SocketFlags.None, ReceiveCallBack, session);
//服务器继续监听下一个连接到来
listener.BeginAccept(AcceptCallBack, listener);
}
catch
{
}
}
private static void ReceiveCallBack(IAsyncResult ar)
{
Session session = (Session)ar.AsyncState;
int readCount = 0;
try
{
//读取消息长度
readCount = session.socket.EndReceive(ar);//调用这个函数来结束本次接收并返回接收到的数据长度。
if (readCount == 0)
{
Console.WriteLine("有客户端断开连接");
LogicHandler.getInstance().sessionClose(session);
return;
}
byte[] bytes = new byte[readCount];//创建长度对等的bytearray用于接收
Buffer.BlockCopy(session.message, 0, bytes, 0, readCount);//拷贝读取的消息到消息接收数组
readMessage(session, bytes);//消息读取完成
}
catch (SocketException)//出现Socket异常就关闭连接
{
session.socket.Close();//这个函数用来关闭客户端连接
return;
}
//继续监听下一条消息的到来
session.socket.BeginReceive(session.message, 0, session.message.Length, SocketFlags.None, ReceiveCallBack, session);
}
}

复制代码