mmsgetter.java

JAVA一个有关通信方面的实例

/*
 * Created on Jan 21, 2005
 * 
 * @see CWapGetExample in the jWap library
 * @see Getter in the MmsLib library
 */
import java.net.InetAddress;
import java.net.UnknownHostException;

import net.sourceforge.jwap.wsp.CWSPMethodManager;
import net.sourceforge.jwap.wsp.CWSPSession;
import net.sourceforge.jwap.wsp.IWSPUpperLayer;

import com.tripod.cookiebreak.common.adapt.IOUtil;
import com.tripod.cookiebreak.mms.MMSPDUDecodeHelper;


public class MMSGetter implements IWSPUpperLayer {

    private InetAddress wapGateway;

    private String uriToGet;

    private CWSPSession session;

    private CWSPMethodManager m;

    private int wapGatewayPort;

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_connect_cnf()
     */
    public void s_connect_cnf() {
        System.out.println("connected: " + wapGateway);
        System.out.println("GET " + uriToGet);
        m = session.s_get(uriToGet);
    }

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_suspend_ind(short)
     */
    public void s_suspend_ind(short reason) {
        System.out.println("s_suspend_ind(short reason)");
    }

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_resume_cnf()
     */
    public void s_resume_cnf() {
        System.out.println("s_resume_cnf()");
    }

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_disconnect_ind(short)
     */
    public void s_disconnect_ind(short reason) {
        System.out.println("disconnected: " + wapGateway);
    }

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_disconnect_ind(java.net.InetAddress[])
     */
    public void s_disconnect_ind(InetAddress[] redirect) {
        System.out.println("s_disconnect_ind(InetAddress[] redirect)");
    }

    /*
     * (non-Javadoc)
     * 
     * @see net.sourceforge.jwap.wsp.IWSPUpperLayer#s_methodResult_ind(byte[],
     *      java.lang.String, boolean)
     */
    public void s_methodResult_ind(byte[] payload, String contentType,
            boolean moreData) {
        // response goes in here
        if (moreData)
            System.out.println("there's more data coming");
        System.out.println("response content type: " + contentType);

        try {
            String filename = "tmp/" + contentType.replace('/', '_')
                    + System.currentTimeMillis();
            IOUtil.save(filename, payload);

            System.out.println("response saved as: " + filename);

            if (!moreData) {
                System.out.println("disconnecting from WAP gateway "
                        + wapGateway);
                m.s_methodResult(null);
                session.s_disconnect();

                if ("application/vnd.wap.mms-message"
                        .equalsIgnoreCase(contentType)) {
                    System.out.println("starting to parse response");                    
                    MMSPDUDecodeHelper parser = new MMSPDUDecodeHelper();
                    parser.setPayload(payload);
                    parser.parse();
                }
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /*
     * connects to the wap gateway and starts the WSP session
     */
    private void init() {
        try {
            session = new CWSPSession(wapGateway, wapGatewayPort, this, true);
            System.out.println("connecting to WAP gateway " + wapGateway);
            session.s_connect();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public MMSGetter(InetAddress wapGateway, int wapGatewayPort, String uriToGet) {
        this.uriToGet = uriToGet;
        this.wapGateway = wapGateway;
        this.wapGatewayPort = wapGatewayPort;

        init();
    }

    public static void main(String[] args) throws UnknownHostException {
        // @see main method of MMSSender, README
        String wapIPAddress = "10.102.61.46";
        String mmsc = "http://10.102.61.238:8002/";
        //String messageID = "Qf2rAQpmPe4AAEysAAAAAwAANvoAAAAA";
        String messageID = "QjEX0gpmPe4AAANrAAAABAAASbEAAAAA";
        
        InetAddress gateway = InetAddress.getByName(wapIPAddress);

        MMSGetter getter = new MMSGetter(gateway, 9201, mmsc + messageID);
    }

}