W jaki sposób nadawanie z kanału Phoenix wpływa na klientów w innych węzłach?

Question

Próbuję porównać kanały Phoenix z nowym Rails ActionCable, jeśli chodzi o pracę z WebSockets.

Dla niektórych kontekstów, ActionCable wykorzystuje Redis do obsługi PubSub podczas nadawania komunikatu wszystkim klientom. Przykładowy scenariusz: 1 z 3 procesów szyny na oddzielnym węźle będzie mógł nadawać do klientów połączonych na wszystkich serwerach internetowych. Odbywa się to poprzez naciśnięcie przycisku Redis, który z kolei publikuje wszystkie serwery railsowe, które następnie przesyłają do wszystkich podłączonych klientów.

Ostatnio czytałem o połączeniach sieciowych 2 million websocket connections achieved by Phoenix.

Także ten klejnot: The Phoenix 1.0 Release Notes wspomnieć o tym dotyczące kanały:

Nawet na klastrze maszyn, wiadomości są nadawane w poprzek węzły automatycznie

Jak Phoenix może transmitować do klientów w węzłach? Czy używa on skrzynek pocztowych i/lub innej komunikacji międzyprocesowej pod maską?

Jest to podobne do pytania 2) w tym post.

Dzięki!

Answer 1

Warstwa PubSub Phoenix jest zaimplementowana wyłącznie z biblioteką standardową. Model współbieżności maszyny Erlang VM jest rozprowadzany po wyjęciu z pudełka. Tak więc model skrzynki pocztowej/przesyłania wiadomości Just Works wysyła wiadomość lokalnie pod numer send(some_local_pid, :a_message) lub globalnie send(some_pid_on_another_machine, :a_message). Jest to jedna z niesamowitych rzeczy o Elixir i Erlang, które pozwalają Phoenixowi pozbyć się zależności takich jak Redis. Jeśli jesteś ciekaw, jak układ Phoenixa PubSub wykorzystuje te funkcje w jego realizacji, zobacz ten post na blogu:

http://www.zohaib.me/guts-of-phoenix-channels/?utm_campaign=elixir_radar_28&utm_medium=email&utm_source=RD+Station

tldr; używamy lokalnych tablic ETS do przechowywania subskrypcji PubSub dla procesów lokalnych do węzła, a my transmitujemy w węzłach za pomocą pojedynczej grupy :pg2, z której każdy serwer PubSub.Local jest członkiem. Gdy serwer PubSub.Local odbierze transmisję, przesyła wiadomość do wszystkich subskrybentów lokalnie, wyszukując lokalne subskrypcje ETS. Rzeczywiste szczegóły IPC i węzeł komunikacyjny węzła są obsługiwane w całości przez środowisko wykonawcze.