java服务器与客户端源码1.docVIP

服务器（server） 1 类ServerTest 1 类ChatClient 2 类MyQueue 3 类ReceiveFromClient 4 类SendToClientThread 11 客户端（client） 12 类StudentWindow 12 类StudentDuQu 15 类ClientTest 19 类BaoCunJiLu 20 服务器（server） 类ServerTest package Server_System; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.Vector; import Client_System.TeacherWindow; public class ServerTest extends Thread { private int number; private Vector allClient = new Vector(); private MyQueue chatCon = new MyQueue(); public ServerTest(int number) { this.number=number; this.start(); } public void run() { ServerSocket server =null; try { server = new ServerSocket(number); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } new SendToClientThread(chatCon,allClient); while(true) { try { Socket ss=server.accept(); ChatClient cc=new ChatClient(ss); //System.out.println(cc.toString()); allClient.add(cc); //String name=ss.getInetAddress().toString(); chatCon.offer(cc.IP+来聊天了。。。); new ReceiveFromClient(cc,chatCon,allClient ); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } 类ChatClient package Server_System; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintStream; import java.io.Reader; import java.net.Socket; import Mysql_System.User; public class ChatClient { public Socket so; public String IP; public PrintStream out; public BufferedReader in; public ChatClient(Socket so) throws Exception { this.so=so; Reader r = new InputStreamReader(so.getInputStream()); in= new BufferedReader(r); OutputStream os = so.getOutputStream(); out = new PrintStream(os); IP= so.getInetAddress().toString()