消息通信流程

ET框架中是使用Session和Channel实现的消息通信

Session是会话，比如打电话，从拨号到挂断这就是一个Session

Channel是通道,我的理解是比如打电话时，Channel表示是使用联通信号或者是移动信号或者是电信信号

创建一个Channel(以TCP为例)

设置包体长度为service中的包体长度->通过service.MemoryStreamManager.GetStream设置memoryStream->创建Socket->创建PacketParser->设置SocktArgs innArgs/outArgs的回调函数，用于处理信息->设置连接和发送状态

1
public TChannel(IPEndPoint ipEndPoint, TService service): base(service, ChannelType.Connect)

创建一个Session

得到Game.Scene.NetInnerComponent/NetOuterComponent组件调用Get函数

NetInnerComponent/NetOuterComponent的Get函数

1
public Session Get(IPEndPoint ipEndPoint){}

首先会判断是是否有缓存的Sesssion->根据address连到并得到NetInnerComponent上对应的Channel->通过ComponentFactory使用channel作为参数创建Session

Session的初始化流程

将Session的channel赋值参数中的channel->清空requestCallback字典(用于调用Request信息时,给awiat提供Result)->给channel设置ErrorCall(Request出现错误,会移除Session)->设置channel.ReadCallback为OnRead函数(接收信息时读取信息)

Session发送一个消息

Session的Send函数

1
2
3
4
5
6
7
public void Send(IMessage message)
{
	OpcodeTypeComponent opcodeTypeComponent = this.Network.Entity.GetComponent<OpcodeTypeComponent>();
	ushort opcode = opcodeTypeComponent.GetOpcode(message.GetType());
	
	Send(opcode, message);
}

通过消息类型判断opcode->得到channel的stream，序列化message和opcode将其写入到channel的stream中->调用Session的channel的Send函数发送消息

1
public override void Send(MemoryStream stream){}

Channel的Send函数

得到Channel的Service->根据Service的PacketSizeLength判断包体长度->设置Channel的sendBuffer长度->将stream写入到sendBuffer->调用Service的MarkNeedStartSend函数

1
2
public override void Send(MemoryStream stream){}
public void MarkNeedStartSend(long id){}

Service的MarkNeedStartSend函数

将channel的id写入到Service中的HashSet needStartSendChannel中

在Service的Update生命周期中会，根据needStartSendChannel判断channel是否有待发送的信息，如果此信息待发送则调用channel的StartSend()

1
public void StartSend()

Channel的StartSend函数

判断连接状态->判断消息是否为空->设置发送状态->设置SocketAsyncEventArgs的Buffer->socket异步发送SocketAsyncEventArgs