chatserver.java

关于客户端与服务端间的聊天室

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.*;
import java.util.*;


public class chatServer extends JFrame 
{
	  //以下为图形界面变量
	  JPanel contentPane;
	  JMenuBar jMenuBar1 = new JMenuBar();
	  JMenu jMenuFile = new JMenu();
	  JMenuItem jMenuFileExit = new JMenuItem();
	  JMenu jMenuHelp = new JMenu();
	  JMenuItem jMenuHelpAbout = new JMenuItem();
	  JLabel statusBar = new JLabel();
	  BorderLayout borderLayout1 = new BorderLayout();
	  JPanel jPanel1 = new JPanel();
	  BorderLayout borderLayout2 = new BorderLayout();
	  JLabel jLabel1 = new JLabel();
	  static java.awt.List jList1 = new java.awt.List(13);
	
	  JScrollPane scrollpane=new JScrollPane(jList1);
	
	
	  //以下为网络相关变量
	  static Vector clients=new Vector(10);   //用vector向量数组存储连接客户变量
	  static ServerSocket server=null;        //建立服务器socket
	  static int active_connects=0;           //用来存储目前连接的客户数
	  static Socket socket=null;               //用来存储一个套接字连接
	  static String send=null;


	  //chatServer main method
	   public static void main(String[] args)
	   {
		    try 
		    {
		      UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
		    }
		    catch(Exception e) 
		    {
		      e.printStackTrace();
		    }
		    chatServer chatServer1=new chatServer();      //实例化一个chatServer类
			chatServer1.show();
			System.out.println("Server starting ...");
		
			try
			{
			    server=new ServerSocket(2525);      //使用端口2525初始化服务器套接字
			}
			catch(IOException e)
			{
			    System.out.println("Error:"+e);
			}
			while(true)
			{
		
			    if(clients.size()<5)       //当客户数小于5个时开始连接
				{
				    try
					{
					    socket=server.accept();   //用来存储连接上的客户socket
					    if(socket!=null)
					    {
					    System.out.println(socket+"连接");    //在控制台打印客户连接信息
		     		    }
					}
					catch(IOException e)
					{
					    System.out.println("Error:"+e);
					}
					int i=0;
					do
					{
					    Client c=new Client(socket);      //定义并实例化一个Client线程类，一个就对应一个客户连接
					    clients.addElement(c);             //加入clients数组中
						if(checkName(c))                  //调用checkName方法验证c的合法性
						{
						    int connum=++chatServer1.active_connects;  //定义connum来存储活动连接数
						    String constr="目前有"+connum+"客户相连";    //在状态栏里显示连接数
						    chatServer1.statusBar.setText(constr);
						    Client listdata=(Client)clients.elementAt(i);   //将连接客户的socket信息存储进listdata数组
		
						    chatServer1.jList1.addItem(listdata.ip+":"+listdata.name+"连接",i);  //将客户socket信息写入list框
						    c.start();                                        //启动线程
							notifyRoom();                                    //用notifyRoom方法来监视聊天室连接变化
							                                                 //不断改变clients数组并刷新客户端信息
		
						}
						else
						{
						    //如果名字不合法
						    c.ps.println("TAKEN");
		
							disconnect(c);
		
						}
						i++;
						break;
		
					}
					while(i<clients.size());
		
				}
				else                                   //如果clients数组超过了5个
				{
					try
					{
						Thread.sleep(200);
					}
					catch(InterruptedException e)
					{
					}
				}
		}//end of while
  }// end of main method


  /**Construct the frame*/
  public chatServer()                          //chatServer类的构造器用来初始化一些UI信息
  {
	    enableEvents(AWTEvent.WINDOW_EVENT_MASK);
	    try 
	    {
	      jbInit();
	    }
	    catch(Exception e) 
	    {
	      e.printStackTrace();
	    }
  }
  /**Component initialization*/
  private void jbInit() throws Exception 
  {
	    //setIconImage(Toolkit.getDefaultToolkit().createImage(Frame1.class.getResource("[Your Icon]")));
	    contentPane = (JPanel) this.getContentPane();
	    contentPane.setLayout(borderLayout1);
	    this.setSize(new Dimension(400, 300));
	    System.out.println("我的输出信息。。。");
	    this.setTitle("简易聊天服务器端");
	    statusBar.setText("目前的连接数为：");
	
	    jMenuFile.setText("File");
	    jMenuFileExit.setText("Exit");
	    jMenuFileExit.addActionListener(new ActionListener()  {
	      public void actionPerformed(ActionEvent e) 
	      {
	        jMenuFileExit_actionPerformed(e);
	      }
	    });
	    jMenuHelp.setText("Help");
	    jMenuHelpAbout.setText("About");
	    jMenuHelpAbout.addActionListener(new ActionListener()  {
	      public void actionPerformed(ActionEvent e) {
	        jMenuHelpAbout_actionPerformed(e);
	      }
	    });
	
	
	    jPanel1.setLayout(borderLayout2);
	    jLabel1.setText("服务器端连接客户");
	    jMenuFile.add(jMenuFileExit);
	    jMenuHelp.add(jMenuHelpAbout);
	    jMenuBar1.add(jMenuFile);
	    jMenuBar1.add(jMenuHelp);
	    this.setJMenuBar(jMenuBar1);
	    contentPane.add(statusBar, BorderLayout.SOUTH);
	    contentPane.add(jPanel1, BorderLayout.CENTER);
	    jPanel1.add(jLabel1,  BorderLayout.NORTH);
	    jPanel1.add(scrollpane, BorderLayout.CENTER);


  }//end of jbinit
  /**File | Exit action performed*/
  public void jMenuFileExit_actionPerformed(ActionEvent e)   //实现退出菜单方法
  {
	    sendClients(new StringBuffer("QUIT"));                   //向客户端发送断开连接信息
		closeAll();                                               //调用closeAll方法关闭所有连接
		System.exit(0);
  }
  /**Help | About action performed*/
  public void jMenuHelpAbout_actionPerformed(ActionEvent e)  //实现about对话框，意义不大，可以去掉
  {
	    chatServer_AboutBox dlg = new chatServer_AboutBox(this);
	    Dimension dlgSize = dlg.getPreferredSize();
	    Dimension frmSize = getSize();
	    Point loc = getLocation();
	    dlg.setLocation((frmSize.width - dlgSize.width) / 2 + loc.x, (frmSize.height - dlgSize.height) / 2 + loc.y);
	    dlg.setModal(true);
	    dlg.show();
  }
  /**Overridden so we can exit when window is closed*/
  protected void processWindowEvent(WindowEvent e)          //实现关闭服务器程序要进行的操作
  {
	    super.processWindowEvent(e);
	    if (e.getID() == WindowEvent.WINDOW_CLOSING) 
	    {
	        jMenuFileExit_actionPerformed(null);
        }
  }



  /*以下实现各种方法*/
  public static void notifyRoom()                          //用来监视连接信息，不断刷新clients数组并刷新客户端用户列表信息
  {
     StringBuffer people=new StringBuffer("PEOPLE");
	 for(int i=0;i<clients.size();i++)
	 {
	     Client c=(Client)clients.elementAt(i);
		 people.append(":"+c.name);

	 }
	 sendClients(people);                                 //用sendClients方法向客户端发送信息
  }
  public static synchronized String getGB(String str)
        {
	        if (str==null) return null;
	        try {
	            byte[] bytes = str.getBytes("ISO8859-1");
	            String sRet = new String(bytes, "GBK");