chatserver.java

java编写的聊天室

import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;
import java.util.*;


public class ChatServer {

	boolean started = false;
	ServerSocket ss = null;	
	List<Client> clients = new ArrayList<Client>();//clients用于存放每一个客户端的连接，List为集合类
	
	public static void main(String[] args) {		
		new ChatServer().start();
		
	}
	
	public void start(){
		try{
			ss = new ServerSocket(8888);
			started = true;
		}catch(BindException e){
			System.out.println("服务器启动失败，所申请端口正在使用中......");
			System.out.println("请关闭相关程序，并重新启动服务器！");
			System.exit(0);
		}catch(IOException e){
			System.out.println("服务器启动失败!");
		}
		
		try{
			while(started){
				Socket s = ss.accept();//一旦启动就不停地接收客户端的连接
				Client c = new Client(s);				
				System.out.println("一个客户端已经连接上……");				
				new Thread(c).start();//创建一个接收客户端连接的线程，并启动，这样就和处理数据的线程分开，也就是和Client类这个处理数据的线程分开。这样就实现了每当有一个客户端连接上后，就启动一个单独的处理数据的线程去处理。
				clients.add(c);//一有客户端连接，就存放进clients
			}
		}catch(IOException e){
			System.out.println("服务器与客户端的连接关闭！");
		}finally{
			try {
				ss.close();//最后关闭整个ServerSocket
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	class Client implements Runnable{
		private Socket s = new Socket();//为每一个客户端都保留分配一个Socket
		private DataInputStream dis = null;//为每一个客户端都保留一个输入流
		private DataOutputStream dos = null;
		private boolean bConnected = false;
		
		public Client(Socket s){
			this.s = s;//从start方法中传递过来Socket对象的s，赋给Client类的保留连接对象s，this代表当前Client类
			try {
				dis = new DataInputStream(s.getInputStream());
				dos = new DataOutputStream(s.getOutputStream());
				bConnected = true;//当连接上后，使bConnected为true
			} catch (IOException e) {
				e.printStackTrace();
			}		
		}
		
		public void send(String str){
			try {
				dos.writeUTF(str);
			} catch (IOException e) {
				clients.remove(this);//针对当前客户端，如果退出则把这个客户端移除掉，否则服务器压力会越来越大
				System.out.println("对方已经从服务器退出！");
			}
		}
		
		@Override
		public void run() {
			try{
				while(bConnected){					
					String str = dis.readUTF();
					System.out.println(str);
					for(int i = 0; i<clients.size(); i++){
						Client c = clients.get(i);
						c.send(str);
					}
				}
			}catch(EOFException e){
				System.out.println("一个客户端已经关闭！");
			}catch(IOException e){
				System.out.println("服务器与客户端的连接中断！");
			}finally{
				try{
					if(dis != null){
						dis.close();
					}
					if(dos != null){
						dos.close();
					}
					if(s != null){
						s.close();
					}
				}catch(IOException e){
					System.out.println("服务器与客户端的连接未能关闭！");
				}
			}
		}
		
	}
}