Unity3D与AvosCloud网游开发实践 - 单线程U3D中的异步通讯处理

Unity3D被设计为单线程的结构，即在主线程之外绝大多数API都是无法使用的，而AvosCloud所有数据通讯都是异步的，这样就产生了一些问题。

举例来说，角色获得了足够的升级经验，于是向服务器发送升级请求，然而在服务器返回成功的回调里，你没法显示一个恭喜升级之类的面板。因为这个回调不在主线程中。

此文就如何处理这个矛盾进行讨论。

思路

简单起见，此文以登陆为例。下面是必须的登陆调用。

// <异步调用前>
AVUser.LogInAsync(userNameStr, passWordStr).ContinueWith(t=>{// <异步线程内>AVUser loginUser = AVUser.CurrentUser;
});

在这段代码中，先做两个标记位置#异步调用前和#异步线程内，便于后续讨论。

<异步线程内> 无法执行UnityAPI。但是我们必然需要让玩家登陆之后，进入到游戏画面。

但是在<异步调用前>和<异步线程内>都可以访问共享数据。

那么核心思路就是，设置一个共享数据，它拥有三个状态，待机、等待和完成。

在<异步调用前>，将共享数据写为等待，在<异步线程内>，将此共享数据写为完成。

主线程要反复查询此共享数据，如果它处于完成态，则根据异步调用获得的数据，调用相关UnityAPI。并将其重置回待机。

方案实现

这个是我比较推荐，自己也在使用的方案。

主线程设锁
此方案的结构很简单，放哪里都可以，这里我放进自己的GameManager类中。

// ---------------------------------
// GameManager.cs
// ---------------------------------
// NOTE 此方法必须在主线程中调用
public void AsyncBeginWait()
{UIManager.Instance.WidgetWaiting.Show(true);lock(asyncWaitObj){asyncWaitObj.AsyncWaiting = true;}
}// NOTE 可在任何线程中调用
public void AsyncEndWait(Action callback)
{lock(asyncWaitObj){asyncWaitObj.AsyncWaiting = false;asyncWaitObj.AsyncWaitAction = callback;}
}void Update () {lock(asyncWaitObj){if(!asyncWaitObj.AsyncWaiting && asyncWaitObj.AsyncWaitAction != null){asyncWaitObj.AsyncWaitAction();asyncWaitObj.AsyncWaitAction = null;UIManager.Instance.WidgetWaiting.gameObject.SetActive(false);}}
}

将上述结构应用到登陆

// -----------------------------------
// SomeLogin.cs
// -----------------------------------
// #异步调用前
GameManager.Instance.AsyncBeginWait();
AVUser.LogInAsync(userName, passWord).ContinueWith(t=>{// #异步线程内AVUser loginUser = AVUser.CurrentUser;GameManager.Instance.AsyncEndWait(()=>{// TODO 任何UnityAPI相关操作});
});

首先调用AsyncBeginWait显示等待画面WidgetWaiting，等待画面也起到阻断用户输入的作用。

AsyncWaiting设为true，告诉主线程异步工作已开始。

在异步调用完成之前，让玩家等待小段时间。这个时间很难说，Avos的登陆大多在0-2秒内，也出现过长达10s的情况。

在数据请求执行完毕后，设置AsyncWaitAction回调。

随后异步线程执行完毕退出，到达下一个主循环时，GameManager的Update发现有新完成的消息，于是在主线程调用AsyncWaitAction。

方案特点

代码简洁，数据请求到后续处理都在一起，便于阅读和复查
借助匿名函数优势，获取相关数据时会处于最便捷的位置

其他方案

我最初的一个方案是事件队列，类似网游的消息协议，将每一个数据请求对应于一个事件。后来发现太庞大了，而且每必要，于是撤掉了。

PInvoke是否另一种方案？问题是需要对所有必要的UnityAPI进行封装，究竟效果如何，得有心人试过才知道了。

阅读原文:http://www.lolofinil.com/2014/07/14/unity_work_with_async_api/