.建立一个服务监听和多个客户端,模拟多人聊天程序
求代码


[解决办法]
package com.tsing.chat.frame;



import java.io.ObjectInputStream;


public class ClientThread implements Runnable {

ClientFrame frame;
public ClientThread(ClientFrame frame){
this.frame=frame;
}

public void run() {

try {
while(true){
ObjectInputStream objin =new ObjectInputStream(frame.socket.getInputStream());
MsgBean bean=(MsgBean)objin.readObject();
// 得到的信息往窗体上的list里写,list会自动更新显示
frame.list.add( bean.getSource()+" 说: "+bean.getInfo()+"\n");
}
} catch (Exception e) {
e.printStackTrace();
}

}

}




package com.tsing.chat.frame;


import java.io.Serializable;

public class MsgBean implements Serializable{

String type;
String source;
String target;
String info;

public String getInfo() {
return info;
}
public void setInfo(String info) {
this.info = info;
}
public String getSource() {
return source;
}
public void setSource(String source) {
this.source = source;
}
public String getTarget() {
return target;
}
public void setTarget(String target) {
this.target = target;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}


}

package com.tsing.chat.server;


import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Hashtable;

import com.tsing.thread.ServerThread;


public class Server {

Hashtable allsocket=new Hashtable ();

public Server(){

try {
ServerSocket serverSocket=new ServerSocket(9000);
while(true) {
Socket socket=serverSocket.accept();
//启动线程
new Thread(new ServerThread(allsocket,socket)).start();
}
} catch (IOException e) {
e.printStackTrace();
}

}


public static void main(String[] args) {
new Server();
}


}