utility.java

j2me的基于http协议的断点续传。支持多线程的断点续传。

/*
 * *Utility.java
 */
package NetFox;

import java.io.*;
import javax.microedition.io.*;
import javax.microedition.io.file.*;
import javax.microedition.lcdui.*;
import javax.microedition.io.HttpConnection;

public class Utility {
    public final static String CMWAP_PROXY = "http://10.0.0.172/pimweb/";

    public final static String DOWNLOAD_HOST = "http://59.108.23.208:8080/pimweb/";
    public final static String LOCAL_DIR = "file:///E:/";
    //public final static String LOCAL_DIR = "file:///root1/";
    //public final static String FILE_NAME = "phonebook.jar";
    //public final static String FILE_NAME = "FortiBalancer-br100-xmlfw-trunk.tar.gz";
    //public final static String FILE_NAME = "pimweb.war";
    public final static String FILE_NAME = "test.3gp";
    public final static int THREAD_NUM = 2;
        
    //public final static String MOBILE_UA = "Nokia6681/2.0 (5.0614.0) SymbianOS/8.0a Series60/2.1 Profile/MIDP-2.0 Configuration/CLDC-1.1";
    public final static String MOBILE_UA = "NokiaN70-1/5.0616.2.0.3 Series60/2.8 Profile/MIDP-2.0 Configuration/CLDC-1.1";
    public final static String PROP_USER_AGENT = "User-Agent";
    
    public final static long SLEEP = 2000l;

    private static boolean initDone = false;
    private static FileConnection logConn = null;
    private static OutputStream os = null;
    
    private Utility() {
    }
    
    public static int init() {
        if (initDone) return 0;
        
        int ret = 0; 
        try {
            logConn = (FileConnection)Connector.open(LOCAL_DIR + "zlog.txt");
            if (!logConn.exists()) {
                logConn.create();
            }
            os = logConn.openOutputStream();
        } catch (Exception ex) {
            ret = 1;
        }
        
        initDone = true;
        
        return ret;
    }
    
    public static int close() {
        int ret = 0;
        
        try {
            if (null != os) os.close();
            if (null != logConn) logConn.close();
        } catch (Exception ex) {
            ret = 1;
        }
        
        initDone = false;
        
        return ret;
    }
            
    public static void sleep(long nSecond) {
        try {
            Thread.sleep(nSecond);
        } catch(Exception e) {
            e.printStackTrace ();
        }
    }
    
    public static int log(String sMsg) {
        if (!initDone) return 2;
        int ret = 0;
        
        try {            
            os.write(sMsg.getBytes());
            os.write("\n".getBytes());
            os.flush();
        } catch (Exception ex) {
            ret = 1;
        }

        return ret;    
    }
    
    public static HttpConnection createHttpConn(String host, String url) throws IOException 
    {
    	log("Trying to connecting " + CMWAP_PROXY + url);
        HttpConnection conn  = null;
        /*
        conn = (HttpConnection) Connector.open(host + url, Connector.READ_WRITE, true);
        */
        conn = (HttpConnection) Connector.open(CMWAP_PROXY + url, Connector.READ_WRITE, true);
        conn.setRequestProperty("X-Online-Host", "59.108.23.208:8080");
    	log("After connecting " + CMWAP_PROXY + url);
        
        return conn;
    }
    
    public static FileConnection createFileConn(String url) throws IOException {
        FileConnection conn = (FileConnection)Connector.open(url);

        return conn;
    }
}