pushinitiator.java

Java的wap push

package push;

import java.net.URL;
import java.net.HttpURLConnection;
import java.io.*;

/**
 * <code>PushInitiator</code> class implements a simple push initiator. It can
 * be used to create and send messages to push proxy gateway (ppg)
 * 
 */
public final class PushInitiator {

	/* xml version */
	private final static String XML_VERSION = "<?xml version=\"1.0\"?>";
	/* Push Access Protocol (PAP) document type */
	private final static String PAP_DOCTYPE = "<!DOCTYPE pap PUBLIC \"-//WAPFORUM//DTD PAP 1.0//EN\" \"http://www.wapforum.org/DTD/pap_1.0.dtd\" >";
	/* content type of the push request multipart body */
	private final static String CONTENT_TYPE = "multipart/related; boundary=multipart-boundary; type=\"application/xml\"";

	/* Service Indication (SI) document type */
	private static final String SI_DOCTYPE = "<!DOCTYPE si PUBLIC \"-//WAPFORUM//DTD SI 1.0//EN\" "
			+ "\"http://www.wapforum.org/DTD/si.dtd\">";

	private static int pushId = 0;

	/* PPG url where the pap message is to be sent */
	private final URL ppgUrl;

	/*
	 * Some push proxy gateways may also require the authentication of the push
	 * initiator. For instance, the push initiator imay be required to send an
	 * HTTP "authorization" header in each request
	 */
	private final String authorization;

	/**
	 * Creates a new <code>PushInitiator</code> instance.
	 * 
	 * @param ppgUrl
	 *            an <code>URL</code> value
	 */
	public PushInitiator(URL ppgUrl) {
		this.ppgUrl = ppgUrl;
		authorization = null;
	}

	/**
	 * Creates a new <code>PushInitiator</code> instance.
	 * 
	 * @param ppgUrl
	 *            an <code>URL</code> value
	 * @param authorization
	 *            a <code>String</code> value
	 */
	public PushInitiator(URL ppgUrl, String authorization) {
		this.ppgUrl = ppgUrl;
		this.authorization = authorization;
		System.out.println("Push Initiator created: ppgUrl = " + ppgUrl);
	}

	/**
	 * <code>sendPushMessage</code> sends push message to ppg
	 * 
	 * @param clientAddress
	 *            a <code>String</code> value
	 * @param addressType
	 *            a <code>String</code> value
	 * @param message
	 *            a <code>String</code> value
	 * @param mimeType
	 *            a <code>String</code> value
	 * @exception Exception
	 *                if an error occurs
	 */
	public void sendPushMessage(String clientAddress, String addressType,
			String message, String mimeType) throws Exception {
		HttpURLConnection http = (HttpURLConnection) ppgUrl.openConnection();
		String ppgServer = ppgUrl.getHost();
		http.setDoInput(true);
		http.setRequestProperty("Content-Type", CONTENT_TYPE);
		if (authorization != null) {
			if (!authorization.trim().equals(""))
				http.setRequestProperty("Authorization", authorization);
		}
		http.setDoOutput(true);
		PrintWriter out = new PrintWriter(new BufferedOutputStream(http
				.getOutputStream()));
		out.println("--multipart-boundary");
		out.println("Content-type: application/xml");
		out.println();
		out.println(createPapMessage(clientAddress, addressType, ppgServer,
				genPushId(), null));
		out.println();
		out.println("--multipart-boundary");
		out.println("Content-type: " + mimeType);
		out.println();
		out.println(message);
		out.println();
		out.println("--multipart-boundary--");
		out.flush();
		out.close();
		http.connect();

		/* finally, read and debug the response received from PPG */
		try {
			debugResponse(http);
		} catch (Exception e) {
			System.err.println("Error in receiving the response!");
		}
	}

	/**
	 * <code>createPapMessage</code> creates a Push Access Protocol type message
	 * 
	 * @param address
	 *            a <code>String</code> value
	 * @param addressType
	 *            a <code>String</code> value
	 * @param ppgServer
	 *            a <code>String</code> value
	 * @param pushId
	 *            a <code>String</code> value
	 * @param notificationTo
	 *            a <code>String</code> value
	 * @return a <code>String</code> value
	 */
	public static String createPapMessage(String address, String addressType,
			String ppgServer, String pushId, String notificationTo) {
		return XML_VERSION
				+ "\n"
				+ PAP_DOCTYPE
				+ "\n"
				+ "<pap product-name=\"Mobile Zoo Push Initiator\">\n"
				+ "<push-message push-id=\""
				+ pushId
				+ (notificationTo != null ? " request-notification-to=\""
						+ notificationTo : "") + "\">\n"
				+ "<address address-value=\"WAPPUSH=" + address + "/TYPE="
				+ addressType + "@" + ppgServer + "\"/>\n"
				+ "</push-message>\n</pap>";
	}

	/**
	 * <code>createSiMessage</code> creates a service indication type message
	 * 
	 * @param url
	 *            a <code>String</code> value
	 * @param created
	 *            a <code>String</code> value
	 * @param expires
	 *            a <code>String</code> value
	 * @param message
	 *            a <code>String</code> value
	 * @return a <code>String</code> value
	 */
	public static String createSiMessage(String url, String sid,
			String created, String expires, String action, String message) {
		return XML_VERSION + SI_DOCTYPE + "<si>\n" + "<indication href=\""
				+ url + "\"" + (sid != null ? " si-id=\"" + sid + "\"" : "")
				+ (created != null ? " created=\"" + created + "\"" : "")
				+ (action != null ? " action=\"" + action + "\"" : "")
				+ (expires != null ? " expires=\"" + expires + "\"" : "") + ">"
				+ message + "</indication>\n</si>";
	}

	/**
	 * Debug response
	 * 
	 * @param http
	 *            a <code>HttpURLConnection</code> value
	 * @exception Exception
	 *                if an error occurs
	 */
	private void debugResponse(HttpURLConnection http) throws Exception {
		System.out.println(http.getResponseMessage());
		String headerName;
		int i = 0;
		while ((headerName = http.getHeaderFieldKey(i++)) != null) {
			System.out.println("headerName" + ": "
					+ http.getHeaderField(headerName));
		}
		System.out.println();
		InputStreamReader in = new InputStreamReader(new BufferedInputStream(
				http.getInputStream()));
		int c;
		while ((c = in.read()) != -1)
			System.out.print((char) c);
		System.out.println();
	}

	/**
	 * <code>genPushId</code> generates an unique push id
	 * 
	 * @return a <code>String</code> value
	 */
	private String genPushId() {
		pushId %= 100000;
		return System.currentTimeMillis() + ":" + pushId++;
	}
}