关于工作线程数的疑问

问题讨论云引擎

coman 2017-02-20 10:41:18 UTC #18

问一下，如果某个瞬间的并发请求占满了线程，那是会丢弃请求，还是排队处理呢？

DamaoZhang 2017-02-20 11:03:30 UTC #19

会丢弃请求，这样客户端可以自行处理重试逻辑

DamaoZhang 2017-02-20 11:06:28 UTC #20

另外如果是游戏里的「每帧」都会发起请求，那肯定是有问题的……

artsungames 2017-02-20 11:08:10 UTC #21

不是每帧都发起请求，而是原来一帧发起来近30个请求，我准备改成分散到15个帧中去。

asaka 2017-02-20 11:13:13 UTC #22

这样区别应该也不会太大。要改成「上一个请求发送完成并响应，再发送下一个请求」才可以。

asaka 2017-02-20 11:13:46 UTC #23

是会被丢弃的，就是这个帖子里描述的 429 异常。

artsungames 2017-02-20 11:16:27 UTC #24

如果改成以下这样呢？
原来一帧调用了20个按ID查询、10个云引擎函数；现在服务器端更新增加2个云函数，客户端改为2个调用，一个是传入20个要查询的ID，另一个是传入10个要查到云引擎；在服务器端的新的云函数中分别再去调用相应的查询和原云引擎接口调用。也就是说只省掉了多次网络传输，但原接口调用的次数并没减少。

asaka 2017-02-20 12:04:32 UTC #25

不管是否是在云引擎还是在客户端，串行调用就可以解决问题。并发调用还是会有问题。

artsungames 2017-02-20 12:08:18 UTC #26

那么我先在客户端将原来一帧发起的近30个请求分散到15个帧中去试试看再来update。服务器端不会改成串行。谢谢你～

leeyeh 2017-02-20 13:10:14 UTC #27

20 个按 id 查询，如果是一个 Class 的话，可以合并成一个 containsIn 查询。

artsungames 2017-02-20 13:22:59 UTC #29

非常感谢，但在unity SDK的文档中没搜到呢。https://leancloud.cn/docs/unity_guide.html

我现在使用的是：

AVQuery<AVObject> query=new AVQuery<AVObject>("GameScore");
query.GetAsync("53706cd1e4b0d4bef5eb32ab").ContinueWith(t =>
{
    AVObject gameScore = t.Result;//如果成功获取，t.Result将是一个合法有效的AVObject
});

leeyeh 2017-02-20 13:41:32 UTC #30

@wujun

artsungames 2017-02-21 11:51:51 UTC #31

更新：
目前重构为可以在客户端设置同时最多有几个并行的查询任务，若未满则会开始队列里下一个查询任务。
当任务多时，服务器端仍然会报那一长串错（ https://github.com/leancloud/python-sdk/issues/295 即这个issue），但即使我在客户端调到极高的并行上限，也没有再发生过unity崩溃死机的情况。可能是因为我的重构让代码鲁棒性更强了。持续观察中。

artsungames 2017-03-08 04:38:10 UTC #32

更新:
今天学会了python的containsIn的用法，在服务器对某个云函数将多个按id查询合并为一个，然后效率提高了不少：
（只看前后红框的对比，非红框的是其他查询测试操作）

关于统计图的疑问：
统计图里是每五分钟一个数据点，以某点的最大QPS = 9为例，请问意思是以下哪个？

该点向前5分钟这个时间段内，总计的请求数是9
该点向前5分钟这个时间段内，每秒都有一个最大QPS统计数据，其中最大的QPS为9
该点向前5分钟内总计请求数/所有秒数（60*5=300）得到9

谢谢！

dennis 2017-03-08 10:02:41 UTC #33

第二个理解是对的，目前取的是区间里的最大值，因为这个对用户最有参考价值。

artsungames 2017-03-08 10:04:10 UTC #34

非常感谢！
明白了！那开发期间测试想要更准的数据，就每15分钟测一次吧

artsungames 2017-03-23 14:36:49 UTC #35

您好，今天我看之前类比您建议的这个结构写的代码，有一点疑问。我的代码：

try:
    object.fetch()
except leancloud.LeanCloudError as e:
    if e.code == 429:
        print '并发超限, code = 429'
    else:
        raise e
else:
        对object进行操作A
其他操作B

我的代码中catch到了429 error后只是print了，并没有做什么事情。我希望的效果是即时catch到了429也终止整个函数，而我这样写是错误的吧？（因为如果是429了，代码会继续执行“其他操作B”）。

那么我这里是否可以将结构改成：

object.fetch()
对object进行操作A
其他操作B

既然catch到了我也做不了什么，是否不如根本就不用try？只要客户端发现失败了，重新发起请求就可以。

另外请问一般catch到了429，有什么workaround推荐？

DamaoZhang 2017-03-23 15:57:27 UTC #36

这里捕获异常的作用是让发生并发超限时程序不至于崩溃。至于怎么处理就看自己的选择了，但是仍然推荐在日志中打印这个异常，这样可以在事后回溯的时候知道究竟发生了什么。

如果客户端在发生 429 错误时立刻自动重试容易导致更多的并发。比较好的处理方法可能是提示用户主动重试。

当然最根本的解决方案还是升级到商用版……

artsungames 2017-03-24 03:21:51 UTC #37

感谢您回复，日后游戏上线肯定是要升级成商用版的，现在还在原型开发阶段
我的主要问题是：
1 即使不捕获并print，当出现任何异常时，在云引擎网页后台也是可以看到出错信息，那么为什么要捕获呢？
2 在我回复的第一部分代码中，“其他操作B”这部分逻辑是否错误的？如果非要捕获并打印，正确的逻辑是否应该在print '并发超限, code = 429'这行后，也加上raise e。这样当并发超限后打印了就终止该函数运行了，不会再运行“其他操作B”这部分。

DamaoZhang 2017-03-24 05:28:22 UTC #38

异常通常来说都是要处理的，不在云引擎做，那就在客户端做。看你的描述是在客户端做异常处理，也没问题的。

采用 Discourse，启用 JavaScript 以获得最佳效果