在我用 Erlang 开发的 websocket 服务器中,我想start_timer/3
为每个连接使用一个计时器(
假设我将有大量客户端连接,Erlang 计时器是否可以很好地扩展?
什么是大量连接?Erlangs VM 在内部使用计时器轮来处理计时器,因此它可以很好地扩展到数千个连接。那么你可能会遇到麻烦。
通常,诀窍是在计时器上将 pid 组合在一起。这也是内核倾向于做的事情。例如,如果您有一个必须在 200 毫秒内唤醒的计时器,您可以提前安排自己,而不是在下一个计时器上,而是再次安排下一个 200 毫秒计时器。这意味着您将等待至少 200 毫秒,也许 400 毫秒,300 毫秒是典型的。通过近似这样的计时器,您可以运行更多,因为您可以让单个计时器一次性唤醒大量进程。但是根据定时器的频率和定时器的数量,一个标准send_after/3
可能就足够了。
在任何情况下,我都会首先假设它可以扩展,然后如果它不能通过像上面设想的近似时间来处理问题。
这种服务器的一个常见模式是利用轻量级 Erlang 进程,并为每个连接创建一个服务器。
例如,您可以使用为您提供两者的 gen_server 行为来构建您的服务器
好消息是每个服务器都必须处理一个客户端,因此编写起来非常容易。
初始化阶段应该启动一个等待连接的服务器,
然后在连接时,服务器应该启动一个新的客户端,为下一个客户端做好准备(最好是通过主管启动 simple_one_for_one 孩子)并进入登录步骤或任何你想做的事情。
您会在网站 LearnYouSomeErlang 上找到非常有趣的信息,特别是在http://learnyousomeerlang.com/supervisors章节和以下章节中。