Применение Phoenix на парке машин

Я разрабатываю приложение Phoenix в реальном времени, используя его модули Channel и Socket. Приложение состоит из нескольких процессов и GenServers. У меня есть вариант использования, когда в событии (которое является вызовом API из микросервиса) мне нужно транслировать сообщения во все разные темы на моем канале с разными временными метками. Я добился этого, используя Process.send_after(..) на моем локальном компьютере. Но я сомневаюсь:

В группе машин, поскольку вызов API будет касаться только одной машины в кластере, другие машины не смогут отправлять широковещательные сообщения. А это приведет к неточности. Как я могу сообщить всем машинам об этом конкретном событии? Или я делаю это неправильно?


deployment phoenix-framework elixir gen-server phoenix-channels
person Rahul Sharma    schedule 26.05.2018    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Предполагая, что вы знаете имена узлов в кластере, вы можете зациклить узлы, вызвав Node.spawn/2 на каждом:

def broadcast(msg) do
  Process.send_after ...
end

def broadcast_everywhere(msg) do
  Enum.each(@nodes, fn node ->
    # if not node == Node.self do
      Node.spawn node, fn ->
        Broadcaster.broadcast(msg)
      end
    # end
  end)
end

Раскомментируйте закомментированные строки, если текущий узел уже обслуживался, и [возможно] каким-то образом заранее убедитесь, что узлы подключены и работают.

Кроме того, может быть полезно Node.spawn_link/*. чтобы взглянуть на.

person Aleksei Matiushkin    schedule 26.05.2018