简易聊天室JAVA代码.doc

import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import .*;

public class ChatClient extends Frame {
private boolean connected = false;
private DataOutputStream dos = null;
private DataInputStream dis = null;
private static final long serialVersionUID = 1L;
private Socket s = null;
private TextField tfWords = null;
private TextArea taShow = null;

public static void main(String args[]) {
ChatClient cc = new ChatClient();
cc.launchFrame();
cc.Listen();
}

public void launchFrame() {
try {
s = new Socket(InetAddress.getByName("localhost"), 8888);
connected = true;
dos = new DataOutputStream(s.getOutputStream());
dis = new DataInputStream(s.getInputStream());
} catch (IOException ioe) {
System.out.println("服务器连接失败！");
ioe.printStackTrace();
}
this.tfWords = new TextField();
this.taShow = new TextArea();
this.setTitle("Chatroom Client");
this.setLocation(700, 50);
this.add(tfWords, BorderLayout.SOUTH);
this.add(taShow, BorderLayout.NORTH);
this.setSize(200, 250);
this.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
try {
connected = false;
dos.writeUTF("###Exit###");
dos.flush();
close();
System.exit(0);
} catch (IOException ioe) {
System.out.println("消息发送出错！");
ioe.printStackTrace();
}
}
});
this.setVisible(true);
this.tfWords.addActionListener(new TFWordsListener());
}

public void Listen() {
new Thread(new ListenThread()).start();
}

public void close() {
try {
if (dos != null)
dos.close();
if (s != null)
s.close();
} catch (IOException ioe) {
ioe.printStackTrace();
System.out.println("客户端断开时出错！");
System.exit(-1);
}
}
public class ListenThread implements Runnable{
public void run(){
while (connected) {
try {
String back = dis.readUTF(); //阻塞IO
taShow.append(back);
}catch(SocketException se){
System.out.println("谢谢使用！");
}catch (IOException e) {
System.out.println("数据丢失！");
e.printStackTrace();
}
}
}
}

private class TFWordsListener implements ActionListener {
public void actionPerformed(ActionEvent e) {
String words = tfWords.getText();

tfWords.setText("");
try {
dos.writeUTF(words+ "\n");
} catch (IOException ioe) {
System.out.println("发送出错！");
ioe.printStackTrace();
}
}
}

}

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import .*;
import java.util.List;
import java.util.ArrayList;

public class ChatServer {
private List<Client> clients = new ArrayList<Client>();
private boolean started = false;
private ServerSocket ss = null;
private Client c = null;

public ChatServer() {
try {
ss = new ServerSocket(8888);
started = true;
} catch (IOException ioe) {
System.out.println("对不起，服务器不能启动！");
ioe.printStackTrace();
System.exit(-1);
}
}

public void start() {
try {
Socket s = this.getSs().accept();
System.out.println("Here comes a client! ");
if (s != null) {
c = this.new Client(s, true);
this.clients.add(c);
new Thread(c).start(); // 线程始终没能停止！！！?
c = null;
}
} catch (IOException e) {
System.out.println("连接错误！");
e.printStackTrace();
}
}

public boolean isStarted() {
return started;
}

public void setStarted(boolean started) {
this.started = started;
}

public ServerSocket getSs() {
return ss;
}

public void setSs(ServerSocket ss) {
this.ss = ss;
}

public List<Client> getClients() {
return clients;
}

public void setClients(List<Client> clients) {
this.clients = clients;
}

public static void main(String args[]) {
ChatServer cs = new ChatServer();

while (cs.isStarted()) {
cs.start();
}
}

private class Client implements Runnable {
private boolean connected = false;
private Socket s = null;
private DataInputStream dis = null;
private DataOutputStream dos = null;

public Client(Socket s, boolean connected) {
this.s = s;
this.connected = connected;
}

public void run() {
InetAddress ip = null;
int port = 9999;
try {
if (connected) {
dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());
ip = s.getInetAddress();
port = s.getPort();
}
while (connected) {
String line = dis.readUTF();
if (line.equals("###Exit###")) {
getClients().remove(this); // 当接收到推出的消息，移除客户端记录
line = "Bye-Bye!";
connected = false;
}
System.out.println("From: (" + ip.toString() + ":" + port
+ "): " + line);
for (int i = 0; i < getClients().size(); i++) {
if (this.equals(getClients().get(i))) {
continue;
} else {
getClients().get(i).dos.writeUTF("From: ("
+ ip.toString() + ":" + port + "): " + line
+ "/n");
}
}
}

} catch (IOException ioe) {
System.out.println("客户端连接出错！");
ioe.printStackTrace();
}
}
}

}