U3D + KBE Demo传输消息流程图文解析【客户端】丨少狼

U3D + KBE Demo传输消息流程图文解析【客户端】

本文选择kbe中最简单直接的账户注册登录为实例。

该流程测试例子为 kbengine_unity3d_warring-0.1.13 + kbengine-master.

unity3d + kbengine demo搭建见文。

客户端：

该脚本clientapp是kbengine的客户端插件的入口脚本，通过挂载该脚本，start启动，连接服务器，导入基本的消息，以及loginapp相关消息为登录模块作准备。

在这里，我们可以更加详细的进入kbengine插件内部去看下，在导入消息之前做了哪些工作？

gameapp = new KBEngineApp();

创建了一个KBEngineApp的实例，看下构造函数做了什么工作？

        public KBEngineApp()
        {
	    app = this;
            networkInterface_ = new NetworkInterface(this);
            kbethread = new KBEThread(this);
            t_ = new Thread(new ThreadStart(kbethread.run));
            t_.Start();
            
            // 注册事件
            installEvents();
        }

看样子是开启了一个线程。

networkInterface和kbethread两个对象是干嘛用的？

networkInterface:

        public NetworkInterface(KBEngineApp app)
        {
        	this.app_ = app;
			bindMessage();
        	packets_ = new List<MemoryStream>();
        }

		public void bindMessage()
		{
			if(Message.messages.Count == 0)
			{
				Message.messages["Loginapp_importClientMessages"] = new Message(5, "importClientMessages", 0, 0, new List<Byte>(), null);
				Message.messages["Baseapp_importClientMessages"] = new Message(207, "importClientMessages", 0, 0, new List<Byte>(), null);
				Message.messages["Baseapp_importClientEntityDef"] = new Message(208, "importClientMessages", 0, 0, new List<Byte>(), null);
				
				Message.messages["Client_onImportClientMessages"] = new Message(518, "Client_onImportClientMessages", -1, -1, new List<Byte>(), 
					this.app_.GetType().GetMethod("Client_onImportClientMessages"));
				Message.clientMessages[Message.messages["Client_onImportClientMessages"].id] = Message.messages["Client_onImportClientMessages"];
			}
		}

看到这里大概知道了，这里是定义了几个消息类型，初始化了一下需要服务器交互的消息。

这就明白了gameapp.autoImportMessagesFromServer(true);通过这些消息，与服务器连通。

kbethread:

kbethread = new KBEThread(this);这个很简单，声明一个对象，并将KBEngine的实例给KBEthread。

new ThreadStart(kbethread.run) 开启线程的时候调用了一个run函数，进去看下。

到这里就不列举进去了，里面是通过process循环执行events，来保证能够及时处理服务器发到客户端的消息。

			Monitor.Enter(events_in);
			if(firedEvents_in.Count > 0)
			{
				foreach(EventObj evt in firedEvents_in)
				{
					doingEvents_in.AddLast(evt);
				}
				firedEvents_in.Clear();
			}
			Monitor.Exit(events_in);

看到DEBUG时候，很疑惑为什么会有这多消息导入呢，貌似代码中并没有这么多处理的。

经过分析，是服务器返回一个消息，调用Client_onImportClientMessages该函数，这个消息可以上面的消息定义中找到。

		public void Client_onImportClientMessages(MemoryStream stream)
		{
			byte[] datas = new byte[stream.wpos - stream.rpos];
			Array.Copy (stream.data (), stream.rpos, datas, 0, stream.wpos - stream.rpos);
			Event.fireAll ("onImportClientMessages", new object[]{currserver, datas});

			onImportClientMessages (stream);
		}

然后它就开始了它的消息导入之旅，也可以说是消息定义，这样这样服务器就可以通过这些消息与服务器进行通信了。