fwserverframe.java~97~

Firewall Application & source code.

package fwserver;

import java.awt.BorderLayout;
import javax.swing.JFrame;
import javax.swing.JPanel;
import java.awt.*;
import javax.swing.JButton;
import javax.swing.JTextArea;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.net.Socket;
import java.io.IOException;
import java.io.FileWriter;
import java.net.ServerSocket;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.FileNotFoundException;
import java.io.PrintStream;
import java.io.FileReader;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import javax.swing.*;
import javax.swing.border.TitledBorder;
import java.io.DataInputStream;
import java.io.ObjectInputStream;
import com.borland.jbcl.layout.*;
import java.io.OutputStreamWriter;
import java.io.ObjectOutputStream;

/**
 * Copyright: Copyright (c) 2005 CH 版权所有
 * 生成日期 2005-6-5
 * 作者姓名 崔灏
 * 类的名称 FwServerFrame
 * 功能描述
 * 字段清单
 * 方法清单
 * @version 1.0
 */
public class FwServerFrame extends JFrame {
    FwServerThread server;
    Thread servert;
    ServerSocket ssock;
    Socket sock;
    JButton jBtnListen = new JButton();
    JButton jBtnClose = new JButton();
    JTextArea jTextAreaShow = new JTextArea();
    TitledBorder titledBorder1 = new TitledBorder("");
    XYLayout xYLayout1 = new XYLayout();
    JLabel jLabel1 = new JLabel();
    JLabel jLabel2 = new JLabel();
    JTextField jtxtPath = new JTextField();
    public FwServerFrame() {
        try {
            jbInit();
        } catch (Exception exception) {
            exception.printStackTrace();
        }
    }

    /**************************************************************
     *函数名称：private void jbInit() throws Exception
     *功能描述：类FwServerFrame的方法，完初始化界面显示的功能
     *入口参数：无
     *出口参数：无
     *返回值：无
     *调用者：函数public FwServerFrame()
     **************************************************************/
    private void jbInit() throws Exception {
        getContentPane().setLayout(xYLayout1);
        jBtnListen.setFont(new java.awt.Font("宋体", Font.PLAIN, 12));
        jBtnListen.setActionCommand("jBtnListen");
        jBtnListen.addActionListener(new FwServerFrame_jBtnListen_actionAdapter(this));
        jBtnClose.setFont(new java.awt.Font("宋体", Font.PLAIN, 12));
        jTextAreaShow.setEditable(false);
        jTextAreaShow.setText("在1234端口监听");
        jBtnClose.setText("关闭");
        jBtnClose.addActionListener(new FwServerFrame_jBtnClose_actionAdapter(this));
        xYLayout1.setWidth(352);
        xYLayout1.setHeight(204);
        jLabel2.setFont(new java.awt.Font("宋体", Font.PLAIN, 12));
        this.getContentPane().add(jTextAreaShow,
                                  new XYConstraints(18, 113, 238, 74));
        jLabel2.setText("路径示例/E:/firewall.ini");
        jLabel1.setFont(new java.awt.Font("宋体", Font.PLAIN, 12));
        jLabel1.setText("本地配置文件路径 ");
        this.getContentPane().add(jBtnListen, new XYConstraints(21, 73, -1, -1));
        this.getContentPane().add(jBtnClose, new XYConstraints(111, 73, -1, -1));
        this.getContentPane().add(jLabel1, new XYConstraints(25, 14, -1, -1));
        this.getContentPane().add(jLabel2, new XYConstraints(134, 13, 158, -1));
        this.getContentPane().add(jtxtPath,
                                  new XYConstraints(28, 37, 211, -1));
        jBtnListen.setText("监听 ");
    }

    /**************************************************************
     *函数名称：public void CreatAServer() throws Exception
     *功能描述：类FwServerFrame的方法，建立服务器，监听客户端的连接，交互信息
     *入口参数：无
     *出口参数：无
     *返回值：无
     *备注：在后期开发中本函数被扩展成线程类的几个方法
     **************************************************************/
    public void CreatAServer() throws Exception {
        FileInputStream fin;
        FileWriter fout = null;
        StringBuffer buffer = new StringBuffer();
        String line;
        String rule;
        int charindex;
        int i = 1;
        while (true) {
            ssock = new ServerSocket(1234);
            System.out.println("Listening");
            sock = ssock.accept();
            ssock.close();
            try {
                fin = new FileInputStream("1234.txt");
            } catch (FileNotFoundException e) {
                System.out.println("InputFileNotFoud");
                return;
            }
            /**********************************
             *  Display the FireWall Ini  in the Client Consle;
             *********************************/

            OutputStreamWriter pstest = new OutputStreamWriter(sock.
                    getOutputStream());
            try {
                FileReader freadtest = new FileReader("1234.txt");
                BufferedReader finputtest = new BufferedReader(freadtest);
                String tempss = new String();
                StringBuffer testbuffer = new StringBuffer();
                tempss = finputtest.readLine();
                while (tempss != null) {
                    testbuffer.append(tempss + "\r\n");
                    tempss = finputtest.readLine();
                }
                pstest.write(testbuffer.toString());
                pstest.flush();
                testbuffer.delete(0, testbuffer.length());
            } catch (Exception eee) {
                System.err.println("Error In Read FireRule ");
            }

            /********************************
             *  Receive the Client's Information about the FireWall Rule
             *  Write The Rule to FireWall Ini File
             *************************************/

            try {
                FileReader fread = new FileReader("1234.txt");
                BufferedReader finput = new BufferedReader(fread);
                // Receive the Client's Information
                try {
                    InputStreamReader pss = new InputStreamReader(sock.
                            getInputStream());
                    BufferedReader ins = new BufferedReader(pss);
                    line = ins.readLine();
                    rule = ins.readLine();
                } catch (Exception ee) {
                    System.err.println("Net Transport Error !!");
                    return;
                }
                byte buf[] = line.getBytes();
                String temp = new String();
                temp = finput.readLine();
                while (temp != null) {
                    if (line.equals("[MANUAL UDP low REJECT]")) {
                        while (temp != null) {
                            buffer.append(temp + "\r\n");
                            temp = finput.readLine();
                            if (temp != null) {
                                while (temp != null) {
                                    if (temp.equals("[MANUAL UDP low REJECT]")) {
                                        buffer.append(temp + "\r\n");
                                        //buffer.append(
                                        //        "REJECT, 1024 - 60000, default, 2005-01-01 00:00:00, PERPETUAL, 1000, unknown" +
                                        //        "\r\n");
                                        buffer.append(rule + "\r\n");
                                        temp = finput.readLine();
                                    } else {
                                        buffer.append(temp + "\r\n");
                                        temp = finput.readLine();
                                    }
                                }
                            }
                        }
                        break;
                    }
                    temp = finput.readLine();
                }

            } catch (IOException e) {
                System.out.println("Read File Error");
            }
            try {
                fout = new FileWriter("1234.txt");
                BufferedWriter writer = new BufferedWriter(fout);
                fout.write(buffer.toString());
                int bufferlen = buffer.length();
                buffer.delete(0, bufferlen);
            } catch (FileNotFoundException e) {
                System.out.println("Write  File  Error ");
            }

            //  pstream.close();
            sock.close();
            fout.close();
        }
    }

    /**************************************************************
     *函数名称：public void jBtnListen_actionPerformed(ActionEvent e)
     *功能描述：启动一个线程，建立服务器，循环监听
     *入口参数：无
     *出口参数：无
     *返回值：无
     *调用者：系统
     **************************************************************/
    public void jBtnListen_actionPerformed(ActionEvent e) {
        try {
            String strpath = jtxtPath.getText();
            strpath = strpath.trim();
            server = new FwServerThread(strpath);
            jBtnListen.setEnabled(false);

        } catch (Exception ee) {
            System.err.print(ee);
        }
    }

    /**************************************************************
     *函数名称：public void jBtnClose_actionPerformed(ActionEvent e)
     *功能描述：关闭程序
     *入口参数：无
     *出口参数：无
     *返回值：无
     *调用者：系统
     **************************************************************/
    public void jBtnClose_actionPerformed(ActionEvent e) {
        System.err.println("Close");
        server.mysuspend();
        jBtnListen.setEnabled(true);
        this.dispose();
    }
}


class FwServerFrame_jBtnClose_actionAdapter implements ActionListener {
    private FwServerFrame adaptee;
    FwServerFrame_jBtnClose_actionAdapter(FwServerFrame adaptee) {
        this.adaptee = adaptee;
    }

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


class FwServerFrame_jBtnListen_actionAdapter implements ActionListener {
    private FwServerFrame adaptee;
    FwServerFrame_jBtnListen_actionAdapter(FwServerFrame adaptee) {
        this.adaptee = adaptee;
    }

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