frame1.java

基于java开发的类似QQ的聊天工具的源程序

package chatserver;

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import com.borland.jbcl.layout.*;
import java.net.*;//需要增加的包
import java.io.*;
import java.util.Vector;
import java.util.StringTokenizer;
import java.lang.Thread;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class Frame1 extends JFrame {
  JPanel contentPane;
  JPanel jPanel1 = new JPanel();
  JPanel jPanel2 = new JPanel();
  XYLayout xYLayout1 = new XYLayout();
  BorderLayout borderLayout1 = new BorderLayout();
  BorderLayout borderLayout2 = new BorderLayout();
  JPanel jPanel3 = new JPanel();
  JLabel jLabel1 = new JLabel();
  JLabel jLabel2 = new JLabel();
  JLabel jLabel3 = new JLabel();
  PaneLayout paneLayout1 = new PaneLayout();
  JPanel jPanel4 = new JPanel();
  JLabel jLabel4 = new JLabel();
  JLabel jLabel5 = new JLabel();
  JLabel jLabel6 = new JLabel();
  PaneLayout paneLayout2 = new PaneLayout();
  JScrollPane jScrollPane1 = new JScrollPane();
  JScrollPane jScrollPane2 = new JScrollPane();
  JTextArea jTextArea2 = new JTextArea();
  JPanel jPanel5 = new JPanel();
  JTextField jTextField1 = new JTextField();
  PaneLayout paneLayout3 = new PaneLayout();
  JButton send = new JButton();
  JButton sysexit = new JButton();
  JTextField jTextField2 = new JTextField();
  java.awt.List list1 = new java.awt.List();
  JButton link = new JButton();//用来列出目前连接的客户数

//定义相关变量
 static ServerSocket serverSocket=null;//建立服务器的socket
  Socket socket=null;  //用来存储一个连接套接字
  BufferedReader cin=null;//用来实现接受从客户端发来的数据流
  PrintWriter cout=null;//用来实现向客户端发送信息的流
  static Vector clients=new Vector(20);   //用vector向量数组存储连接客户变量
  static int active_connects=0;//记录目前连接的客户数



  //Construct the frame
  public Frame1() {
    enableEvents(AWTEvent.WINDOW_EVENT_MASK);
    try {
      jbInit();
    }
    catch(Exception e) {
      e.printStackTrace();
    }
  }
  //Component initialization
  private void jbInit() throws Exception  {
    contentPane = (JPanel) this.getContentPane();
    contentPane.setLayout(xYLayout1);
    this.setLocale(java.util.Locale.getDefault());
    this.setSize(new Dimension(407, 379));
    this.setTitle("网络聊天服务器");
    jPanel1.setLayout(borderLayout1);
    jPanel2.setLayout(borderLayout2);
    jLabel1.setBorder(BorderFactory.createEtchedBorder());
    jLabel1.setText("用户名");
    jLabel2.setBorder(BorderFactory.createEtchedBorder());
    jLabel2.setText("IP地址");
    jLabel3.setBorder(BorderFactory.createEtchedBorder());
    jLabel3.setToolTipText("");
    jLabel3.setText("连接情况");
    jPanel3.setLayout(paneLayout1);
    jLabel4.setBorder(BorderFactory.createEtchedBorder());
    jLabel4.setText("信息类型");
    jLabel5.setBorder(BorderFactory.createEtchedBorder());
    jLabel5.setText("信息来源");
    jLabel6.setBorder(BorderFactory.createEtchedBorder());
    jLabel6.setText("信息内容");
    jPanel4.setLayout(paneLayout2);
    jTextField1.setEditable(false);
    jTextField1.setText("");
    jPanel5.setLayout(paneLayout3);
    send.setText("发送");
    send.addActionListener(new Frame1_send_actionAdapter(this));
    sysexit.setText("退出");
    sysexit.addActionListener(new Frame1_sysexit_actionAdapter(this));
    jTextArea2.setText("");
    link.setText("连接");
    link.addActionListener(new Frame1_link_actionAdapter(this));
    contentPane.add(jPanel1,    new XYConstraints(-2, 0, 402, 152));
    jPanel1.add(jPanel3, BorderLayout.NORTH);
    jPanel1.add(jScrollPane1, BorderLayout.CENTER);
    jScrollPane1.getViewport().add(list1, null);
    contentPane.add(jPanel2,     new XYConstraints(-1, 160, 401, 140));
    jPanel2.add(jPanel4,  BorderLayout.NORTH);
    jPanel4.add(jLabel4,           new PaneConstraints("jLabel4", "jLabel4", PaneConstraints.ROOT, 0.5f));
    jPanel4.add(jLabel5,           new PaneConstraints("jLabel5", "jLabel4", PaneConstraints.RIGHT, 0.7431421f));
    jPanel4.add(jLabel6,           new PaneConstraints("jLabel6", "jLabel5", PaneConstraints.RIGHT, 0.36577183f));
    jPanel2.add(jScrollPane2, BorderLayout.CENTER);
    jPanel2.add(jPanel5, BorderLayout.SOUTH);
    contentPane.add(jTextField2, new XYConstraints(1, 295, 306, 31));
    contentPane.add(jTextField1,  new XYConstraints(2, 329, 242, -1));
    contentPane.add(send,  new XYConstraints(328, 301, 60, 22));
    contentPane.add(sysexit,   new XYConstraints(329, 329, 60, 22));
    contentPane.add(link, new XYConstraints(261, 330, 56, 22));
    jScrollPane2.getViewport().add(jTextArea2, null);
    jPanel3.add(jLabel1,        new PaneConstraints("jLabel1", "jLabel1", PaneConstraints.ROOT, 0.5f));
    jPanel3.add(jLabel2,        new PaneConstraints("jLabel2", "jLabel1", PaneConstraints.RIGHT, 0.8557214f));
    jPanel3.add(jLabel3,        new PaneConstraints("jLabel3", "jLabel2", PaneConstraints.RIGHT, 0.5826087f));
  }
  //File | Exit action performed
  public void jMenuItemClear_actionPerformed(ActionEvent e) {
    System.exit(0);
  }
  //Help | About action performed
  //Overridden so we can exit when window is closed
  protected void processWindowEvent(WindowEvent e) {
    super.processWindowEvent(e);
    if (e.getID() == WindowEvent.WINDOW_CLOSING) {
      jMenuItemClear_actionPerformed(null);
    sendClients(new StringBuffer("QUIT:"+"SERVER"));
   closeAll();
   System.exit(0);

    }
  }

//添加的方法！！！！
  public static void notifyRoom(){//监视聊天窗口的连接变化,不
    //断刷新clients数组并刷新用户列表信息
   StringBuffer people=new StringBuffer("PEOPLE");
   //增加PEOPLE表示是客户列表信息
   for(int i=0;i<clients.size();i++)
   {
     Client c=(Client)clients.elementAt(i);
     people.append(":"+c.name);
   }
   sendClients(people);
  }

public static boolean  checkName(Client newClient)
  {
    for(int i=0;i<clients.size();i++)
    {
      Client c=(Client)clients.elementAt(i);
      if((c!=newClient)&&c.equals(newClient.name))
        return false;
    }
    return true;
  }

  public synchronized void disconnect(Client c)//缺少static
  {
    try{
     jTextArea2.append("系统消息：             "
                       +c.name+"        断开连接\n");
     active_connects--;  //连接数减1
     c.send(new StringBuffer("QUIT"+":"+c.name));
                      //向客户发送断开信息
     clients.removeElement(c);
     jTextField1.setText("目前已经有"+clients.size()+"用户连接");
     c.socket.close();//断开连接
   }
   catch(IOException e)
   {
     jTextArea2.append("系统消息："+"Error "+e);
   }
  }

  public  static synchronized void sendClients(StringBuffer msg)
  {//发送信息到所有用户
   for(int i=0;i<clients.size();i++){
   Client c=(Client)clients.elementAt(i);
   c.send(msg);
   }
  }

  public synchronized void sendtoClient(StringBuffer msg,String name)
       //将信息发送到特定的单个用户
     {
       for(int i=0;i<clients.size();i++)
    {
      Client c=(Client)clients.elementAt(i);
      if(c.name.equalsIgnoreCase(name))
      {
       c.send(msg);
       break;
      }
      }
     }


  public void closeAll()//关闭所有游的连接信息
  {
    while(clients.size()>0)
    //需要在整个数组中将每一个连接遍历，然后删除信息
    {
      Client c=(Client)clients.firstElement();
      try{
        c.socket.close();
      }
      catch(IOException e){
        jTextArea2.append("系统消息："+"        聊天服务器"+ "   Error  "+e);
      }
      finally{
        clients.removeElement(c);
        //从clients数组中删除客户相关的socket信息
      }
    }
  }
class Client extends Thread{
      String name;      //用来存储客户的连接姓名
      String ip;         //用来存储客户的连接IP