serverframe.java

j2se开发的即时聊天系统

/**
 * 服务端界面
 * 
 * @author Yang
 * 
 */
package com.wczy.chatroom.serverui;

import javax.swing.JPanel;
import javax.swing.JFrame;
import javax.swing.JButton;
import java.awt.Rectangle;
import java.io.IOException;

import javax.swing.JTextArea;
import com.wczy.chatroom.server.*;

import java.util.Calendar;
import java.util.List;

import com.wczy.chatroom.server.ChatRoomServer;
import com.wczy.chatroom.server.OnlineListUpdateListener;
import com.wczy.chatroom.server.OnlineUser;
import java.awt.Dimension;
import java.awt.Point;

public class ServerFrame extends JFrame {

	private static final long serialVersionUID = 1L;

	private JPanel jContentPane = null;

	private JButton btnStart = null;

	private JButton btnStop = null;

	private ChatRoomServer server;

	/**
	 * This is the default constructor
	 */
	public ServerFrame() {
		super();
		initialize();
	}

	/**
	 * This method initializes this
	 * 
	 * @return void
	 */
	private void initialize() {
		this.setSize(225, 84);
		this.setResizable(false);
		this.setContentPane(getJContentPane());
		this.setTitle("服务器");
	}

	/**
	 * This method initializes jContentPane
	 * 
	 * @return javax.swing.JPanel
	 */
	private JPanel getJContentPane() {
		if (jContentPane == null) {
			jContentPane = new JPanel();
			jContentPane.setLayout(null);
			jContentPane.add(getBtnStart(), null);
			jContentPane.add(getBtnStop(), null);
		}
		return jContentPane;
	}

	/**
	 * This method initializes btnStart
	 * 
	 * @return javax.swing.JButton
	 */
	private JButton getBtnStart() {
		if (btnStart == null) {
			btnStart = new JButton();
			btnStart.setText("启动");
			btnStart.setSize(new Dimension(60, 30));
			btnStart.setLocation(new Point(34, 16));
			btnStart.addActionListener(new java.awt.event.ActionListener() {
				public void actionPerformed(java.awt.event.ActionEvent e) {
					System.out.println("服务器启动...");
					server = new ChatRoomServer(9527);
					server
							.addOnlineListUpdateListener(new OnlineListUpdateListener() {
								public void update(List<OnlineUser> userList) {
									System.out.println("----在线列表----");
									for (OnlineUser user : userList) {
										System.out.println(user.getNickName());
									}
									System.out.println("----------------");
								}
							});
					server
							.addMessageReceiveListener(new PublicMessageListener() {
								public void receive(String from, String message) {
									System.out.println(formatMessage(from, message));
								}
							});

					btnStart.setEnabled(false);
					btnStop.setEnabled(true);
					try {
						server.start();
					} catch (IOException e1) {
						// TODO 自动生成 catch 块
						e1.printStackTrace();
					}
				}
			});
		}
		return btnStart;
	}
	

	private String formatMessage(String from,String message){
		Calendar cal = Calendar.getInstance();
		int h = cal.get(Calendar.HOUR_OF_DAY);
		int m = cal.get(Calendar.MINUTE);
		int s = cal.get(Calendar.SECOND);
		return "["+((h>9)?"":"0")+h+":"
		+((m>9)?"":"0")+ m+":"
		+((s>9)?"":"0")+ s
		+"]"
		+"  "
		+from +" 说:\n    "
		+message;
	}

	/**
	 * This method initializes btnStop
	 * 
	 * @return javax.swing.JButton
	 */
	private JButton getBtnStop() {
		if (btnStop == null) {
			btnStop = new JButton();
			btnStop.setEnabled(false);
			btnStop.setLocation(new Point(117, 16));
			btnStop.setSize(new Dimension(60, 30));
			btnStop.setText("停止");
			btnStop.addActionListener(new java.awt.event.ActionListener() {
				public void actionPerformed(java.awt.event.ActionEvent e) {
					System.out.println("服务器停止...");
					try {
						server.stop();
						btnStart.setEnabled(true);
						btnStop.setEnabled(false);
					} catch (IOException e1) {
						// TODO 自动生成 catch 块
						e1.printStackTrace();
					}
				}
			});
		}
		return btnStop;
	}

} // @jve:decl-index=0:visual-constraint="10,10"