fangzhao QQ

[java]代码库
package server.serverMain;
 
import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Container;
import java.awt.Cursor;
import java.awt.Dialog;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.ItemEvent;
import java.awt.event.ItemListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.awt.event.MouseEvent;
import java.awt.event.MouseListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
 
import javax.jws.Oneway;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JComboBox;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollBar;
import javax.swing.JScrollPane;
import javax.swing.JSplitPane;
import javax.swing.JTabbedPane;
import javax.swing.JTable;
import javax.swing.JTextField;
import javax.swing.JTextPane;
import javax.swing.table.AbstractTableModel;
import javax.swing.table.TableColumn;
 
import common.message.node_info;
import common.message.node_public;
import common.message.testMessage;
import server.thread.addFriendsThread.addFriendsThread;
import server.thread.addFriendsThread.authenticationMessageReceiverThread;
import server.thread.addFriendsThread.receiveAgreeRefuseThread;
import server.thread.addqqCanUseThread.addqqCanUseThread;
import server.thread.applicateThread.applicateServerThread;
import server.thread.deleteFridendsThread.deleteFriendsThread;
import server.thread.getAnotherQQIpThread.getAnotherQQIpThread;
import server.thread.getInfoThread.getInfoThread;
import server.thread.groupDealThread.groupDealThread;
import server.thread.heartbeatThread.heartbeatReceiver;
import server.thread.heartbeatThread.judgeAliveThread;
import server.thread.loginThread.loginServerThread;
import server.thread.moveFriendThread.moveFriendThread;
import server.thread.safeThread.judgeWhetherQuestionExistThread;
import server.thread.safeThread.receiveSafeAnswerThread;
import server.thread.safeThread.setSafeQuestionThread;
import server.thread.safeThread.updatePasswordThread;
import server.thread.searchThread.searchThread;
import server.thread.systemMessageThread.sendSystemMessageThread;
import server.thread.systemSettingsThread.systemSettingThread;
import server.thread.updatePersonalInfoThread.updatePersonalInfoThread;
import server.thread.updateRemarkThread.updateRemarkThead;
 
public class serverMain extends JFrame
{
    JPanel j1 = null;
    JPanel j2 = null;
    JPanel j3 = null;
    JPanel j4 = null;
    JScrollPane jsroll0 = null;
    JScrollPane jsroll1 = null;
    JScrollPane jsroll2 = null;
    JScrollPane jsroll3 = null;
    JTextPane textPane0 = null;
    JTextPane textPane1 = null;
    public static JTextPane textPane2 = null;
    JTextField textf_setLimit = null;
    JButton jb_setLimit = null;
    JLabel jlable_setLimit = null;
    JComboBox jcom_setDatabase = null;
    JButton jb_setDatabase = null;
    JLabel jlable_setDatabase = null;
    JTable table = null;
    JLabel jlable1 = null;
    JLabel jlable2 = null;
    JLabel jlable_warning = null;
    JButton jb1 = null;
    JButton jb2 = null;
    JButton jb3 = null;
    JButton jb4 = null;
    MyTableModel myModel = null;
    addqqCanUseThread addCanUse;
    heartbeatReceiver heartbeat;
    judgeAliveThread judgeAlive;
    loginServerThread loginServer;
    applicateServerThread applicateServer;
    searchThread searchServer;
    addFriendsThread addServer;
    authenticationMessageReceiverThread authenticationReceiveServer;
    receiveAgreeRefuseThread agreeRefuseServer;
    deleteFriendsThread deleteServer;
    getAnotherQQIpThread getIpServer;
    getInfoThread getInfoServer;
    judgeWhetherQuestionExistThread getPasswordServer;
    receiveSafeAnswerThread receiverAnswerServer;
    groupDealThread groupDealServer;
    moveFriendThread moveFriendServer;
    setSafeQuestionThread safeQuestionServer;
    systemSettingThread systemSettingServer;
    updatePasswordThread updatePasswordServer;
    updatePersonalInfoThread updatepersonalServer;
    updateRemarkThead updateRemarkServer;
    public static int limit = 100; // 申请次数限制
    public static HashMap<String, node_public> map_onlineInfo = new HashMap<String, node_public>();
    public static HashMap<String, Integer> map_IsSysMessageExist = new HashMap<String, Integer>();
    public static HashMap<String, Date> map_date = new HashMap<String, Date>();
    public static HashMap<String, Integer> map_status = new HashMap<String, Integer>();
    public static HashMap<String, String> map_array_passwordMap = new HashMap<String, String>();
    public static ArrayList<String> array_qqCanUse = new ArrayList<String>();
    public static Connection con1 = null;
    public static Connection con2 = null;
    public static int databaseFlag = 0; // 0是mysql 1是SQLServer 默认mysql
    public static int startFlag = 0;
    private String ip = "localhost";
    private int connectException = 0; // 连接正确与否 1、正确 2、错误
 
    public serverMain()
    {
        createUserInterface();
        try
        {
            startServer();
        }
        catch (Exception e)
        {
            JOptionPane.showMessageDialog(null, "服务器启动失败，请查看其是否已经在运行！", "失败",
                    JOptionPane.ERROR_MESSAGE);
        }
    }
 
    class refresh extends Thread
    {}
 
    private void createUserInterface()
    {
        Container contentPane = getContentPane();
        contentPane.setBackground(Color.WHITE);
        contentPane.setLayout(null);
        //
        //
        // 系统消息
        j1 = new JPanel();
        j1.setLayout(null);
        //
        jlable1 = new JLabel("已发送的系统消息：");
        jlable1.setFont(new Font("宋体", Font.PLAIN, 12));
        jlable1.setBounds(0, 0, 120, 15);
        j1.add(jlable1);
        //
        //
        textPane0 = new JTextPane();
        textPane0.setEditable(false);
        textPane0.setFont(new Font("宋体", Font.PLAIN, 12));
        textPane0.setDisabledTextColor(Color.red);
        textPane0.setBounds(0, 20, 600, 180);
        j1.add(textPane0);
        jsroll0 = new JScrollPane(textPane0);
        jsroll0.setBounds(0, 20, 590, 180);
        jsroll0.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
        j1.add(jsroll0);
        //
        //
        jlable2 = new JLabel("请在下面输入系统消息，按ctrl+enter发送：");
        jlable2.setBounds(0, 200, 250, 15);
        jlable2.setFont(new Font("宋体", Font.PLAIN, 12));
        j1.add(jlable2);
        //
        jb1 = new JButton("清空已发送");
        jb1.setBounds(470, 202, 100, 15);
        jb1.setFont(new Font("宋体", Font.PLAIN, 12));
        j1.add(jb1);
        jb1.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e)
            {
                jb1ActionPerfromed(e);
            }
        });
        //
        textPane1 = new JTextPane();
        textPane1.setBounds(0, 220, 600, 80);
        textPane1.setFont(new Font("宋体", Font.PLAIN, 12));
        j1.add(textPane1);
        jsroll3 = new JScrollPane(textPane1);
        jsroll3.setBounds(0, 220, 590, 80);
        jsroll3.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
        j1.add(jsroll3);
        //
        jb2 = new JButton("发送");
        jb2.setBounds(470, 302, 100, 15);
        jb2.setFont(new Font("宋体", Font.PLAIN, 12));
        j1.add(jb2);
        jb2.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e)
            {
                try
                {
                    jb2ActionPerfromed(e);
                }
                catch (SQLException e1)
                {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
            }
        });
        //
        // 系统日志
        j2 = new JPanel();
        j2.setLayout(null);
        textPane2 = new JTextPane();
        textPane2.setBounds(0, 0, 600, 300);
        textPane2.setCursor(new Cursor(Cursor.DEFAULT_CURSOR));
        textPane2.setText("系统日志：\n");
        textPane2.setFont(new Font("宋体", Font.PLAIN, 12));
        textPane2.setEditable(false);
        j2.add(textPane2);
        jsroll1 = new JScrollPane(textPane2);
        jsroll1.setBounds(0, 0, 590, 300);
        jsroll1.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
        j2.add(jsroll1);
        jb3 = new JButton("清空");
        jb3.setBounds(470, 302, 100, 15);
        jb3.setFont(new Font("宋体", Font.PLAIN, 12));
        j2.add(jb3);
        jb3.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e)
            {
                jb3ActionPerfromed(e);
            }
        });
        //
        j3 = new JPanel();
        j3.setLayout(null);
        // 表格
        myModel = new MyTableModel();
        table = new JTable(myModel);
        table.setEnabled(true);
        table.setRowSelectionAllowed(true);// 设置可否被选择.默认为false
        table.setShowHorizontalLines(true);
        table.setShowVerticalLines(true);
        table.setGridColor(Color.blue);
        table.setBounds(0, 0, 600, 200);
        jsroll2 = new JScrollPane(table);
        jsroll2.setBounds(0, 0, 590, 300);
        jsroll2.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
        j3.add(jsroll2);
        //
        jb4 = new JButton("刷新");
        jb4.setBounds(470, 302, 100, 15);
        jb4.setFont(new Font("宋体", Font.PLAIN, 12));
        j3.add(jb4);
        jb4.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e)
            {
                jb4ActionPerfromed(e);
            }
        });
         
        j4 = new JPanel();
        j4.setLayout(null);
        jlable_setLimit = new JLabel("同一个IP一天可申请的次数：");
        jlable_setLimit.setBounds(10, 10, 200, 20);
        textf_setLimit = new JTextField();
        textf_setLimit.setBounds(200, 10, 90, 20);
        jb_setLimit = new JButton("确定");
        jb_setLimit.setBounds(300, 10, 60, 20);
        jb_setLimit.setFont(new Font("宋体", Font.PLAIN, 12));
        j4.add(jlable_setLimit);
        j4.add(jb_setLimit);
        j4.add(textf_setLimit);
        jb_setLimit.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e)
            {
                jb_setActionPerfromed(e);
            }
        });
        jlable_setDatabase = new JLabel("请选择连接数据库：");
        jlable_setDatabase.setBounds(10, 40, 200, 20);
        String item[] = { "MySql", "SQLServer" };
        jcom_setDatabase = new JComboBox(item);
        jcom_setDatabase.setBounds(200, 40, 90, 20);
        jlable_warning = new JLabel("(提示：请先停止服务器再更改此选项！)");
        jlable_warning.setBounds(300, 40, 300, 20);
        jlable_warning.setFont(new Font("宋体", Font.PLAIN, 12));
        j4.add(jlable_setDatabase);
        j4.add(jcom_setDatabase);
        j4.add(jlable_warning);
        jcom_setDatabase.addItemListener(new ItemListener() {
            @Override
            public void itemStateChanged(ItemEvent e)
            {
                jcom_setDatabaseStateChanged(e);
            }
        });
        //
        JTabbedPane tab = new JTabbedPane();
        tab.setBounds(0, 0, 600, 400);
        tab.addTab("系统日志", j2);
        tab.addTab("发送系统消息", j1);
        tab.addTab("在线情况", j3);
        tab.addTab("系统设置", j4);
        tab.setFont(new Font("宋体", Font.PLAIN, 12));
        contentPane.add(tab);
        Menu m = new Menu();
        m.setFont(new Font("宋体", Font.PLAIN, 12));
        this.setJMenuBar(m);
        Dimension screensize = Toolkit.getDefaultToolkit().getScreenSize();
        Dimension framesize = this.getSize();
        int x = (screensize.width - framesize.width) / 5;
        int y = (screensize.height - framesize.height) / 5;
        this.setLocation(x, y);
        this.show();
        setTitle("飞Q2012服务器");
        // this.setIconImage(new ImageIcon("\\icon.jpg").getImage());
        setResizable(false);
        setSize(600, 400);
        setVisible(true);
        // ------------------------给textPane1添加键盘事件--------------------------------//
        textPane1.addKeyListener(new KeyListener() {
            public void keyPressed(KeyEvent e)
            {
                if (e.isControlDown() && e.getKeyCode() == KeyEvent.VK_ENTER)
                {
                    try
                    {
                        if (startFlag == 1)
                        {
                            sendSystemMessageThread sendSys = new sendSystemMessageThread(
                                    textPane1.getText());
                            textPane0.setText(textPane0.getText()
                                    + (new Date()) + "：" + textPane1.getText()
                                    + "\n");
                            textPane1.setText("");
                        }
                        else
                        {
                            JOptionPane.showMessageDialog(null,
                                    "服务器已停止运行，请启动后再发系统消息！", "系统信息",
                                    JOptionPane.INFORMATION_MESSAGE);
                            textPane1.setText("");
                        }
                    }
                    catch (SQLException e1)
                    {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }
                }
            }
 
            public void keyTyped(KeyEvent e)
            {
                if (e.getKeyChar() >= '0' && e.getKeyChar() <= '9')
                {}
            }
 
            public void keyReleased(KeyEvent e)
            {}
        });
        // ---------------------------------------------------------------------//
    }
 
    protected void jcom_setDatabaseStateChanged(ItemEvent e)
    {
        databaseFlag = jcom_setDatabase.getSelectedIndex();
    }
 
    protected void jb_setActionPerfromed(ActionEvent e)
    {
        String str1 = textf_setLimit.getText();
        if (str1.equals(""))
        {
            JOptionPane.showMessageDialog(null, "输入 不能为空！", "输入错误",
                    JOptionPane.ERROR_MESSAGE);
            return;
        }
        for (int i = 0; i < str1.length(); i++)
        {
            if (str1.charAt(i) < '0' || str1.charAt(i) > '9')
            {
                textf_setLimit.setText("");
                JOptionPane.showMessageDialog(null, "输入的只能是数字！", "输入错误",
                        JOptionPane.ERROR_MESSAGE);
                return;
            }
        }
        limit = Integer.parseInt(str1);
        textf_setLimit.setText("");
        JOptionPane.showMessageDialog(null, "设置成功！", "设置成功",
                JOptionPane.INFORMATION_MESSAGE);
    }
 
    protected void jb4ActionPerfromed(ActionEvent e)
    {
        myModel = new MyTableModel();
        table.setModel(myModel);
        table.repaint();
    }
 
    protected void jb3ActionPerfromed(ActionEvent e)
    {
        textPane2.setText("");
        textPane2.setText("系统日志：\n");
    }
 
    protected void jb2ActionPerfromed(ActionEvent e) throws SQLException
    {
        if (startFlag == 1)
        {
            sendSystemMessageThread sendSys = new sendSystemMessageThread(
                    textPane1.getText());
            textPane0.setText(textPane0.getText() + (new Date()) + "："
                    + textPane1.getText() + "\n");
            textPane1.setText("");
        }
        else
        {
            JOptionPane.showMessageDialog(null, "服务器已停止运行，请启动后再发系统消息！", "系统信息",
                    JOptionPane.INFORMATION_MESSAGE);
            textPane1.setText("");
        }
    }
 
    protected void jb1ActionPerfromed(ActionEvent e)
    {
        textPane0.setText("");
    }
 
    // 菜单
    class Menu extends JMenuBar
    {
        private JDialog aboutDialog;
 
        /**
         * 菜单初始化操作
         */
        public Menu()
        {
            JMenu fileMenu1 = new JMenu("文件");
            JMenu fileMenu2 = new JMenu("操作");
            JMenu fileMenu3 = new JMenu("帮助");
            JMenuItem aboutMenuItem = new JMenuItem("关于...");
            JMenuItem exitMenuItem = new JMenuItem("退出");
            JMenuItem startMenuItem = new JMenuItem("重启服务器");
            JMenuItem stopMenuItem = new JMenuItem("停止服务器");
            fileMenu1.setFont(new Font("宋体", Font.PLAIN, 12));
            fileMenu2.setFont(new Font("宋体", Font.PLAIN, 12));
            fileMenu3.setFont(new Font("宋体", Font.PLAIN, 12));
            aboutMenuItem.setFont(new Font("宋体", Font.PLAIN, 12));
            exitMenuItem.setFont(new Font("宋体", Font.PLAIN, 12));
            startMenuItem.setFont(new Font("宋体", Font.PLAIN, 12));
            stopMenuItem.setFont(new Font("宋体", Font.PLAIN, 12));
            fileMenu1.add(exitMenuItem);
            fileMenu2.add(startMenuItem);
            fileMenu2.add(stopMenuItem);
            fileMenu3.add(aboutMenuItem);
            this.add(fileMenu1);
            this.add(fileMenu2);
            this.add(fileMenu3);
            aboutDialog = new JDialog();
            initAboutDialog();
            // 菜单事件
            exitMenuItem.addActionListener(new ActionListener() {
                public void actionPerformed(ActionEvent e)
                {
                    String sql_update = "update mainInfo set status = 0;";
                    dispose();
                    try
                    {
                        con1.createStatement().execute(sql_update);
                    }
                    catch (SQLException e1)
                    {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }
                    System.exit(0);
                }
            });
            aboutMenuItem.addActionListener(new ActionListener() {
                public void actionPerformed(ActionEvent e)
                {
                    aboutDialog.show();
                }
            });
            startMenuItem.addActionListener(new ActionListener() {
                @Override
                public void actionPerformed(ActionEvent e)
                {
                    try
                    {
                        stopServer();
                        Thread.sleep(2000);
                        startServer();
                        textPane2.setText(textPane2.getText() + (new Date())
                                + "：" + "服务器重新启动成功！\n");
                        JOptionPane.showMessageDialog(null, "服务器重启成功！", "系统信息",
                                JOptionPane.INFORMATION_MESSAGE);
                    }
                    catch (Exception e1)
                    {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }
                }
            });
            stopMenuItem.addActionListener(new ActionListener() {
                @Override
                public void actionPerformed(ActionEvent e)
                {
                    try
                    {
                        stopServer();
                        JOptionPane.showMessageDialog(null, "服务器已停止运行！",
                                "系统信息", JOptionPane.INFORMATION_MESSAGE);
                    }
                    catch (Exception e1)
                    {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }
                }
            });
            setFont(new Font("宋体", Font.PLAIN, 12));
        }
 
        /**
         * 返回关于对话框
         */
        public JDialog getAboutDialog()
        {
            return aboutDialog;
        }
 
        /**
         * 设置"关于"对话框的外观及响应事件,操作和JFrame一样都是在内容 框架上进行的
         */
        public void initAboutDialog()
        {
            aboutDialog.setTitle("关于QQserver");
            Container con = aboutDialog.getContentPane();
            // Swing 中使用html语句
            JLabel aboutLabel = new JLabel(
                    "<html><b>"
                            + "<center><br>QQserver</br><br>verson:1.0</br><br>Copyright © 2011 sdust,All rights reserved 版权所有 山东科技大学 王昌帅 司吉峰 王松松</br></html></b>",
                    JLabel.CENTER);
            aboutLabel.setFont(new Font("宋体", Font.PLAIN, 15));
            con.add(aboutLabel, BorderLayout.CENTER);
            aboutDialog.setResizable(false);
            aboutDialog.setSize(600, 200);
            aboutDialog.setLocation(205, 300);
        }
    }
 
    protected void processWindowEvent(WindowEvent e)
    {
        if (e.getID() == WindowEvent.WINDOW_CLOSING)
        {
            String sql_update = "update mainInfo set status = 0;";
            dispose();
            try
            {
                con1.createStatement().execute(sql_update);
            }
            catch (SQLException e1)
            {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            System.exit(0);
        }
        else
        {
            super.processWindowEvent(e);
        }
    }
 
    // 启动服务器
    public void startServer()
    {
        try
        {
            if (databaseFlag == 0)
            {
                System.out.println("链接mysql");
                // 定义MySQL的数据库驱动程序
                String DBDRIVER = "com.mysql.jdbc.Driver";
                // 定义MySQL数据库的连接地址
                /*String DBURL1 = "jdbc:mysql://" + ip
                        + ":3306/main?useUnicode=true&characterEncoding=utf8";
                String DBURL2 = "jdbc:mysql://" + ip
                        + ":3306/users?useUnicode=true&characterEncoding=utf8";*/
                //jdbc\:mysql\://localhost\:3306/manchar2
                String DBURL1 = "jdbc:mysql://localhost:3306/main?useUnicode=true&characterEncoding=utf8";
                String DBURL2 = "jdbc:mysql://localhost:3306/users?useUnicode=true&characterEncoding=utf8";
                // MySQL数据库的连接用户名
                String DBUSER = "root";
                // MySQL数据库的连接密码
                String DBPASS = "root";
                Class.forName(DBDRIVER); // 加载驱动程序
                con1 = DriverManager.getConnection(DBURL1, DBUSER, DBPASS);
                con2 = DriverManager.getConnection(DBURL2, DBUSER, DBPASS);
                textPane2.setText(textPane2.getText() + (new Date()) + "："
                        + "已连接MySQL数据库\n");
            }
            else
            {
                // /////////////////////////////////////////////////////
                Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
                String url1 = "jdbc:sqlserver://" + ip
                        + ":1433;DatabaseName=main;";
                String url2 = "jdbc:sqlserver://" + ip
                        + ":1433;DatabaseName=users;";
                String user = "sa";
                String password = "yizhan";
                con1 = DriverManager.getConnection(url1, user, password);
                con2 = DriverManager.getConnection(url2, user, password);
                // ////////////////////////////////////////////////////////
                textPane2.setText(textPane2.getText() + (new Date()) + "："
                        + "已连接SQLServer数据库\n");
            }
        }
        catch (Exception ex)
        {
            JOptionPane.showMessageDialog(null, "连接数据库失败！", "系统信息",
                    JOptionPane.ERROR_MESSAGE);
            connectException = 1;
            return;
        }
        try
        //
        {
            String sql = "select * from Password;";// 预读密码
            Statement state = con1.createStatement();
            ResultSet res = state.executeQuery(sql);
            while (res.next())
            {
                map_array_passwordMap.put(res.getString("qq"),
                        res.getString("password"));
            }
            String sql_sys = "select * from systemMessage;";// 预读系统消息
            ResultSet res_sys = state.executeQuery(sql_sys);
            while (res_sys.next())
            {
                if (res_sys.getString("warning") != null)
                    map_IsSysMessageExist.put(res_sys.getString("qq"), 1);
                else
                    map_IsSysMessageExist.put(res_sys.getString("qq"), 0);
            }
        }
        catch (SQLException e)
        {
            JOptionPane.showMessageDialog(null, "预读数据库信息失败！", "系统信息",
                    JOptionPane.ERROR_MESSAGE);
            connectException = 1;
            return;
        }
        try
        {
            addCanUse = new addqqCanUseThread();
            heartbeat = new heartbeatReceiver();
            judgeAlive = new judgeAliveThread();
            loginServer = new loginServerThread();
            applicateServer = new applicateServerThread();
            searchServer = new searchThread();
            addServer = new addFriendsThread();
            authenticationReceiveServer = new authenticationMessageReceiverThread();
            agreeRefuseServer = new receiveAgreeRefuseThread();
            deleteServer = new deleteFriendsThread();
            getIpServer = new getAnotherQQIpThread();
            getInfoServer = new getInfoThread();
            getPasswordServer = new judgeWhetherQuestionExistThread();
            receiverAnswerServer = new receiveSafeAnswerThread();
            groupDealServer = new groupDealThread();
            moveFriendServer = new moveFriendThread();
            safeQuestionServer = new setSafeQuestionThread();
            systemSettingServer = new systemSettingThread();
            updatePasswordServer = new updatePasswordThread();
            updatepersonalServer = new updatePersonalInfoThread();
            updateRemarkServer = new updateRemarkThead();
        }
        catch (Exception e)
        {
            JOptionPane.showMessageDialog(null, "启动服务器子程序异常，请重启！", "系统信息",
                    JOptionPane.ERROR_MESSAGE);
            connectException = 1;
            return;
        }
        startFlag = 1;
        jcom_setDatabase.setEnabled(false);
        textPane2.setText(textPane2.getText() + (new Date()) + "："
                + "服务器启动成功！\n");
    }
 
    @SuppressWarnings("deprecation")
    public void stopServer() throws ClassNotFoundException, SQLException,
            IOException, InterruptedException
    {
        if (connectException != 1)
        {
            addCanUse.stop();
            heartbeat.stop();
            judgeAlive.stop();
            loginServer.stop();
            applicateServer.stop();
            searchServer.stop();
            addServer.stop();
            authenticationReceiveServer.stop();
            agreeRefuseServer.stop();
            deleteServer.stop();
            getIpServer.stop();
            getInfoServer.stop();
            getPasswordServer.stop();
            receiverAnswerServer.stop();
            groupDealServer.stop();
            moveFriendServer.stop();
            safeQuestionServer.stop();
            systemSettingServer.stop();
            updatePasswordServer.stop();
            updatepersonalServer.stop();
            updateRemarkServer.stop();
            heartbeat.server.close();
            loginServer.server.close();
            applicateServer.server.close();
            searchServer.server.close();
            addServer.server.close();
            authenticationReceiveServer.server.close();
            agreeRefuseServer.server.close();
            deleteServer.server.close();
            getIpServer.server.close();
            getInfoServer.server.close();
            getPasswordServer.server.close();
            receiverAnswerServer.server.close();
            groupDealServer.server.close();
            moveFriendServer.server.close();
            safeQuestionServer.server.close();
            systemSettingServer.server.close();
            updatePasswordServer.server.close();
            updatepersonalServer.server.close();
            updateRemarkServer.server.close();
            map_date.clear();
            map_IsSysMessageExist.clear();
            map_onlineInfo.clear();
            map_status.clear();
            map_array_passwordMap.clear();
            array_qqCanUse.clear();
            String sql_update = "update mainInfo set status = 0;";
            con1.createStatement().execute(sql_update);
            startFlag = 0;
            jcom_setDatabase.setEnabled(true);
            textPane2.setText(textPane2.getText() + (new Date()) + "："
                    + "服务器已停止！\n");
        }
    }
 
    class MyTableModel extends AbstractTableModel
    {
        int count = map_onlineInfo.size();
        private String[] columnNames = { "QQ", "ip", "main_port", "sys_port",
                "heartbeat_port", "chat_port" };
        private String[][] data = new String[count][];
 
        public MyTableModel()
        {
            Map m = serverMain.map_onlineInfo;
            Iterator ite = m.keySet().iterator();
            for (int i = 0; ite.hasNext(); i++)
            {
                Object key = ite.next();
                data[i] = new String[6];
                data[i][0] = key.toString();
                data[i][1] = map_onlineInfo.get(key).ip;
                data[i][2] = "" + map_onlineInfo.get(key).port_main;
                data[i][3] = "" + map_onlineInfo.get(key).port_sys;
                data[i][4] = "" + map_onlineInfo.get(key).port_alive;
                data[i][5] = "" + map_onlineInfo.get(key).port_chat;
            }
        }
 
        public int getColumnCount()
        {
            return columnNames.length;
        }
 
        public int getRowCount()
        {
            return data.length;
        }
 
        public String getColumnName(int col)
        {
            return columnNames[col];
        }
 
        public String getValueAt(int row, int col)
        {
            return data[row][col];
        }
 
        public Class getColumnClass(int c)
        {
            return getValueAt(0, c).getClass();
        }
 
        public boolean isCellEditable(int row, int col)
        {
            return false;
        }
    }
 
    public static void main(String args[]) throws ClassNotFoundException,
            SQLException, IOException, InterruptedException
    {
        serverMain server = new serverMain();
    }
}
用户注册

用户登录

发表随想

该用户最新代码

编程随想

[java]代码库

网友评论 (发表评论)

回复评论

发表评论：

评论须知：

扫码下载

输入口令后可复制整站源码
