java在线聊天室服务端ServerSocket

package chartall;
import java.io.*;
import java.net.*;
import java.util.HashMap;
import java.util.Set;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import javax.swing.*;

public class server extends JFrame { 
	private JButton serverstart;
	private JPanel up;
	private JPanel down;
	private JLabel serverstartlable;
	private JTextField port;
	private JButton serversubmit=new JButton("确定启动");
	private ServerSocket serversocket;
	private HashMap userlist=new HashMap();
	private Socket client;
	
	public server() {
		gui();//图形界面
		listion();//按钮监听
		waitsocket();//等待客户端连接
		flashchart();//刷新聊天内容
	}
	
	void gui(){
		//窗体
		JFrame f=new JFrame("服务端");
		f.setSize(400,200);
		f.setLocation(300,100);	
		up=new JPanel() ;
		down=new JPanel() ;
		serverstartlable=new JLabel("未启动服务器") ;
		up.add(serverstartlable);
		serverstart=new JButton("启动服务器") ;
		down.add(serverstart);
		f.setLayout(new BorderLayout());
		f.add(up,BorderLayout.NORTH);
		f.add(down,BorderLayout.SOUTH);
		f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);				
		f.setVisible(true);
	}
	
	void listion() {
		//服务器端口
		serverstart.addActionListener(new ActionListener() { 
			public void actionPerformed(ActionEvent e) {
				JDialog dialog = new JDialog(server.this, true );
				dialog.setTitle("服务器连接端口");
				dialog.setSize(300, 200);
				dialog.setLocation(50, 50);
				dialog.setLayout(new FlowLayout());
				JLabel portlable=new JLabel("端口号");
				port=new JTextField(10);
				dialog.add(portlable);
				dialog.add(port);
				dialog.add(serversubmit);
				dialog.setVisible(true);
			}
		});
		
		//服务器端口确定
		serversubmit.addActionListener(new ActionListener() { 
			public void actionPerformed(ActionEvent e) {
				String a="服务器已启动，端口："+port.getText();
				serverstartlable.setText(a);
				int ports=Integer.parseInt(port.getText());
				try {
					serversocket=new ServerSocket(ports);
				}catch(Exception e1) {
					return;
				}				
			}
		});
	}
	
	void flashchart(){		
		new Thread() {
			public void run() {
				while(true) {
					System.out.println(client);
					if(client!=null) {
						String str;
						try {
							BufferedReader reader = new BufferedReader(new InputStreamReader(client  
				                    .getInputStream()));  
							str=reader.readLine();
						}catch(Exception e1) {
							return;
						}
						
					String[] arr=str.split("@");
	                String usrename = arr[0];  
	                String message = arr[1]; 
	                String status = arr[2]; 
					//zhangshan@@reg
					//zhangshan@聊天内容@all
					//zhangshan@聊天@wang
	                if(status.equals("reg")) {
	                	Setkeyset=userlist.keySet();
						int a=0;
	                	for(String user:keyset) {	
							if(user.equals(usrename)) {
								a=1;
								break;
							}
						}
	                	if(a==0) {
	                		userlist.put(usrename, client);
	                	}
	                	String userflash=null;
	                	for(String user:keyset) {	
	                		userflash=userflash+"@"+user;
						}
	                	userflash=userflash+"@userlist";
	                	for(String user:keyset) {	
		                	try {	
		                	PrintWriter writer = new PrintWriter(userlist.get(user).getOutputStream()); 
		                	writer.println(userflash);  
		                	writer.flush(); 
		                	}catch(Exception e1) {
								return;
							}
	                	}
	                }else if(status.equals("所有人")) {
	                	Setkeyset=userlist.keySet();
	                	for(String user:keyset) {	
		                	try {	
		                	String allchart=usrename+"@对所有人说："+message+"@群发聊天";
		                	PrintWriter writer = new PrintWriter(userlist.get(user).getOutputStream()); 
		                	writer.println(allchart);  
		                	writer.flush(); 
		                	}catch(Exception e1) {
								return;
							}
	                	}                	
	                }else{
	                	Setkeyset=userlist.keySet();
	                	for(String user:keyset) {	
		                	try {
		                	if(status.equals(user)) {
			                	String allchart=usrename+"@对"+status+"说：@"+message;
			                	PrintWriter writer = new PrintWriter(userlist.get(user).getOutputStream()); 
			                	writer.println(allchart);  
			                	writer.flush(); 
		                	}
		                	}catch(Exception e1) {
								return;
							}
	                	}    						
	                }					 
                }	
			   }
			}
		}.start();
	}
	
	void waitsocket(){		
		new Thread() {
			public void run() {
				while(true) {
					System.out.println(serversocket);
					if(serversocket!=null) {					
					try {
						client= serversocket.accept();
					}catch(Exception e1) {
						return;
					}
                    }	
			  }
		  }
	  }.start();			
	}
	
	public static void main(String[] args) {
		new server();

	}

}