Elixir游戏服设计四

Posted 2020-07-16 damnit

上章说到我们要引入syn https://github.com/ostinelli/syn/

看过文档，它并没有直接提供{via, Module, Name} 相关的方法。我们需要封装一下。

Name暂时可以用id，如果有需要再调整

以后有回调需求的话，刚好也可以做在那个模块里。

在player_server_manager项目里增加{:syn, "1.4.0"} 运行命令获取依赖

修改application 方法，增加依赖

  def application do
    [applications: [:logger, :syn],
     mod: {PlayerServerManager, []}]
  end

然后在项目里增加PlayerRegistry模块

defmodule PlayerRegistry do
    def register_name(name, pid) when is_pid(pid) do
        case :syn.register(name, pid) do
            :ok -> :yes
            _ -> :no
        end
    end

    def unregister_name(name) do
        :syn.unregister(name)
        :ok
    end

    def whereis_name(name) do
        :syn.find_by_key(name)
    end

    def send(name, msg) do
        case whereis_name(name) do
            :undefined ->
                exit({:badarg, {name, msg}})
            pid ->
                Kernel.send pid, msg
                pid
        end
    end
end

参照:global 模块实现。

修改PlayerServer.start_link 如下

    def via_tuple(id), do: {:via, PlayerRegistry, id}
    def start_link(player) do
         GenServer.start_link(__MODULE__, %{player: player, socket: nil}, name: via_tuple(player.base_info.id))
    end

PlayerServerManager.start 修改，增加syn的初始化，

  def start(_type, _args) do
    import Supervisor.Spec, warn: false
    :syn.init()
    children = [
      # Define workers and child supervisors to be supervised
      worker(PlayerServer, [], restart: :temporary),
    ]

    # See http://elixir-lang.org/docs/stable/elixir/Supervisor.html
    # for other strategies and supported options
    opts = [strategy: :simple_one_for_one, name: PlayerServerManager.Supervisor]
    Supervisor.start_link(children, opts)
  end

PlayerServerManagerTest增加测试代码

  test "player_registry", %{player: player} do
    assert {:ok, pid} = PlayerServerManager.start_player_server(player)
    assert PlayerServer.gem(PlayerServer.via_tuple(player.base_info.id)) == 0
  end

测试成功，ok。目前看起来还好。分布式的注册以及冲突处理留待以后再做测试了。

写到这，发现via_tuple要能接受player和id2种参数更好，方便点。