SuperSocket源码解析之会话生命周期

2023-08-26 14:34:52

一基本概念

会话(Session)是客户端与服务器进行通信的基本单元，也是一个Socket的封装，在http协议中也有Session机制，其主要作用封装一个通信单元socket，负责服务器与客户端消息发送与接收，会话之间相互独立互不干扰且拥有唯一SessionId标识，维护着客户与服务器通信的生命周期。

二 SocketSession

SocketSession是SuperSocket建立在消息收发层的会话，其主要作用在于客户与服务器通信，其生命周期主要由创建，初始化，启动，运行，关闭过程组成；

2.1 创建

SocketSession的创建源于服务器监听端口接收到一个客户端连接请求，取出该连接的Socket触发新客户端请求事件，且看代码

private IAppSession ProcessNewClient(Socket client, SslProtocols security)
{
//取出预先准备好的SocketAsyncEventArgsProxy代理
SocketAsyncEventArgsProxy socketEventArgsProxy;
if (!m_ReadWritePool.TryPop(out socketEventArgsProxy))
{
AppServer.AsyncRun(client.SafeClose);
if (AppServer.Logger.IsErrorEnabled)
AppServer.Logger.ErrorFormat("Max connection number {0} was reached!", AppServer.Config.MaxConnectionNumber);

return null;
}

ISocketSession socketSession;

if (security == SslProtocols.None)
socketSession = new AsyncSocketSession(client, socketEventArgsProxy);
else
socketSession = new AsyncStreamSocketSession(client, security, socketEventArgsProxy);

var session = CreateSession(client, socketSession);

//很大原因在于被连接过滤掉了这个地址,所以把拿出来的资源重置后在压入连接栈,并关闭端口
if (session == null)
{
socketEventArgsProxy.Reset();
this.m_ReadWritePool.Push(socketEventArgsProxy);
AppServer.AsyncRun(client.SafeClose);
return null;
}

socketSession.Closed += SessionClosed;

var negotiateSession = socketSession as INegotiateSocketSession;

if (negotiateSession == null)
{
if (RegisterSession(session))
{
AppServer.AsyncRun(() => socketSession.Start());
}

return session;
}

negotiateSession.NegotiateCompleted += OnSocketSessionNegotiateCompleted;
negotiateSession.Negotiate();

return null;
}

1）每一个客户端Socket都将交由SocketAsyncEventArgsProxy代理托管，该代理主要用着socket连接是否断开判断；

2）首先创建一个SocketSession实例，将该实例作为AppSession创建的参数；