Java Game Server 线程安全接收 websocket 消息答案

【问题标题】：Java Game Server thread-safe recieving web-socket messagesJava Game Server 线程安全接收 websocket 消息
【发布时间】：2016-08-19 19:17:46
【问题描述】：

我正在将我的 python websocket 游戏服务器升级到 Java，（将 Jetty 用于 websockets），最近开始学习线程安全。

我的挑战是，游戏逻辑（gameRoom 实例）在主线程上运行，但服务器将接收玩家消息（例如加入游戏房间的消息），并通知游戏来自另一个线程的逻辑。我最初（在 python 中，当一切都在主线程上时）只是立即处理了消息，（例如，在接收消息时添加一个播放器）。这可能会导致多个线程出现问题，因为 gameRoom 线程可能同时将玩家添加到玩家数组。（玩家列表最终在添加玩家时被共享=不是线程安全的！）

什么是最简单的方法来处理从运行在它自己的线程上的 servlet 接收消息，并处理这些消息而不会弄乱在主线程上运行的游戏（不同的线程）？在我的脑海中，我会想象某种单向缓冲区（例如http://web.mit.edu/6.005/www/fa14/classes/20-queues-locks/message-passing/）在部分逻辑期间将仅由游戏室本身处理的新消息排队。或者有没有办法完全避免多线程！？ *请给出你的想法，我很想听听比我的线程知识初级水平更高的人的意见。我非常感谢所有提示/建议 :) *

我花时间做了一个简单的例子来说明发生了什么（请忽略语法错误，为了您的方便，我把它写得很短:)）：

class ServerClass {
    static GameRoomClass gameRoom;


    static void main() {
        //psuedocode start Jetty Server, this server runs in another thread, will call onServerMessage()
        jettyServer.start();
        jettyServer.onMessageCallback=(onServerMessage); //set message callback (pseudocode)

        //create game room, run on main thread
        gameRoom = GameRoomClass();
        gameRoom.runGameRoom();
    }

    //when the server gets a message from a player,
    //this will be called by the server from another thread, will affect the GameRoom
    static void onServerMessage(Message theMessage) {
        gameRoom.gotServerMessage();
    }
}

//this runs game logic
class GameRoomClass {
    ArrayList<E> players = new ArrayList<>();

    public void runGameRoom() {
        while (true) {
            //move players, run logic...

            //sometimes, may call addNewPlayer AS WELL
            if(...){
                addNewPlayer();
            }
        }

    }

    public gotServerMessage(){
        //this will only be called by the 'Server' thread, but will enter 'addNewPlayer' method
        //meaning it will access shared value players?
        addNewPlayer()
    }

    public addNewPlayer(){
        //this will be called by the server thread, on getting a message
        //can ALSO be called by gameRoom itself
        players.add(new PlayerObj());
    }

}

class PlayerObj {
    //a player in the game
}

【问题讨论】：

标签： java multithreading websocket server main

【解决方案1】：

最简单有效的方法是使用 java.util.concurrent 包中的线程安全集合类之一。对于给定的情况，ConcurrentLinkedQueue 似乎是一个好的开始。

【讨论】：