mainframe.java~22~

一个java写的qq代码……大家用来学习 非常好用

package lxl聊天系统;

import java.awt.BorderLayout;
import java.awt.Dimension;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JLabel;
import java.awt.Rectangle;
import javax.swing.JTextField;
import javax.swing.JButton;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTabbedPane;
import java.awt.Font;
import javax.swing.BorderFactory;
import javax.swing.border.BevelBorder;
import java.awt.Color;
import javax.swing.border.Border;
import javax.swing.border.EtchedBorder;
import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.sql.*;

public class MainFrame extends JFrame {
    JPanel contentPane;
    JLabel jLabel1 = new JLabel();
    JTextField jTextField1 = new JTextField();
    JButton jButton1 = new JButton();
    JTabbedPane jTabbedPane1 = new JTabbedPane();
    JPanel jPanel1 = new JPanel();
    JPanel jPanel2 = new JPanel();
    JScrollPane jScrollPane2 = new JScrollPane();
    JScrollPane jScrollPane3 = new JScrollPane();
    Border border1 = BorderFactory.createBevelBorder(BevelBorder.RAISED,
            Color.white, Color.white, new Color(115, 114, 105),
            new Color(165, 163, 151));
    Border border2 = BorderFactory.createEtchedBorder(EtchedBorder.RAISED,
            Color.white, new Color(165, 163, 151));
    JTextArea jTextArea2 = new JTextArea();
    JTextArea jTextArea3 = new JTextArea();
    JScrollPane jScrollPane1 = new JScrollPane();
    Border border3 = BorderFactory.createEtchedBorder(Color.white,
            new Color(165, 163, 151));
    JTextArea jTextArea1 = new JTextArea();
    ServerSocket server=null;
   // ConnectSocket connect=null;
    static Vector clients=new Vector();
    class ConnectSocket extends Thread{
        Socket socket;
        public void run(){
            while(true){
                try {
                    socket = server.accept();
                } catch (IOException ex) {
                    jTextArea1.append("客户连接失败！\n");
                }
                Client c=new Client(socket);
                clients.addElement(c);
                if(checkName(c)){
                    c.start();
                    notifyRoom();
                }
                else {
                    disconnect(c);
                }


            }
        }
    }
    class Client extends Thread{
        String name,pa;
        BufferedReader dis;
        PrintStream ps;
        Socket socket;
        public Client(Socket s){
            socket=s;
            try {
                dis = new BufferedReader(new InputStreamReader(socket.
                        getInputStream()));
                ps=new PrintStream(socket.getOutputStream());
                String info=dis.readLine();
                StringTokenizer stinfo=new StringTokenizer(info,":");
                String head=stinfo.nextToken();
                name=stinfo.nextToken();
                pa=stinfo.nextToken();
                //加入数据
                try {
                    Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                    Connection con=DriverManager.getConnection("Jdbc:Odbc:MyLXL","","");
                    Statement st=con.createStatement();
                    ResultSet rs=st.executeQuery("select * from LXLuser where name='"+name+"'and pa='"+pa+"'");
                    if(rs.next()){
                        String str="YES:";
                        ResultSet rs1=st.executeQuery("select name from LXLFriend where username='"+name+"'");
                        while(rs1.next())
                            str+="rs1:";
                        ps.println(str);
                    }else{
                        String str1 = "NO："+"密码不正确";
                        ps.println(str1);
                    }
                } catch (Exception ex1) {
                }
               // jTextArea1.append("系统提示："+name+"已经连接\n");
                //jTextArea1.append("ddd"+pa);

            } catch (IOException ex) {
                jTextArea1.append("系统消息：用户连接出错\n");
            }
        }
        public void send(String msg){
            ps.println(msg);
            ps.flush();
        }
        public void run(){
            while(true){
                String line=null;
                try {
                    line = dis.readLine();
                } catch (IOException ex) {
                    jTextArea1.append("系统提示：读客户信息出错");
                    disconnect(this);
                    notifyRoom();
                    return;
                }
                StringTokenizer st=new StringTokenizer(line,":");
                String keyword=st.nextToken();
                if(keyword.equalsIgnoreCase("msg")){
                    sendClients(line);
                }
                else if(keyword.equalsIgnoreCase("quit")){
                    send("quit");
                    disconnect(this);
                    notifyRoom();
                    this.stop();
                }

            }
        }
    }

   public boolean checkName(Client newClient){
       for(int i=0;i<clients.size();i++){
           Client c=(Client)clients.elementAt(i);
      if((c!=newClient)&&(c.name).equals(newClient.name)){
             return false;
           }
       }
       return true;
   }
  public void notifyRoom(){
      String people="PEOPLE";
      for(int i=0;i<clients.size();i++){
          Client c=(Client)clients.elementAt(i);
          people+=":"+c.name;
      }
      sendClients(people);
  }
  public void sendClients(String msg){
      for(int i=0;i<clients.size();i++){
          Client c=(Client)clients.elementAt(i);
          c.send(msg);
      }
  }
   public void disconnect(Client c){
    try {
        jTextArea1.append(c.name + "断开连接\n");
        c.send("quit");
        clients.removeElement(c);
        c.socket.close();
    } catch (IOException ex) {
        jTextArea1.append("服务器断开出错\n");
    }
   }

    public MainFrame() {
        try {
            setDefaultCloseOperation(EXIT_ON_CLOSE);
            jbInit();
        } catch (Exception exception) {
            exception.printStackTrace();
        }
    }

    /**
     * Component initialization.
     *
     * @throws java.lang.Exception
     */
    private void jbInit() throws Exception {
        border1 = BorderFactory.createEtchedBorder(EtchedBorder.RAISED,
                Color.white, new Color(165, 163, 151));
        contentPane = (JPanel) getContentPane();
        contentPane.setLayout(null);
        setSize(new Dimension(420, 350));
        setTitle("LXL聊天系统服务器");
        jLabel1.setText("服务器");
        jLabel1.setBounds(new Rectangle(18, 17, 84, 36));
        jTextField1.setEditable(false);
        jTextField1.setText("6544");
        jTextField1.setBounds(new Rectangle(108, 15, 152, 37));
        jButton1.setBounds(new Rectangle(266, 15, 115, 36));
        jButton1.setText("启动系统");
        jButton1.addActionListener(new MainFrame_jButton1_actionAdapter(this));
        jTabbedPane1.setBounds(new Rectangle(12, 67, 377, 223));
        jPanel1.setLayout(null);
        jPanel2.setLayout(null);
        jScrollPane2.setBorder(border2);
        jScrollPane2.setBounds(new Rectangle(4, 7, 363, 93));
        jScrollPane3.setBorder(border1);
        jScrollPane3.setBounds(new Rectangle(5, 110, 363, 80));
        jTextArea2.setText("jTextArea2");
        jTextArea3.setText("jTextArea3");
        jScrollPane1.setBorder(border3);
        jScrollPane1.setBounds(new Rectangle(4, 9, 363, 182));
        contentPane.add(jLabel1);
        contentPane.add(jTextField1);
        contentPane.add(jButton1);
        contentPane.add(jTabbedPane1);
        jTabbedPane1.add(jPanel1, "系统提示");
        jPanel1.add(jScrollPane1);
        jScrollPane1.getViewport().add(jTextArea1);
        jPanel2.add(jScrollPane2);
        jScrollPane2.getViewport().add(jTextArea2);
        jPanel2.add(jScrollPane3);
        jScrollPane3.getViewport().add(jTextArea3);
        jTabbedPane1.add(jPanel2, "客户");
    }

    public void jButton1_actionPerformed(ActionEvent e) {
    try {
        server = new ServerSocket(Integer.parseInt(jTextField1.getText()));
        jTextArea1.append("系统提示：聊天服务器系统开始启动…………\n");
    } catch (IOException ex) {
        jTextArea1.append("服务器端口打开出错\n");
    }
    if(server!=null){
        ConnectSocket connect=new ConnectSocket();
        connect.start();
    }
    }
}


class MainFrame_jButton1_actionAdapter implements ActionListener {
    private MainFrame adaptee;
    MainFrame_jButton1_actionAdapter(MainFrame adaptee) {
        this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
        adaptee.jButton1_actionPerformed(e);
    }
}