jarcompressor.java

Ftp服务1.0

package ranab.jar;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.util.jar.JarEntry;
import java.util.jar.JarOutputStream;

/**
 * Jar file compression class.
 *
 * @author <a href="mailto:[e-mail]">Rana Bhattacharyya</a>
 */
public 
class JarCompressor extends Compressor {

    private JarOutputStream mJos;
    private int miCurrentCount;

    public JarCompressor(File jarfl) {
        super(jarfl);
        miCurrentCount = 0;
    }


    /**
     * open new jar file
     */
    public void open() throws Exception {
        try {
            mJos = new JarOutputStream(new FileOutputStream(mCompressedFile));
            mObserverCont.start();
            mObserverCont.setCount(0);
        } catch (Exception ex) {
            mObserverCont.setError(ex.getMessage());
            throw ex;
        }
    }


    /**
     * set compression level
     */
    protected void setCompressionLevel(int level) {
        mJos.setLevel(level);
    }


    /**
     * add a new file
     */
    protected void addFile(File newEntry, String name) {

        // if directory return
        if (newEntry.isDirectory()) {
            return;
        }

        try {
            JarEntry je = new JarEntry(name);
            mJos.putNextEntry(je);

            FileInputStream fis = new FileInputStream(newEntry);

            byte fdata[] = new byte[1024];
            int readCount = 0;
            while ( (readCount = fis.read(fdata)) != -1 ) {
                mJos.write(fdata, 0, readCount);
            }
            fis.close();
            mJos.closeEntry();
            mObserverCont.setNext(je);
            mObserverCont.setCount(++miCurrentCount);
        } catch (Exception ex) {
            mObserverCont.setError(ex.getMessage());
        }
    }


    /**
     * close the newly created jar file
     */
    public void close() {
        try {
            mJos.finish();
            mJos.close();
        } catch (Exception ex) {
            mObserverCont.setError(ex.getMessage());
        } finally {
            mObserverCont.end();
        }
    }

}