reportserverthread.java~5~

Firewall Application & source code.

package fwserver;

import java.io.*;
import java.net.Socket;

/**
 * Copyright: Copyright (c) 2005 CH 版权所有
 * 生成日期 2005-6-5
 * 作者姓名 崔灏
 * 类的名称 ReportServerThread 父类 Thread
 * 功能描述 建立服务器，监听客户端的连接，交互信息
 * 字段清单 length_last ; 文件上次的长度
 *         length_now ；文件的当前长度
 *         suspendFlag；线程执行标志
 * 方法清单  public void CreatReportServer()
 *          public void run()
 *          public void mysuspend()
 * @version 1.0
 */
public class ReportServerThread extends Thread {
    private long length_last = 0;
    private long length_now = 0;
    private String IPtemp;
    public ReportServerThread(String IP) {
        System.err.println("Test Read File!");
        IPtemp = IP;
        start();
    }
    /**************************************************************
     *函数名称：public void run()
     *功能描述：类ReportServerThread的方法，完成与客户端建立连接，发送报警的功能
     *入口参数：无
     *出口参数：无
     *返回值：无
     *调用者：函数public void run()
     **************************************************************/
    public void CreatReportServer() {
        FileInputStream fin;
        Socket sock;
        String IP;
        try {
            //String IPtemp = jtxtIP.getText();
            IP = IPtemp.trim();
            sock = new Socket(IP, 5168);
            System.out.println("GET Connection!!");
            //fin = new FileInputStream("test.txt");
            OutputStreamWriter pstest = new OutputStreamWriter(sock.
                    getOutputStream());
            FileReader fread = new FileReader("test.txt");
            BufferedReader finputbuffer = new BufferedReader(fread);
            String tempstr = new String();
            StringBuffer strbuffer = new StringBuffer();
            tempstr = finputbuffer.readLine();
            while (tempstr != null) {
                strbuffer.append(tempstr + "\r\n");
                tempstr = finputbuffer.readLine();
            }
            pstest.write(strbuffer.toString());
            pstest.flush();
            sock.close();
        } catch (Exception e) {
            System.err.println(e);
        }

    }

    /**************************************************************
     *函数名称：public void run()
     *功能描述：类ReportServerThread的方法，完成与客户端建立连接，发送报警的功能
     *入口参数：无
     *出口参数：无
     *返回值：无
     *调用者：函数public void run()
     **************************************************************/
    public void run() {
        while (true) {
            try {
                File file = new File("test.txt");
                length_now = file.length();
                if (length_now != length_last) {
                    System.err.println("File Has Changed!");
                    CreatReportServer();
                }
                length_last = length_now;
                sleep(5000);
            } catch (Exception e) {
                System.err.println(e);
            }
        }
    }
}