chatserver.java

关于网络聊天的

import java.awt.BorderLayout;
import java.awt.GridLayout;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.Serializable;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Observable;
import java.util.Observer;

import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.ScrollPaneConstants;

public class ChatServer extends Observable implements Serializable {
	JTextArea jtArea = new JTextArea();
	JTextArea clientInfo = new JTextArea();
	List<ConnectClient> clientList = new ArrayList<ConnectClient>();

	public static void main(String[] args) {
		new ChatServer().newServer();
	}

	public void addText(String s) {
		// jtArea.append(s + "\n");
		this.setChanged();
		this.notifyObservers(s);
	}

	public void newServer() {
		JFrame jf = new JFrame();
		jf.setLayout(new GridLayout(1, 2));
		jf.setTitle("简易聊天服务端1.0");
		this.jtArea.setEditable(false);
		this.clientInfo.setEditable(false);
		JScrollPane jsp = new JScrollPane(jtArea);
		jsp
				.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
		JScrollPane jspInfo = new JScrollPane(clientInfo);
		jspInfo
				.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
		jf.add(jspInfo);
		jf.add(jsp);
		jf.setBounds(150, 100, 400, 500);
		jf.addWindowListener(new WindowAdapter() {
			public void windowClosing(WindowEvent e) {
				System.exit(0);
			}
		});
		jf.setVisible(true);
		startSever();
	}

	public void startSever() {
		ServerSocket server = null;
		try {
			server = new ServerSocket(8788);
			jtArea.append("服务器启动成功....." + "\n");
			new Thread(new updataClients()).start();
			while (true) {
				Socket s = server.accept();
				ConnectClient cc = new ConnectClient(s);
				clientList.add(cc);
				addText(cc.getName() + ":" + new Date() + ":" + "连接到服务器");
				jtArea.append(cc.getName() + ":" + s.getInetAddress() + ":"
						+ s.getPort() + ":" + "连接到服务器" + ":" + new Date()
						+ "\n");
				this.addObserver(cc);
				new Thread(cc).start();
			}
		} catch (BindException e) {
			jtArea.append("端口被占用，请退出" + "\n");
		} catch (IOException e) {
			jtArea.append("服务器启动失败，请退出" + "\n");
			e.printStackTrace();
		}
	}

	class ConnectClient implements Runnable, Observer, Serializable {
		private boolean beConneted = false;
		private transient Socket s = null;
		private transient DataInputStream dis = null;
		private transient DataOutputStream dos = null;
		private String name = null;

		public String getName() {
			return name;
		}

		public ConnectClient(Socket ss) {
			this.s = ss;
			this.name = name;
			beConneted = true;
			try {
				dis = new DataInputStream(s.getInputStream());
				dos = new DataOutputStream(s.getOutputStream());
				name = dis.readUTF();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

		public void sendMes(String s) {
			try {
				if (beConneted)
					dos.writeUTF(s);
			} catch (IOException e) {

			}
		}

		@Override
		public void run() {
			try {
				while (beConneted) {
					String ss = dis.readUTF();
					addText(name + ":" + ss + "      " + new Date());
				}
			} catch (SocketException e) {
				addText(name + ":" + "断开" + ":" + new Date());
				jtArea.append(name + ":" + s.getInetAddress() + ":"
						+ s.getPort() + ":" + "断开" + ":" + new Date() + "\n");
				clientList.remove(this);
				beConneted = false;
			} catch (IOException e) {
			} finally {
				try {
					if (dos != null)
						dos.close();
					if (dis != null)
						dis.close();
					if (s != null)
						s.close();
					beConneted = false;
					clientList.remove(this);
					deleteObserver(this);
				} catch (IOException e1) {
					e1.printStackTrace();
				}
			}
		}

		@Override
		public void update(Observable o, Object arg) {
			String temp = (String) arg;
			// System.out.println(temp);
			this.sendMes(temp);
		}
	}

	class updataClients implements Runnable {
		@Override
		public void run() {
			while (true) {
				updataInfo();
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}

		public void updataInfo() {
			ObjectOutputStream oos = null;
			clientInfo.setText("");
			String temp = null;
			for (int i = 0; i < clientList.size(); i++) {
				ConnectClient cc = clientList.get(i);
				temp = cc.getName();
				clientInfo.append(temp + "\n");
			}
		}

	}
}