chessclient.java

局域网内实现的五子棋和简单的聊天工具。

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.*;

class clientThread
    extends Thread{
  chessClient chessclient;
  clientThread(chessClient chessclient){
    this.chessclient = chessclient;
  }
  //clientThread接收消息部分
  public void acceptMessage(String recMessage){
    if (recMessage.startsWith("/userlist ")){
      StringTokenizer userToken = new StringTokenizer(recMessage, " ");
      int userNumber = 0;
      chessclient.userpad.userList.removeAll();
      chessclient.inputpad.userChoice.removeAll();
      chessclient.inputpad.userChoice.addItem("所有人");
      while(userToken.hasMoreTokens()){
         String user = (String) userToken.nextToken(" ");
        if(userNumber > 0 && !user.startsWith("[inchess]")){
          chessclient.userpad.userList.add(user);
          chessclient.inputpad.userChoice.addItem(user);
        }
        userNumber++;
      }
      chessclient.inputpad.userChoice.select("所有人");
    }
    else if (recMessage.startsWith("/yourname ")){
      chessclient.chessClientName = recMessage.substring(10);
      chessclient.setTitle("Java五子棋客户端 " + "用户名:" + chessclient.chessClientName);
    }
    else if (recMessage.equals("/reject")){
      try{
        chessclient.chesspad.statusText.setText("不能加入游戏");
        chessclient.controlpad.cancelGameButton.setEnabled(false);
        chessclient.controlpad.joinGameButton.setEnabled(true);
        chessclient.controlpad.creatGameButton.setEnabled(true);
      }
      catch(Exception ef){
        chessclient.chatpad.chatLineArea.setText(
            "chessclient.chesspad.chessSocket.close无法关闭");
      }
      chessclient.controlpad.joinGameButton.setEnabled(true);
    }
    else if (recMessage.startsWith("/peer ")){
      chessclient.chesspad.chessPeerName = recMessage.substring(6);
      if (chessclient.isServer){
        chessclient.chesspad.chessColor = 1;
        chessclient.chesspad.isMouseEnabled = true;
        chessclient.chesspad.statusText.setText("请黑棋下子");
      }
      else if (chessclient.isClient){
        chessclient.chesspad.chessColor = -1;
        chessclient.chesspad.statusText.setText("已加入游戏，等待对方下子...");
      }
    }
    else if (recMessage.equals("/youwin")){
      chessclient.isOnChess = false;
      chessclient.chesspad.chessVictory(chessclient.chesspad.chessColor);
      chessclient.chesspad.statusText.setText("对方退出，请点放弃游戏退出连接");
      chessclient.chesspad.isMouseEnabled = false;
    }
    else if (recMessage.equals("/OK")){
      chessclient.chesspad.statusText.setText("创建游戏成功，等待别人加入...");
    }
    else if (recMessage.equals("/error")){
      chessclient.chatpad.chatLineArea.append("传输错误：请退出程序，重新加入 \n");
    }
    else{
      chessclient.chatpad.chatLineArea.append(recMessage + "\n");
      chessclient.chatpad.chatLineArea.setCaretPosition(
      chessclient.chatpad.chatLineArea.getText().length());
    }
  }
  public void run(){
    String message = "";
    try{
      while (true){
        message = chessclient.in.readUTF();
        System.out.println("客户端接受的信息"+message);
        acceptMessage(message);
      }
    }
    catch (IOException es){
    }
  }
}
public class chessClient
    extends Frame
    implements ActionListener, KeyListener {
  userPad userpad = new userPad();
  chatPad chatpad = new chatPad();
  controlPad controlpad = new controlPad();
  chessPad chesspad = new chessPad();//棋盘，以及下棋socket，以及之间的信息传输
  inputPad inputpad = new inputPad();
  Socket chatSocket;
  DataInputStream in;
  DataOutputStream out;
  String chessClientName = null;
  String host = null;
  int port = 4331;

  boolean isOnChat = false; //在聊天？
  boolean isOnChess = false; //在下棋？
  boolean isGameConnected = false; //下棋的客户端连接？
  boolean isServer = false; //如果是下棋的主机
  boolean isClient = false; //如果是下棋的客户端

  Panel southPanel = new Panel();
  Panel northPanel = new Panel();
  Panel centerPanel = new Panel();
  Panel westPanel = new Panel();
  Panel eastPanel = new Panel();

  chessClient() {
    super("Java五子棋客户端");
    setLayout(new BorderLayout());
    host = controlpad.inputIP.getText();
    westPanel.setLayout(new BorderLayout());
    westPanel.add(userpad, BorderLayout.NORTH);
    westPanel.add(chatpad, BorderLayout.CENTER);
    westPanel.setBackground(Color.pink);
    inputpad.inputWords.addKeyListener(this);
    chesspad.host = controlpad.inputIP.getText();
    centerPanel.add(chesspad, BorderLayout.CENTER);
    centerPanel.add(inputpad, BorderLayout.SOUTH);
    centerPanel.setBackground(Color.pink);

    controlpad.connectButton.addActionListener(this);
    controlpad.creatGameButton.addActionListener(this);
    controlpad.joinGameButton.addActionListener(this);
    controlpad.cancelGameButton.addActionListener(this);
    controlpad.exitGameButton.addActionListener(this);

    controlpad.creatGameButton.setEnabled(false);
    controlpad.joinGameButton.setEnabled(false);
    controlpad.cancelGameButton.setEnabled(false);

    southPanel.add(controlpad, BorderLayout.CENTER);
    southPanel.setBackground(Color.pink);

    addWindowListener(new WindowAdapter(){
      public void windowClosing(WindowEvent e){
        if (isOnChat) {
          try {
            chatSocket.close();
          }
          catch (Exception ed) {
          }
        }
        if (isOnChess || isGameConnected){
          try {
            chesspad.chessSocket.close();
          }
          catch (Exception ee) {
          }
        }
        System.exit(0);
      }
      public void windowActivated(WindowEvent ea) {
      }
    });

    add(westPanel, BorderLayout.WEST);
    add(centerPanel, BorderLayout.CENTER);
    add(southPanel, BorderLayout.SOUTH);
    pack();
    setSize(670, 548);
    setVisible(true);
    setResizable(false);
    validate();
  }
  //连接到服务器的指定端口，并返回其输入和输出流，并启动客户线程负责和服务器的连接；
  public boolean connectServer(String serverIP, int serverPort)throws
      Exception {
    try {
      chatSocket = new Socket(serverIP, serverPort);
      System.out.println("客户端的IP地址:"+chatSocket);
      in = new DataInputStream(chatSocket.getInputStream());
      out = new DataOutputStream(chatSocket.getOutputStream());
      clientThread clientthread = new clientThread(this);
      clientthread.start();
      isOnChat = true;
      return true;
    }
    catch (IOException ex) {
      chatpad.chatLineArea.setText("chessClient:connectServer:无法连接,建议重新启动程序 \n");
    }
    return false;
  }
  public void actionPerformed(ActionEvent e){
    //点击连接服务器的按钮，连接服务器的方法；
    if (e.getSource() == controlpad.connectButton){
      host = chesspad.host = controlpad.inputIP.getText();
      try {
        if (connectServer(host, port)){
          chatpad.chatLineArea.setText("");
          controlpad.connectButton.setEnabled(false);
          controlpad.creatGameButton.setEnabled(true);
          controlpad.joinGameButton.setEnabled(true);
          chesspad.statusText.setText("连接成功，请创建游戏或加入游戏");
        }
      }
      catch (Exception ei){
        chatpad.chatLineArea.setText(
            "controlpad.connectButton:无法连接,建议重新启动程序 \n");
      }
    }
    if(e.getSource() == controlpad.exitGameButton) {
      if (isOnChat) {
        try {
          chatSocket.close();
        }
        catch (Exception ed) {
        }
      }
      if (isOnChess || isGameConnected) {
        try {
          chesspad.chessSocket.close();
        }
        catch (Exception ee) {
        }
      }
      System.exit(0);
    }
    if (e.getSource() == controlpad.joinGameButton){
      String selectedUser = userpad.userList.getSelectedItem();
      if (selectedUser == null || selectedUser.startsWith("[inchess]") ||
          selectedUser.equals(chessClientName)){
        chesspad.statusText.setText("必须先选定一个有效用户");
      }
      else{
        try {
          if (!isGameConnected){
            if (chesspad.connectServer(chesspad.host, chesspad.port)){
              isGameConnected = true;
              isOnChess = true;
              isClient = true;
              controlpad.creatGameButton.setEnabled(false);
              controlpad.joinGameButton.setEnabled(false);
              controlpad.cancelGameButton.setEnabled(true);
              chesspad.chessthread.sendMessage("/joingame " +
                                               selectedUser +
                                               " " + chessClientName);
            }
          }
          else {
            isOnChess = true;
            isClient = true;
            controlpad.creatGameButton.setEnabled(false);
            controlpad.joinGameButton.setEnabled(false);
            controlpad.cancelGameButton.setEnabled(true);
            chesspad.chessthread.sendMessage("/joingame " +
                                             userpad.userList.getSelectedItem() +
                                             " " + chessClientName);
          }

        }
        catch (Exception ee) {
          isGameConnected = false;
          isOnChess = false;
          isClient = false;
          controlpad.creatGameButton.setEnabled(true);
          controlpad.joinGameButton.setEnabled(true);
          controlpad.cancelGameButton.setEnabled(false);
          chatpad.chatLineArea.setText("chesspad.connectServer无法连接 \n" + ee);
        }
      }
    }
    if (e.getSource() == controlpad.creatGameButton) {
      try {
        if (!isGameConnected) {
          if (chesspad.connectServer(chesspad.host, chesspad.port)) {
            isGameConnected = true;
            isOnChess = true;
            isServer = true;
            controlpad.creatGameButton.setEnabled(false);
            controlpad.joinGameButton.setEnabled(false);
            controlpad.cancelGameButton.setEnabled(true);
            chesspad.chessthread.sendMessage("/creatgame " + "[inchess]" +
                                             chessClientName);
          }
        }
        else{
          isOnChess = true;
          isServer = true;
          controlpad.creatGameButton.setEnabled(false);
          controlpad.joinGameButton.setEnabled(false);
          controlpad.cancelGameButton.setEnabled(true);
          chesspad.chessthread.sendMessage("/creatgame " + "[inchess]" +
                                           chessClientName);
        }
      }
      catch (Exception ec) {
        isGameConnected = false;
        isOnChess = false;
        isServer = false;
        controlpad.creatGameButton.setEnabled(true);
        controlpad.joinGameButton.setEnabled(true);
        controlpad.cancelGameButton.setEnabled(false);
        ec.printStackTrace();
        chatpad.chatLineArea.setText("chesspad.connectServer无法连接 \n" + ec);
      }
    }
    if (e.getSource() == controlpad.cancelGameButton){
      if (isOnChess){
        chesspad.chessthread.sendMessage("/giveup " + chessClientName);
        chesspad.chessVictory( -1 * chesspad.chessColor);
        controlpad.creatGameButton.setEnabled(true);
        controlpad.joinGameButton.setEnabled(true);
        controlpad.cancelGameButton.setEnabled(false);
        chesspad.statusText.setText("请建立游戏或者加入游戏");
      }
      if (!isOnChess){
        controlpad.creatGameButton.setEnabled(true);
        controlpad.joinGameButton.setEnabled(true);
        controlpad.cancelGameButton.setEnabled(false);
        chesspad.statusText.setText("请建立游戏或者加入游戏");
      }
      isClient = isServer = false;
    }
  }
  public void keyPressed(KeyEvent e){
    TextField inputWords = (TextField) e.getSource();
    if (e.getKeyCode() == KeyEvent.VK_ENTER) {
      if (inputpad.userChoice.getSelectedItem().equals("所有人")) {
        try {
          out.writeUTF(inputWords.getText());
          inputWords.setText("");
        }
        catch (Exception ea) {
          chatpad.chatLineArea.setText("chessClient:KeyPressed无法连接,建议重新连接 \n");
          userpad.userList.removeAll();
          inputpad.userChoice.removeAll();
          inputWords.setText("");
          controlpad.connectButton.setEnabled(true);
        }
      }
      else {
        try {
          out.writeUTF("/" + inputpad.userChoice.getSelectedItem() + " " +
                       inputWords.getText());
          inputWords.setText("");
        }
        catch (Exception ea) {
          chatpad.chatLineArea.setText("chessClient:KeyPressed无法连接,建议重新连接 \n");
          userpad.userList.removeAll();
          inputpad.userChoice.removeAll();
          inputWords.setText("");
          controlpad.connectButton.setEnabled(true);
        }
      }
    }
  }
  public void keyTyped(KeyEvent e) {
  }
  public void keyReleased(KeyEvent e) {
  }
  public static void main(String args[]) {
    chessClient chessClient = new chessClient();
  }
}