pushservice.java

Java的wap push

package push;

import members.Members;
import java.util.Vector;
import java.util.StringTokenizer;

/**
 * Handling of user selected push services
 * 
 * @version 1.0
 * @since 1.0
 * @see Runnable
 */
public final class PushService implements Runnable {

	private final PushInitiator pusher;
	private final String serviceContextPath;
	/**
	 * interval in hours between Push message submissions
	 */
	private final int interval;
	private final String addressType;

	public static final String SI_CONTENT_TYPE = "text/vnd.wap.si";

	/**
	 * Creates a new <code>PushService</code> instance.
	 * 
	 * @param pusher
	 *            a <code>PushInitiator</code> value
	 * @param serviceContextPath
	 *            a <code>String</code> value
	 * @param interval
	 *            an <code>int</code> value; in hours
	 */
	public PushService(PushInitiator pusher, String serviceContextPath,
			String addressType, int interval) {
		this.pusher = pusher;
		this.serviceContextPath = serviceContextPath;
		this.interval = interval;
		this.addressType = addressType;
	}

	/**
	 * A push service checker thread sends push messages related to ordered
	 * services
	 */
	public void run() {
		while (true) {
			try {
				Vector users = User.getUsersOnline();
				for (int i = 0; i < users.size(); i++) {
					User user = (User) users.get(i);
					String name = user.getName();
					String pushServices = user.getPushServices();
					/*
					 * Check if the user has selected push services. If so, then
					 * generate and send (if not yet sent within a time
					 * interval) a push message!
					 */
					if (pushServices != null) {
						StringTokenizer st = new StringTokenizer(pushServices,
								";");
						while (st.hasMoreTokens()) {
							int serviceId = Integer.parseInt(st.nextToken());
							Object pushService = Members
									.getPushService(serviceId);
							String serviceName = ((String[]) pushService)[0];
							String serviceUrl = ((String[]) pushService)[1];
							Object serviceObject = user
									.getProperty(serviceName);
							if (serviceObject != null) {
								if ((System.currentTimeMillis() - ((Long) serviceObject)
										.longValue()) > interval * 1000 * 60 * 60)
									/*
									 * If there are more hours than specified by
									 * the interval variable from the previous
									 * submission, the service message is ready
									 * to be sent again.
									 */
									serviceObject = null;
							}
							if (serviceObject == null) {
								String url = serviceContextPath + serviceUrl;
								String message = PushInitiator.createSiMessage(
										url, null, null, null, null,
										serviceName);
								String address = user.getAddress(addressType);
								System.out.println(message);
								System.out.println("client Address = "
										+ address);
								if (address != null
										&& !address.trim().equals("")) {
									try {

										pusher.sendPushMessage(address,
												addressType, message,
												SI_CONTENT_TYPE);
										user.setProperty(serviceName, new Long(
												System.currentTimeMillis()));
									} catch (Exception ee) {
										System.err
												.println("Error in sending push message!");
									}
								}
							}
						}
					}
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
			try {
				Thread.sleep(10000); // 10 s
			} catch (InterruptedException e) {
			}
		}
	}

}