下传监听类

上传监听类
package com.huawei.hedex.upload;

import java.io.Serializable;

/**
* 上传监听类，实现OutputStreamListener接口
* @author j65181
* @version V1.0, 2007-8-4
* @see
*/
public class UploadListener implements OutputStreamListener
{
    /**
     * 注释内容
     */
    private static final long serialVersionUID = 4780612136871889921L;
   
    // 保存状态的内部类对象
    private FileUploadStats fileUploadStats = new FileUploadStats();
   
    /**
     * 构造方法，传入文件流总大小
     * @param totalSize
     */
    public UploadListener(long totalSize)
    {
        fileUploadStats.setTotalSize(totalSize);
    }
   
    public void start()
    {
        // 设置当前状态为开始
        fileUploadStats.setCurrentStatus("start");
    }
   
    public void bytesRead(int byteCount)
    {
        // 将已读取的数据保存到状态对象中
        fileUploadStats.incrementBytesRead(byteCount);
        // 设置当前的状态为读取过程中
        fileUploadStats.setCurrentStatus("reading");
    }
   
    public void error(String s)
    {
        // 设置当前状态为出错
        fileUploadStats.setCurrentStatus("error");
    }
   
    public void done()
    {
        // 设置当前已读取数据等于总数据大小
        fileUploadStats.setBytesRead(fileUploadStats.getTotalSize());
        // 设置当前状态为完成
        fileUploadStats.setCurrentStatus("done");
    }
   
    public FileUploadStats getFileUploadStats()
    {
        // 返回当前状态对象
        return fileUploadStats;
    }
   
    /**
     * 用来保存上传文件的状态
     * @author j65181
     * @version V1.0, 2007-8-4
     * @see
     */
    public static class FileUploadStats implements  Serializable
    {
        /**
         * 注释内容
         */
        private static final long serialVersionUID = -6689000695807341372L;

        //总数据的大小
        private long totalSize = 0;
       
        //已读数据大小
        private long bytesRead = 0;
       
        //开始读取的时间
        private long startTime = System.currentTimeMillis();
       
        //默认的状态
        private String currentStatus = "none";
       
        //获得已经上传得时间
        public long getElapsedTimeInSeconds()
        {
            return (System.currentTimeMillis() - startTime) / 1000;
        }
       
        public void incrementBytesRead(int byteCount)
        {
            this.bytesRead += byteCount;
        }
       
        /**
         * @return the totalSize
         */
        public long getTotalSize()
        {
            return totalSize;
        }
       
        /**
         * @param totalSize the totalSize to set
         */
        public void setTotalSize(long totalSize)
        {
            this.totalSize = totalSize;
        }
       
        /**
         * @return the currentStatus
         */
        public String getCurrentStatus()
        {
            return currentStatus;
        }
       
        /**
         * @param currentStatus the currentStatus to set
         */
        public void setCurrentStatus(String currentStatus)
        {
            this.currentStatus = currentStatus;
        }
       
        /**
         * @return the bytesRead
         */
        public long getBytesRead()
        {
            return bytesRead;
        }
       
        /**
         * @param bytesRead the bytesRead to set
         */
        public void setBytesRead(long bytesRead)
        {
            this.bytesRead = bytesRead;
        }
    }
}