Java网络编程技术-08

第8章JavaSocket网络编程案例Java网络五子棋程序设计28.1Java网络五子棋需求分析1.应用程序架构： Client/Server2.通信协议： TCP协议3.程序界面3

ServerClientClient48.2Server

HashtablekeyvalueclientDataHashSocketDataOutputStreamclientNameHashSochetclientNameclientPeerHashgameCreatorgameJoiner1〕集合

5publicclassFIRServerextendsFrameimplementsActionListener{JButtonclearMsgButton=newJButton("清空列表");JButtonserverStatusButton=newJButton("效劳器状态");JButtoncloseServerButton=newJButton("关闭效劳器");PanelbuttonPanel=newPanel();ServerMsgPanelserverMsgPanel=newServerMsgPanel();ServerSocketserverSocket;HashtableclientDataHash=newHashtable(50);HashtableclientNameHash=newHashtable(50);HashtablechessPeerHash=newHashtable(50);publicFIRServer(){try{createServer(4331,serverMsgPanel);}catch(Exceptione){e.printStackTrace();}}2〕ServerClass6createServer()方法

publicvoidcreateServer(intport,ServerMsgPanelserverMsgPanel)throwsIOException{SocketclientSocket;longclientAccessNumber=1;this.serverMsgPanel=serverMsgPaneltry{

serverSocket=newServerSocket(port);while(true){

clientSocket=serverSocket.accept();

DataOutputStreamoutputData=newDataOutputStream(clientSocket.getOutputStream());clientDataHash.put(clientSocket,outputData);clientNameHash.put(clientSocket,("新玩家"

+clientAccessNumber++));

FIRServerThreadthread=newFIRServerThread(clientSocket,clientDataHash,clientNameHash,chessPeerHash,serverMsgPanel);

thread.start();}}catch(IOExceptionex){ex.printStackTrace();}}73〕FIRServerThreadClass

publicclassFIRServerThreadextendsThread{

SocketclientSocket;HashtableclientDataHash;HashtableclientNameHash;HashtablechessPeerHash;ServerMsgPanelserverMsgPanel;booleanisClientClosed=false;publicFIRServerThread(SocketclientSocket,HashtableclientDataHash,HashtableclientNameHash,HashtablechessPeerHash,

ServerMsgPanelserver){this.clientSocket=clientSocket;this.clientDataHash=clientDataHash;this.clientNameHash=clientNameHash;this.chessPeerHash=chessPeerHash;this.serverMsgPanel=server;}}8Feedback()方法publicvoidFeedback(StringfeedBackMsg){synchronized(clientDataHash){

DataOutputStreamoutputData=(DataOutputStream)

clientDataHash.get(clientSocket);try{outputData.writeUTF(feedBackMsg);}catch(Exceptioneb){eb.printStackTrace();}}}9sendGamePeerMsg()方法publicbooleansendGamePeerMsg(StringgamePeerTarget,StringgamePeerMsg){for(Enumerationenu=clientDataHash.keys();enu.hasMoreElements();){SocketuserClient=(Socket)enu.nextElement();if(gamePeerTarget.equals((String)clientNameHash.get(userClient))&&!gamePeerTarget.equals((String)clientNameHash.get(clientSocket))){synchronized(clientDataHash){DataOutputStreampeerOutData=(DataOutputStream)clientDataHash.get(userClient);try{peerOutData.writeUTF(gamePeerMsg);}catch(IOExceptiones){es.printStackTrace();}}returnfalse;}}returntrue;}10sendPublicMsg()方法publicvoidsendPublicMsg(StringpublicMsg){synchronized(clientDataHash){for(Enumerationenu=clientDataHash.elements();enu.hasMoreElements();){DataOutputStreamoutputData=(DataOutputStream)enu.nextElement();try{outputData.writeUTF(publicMsg);}catch(IOExceptiones){es.printStackTrace();}}}}11getUserList()方法publicStringgetUserList(){StringuserList="/userlist";for(Enumerationenu=clientNameHash.elements();enu.hasMoreElements();){userList=userList+""+(String)enu.nextElement();}returnuserList;}12getHashKey()方法publicObjectgetHashKey(HashtabletargetHash,ObjecthashValue){ObjecthashKey;for(Enumerationenu=targetHash.keys();enu.hasMoreElements();){hashKey=(Object)enu.nextElement();if(hashValue.equals((Object)targetHash.get(hashKey)))returnhashKey;}returnnull;}13sendInitMsg()方法publicvoidsendInitMsg(){sendPublicMsg(getUserList());Feedback("/yourname"+(String)clientNameHash.get(clientSocket));Feedback("Java五子棋客户端");Feedback("/list--更新用户列表");Feedback("/<username><talk>--私聊");Feedback("注意：命令必须对所有用户发送");}14closeClient()方法publicvoidcloseClient(){serverMsgPanel.msgTextArea.append("用户断开连接:"

+clientSocket+"\n");synchronized(chessPeerHash){if(chessPeerHash.containsKey(clientNameHash.get(clientSocket))){chessPeerHash.remove((String)clientNameHash.get(clientSocket));}if(chessPeerHash.containsValue(clientNameHash.get(clientSocket))){chessPeerHash.put((String)getHashKey(chessPeerHash,(String)clientNameHash.get(clientSocket)),"tobeclosed");}}synchronized(clientDataHash){clientDataHash.remove(clientSocket);}synchronized(clientNameHash){clientNameHash.remove(clientSocket);}sendPublicMsg(getUserList());serverMsgPanel.statusLabel.setText("当前连接数:"

+clientDataHash.size());try{clientSocket.close();}catch(IOExceptionexx){exx.printStackTrace();}isClientClosed=true;}15run()方法publicvoidrun(){DataInputStreaminputData;synchronized(clientDataHash){serverMsgPanel.statusLabel.setText("当前连接数:"

+clientDataHash.size());}try{inputData=newDataInputStream(clientSocket.getInputStream());sendInitMsg();while(true){Stringmessage=inputData.readUTF();dealWithMsg(message);}}catch(IOExceptionesx){}finally{if(!isClientClosed){closeClient();}}}16dealWithMsg()方法publicvoiddealWithMsg(StringmsgReceived){StringclientName;StringpeerName;if(msgReceived.startsWith("/"))

{if(msgReceived.equals("/list"))

{Feedback(getUserList());}

elseif(msgReceived.startsWith("/creatgame[inchess]")){StringgameCreaterName=msgReceived.substring(20);synchronized(clientNameHash)

{

clientNameHash.put(clientSocket,msgReceived.substring(11));}synchronized(chessPeerHash)

{

chessPeerHash.put(gameCreaterName,"wait");}Feedback("/yourname"+clientNameHash.get(clientSocket));sendGamePeerMsg(gameCreaterName,"/OK");sendPublicMsg(getUserList());}17elseif(msgReceived.startsWith("/joingame")){StringTokenizeruserTokens=newStringTokenizer(msgReceived,"");StringuserToken;StringgameCreatorName;StringgamePaticipantName;String[]playerNames={"0","0"};intnameIndex=0;while(userTokens.hasMoreTokens()){userToken=(String)userTokens.nextToken("");if(nameIndex>=1&&nameIndex<=2){playerNames[nameIndex-1]=userToken;}nameIndex++;}gameCreatorName=playerNames[0];gamePaticipantName=playerNames[1];18if(chessPeerHash.containsKey(gameCreatorName)&&chessPeerHash.get(gameCreatorName).equals("wait")){synchronized(clientNameHash){clientNameHash.put(clientSocket,("[inchess]"+gamePaticipantName));}synchronized(chessPeerHash){chessPeerHash.put(gameCreatorName,gamePaticipantName);}sendPublicMsg(getUserList());sendGamePeerMsg(gamePaticipantName,("/peer"+"[inchess]"+gameCreatorName));sendGamePeerMsg(gameCreatorName,("/peer"+"[inchess]"+gamePaticipantName));}else{sendGamePeerMsg(gamePaticipantName,"/reject");try{closeClient();}catch(Exceptionez){ez.printStackTrace();}}}19elseif(msgReceived.startsWith("/[inchess]")){intfirstLocation=0,lastLocation;lastLocation=msgReceived.indexOf("",0);peerName=msgReceived.substring((firstLocation+1),lastLocation);msgReceived=msgReceived.substring((lastLocation+1));if(sendGamePeerMsg(peerName,msgReceived)){Feedback("/error");}}20elseif(msgReceived.startsWith("/giveup")){StringchessClientName=msgReceived.substring(8);

if(chessPeerHash.containsKey(chessClientName)&&!((String)chessPeerHash.get(chessClientName)).equals("wait")){sendGamePeerMsg((String)chessPeerHash.get(chessClientName),"/youwin");synchronized(chessPeerHash){chessPeerHash.remove(chessClientName);}}if(chessPeerHash.containsValue(chessClientName)){sendGamePeerMsg((String)getHashKey(chessPeerHash,chessClientName),"/youwin");synchronized(chessPeerHash){chessPeerHash.remove((String)getHashKey(chessPeerHash,chessClientName));}}}21else{intlastLocation=msgReceived.indexOf("",0);if(lastLocation==-1){Feedback("无效命令");return;}}22else{msgReceived=clientNameHash.get(clientSocket)+">"+msgReceived;serverMsgPanel.msgTextArea.append(msgReceived+"\n");sendPublicMsg(msgReceived);serverMsgPanel.msgTextArea.setCaretPosition(serverMsgPanel.msgTextArea.getText().length());}}8.3ClientpublicclassFIRClientextendsJFrameimplementsActionListener,KeyListener{SocketclientSocket;DataInputStreaminputStream;DataOutputStreamoutputStream;StringchessClientName=null;Stringhost=null;intport=4331;booleanisOnChat=false;//是否在聊天booleanisOnChess=false;//是否在下棋booleanisGameConnected=false;//游戏是否进行中booleanisCreator=false;//是否为游戏创立者booleanisParticipant=false;//是否为游戏参加者UserListPaduserListPad=newUserListPad();//用户列表区UserChatPaduserChatPad=newUserChatPad();//用户聊天区23UserControlPaduserControlPad=newUserControlPad();//用户操作区UserInputPaduserInputPad=newUserInputPad();//用户输入区FIRPadfirPad=newFIRPad();//下棋区PanelsouthPanel=newPanel();//面板区PanelnorthPanel=newPanel();PanelcenterPanel=newPanel();PaneleastPanel=newPanel();24publicFIRClient(){super("Java五子棋客户端");setLayout(newBorderLayout());host=userControlPad.ipInputted.getText();eastPanel.setLayout(newBorderLayout());eastPanel.add(userListPad,BorderLayout.NORTH);eastPanel.add(userChatPad,BorderLayout.CENTER);eastPanel.setBackground(Color.LIGHT_GRAY);userInputPad.contentInputted.addKeyListener(this);firPad.host=userControlPad.ipInputted.getText();centerPanel.add(firPad,BorderLayout.CENTER);centerPanel.add(userInputPad,BorderLayout.SOUTH);centerPanel.setBackground(Color.LIGHT_GRAY);25userControlPad.connectButton.addActionListener(this);userControlPad.createButton.addActionListener(this);userControlPad.joinButton.addActionListener(this);userControlPad.cancelButton.addActionListener(this);userControlPad.exitButton.addActionListener(this);userControlPad.createButton.setEnabled(false);userControlPad.joinButton.setEnabled(false);userControlPad.cancelButton.setEnabled(false);southPanel.add(userControlPad,BorderLayout.CENTER);southPanel.setBackground(Color.LIGHT_GRAY);26addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){if(isOnChat){//聊天中try{//关闭客户端套接口clientSocket.close();}catch(Exceptioned){}}if(isOnChess||isGameConnected){//下棋中try{//关闭下棋端口firPad.chessSocket.close();}catch(Exceptionee){}}System.exit(0);}});27add(eastPanel,BorderLayout.EAST);add(centerPanel,BorderLayout.CENTER);add(southPanel,BorderLayout.SOUTH);pack();setSize(670,560);setVisible(true);setResizable(false);this.validate();}28publicbooleanconnectToServer(StringserverIP,intserverPort)throwsException{try{clientSocket=newSocket(serverIP,serverPort);inputStream=newDataInputStream(clientSocket.getInputStream());outputStream=newDataOutputStream(clientSocket.getOutputStream());FIRClientThreadclientthread=newFIRClientThread(this);clientthread.start();isOnChat=true;returntrue;}catch(IOExceptionex){userChatPad.chatTextArea.setText("不能连接!\n");}returnfalse;}29publicvoidactionPerformed(ActionEvente){if(e.getSource()==userControlPad.connectButton){//连接到主机按钮单击事件host=firPad.host=userControlPad.ipInputted.getText();try{if(connectToServer(host,port)){userChatPad.chatTextArea.setText("");userControlPad.connectButton.setEnabled(false);userControlPad.createButton.setEnabled(true);userControlPad.joinButton.setEnabled(true);firPad.statusText.setText("连接成功，请等待!");}}catch(Exceptionei){userChatPad.chatTextArea.setText("不能连接!\n");}}30if(e.getSource()==userControlPad.exitButton){if(isOnChat){//假设用户处于聊天状态中try{//关闭客户端套接口clientSocket.close();}catch(Exceptioned){}}if(isOnChess||isGameConnected){//假设用户处于游戏状态中try{//关闭游戏端口firPad.chessSocket.close();}catch(Exceptionee){}}System.exit(0);}31if(e.getSource()==userControlPad.joinButton){//参加游戏按钮单击事件StringselectedUser=(String)userListPad.userList.getSelectedItem();if(selectedUser==null||selectedUser.startsWith("[inchess]")||selectedUser.equals(chessClientName)){firPad.statusText.setText("必须选择一个用户!");}else{//执行参加游戏的操作try{if(!isGameConnected){//假设游戏套接口未连接if(firPad.connectServer(firPad.host,firPad.port)){isGameConnected=true;isOnChess=true;isParticipant=true;userControlPad.createButton.setEnabled(false);userControlPad.joinButton.setEnabled(false);userControlPad.cancelButton.setEnabled(true);32firPad.firThread.sendMessage("/joingame"+(String)userListPad.userList.getSelectedItem()+""+chessClientName);}}else{//假设游戏端口连接中isOnChess=true;isParticipant=true;userControlPad.createButton.setEnabled(false);userControlPad.joinButton.setEnabled(false);userControlPad.cancelButton.setEnabled(true);firPad.firThread.sendMessage("/joingame"+(String)userListPad.userList.getSelectedItem()+""+chessClientName);}}catch(Exceptionee){isGameConnected=false;isOnChess=false;isParticipant=false;userControlPad.createButton.setEnabled(true);userControlPad.joinButton.setEnabled(true);userControlPad.cancelButton.setEnabled(false);userChatPad.chatTextArea.setText("不能连接:\n"+ee);}}}if(e.getSource()==userControlPad.createButton){try{if(!isGameConnected){//假设游戏端口未连接if(firPad.connectServer(firPad.host,firPad.port)){isGameConnected=true;isOnChess=true;isCreator=true;userControlPad.createButton.setEnabled(false);userControlPad.joinButton.setEnabled(false);userControlPad.cancelButton.setEnabled(true);firPad.firThread.sendMessage("/creatgame"+"[inchess]"+chessClientName);}}else{//假设游戏端口连接中isOnChess=true;isCreator=true;userControlPad.createButton.setEnabled(false);userControlPad.joinButton.setEnabled(false);userControlPad.cancelButton.setEnabled(true);34firPad.firThread.sendMessage("/creatgame"+"[inchess]"+chessClientName);}}catch(Exceptionec){isGameConnected=false;isOnChess=false;isCreator=false;userControlPad.createButton.setEnabled(true);userControlPad.joinButton.setEnabled(true);userControlPad.cancelButton.setEnabled(false);ec.printStackTrace();userChatPad.chatTextArea.setText("不能连接:\n”+ec);}}35if(e.getSource()==userControlPad.cancelButton){if(isOnChess){//游戏中firPad.firThread.sendMessage("/giveup"+chessClientName);firPad.setVicStatus(-1*firPad.chessColor);userControlPad.createButton.setEnabled(true);userControlPad.joinButton.setEnabled(true);userControlPad.cancelButton.setEnabled(false);firPad.statusText.setText("请创立或参加游戏!");}if(!isOnChess){//非游戏中userControlPad.createButton.setEnabled(true);userControlPad.joinButton.setEnabled(true);userControlPad.cancelButton.setEnabled(false);firPad.statusText.setText("请创立或参加游戏!");}isParticipant=isCreator=false;}}36publicvoidkeyPressed(KeyEvente){TextFieldinputwords=(TextField)e.getSource();if(e.getKeyCode()==KeyEvent.VK_ENTER){if(userInputPad.userChoice.getSelectedItem().equals("所有用户")){//给所有人发信息try{//发送信息outputStream.writeUTF(inputwords.getText());inputwords.setText("");}catch(Exceptionea){userChatPad.chatTextArea.setText("不能连接到效劳器!\n");userListPad.userList.removeAll();userInputPad.userChoice.removeAll();inputwords.setText("");userControlPad.connectButton.setEnabled(true);}}else37{//给指定人发信息try{outputStream.writeUTF("/"+userInputPad.userChoice.getSelectedItem()+""+inputwords.getText());inputwords.setText("");}catch(Exceptionea){userChatPad.chatTextArea.setText("不能连接到效劳器!\n");userListPad.userList.removeAll();userInputPad.userChoice.removeAll();inputwords.setText("");userControlPad.connectButton.setEnabled(true);}}}}38publicvoidkeyTyped(KeyEvente){}publicvoidkeyReleased(KeyEvente){}publicstaticvoidmain(Stringargs[]){FIRClientchessClient=newFIRClient();}}398.4FIRClientThread类publicclassFIRClientThreadextendsThread{publicFIRClientfirClient;publicFIRClientThread(FIRClientfirClient){this.firClient=firClient;}40publicvoiddealWithMsg(StringmsgReceived){if(msgReceived.startsWith("/userlist")){StringTokenizeruserToken=newStringTokenizer(msgReceived,"");IntuserNumber=0;firClient.userListPad.userList.removeAll();firClient.userInputPad.userChoice.removeAll();firClient.userInputPad.userChoice.addItem("所有用户");while(userToken.hasMoreTokens()){Stringuser=(String)userToken.nextToken("");if(userNumber>0&&!user.startsWith("[inchess]")){firClient.userListPad.userList.add(user);firClient.userInputPad.userChoice.addItem(user);}userNumber++;}firClient.userInputPad.userChoice.setSe