通过传输xml的java网络聊天室（socket通讯）

package server; import java.awt.BorderLayout; import java.awt.Color; import java.awt.Container; import java.awt.FlowLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowEvent; import java.awt.event.WindowListener; import java.io.IOException; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import javax.swing.BorderFactory; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; import utilpackage.XMLUtil; class MainServer extends JFrame implements WindowListener{ private JPanel northPanel; //启动区面板 private JPanel onlinePanel; //在线用户区面板 private JPanel diaryPanel; //系统日志区面板 private JPanel centerPanel; //中间部分面板 private JLabel label1,label2,label3; private JTextField portField; //端口输入区域 private JButton jButton; private JTextArea userArea; //用户列表 private JTextArea diaryArea; //系统日志 private ServerThread serverThread; private boolean isStarted = false; private DateFormat dateFormat; private HashMap<String, MessageThread> userThreadMap = new HashMap<String, MessageThread>(); public MainServer(){ dateFormat = new SimpleDateFormat("yyyy-mm-dd hh:mm:ss"); addWindowListener(this); initUI(); } private void initUI(){ setTitle("服务端！"); //设置标题 Container container = getContentPane(); northPanel = new JPanel(); onlinePanel = new JPanel(); diaryPanel = new JPanel(); centerPanel = new JPanel(); /** * 启动栏界面设置 */ northPanel.setLayout(new FlowLayout()); northPanel.setSize(400, 80); label1 = new JLabel("port: "); portField = new JTextField("5000"); portField.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { startAndStopServer(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } catch (InterruptedException e2) { // TODO Auto-generated catch block e2.printStackTrace(); } } }); //给 端口输入框添加事件监听器 jButton = new JButton("启动"); jButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { startAndStopServer(); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } catch (InterruptedException e2) { // TODO Auto-generated catch block e2.printStackTrace(); } } }); //给 “启动” 按钮添加事件监听器 label2 = new JLabel(" 状态 : "); label3 = new JLabel(" 停止 "); label3.setForeground(Color.RED); northPanel.add(label1); northPanel.add(portField); northPanel.add(jButton); northPanel.add(label2); northPanel.add(label3); centerPanel.setLayout(new BorderLayout()); onlinePanel.setBorder(BorderFactory.createTitledBorder("在线用户：")); diaryPanel.setBorder(BorderFactory.createTitledBorder("系统日志：")); onlinePanel.setLayout(new BorderLayout()); diaryPanel.setLayout(new BorderLayout()); centerPanel.add(onlinePanel,BorderLayout.WEST); centerPanel.add(diaryPanel,BorderLayout.CENTER); userArea = new JTextArea(); userArea.setColumns(12); userArea.setEditable(false); diaryArea = new JTextArea(); diaryArea.setEditable(false); onlinePanel.add(new JScrollPane(userArea)); diaryPanel.add(new JScrollPane(diaryArea)); northPanel.setBorder(BorderFactory.createTitledBorder("启动区")); container.setLayout(new BorderLayout()); container.add(centerPanel,BorderLayout.CENTER); container.add(northPanel,BorderLayout.NORTH); /** * 设置程序大小及位置 */ int width = 600; int height = 500; setVisible(true); setSize(width,height); setResizable(false); int locationX = (getToolkit().getScreenSize().width - width)/2; int locationY = (getToolkit().getScreenSize().height - height)/2; setLocation(locationX,locationY); } public boolean isUsernameExist(String name){ //判断name是否已经存在 return userThreadMap.containsKey(name); } public void addUser(String key,MessageThread value){ userThreadMap.put(key, value); } public void deleteUser(String name){ userThreadMap.remove(name); } public void sendMessageToAll(String msg) throws IOException, InterruptedException { for (String key : userThreadMap.keySet()) { userThreadMap.get(key).sendMessage(msg); System.out.println("to ALL" + msg); } } public void sendMessageToOther(String msg,MessageThread thread) throws IOException, InterruptedException{ for (String key : userThreadMap.keySet()) { if (!userThreadMap.get(key).equals(thread)) { userThreadMap.get(key).sendMessage(msg); } } } public void newUserOnline(String username){ String msg =dateFormat.format(new Date()) + ": 用户：\"" + username +"\"" + " 上线\n"; diaryArea.append(msg); } public void oldUserOffline(String username){ String msg =dateFormat.format(new Date()) + ": 用户：\"" + username +"\"" + " 下线\n"; diaryArea.append(msg); } public void updateUserList(){ userArea.setText(""); for(String users : userThreadMap.keySet()){ String msg = users + "\n"; userArea.append(msg); } } public void sendUserListXML() throws IOException, InterruptedException{ String userListXML = XMLUtil.constructUserListXML(userThreadMap); sendMessageToAll(userListXML); } @Override public void windowOpened(WindowEvent e) { // TODO Auto-generated method stub } @Override public void windowClosing(WindowEvent e) { // TODO Auto-generated method stub try { stopServer(); } catch (InterruptedException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } System.exit(0); } @Override public void windowClosed(WindowEvent e) { // TODO Auto-generated method stub } @Override public void windowIconified(WindowEvent e) { // TODO Auto-generated method stub } @Override public void windowDeiconified(WindowEvent e) { // TODO Auto-generated method stub } @Override public void windowActivated(WindowEvent e) { // TODO Auto-generated method stub } @Override public void windowDeactivated(WindowEvent e) { // TODO Auto-generated method stub } private void stopServer() throws InterruptedException{ try { String closeMessage = XMLUtil.constructReplyLoginXML("serverClose"); sendMessageToAll(closeMessage); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } private void startAndStopServer() throws IOException, InterruptedException{ if(!isStarted){ portField.setEditable(false); label3.setText("启动"); jButton.setText("停止"); String port = portField.getText(); serverThread = new ServerThread(Integer.parseInt(port),this); serverThread.start(); diaryArea.append(dateFormat.format(new Date()) + ": 开启服务器\n"); isStarted = true; } else{ label3.setText("停止"); stopServer(); serverThread.stopSocket(); portField.setEditable(true); jButton.setText("启动"); diaryArea.append(dateFormat.format(new Date()) + ": 关闭服务器\n"); isStarted = false; } } public String getPort(){ return portField.getText(