winner.java

WAP Push实现源码！

package push;

import feedback.Feedback;
import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;

/**
 * Selects winner 
 *
 * @version 1.0
 * @since 1.0
 * @see Runnable
 */
public final class Winner implements Runnable {

    private final PushInitiator pusher;
    private final String winnerUrl;
    private final String addressType;

    /**
     * Creates a new <code>Winner</code> instance.
     *
     * @param pusher a <code>PushInitiator</code> value
     * @param winnerUrl a <code>String</code> value
     */
    public Winner(PushInitiator pusher, String winnerUrl, String addressType) {
	this.pusher = pusher;
	this.winnerUrl = winnerUrl;
	this.addressType = addressType;
    }

    /**
     * A checker thread selects a winner from the users that has returned feedback. A winner (if any) is selected 
     * during every cycle (of the while loop). 
     */
    public void run() {
	String message = PushInitiator.createSiMessage(winnerUrl,  null, null, null, 
						       null, "You are lucky! Check the message");
	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();
		    if (Feedback.winner().equals(name)) {
			String address = user.getAddress(addressType);
			if(address != null && !address.trim().equals("")) {
			    try {
				pusher.sendPushMessage(address, addressType, message, PushService.SI_CONTENT_TYPE);
			    } catch(Exception ee) {}
			}
		    }
		}
	    }
	    catch(Exception e) { System.err.println(e); }
	    try {
		Thread.sleep(120000); // 2 min
	    }
	    catch(InterruptedException e){}
	}

    }

}