omokserver.java

基于web应用开发的互联网五子棋游戏基于web应用开发的互联网五子棋游戏基于web应用开发的互联网五子棋游戏基于web应用开发的互联网五子棋游戏

import java.net.*;
import java.io.*;
import java.util.*;
public class OmokServer{
  private ServerSocket server;
  private BManager bMan=new BManager();
  private Random rnd= new Random();
  public OmokServer(){}
  void startServer(){
    try{
      server=new ServerSocket(7777);
      System.out.println("服务器套接字已被创建.");
      while(true){
        Socket socket=server.accept();
        Omok_Thread ot=new Omok_Thread(socket);
        ot.start();
        bMan.add(ot);
        System.out.println("连接数: "+bMan.size());
      }
    }catch(Exception e){
      System.out.println(e); 
    }
  }
  public static void main(String[] args){
    OmokServer server=new OmokServer();
    server.startServer();
  }
  class Omok_Thread extends Thread{
    private int roomNumber=-1;
    private String userName=null;
    private Socket socket;
    private boolean ready=false;
    private BufferedReader reader;
    private PrintWriter writer;
    Omok_Thread(Socket socket){
      this.socket=socket;
    }
    Socket getSocket(){
      return socket; 
    }
    int getRoomNumber(){
      return roomNumber;
    }
    String getUserName(){
      return userName;
    }
    boolean isReady(){
      return ready; 
    }
    public void run(){
      try{
        reader=new BufferedReader(new InputStreamReader(socket.getInputStream()));
        writer=new PrintWriter(socket.getOutputStream(), true);
        String msg;
        while((msg=reader.readLine())!=null){
          if(msg.startsWith("[NAME]")){
            userName=msg.substring(6);
          }   
          else if(msg.startsWith("[ROOM]")){
            int roomNum=Integer.parseInt(msg.substring(6));
            if( !bMan.isFull(roomNum)){
              if(roomNumber!=-1)
                bMan.sendToOthers(this, "[EXIT]"+userName);
              roomNumber=roomNum;
              writer.println(msg);
              writer.println(bMan.getNamesInRoom(roomNumber));
              bMan.sendToOthers(this, "[ENTER]"+userName);
            }    
            else writer.println("[FULL]");
          }
          else if(roomNumber>=1 && msg.startsWith("[STONE]"))
            bMan.sendToOthers(this, msg);
          else if(msg.startsWith("[MSG]"))
            bMan.sendToRoom(roomNumber, "["+userName+"]: "+msg.substring(5));
          else if(msg.startsWith("[START]")){
            ready=true;
            if(bMan.isReady(roomNumber)){
              int a=rnd.nextInt(2);
              if(a==0){
                writer.println("[COLOR]BLACK");
                bMan.sendToOthers(this, "[COLOR]WHITE");
              }  
              else{
                writer.println("[COLOR]WHITE");
                bMan.sendToOthers(this, "[COLOR]BLACK");
              }
            }  
          }
          else if(msg.startsWith("[STOPGAME]"))
            ready=false;
          else if(msg.startsWith("[DROPGAME]")){
            ready=false;
            bMan.sendToOthers(this, "[DROPGAME]");
          }
          else if(msg.startsWith("[WIN]")){
            ready=false;
            writer.println("[WIN]");
            bMan.sendToOthers(this, "[LOSE]");
          }
        }
      }catch(Exception e){
      }finally{
        try{
          bMan.remove(this);
          if(reader!=null) reader.close();
          if(writer!=null) writer.close();
          if(socket!=null) socket.close();
          reader=null; writer=null; socket=null;
          System.out.println(userName+"已断线.");
          System.out.println("连接人数: "+bMan.size());
          bMan.sendToRoom(roomNumber,"[DISCONNECT]"+userName);
        }catch(Exception e){}
      }
    }
  }
  class BManager extends Vector{
    BManager(){}
    void add(Omok_Thread ot){
      super.add(ot);
    }
    void remove(Omok_Thread ot){
       super.remove(ot);
    }
    Omok_Thread getOT(int i){
      return (Omok_Thread)elementAt(i);
    }
    Socket getSocket(int i){
      return getOT(i).getSocket();
    }
    void sendTo(int i, String msg){
      try{
        PrintWriter pw= new PrintWriter(getSocket(i).getOutputStream(), true);
        pw.println(msg);
      }catch(Exception e){}  
    }
    int getRoomNumber(int i){
      return getOT(i).getRoomNumber();
    }
    synchronized boolean isFull(int roomNum){
      if(roomNum==0)return false;
      int count=0;
      for(int i=0;i<size();i++)
        if(roomNum==getRoomNumber(i))count++;
      if(count>=2)return true;
      return false;
    }
    void sendToRoom(int roomNum, String msg){
      for(int i=0;i<size();i++)
        if(roomNum==getRoomNumber(i))
          sendTo(i, msg);
    }
    void sendToOthers(Omok_Thread ot, String msg){
      for(int i=0;i<size();i++)
        if(getRoomNumber(i)==ot.getRoomNumber() && getOT(i)!=ot)
          sendTo(i, msg);
    }
    synchronized boolean isReady(int roomNum){
      int count=0;
      for(int i=0;i<size();i++)
        if(roomNum==getRoomNumber(i) && getOT(i).isReady())
          count++;
      if(count==2)return true;
      return false;      
    }
    String getNamesInRoom(int roomNum){
      StringBuffer sb=new StringBuffer("[PLAYERS]");
      for(int i=0;i<size();i++)
        if(roomNum==getRoomNumber(i))
          sb.append(getOT(i).getUserName()+"\t");
      return sb.toString();
    }
  }
}