mytimertask.java~3~

Firewall Application & source code.

package fwserver;

import java.util.*;
import java.io.File;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.OutputStreamWriter;
import java.net.Socket;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class MyTimerTask extends TimerTask {
    private String IP = "127.0.0.1";
    private long length_now = 0;
    private long length_last = 0;
    public Vector RuleVec = new Vector();
    public MyTimerTask() {
    }

    /**
     * When an object implementing interface <code>Runnable</code> is used to
     * create a thread, starting the thread causes the object's
     * <code>run</code> method to be called in that separately executing
     * thread.
     *
     * @todo Implement this java.lang.Runnable method
     */
    public void run() {
        String strRule = null;
        String strAction = "Reject";
        String strIP_port = " ";
        String name = "Default";
        String strwhenSet = " ";
        String strwhenExpire = " ";
        String precedence = "1000";
        String strwhoSet = "unknown";
        int Index = 0;
//long length_now=0;
//long length_last=0;
        try {
            File file = new File("test.txt");
            length_now = file.length();
            FileReader filereader = new FileReader("test.txt");
            BufferedReader filebuffer = new BufferedReader(filereader);
            if (length_last != 0) {
                filebuffer.skip(length_last + 4);
            }
            length_last = length_now;
            Index = 0;
            String strLinetxt = filebuffer.readLine();
            Index = Index + 1;
            while (strLinetxt != null) {
                if (Index == 5) {
                    Index = 0;
                    strRule = strAction + ", " + strIP_port + ", " + name +
                              ", " + strwhenSet + ", " + strwhenExpire + ", " +
                              precedence + ", " + strwhoSet;
                    RuleVec.add(strRule);
                }
                if (Index == 3) {
                    int FirstblankIndex = strLinetxt.indexOf(" ");
                    int flagIndex = strLinetxt.indexOf("->");
                    strIP_port = strLinetxt.substring(FirstblankIndex,
                            flagIndex - 1);
                }
                strLinetxt = filebuffer.readLine();
                Index = Index + 1;
            }

        } catch (Exception e) {
            System.err.println("Error In Read AlertReport");
        }

        try {
            Socket socket = new Socket("59.64.0.48", 1234);
            String temp;
            String strinfo;
            String temprule;
            int number = 0;
            number = RuleVec.size();
            String strnumber = String.valueOf(number);
            strnumber = strnumber + "\r\n";
            Vector strvec = new Vector();
            strvec.add(strnumber);
            for (int i = 0; i < number; i++) {
                temprule = (String) RuleVec.elementAt(i);
                strvec.add(temprule);
            }
            //temp = "[MANUAL UDP low REJECT]\r\nAAAAAAAAAAA\r\n";
            // strvec.add("3\r\n");
            // strvec.add("[MANUAL UDP low REJECT]\r\nAAAAAAAAAAA\r\n");
            //  strvec.add("[MANUAL UDP low REJECT]\r\nBBBBBBBBBBBB\r\n");
            //  strvec.add("[MANUAL IP ACCEPT]\r\nDDDDDDDDDDDD\r\n");

            temp = strvec.toString();
            strinfo = temp.substring(1, temp.length() - 1);
            OutputStreamWriter ps = new OutputStreamWriter(socket.
                    getOutputStream());
            ps.write(strinfo);
            ps.flush();

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

    }


}