NodeJS + Cluster + Socket.IO, wie Spielräume richtig erstellen?

Question

Ich mache eine einfache Spiel-Engine, die Raummanipulation implementiert.

Ich habe viel nachgedacht und habe immer noch Zweifel, dass ich Räume nicht in der gültigen Weise mache.

Hier ist das Szenario.

1) There's one static room, where users are able to 'register'. 2) after certain number of users are registered, it should create dynamic room and put these certain number of users in that room and make them quit the static room.

Also, wenn wir laufen diese in mehreren Instanzen und lassen Sie uns sagen, dass wir für zwei Benutzer auf jemanden warten.

2 Benutzer betreten den statischen Raum -> neuen Raum erstellen (in Redis) -> geben Sie diese zwei Spieler in diesen Raum ein (abonnieren) -> diese Spieler veranlassen, den statischen Raum zu verlassen (Warteschlangen-ähnliches System).

Nun, was ich denke, ist ein Problem.

2 Benutzer betreten den statischen Raum -> vor dem Erstellen eines neuen Raumes, ein anderer Spieler verbindet den statischen Raum (unterschiedliche Knoteninstanz) -> neuen Raum erstellen -> zwei Spieler dorthin bewegen -> andere Instanz denkt immer noch, dass genug Benutzer vorhanden sind neues Zimmer -> etwas Seltsames passiert.

Ist das korrekt? Wie soll ich den Queue Style Room implementieren?

Answer 1

Sie benötigen atomare Operationen: setzen Sie alle diese 4 Schritte in eine Transaktion. Mit Redis können Sie entweder Transaction oder Lua Scripting verwenden, um dies zu erreichen.

Mit lua scripting, können Sie ein Skript wie diese:

-- add new user to static room 
redis.call('lpush', 'static_room', ARGV[1]) 

-- if the number of static room reaches the limit 
local num = redis.call('llen', 'static_room') 
if num == 2 then 
    -- get the room number for a new dynamic room 
    local new_dynamic_room_num = redis.call('incr', 'dynamic_room'); 
    local dynamic_room = 'dynamic_room' .. new_dynamic_room_num 

    -- move all users from static room to dynamic room 
    while true do 
     local num = redis.call('llen', 'static_room') 

     if num == 0 then break end 

     redis.call('rpoplpush', 'static_room', dynamic_room) 
    end 
end 

Da das Lua Script atomar ausführt, kann kein anderer Benutzer den statischen Raum beitreten, bevor wir alle Benutzer aus dem statischen Raum dynamisch beenden bewegen Zimmer.

Answer 2

Eine Lösung könnte sein, alle nicht verbundenen Spieler in eine einzige Knoteninstanz einzutragen, die für das Erstellen von Räumen und die Zuweisung von Spielern zu diesen Räumen verantwortlich ist. Sobald sie einem bestimmten Raum zugeordnet sind, leitet er sie an die Knoteninstanz weiter, die für diesen Raum zuständig ist.