java C/S结构代码

一个c/s的聊天室（3） public void jButton1_actionPerformed(ActionEvent e) { setClection2(); } public void jButton2_actionPerformed(ActionEvent e) { jTextArea1.setText(""); } public void jTextArea2_keyPressed(KeyEvent e) { if(e.isControlDown() &&e.getKeyCode()==KeyEvent.VK_ENTER ){ setClection2(); } } } class Frame1_jTextArea2_keyAdapter extends KeyAdapter { private Frame1 adaptee; Frame1_jTextArea2_keyAdapter(Frame1 adaptee) { this.adaptee = adaptee; } public void keyPressed(KeyEvent e) { adaptee.jTextArea2_keyPressed(e); } } class Frame1_jButton2_actionAdapter implements ActionListener { private Frame1 adaptee; Frame1_jButton2_actionAdapter(Frame1 adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.jButton2_actionPerformed(e); } } class Frame1_jButton1_actionAdapter implements ActionListener { private Frame1 adaptee; Frame1_jButton1_actionAdapter(Frame1 adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.jButton1_actionPerformed(e); } } //主程序 public class Application1 { boolean packFrame = false; /** * Construct and show the application. */ public Application1() { Frame1 frame = new Frame1(); // Validate frames that have preset sizes // Pack frames that have useful preferred size info, e.g. from their layout if (packFrame) { frame.pack(); } else { frame.validate(); } // Center the window Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize(); Dimension frameSize = frame.getSize(); if (frameSize.height > screenSize.height) { frameSize.height = screenSize.height; } if (frameSize.width > screenSize.width) { frameSize.width = screenSize.width; } frame.setLocation((screenSize.width - frameSize.width) / 2, (screenSize.height - frameSize.height) / 2); } /** * Application entry point. * * @param args String[] */ public static void main(String[] args) { SwingUtilities.invokeLater(new Runnable() { public void run() { try { UIManager.setLookAndFeel(UIManager. getSystemLookAndFeelClassName()); } catch (Exception exception) { exception.printStackTrace(); } new Application1(); } }); } } // 服务器 import java.io.*; import java.net.*; import java.util.*; public class Server extends ServerSocket { private static final int SERVER_PORT = 10000; Vector vector1 =new Vector(); Vector vector2 =new Vector(); public Server() throws IOException { super(SERVER_PORT); try { while (true) { Socket socket = accept(); new CreateServerThread(socket,vector1,vector2); } } catch (IOException e) {} finally { close(); } } public static void main(String[] args) throws IOException { new Server(); } } //--- CreateServerThread class CreateServerThread extends Thread { Socket client; DataInputStream in; DataOutputStream out; Vector vector1; Vector vector2; public boolean bool=false; String ss=null; String string=null; int iii; String str=null; Enumeration enu; public CreateServerThread(Socket s,Vector vec1,Vector vec2) throws IOException { client = s; vector1=vec1; vector2=vec2; out=new DataOutputStream(client.getOutputStream()); in=new DataInputStream(client.getInputStream()); start(); } public void run() { StringTokenizer st; StringTokenizer stc; try { while (true) { ss=in.readUTF(); if(ss.startsWith("新的朋友")){ if(vector1.contains(str)){ iii=vector1.indexOf(str); vector1.remove(iii);vector2.removeElement(this);} if(vector1.contains(ss) ){ out.writeUTF("不可以"); } else{ out.writeUTF("可以"); str=ss; vector1.add(ss); Enumeration enu=vector1.elements(); while(enu.hasMoreElements()){ out.writeUTF((String)enu.nextElement()); } bool=true; Enumeration enuc=vector2.elements(); while(enuc.hasMoreElements()){ CreateServerThread th=(CreateServerThread)enuc.nextElement(); th.out.writeUTF(ss); } stc=new StringTokenizer(ss,":"); string=stc.nextToken(); string=stc.nextToken(); Enumeration enuc1=vector2.elements(); while(enuc1.hasMoreElements()){ CreateServerThread th=(CreateServerThread)enuc1.nextElement(); th.out.writeUTF(string+"...上线了"); } vector2.add(this); } } else if(ss.startsWith("下线了")||client.isClosed()){ st=new StringTokenizer(ss,":"); string=st.nextToken(); string=st.nextToken(); iii=vector1.indexOf(str); vector1.remove(iii); Enumeration enu=vector2.elements(); while(enu.hasMoreElements()){ CreateServerThread th=(CreateServerThread)enu.nextElement(); if(th!=this&&th.isAlive()) th.out.writeUTF("下线了:"+str.substring(str.indexOf(":")+1)); th.out.writeUTF(str.substring(str.indexOf(":")+1)+"...下线了"); } vector2.remove(this); break; } else{ enu=vector2.elements(); while(enu.hasMoreElements()){ CreateServerThread th=(CreateServerThread)enu.nextElement(); th.out.writeUTF(ss); } } } } catch (IOException e) { try{ iii=vector1.indexOf(str); vector1.remove(iii); Enumeration enun=vector2.elements(); while(enun.hasMoreElements()){ CreateServerThread th=(CreateServerThread)enun.nextElement(); if(th!=this&&th.isAlive()) th.out.writeUTF("下线了:"+str.substring(str.indexOf(":")+1)); th.out.writeUTF(str.substring(str.indexOf(":")+1)+"...下线了"); } vector2.remove(this); return; }catch(Exception ee){return;} } } （全文完）