chessclient.java

实现了一个网络五子棋的对弈程序

                    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();
    }
}

class clientThread extends Thread {
    chessClient chessclient;

    clientThread(chessClient chessclient) {
        this.chessclient = chessclient;
    }

    /**
     * 客户端线程对接收到的信息进行处理的函数
     */
    public void acceptMessage(String recMessage) {
        if (recMessage.startsWith("/userlist ")) {
            // 如果接收到的信息以"/userlist "开头，将其后的用户名提取出来，添加到
            // 输入信息Panel左边的用户列表中。
            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("所有人");
        }
        // 如果如果接收到的信息以"/yourname "开头,将用户名显示在客户端对话框标题栏。
        else if (recMessage.startsWith("/yourname ")) {
            //之所以是10因为“/yourname ”正好10个字符，后面的是用户名。。
            chessclient.chessClientName = recMessage.substring(10);
            chessclient.setTitle("五子棋客户端 " + "当前用户名:" + chessclient.chessClientName);
        }
        // 如果如果接收到的信息以"/reject"开头，在状态栏显示拒绝加入游戏。
        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);
        }
        // 如果如果接收到的信息以"/peer"开头,则记下对方的名字，然后进入等待状态
        else if (recMessage.startsWith("/peer ")) {
            //同理,因为/peer 六个字符,所以是6
            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) {
                //同chessface.chessThread类一样，这里利用socket读取会阻塞。。。
                message = chessclient.in.readUTF();
                acceptMessage(message);
            }
        } catch (IOException es) {
            //读取异常..读者可以试着添加相应处理,不如像服务器发回相应的信息提示等,
            //从而可提高程序运行可靠性。
        }
    }

}