import java.util.*; import java.io.*; import java.net.*; public class MultiplayerSnakeGame { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(8888); System.out.println("Server started at " + new Date()); int sessionNo = 1; while (true) { Socket player1 = serverSocket.accept(); System.out.println("Player 1 joined session " + sessionNo); new DataOutputStream(player1.getOutputStream()).writeInt(1); Socket player2 = serverSocket.accept(); System.out.println("Player 2 joined session " + sessionNo); new DataOutputStream(player2.getOutputStream()).writeInt(2); new Thread(new HandleASession(player1, player2)).start(); sessionNo++; } } } class HandleASession implements Runnable { private Socket player1; private Socket player2; public HandleASession(Socket player1, Socket player2) { this.player1 = player1; this.player2 = player2; } public void run() { try { DataInputStream fromPlayer1 = new DataInputStream(player1.getInputStream()); DataOutputStream toPlayer1 = new DataOutputStream(player1.getOutputStream()); DataInputStream fromPlayer2 = new DataInputStream(player2.getInputStream()); DataOutputStream toPlayer2 = new DataOutputStream(player2.getOutputStream()); // TODO: Implement game logic here } catch (IOException ex) { ex.printStackTrace(); } } }