有登陆界面的聊天室程序

客户端程序:importjavax.swing.*;importjava.awt.*;importjava.awt.event.*;import.*;importjava.io.*;importjava.util.*;publicclassChatClientextendsJFrameimplementsActionListener{JFrameframe=newJFrame("T923-1-29-闫龙-客户端")；JPanelpanelLogin;JPanelpanelBack；JPanelpanelTalk；JLabellabelServerIP；JLabellabelName；JLabellabelPassword；JTextAreatextViewTalk；//显示聊天内容的文本区JLabellabelTalk；JLabellabelTo；JTextFieldtextTalk；JTextFieldtextServerIP；//输入服务器IPJTextFieldtextName；//输入用户名JPasswordFieldtextPassword;//输入密码JButtonbuttonTalk；//发送按钮JButtonbuttonLogin;//登录按钮JButtonbuttonReg;//注册按钮JComboBoxlistOnline;GridBagLayoutgl;BorderLayoutbdl;GridBagConstraintsgbc;JDialogdialogLogin=newJDialog(this,"登陆",true);Socketsocket;//定义客户端套接字BufferedReaderin;//定义输入流PrintWriterout;//定义输出流StringstrSend,strReceive,strKey,strStatus;privateStringTokenizerst;publicChatClient(){//初始化gl=newGridBagLayout();bdl=newBorderLayout();gbc=newGridBagConstraints();panelBack=(JPanel)getContentPane();panelBack.setLayout(bdl);panelLogin=newJPanel();panelLogin.setLayout(gl);//初始化控件labelServerIP=newJLabel("服务器IP:");labelName=newJLabel(" 用户名:");labelPassword=newJLabel("密码: ");textServerIP=newJTextField(12);textName=newJTextField(12);textPassword=newJPasswordField(12);buttonLogin=newJButtonC登陆")；buttonTalk=newJButton('发送")；buttonReg=newJButton('注册")；labelTalk=newJLabel('发言:")；labelTo=newJLabel("To:")；textTalk=newJTextField(30)；panelTalk=newJPanel()；textViewTalk=newJTextArea(18,40)；listOnline=newJComboBox()；textViewTalk.setForeground(Color.blue)；buttonLogin.addActionListener(this)；buttonTalk.addActionListener(this)；buttonReg.addActionListener(this)；listOnline.addItem("All");〃在线用户列表panelTalk.add(labelTalk)；panelTalk.add(textTalk)；panelTalk.add(labelTo)；panelTalk.add(listOnline)；panelTalk.add(buttonTalk)；panelBack.add("Center",textViewTalk)；panelBack.add("South",panelTalk)；panelTalk.setBackground(Color.green)；buttonTalk.setEnabled(false)；frame.getContentPane().add(panelBack)；frame.setSize(600,450);frame.setVisible(true);frame.setResizable(false);frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//登陆对话框初始化dialogLogin.getContentPane().setLayout(newFlowLayout());dialogLogin.getContentPane().add(labelServerIP);dialogLogin.getContentPane().add(textServerIP);dialogLogin.getContentPane().add(labelName);dialogLogin.getContentPane().add(textName);dialogLogin.getContentPane().add(labelPassword);dialogLogin.getContentPane().add(textPassword);dialogLogin.getContentPane().add(buttonLogin);dialogLogin.getContentPane().add(buttonReg);dialogLogin.setBounds(300,300,250,200);dialogLogin.getContentPane().setBackground(Color.yellow);dialogLogin.show();}publicstaticvoidmain(String[]args){newChatClient();}//建立与服务端通信的套接字voidconnectServer(){try{socket=newSocket(textServerIP.getText(),8049);in=newBufferedReader(newlnputStreamReader(socket.getlnputStream()));〃初始化输入流out=new PrintWriter(new BufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);〃初始化输出流}catch(ConnectExceptione){JOptionPane.showMessageDialog(this,"连接服务器失败!","ERROE",JOptionPane.INFORMATION_MESSAGE);textServerlP.setText("");System.out.println(e);}catch(Exceptione){System.out.println(e);//弹出窗口publicvoidpopWindows(StringstrWarning,StringstrTitle){JOptionPane.showMessageDialog(this,strWarning,strTitle,JOptionPane.INFORMATION_MESSAGE);}privatevoidinitLogin()throwsIOException{strReceive=in.readLine();//接收信息st=newStringTokenizer(strReceive,"|");/份解信息strKey=st.nextToken();if(strKey.equals("login")){strStatus=st.nextToken();if(strStatus.equals("succeed")){buttonLogin.setEnabled(false);buttonTalk.setEnabled(true);panelLogin.setVisible(false);dialogLogin.dispose();newClientThread(socket);out.println("init|online");〃向服务器发送初始化}popWindows(strKey+""+strStatus+"!","Login");}if(strKey.equals("warning")){strStatus=st.nextToken();popWindows(strStatus,"Register");}}publicvoidactionPerformed(ActionEventevt){Objectobj=evt.getSource();try{if(obj==buttonLogin){//登录if((textServerIP.getText().length()>0)&&(textName.getText().length()>0)&&(textPassword.getText().length()>0)){connectServer();strSend ="login|"+textName.getText()+"|"+String.valueOf(textPassword.getPassword());out.println(strSend);initLogin();}else{popWindows("请输入完整信息","ERROE");}}elseif(obj==buttonReg){//注册if((textName.getText().length()>0)&&(textPassword.getText().length()>0)){connectServer();strSend="reg|"+textName.getText()+"|"+String.valueOf(textPassword.getPassword());out.println(strSend);initLogin();}}elseif(obj==buttonTalk){//发送信息if(textTalk.getText().length()>0){out.println("talk|"+textTalk.getText()+"|"+textName.getText()+"|"+listOnline.getSelectedItem().toString());//textTalk.setText("");}}}catch(Exceptione){System.out.println(e);}}classClientThreadimplementsRunnable{//客户端线程privateSocketsocket;privateBufferedReaderin;privatePrintWriterout;privateStringstrReceive,strKey;privateThreadthreadTalk;privateStringTokenizerst;publicClientThread(Sockets)throwsIOException{this.socket=s;in=newBufferedReader(newInputStreamReader(socket.getInputStream()));threadTalk=newThread(this);threadTalk.start();}publicvoidrun(){while(true){synchronized(this){try{strReceive=in.readLine();st=newStringTokenizer(strReceive,"|");strKey=st.nextToken();if(strKey.equals("talk")){StringstrTalk=st.nextToken();strTalk=textViewTalk.getText()+"\r\n"+strTalk;textViewTalk.setText(strTalk);}elseif(strKey.equals("online")){StringstrOnline;while(st.hasMoreTokens()){strOnline=st.nextToken();listOnline.addltem(strOnline);//加入在线列表}}elseif(strKey.equals("remove")){StringstrRemove;while(st.hasMoreTokens()){strRemove=st.nextToken();listOnline.removeltem(strRemove);}}elseif(strKey.equals("warning")){StringstrWarning=st.nextToken();popWindows(strWarning,"Warning");}Thread.sleep(1000);}catch(lnterruptedExceptione){}catch(lOExceptione){}}服务器端程序：importjava.awt.event.*;importjava.io.*;import.*;importjava.util.*;publicclassChatServer{ServerSocketserverSocket;//创建服务器端套接字privatefinalintSERVER_PORT=8049;//定义端口号publicChatServer(){try{serverSocket=newServerSocket(SERVER_PORT);//启动服务System.out.println("Serverstarted...");System.out.println("Serverportis:"+SERVER_PORT);getIP();//得到并显示服务器端IPwhile(true){Socketsocket=serverSocket.accept();//监听客户端的连接请求，并返回客户端socketnewServerThread(socket);//创建一个新线程来处理与该客户的通讯}}catch(IOExceptione){System.out.println("[ERROR]Coundnotstartserver."+e);}}//得到服务器IP地址并显示publicvoidgetIP(){try{InetAddresslocalAddress=InetAddress.getLocalHost();byte[]ipAddress=localAddress.getAddress();System.out.println("ServerIPis:"+(ipAddress[0]&0xff)+"."+(ipAddress[1]&0xff)+"."+(ipAddress[2]&0xff)+"."+(ipAddress[3]&0xff));}catch(Exceptione){System.out.println("[ERROR]CoundnotgetIP."+e);}//实例化服务器端程序publicstaticvoidmain(Stringargs[]){newChatServer();}}〃接收到客户端socket发来的信息后进行解析、处理、转发classServerThreadextendsThread{privateSocketsocket;//定义客户端套接字privateBufferedReaderin;//定义输入流privatePrintWriterout;//定义输出流privatestaticVectoronlineUser=newVector(10,5);privatestaticVectorsocketUser=newVector(10,5);privateStringstrReceive,strKey;privateStringTokenizerst;//拆分信息privatefinalStringUSERLIST_FILE="F:\\java作业\\user.txt";//设定存放用户信息的文件publicServerThread(Socketclient)throwsIOException{socket=client;in=newBufferedReader(newInputStreamReader(socket.getInputStream()));//客户端接收out=new PrintWriter(new BufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);〃客户端输出this.start();}publicvoidrun(){try{while(true){strReceive=in.readLine();〃从客户端接收一条信息后拆分、解析，并执行相应操作st=newStringTokenizer(strReceive,"|");strKey=st.nextToken();if(strKey.equals("login")){login();}elseif(strKey.equals("talk")){talk();elseif(strKey.equals("init")){initClientOnline();}elseif(strKey.equals("reg")){register();}}}catch(IOExceptione){//用户关闭客户端造成此异常，关闭该用户套接字StringleaveUser=closeSocket();System.out.println("[SYSTEM]"+leaveUser+"leavechatroom!");sendAll("talk|>>>"+leaveUser+"退出了聊天室。");}}//判断是否有该注册用户privatebooleanisExistUser(Stringname){StringstrRead;createtry{createFileInputStreaminputfile=newFileInputStream(USERLIST_FILE);//inputstreamDataInputStreaminputdata=newDataInputStream(inputfile);while((strRead=inputdata.readLine())!=null){StringTokenizerstUser=newStringTokenizer(strRead,"|");if(stUser.nextToken().equals(name)){returntrue;}}}catch(FileNotFoundExceptionfn){System.out.println("[ERROR]UserFilehasnotexist!"+fn);out.println("warning|读写文件时出错!")；}catch(IOExceptionie){System.out.println("[ERROR]"+ie)；out.println("warning|读写文件时出错!")；}returnfalse；}//判断用户的用户名密码是否正确privatebooleanisUserLogin(Stringname,Stringpassword){StringstrRead；try{FileInputStreaminputfile=newFileInputStream(USERLIST_FILE);//createinputstreamDataInputStreaminputdata=newDataInputStream(inputfile);while((strRead=inputdata.readLine())!=null){if(strRead.equals(name+"|"+password)){returntrue;}}}catch(FileNotFoundExceptionfn){System.out.println("[ERROR]UserFilehasnotexist!"+fn);out.println("warning|读写文件时出错!")；}catch(IOExceptionie){System.out.println("[ERROR]"+ie)；out.println("warning|读写文件时出错!")；}returnfalse；}//用户注册privatevoidregister()throwsIOException{Stringname=st.nextToken()；//得到用户名称Stringpassword=st.nextToken().trim();//得到用户密码if(isExistUser(name)){System.out.println("[ERROR]"+name+"Registerfail!")；out.println("warning|该用户已存在，请改名!")；}else{RandomAccessFileuserFile=newRandomAccessFile(USERLIST_FILE,"rw")；userFile.seek(userFile.length())；//在文件尾部加入新用户信息userFile.writeBytes(name+"|"+password+"\r\n")；longin(name)；//自动登陆聊天室}}//用户登陆(从登陆框直接登陆)privatevoidlogin()throwsIOException{Stringname=st.nextToken()；//得到用户名称Stringpassword=st.nextToken().trim();//得到用户密码booleansucceed=false；System.out.println("[USERLOGIN]"+name+":"+password+":"+socket);for(inti=0;i<onlineUser.size();i++){if(onlineUser.elementAt(i).equals(name)){System.out.println("[ERROR]"+name+"islogined!");out.println("warning|"+name+"已经登陆聊天室")；}}if(isUserLogin(name,password)){//判断用户名和密码longin(name)；succeed=true；}if(!succeed){out.println("warning|"+name+"登陆失败，请检查您的输入!");System.out.println("[SYSTEM]"+name+"loginfail!")；}}//用户登陆privatevoidlongin(Stringname)throwsIOException{out.println("login|succeed");sendAll("online|"+name);//告知每个用户上线列表onlineUser.addElement(name);socketUser.addElement(socket);sendAll("talk|>>>"+name+"进入聊天室!");System.out.println("[SYSTEM]"+name+"loginsucceed!");}//聊天信息处理privatevoidtalk()throwsIOException{StringstrTalkInfo=st.nextToken();//得到聊天内容;StringstrSender=st.nextToken();//得到发消息人StringstrReceiver=st.nextToken();//得到接收人System.out.println("[TALK_"+strReceiver+"]"+strTalkInfo);SocketsocketSend;PrintWriteroutSend;//得到当前时间GregorianCalendarcalendar=newGregorianCalendar();String strTime ="("+calendar.get(Calendar.HOUR)+":"+calendar.get(Calendar.MINUTE)+":"+calendar.get(Calendar.SECOND)+")";strTalkInfo+=strTime;if(strReceiver.equals("AII")){〃查看是否是发给所有人sendAII("talk|"+strSender+"对所有人说："+strTaIklnfo);〃调用函数发送}eIse{if(strSender.equaIs(strReceiver)){//是否发给自己out.println("talk|>>>不能向自己发送信息!")；}eIse{for(inti=O;i<onIineUser.size();i++){〃循环查找接收者if(strReceiver.equaIs(onIineUser.eIementAt(i))){socketSend=(Socket)socketUser.eIementAt(i);outSend=newPrintWriter(newBufferedWriter(newOutputStreamWriter(socketSend.getOutputStream())),true);outSend.printIn("taIk|"+