java服务器与客户端源码1.doc
文本预览下载声明
服务器(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()
显示全部