在 Eclipse 中构建支持 AIM 的应用程序

				
package com.nathanagood.shopper;

import com.aol.acc.*;

public class MySuperShopperBot implements AccEvents {
    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub

    }

    public void OnImReceived(AccSession session, AccImSession imSession,
            AccParticipant participant, AccIm im) {
        // TODO:  Add implementation
    }
    
    public void OnStateChange(AccSession session, AccSessionState state,
            AccResult result) {
        // TODO:  Add implementation
    }

    /* Many other methods for AccEvents snipped... */
}

				
    public static void main(final String[] args) {

        logger.info("Starting My Super Shopper bot...");

        MySuperShopperBot bot = new MySuperShopperBot();

        try {
            bot.signOn();
        } catch (AccException ae) {
            logger.error("An error occurred while trying to sign on.", ae);
        }

        logger.info("Shutting down bot...");
    }

				
    public MySuperShopperBot() {
        messageHandler = MessageHandlerFactory.createMessageHandler();
    }

				
    public void signOn() throws AccException {

        session = new AccSession();
        session.setEventListener(this);

        AccClientInfo info = session.getClientInfo();
        info.setDescription(AIM_KEY);

        session.setIdentity(AIM_USERNAME);

        session.setPrefsHook(new MySuperShopperPrefs());
        session.signOn(AIM_PASSWORD);
    
        while (isRunning) {
            try {
                AccSession.pump(50);
            } catch (Exception e) {
                logger.error("Exception occurred while handling message", e);
            }

            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                logger.warn("Thread was interrupted", e);
            }

        }

        info = null;
        session = null;

        System.gc();
        System.runFinalization();

    }

				
    public void OnImReceived(AccSession session, AccImSession imSession,
            AccParticipant participant, AccIm im) {
        String message;
        try {
            message = im.getConvertedText(PLAIN_TEXT);

            /* Provide a way to cleanly shut down the client */
            if (message.equals(SHUTDOWN_COMMAND)) {
                session.signOff();
            } else {

                if (messageHandler.canHandle(message)) {

                    String response = messageHandler.handle(message,
                            participant.getName());

                    im.setText(response);
                    imSession.sendIm(im);
                }
            }

        } catch (AccException e) {
            logger.error("Error receiving message.", e);
        }
    }

				
    public void OnStateChange(AccSession session, AccSessionState state,
            AccResult result) {
        if (state == AccSessionState.Offline) {
            isRunning = false;
        }
    }

				
package com.nathanagood.shopper.handlers;

import java.util.List;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

public final class DelegatingMessageHandler implements MessageHandler {

    private final static Logger logger = LogManager
            .getLogger(DelegatingMessageHandler.class);

    private List<MessageHandler> handlers;

    public DelegatingMessageHandler(final List<MessageHandler> handlers) {
        this.handlers = handlers;
    }
    
    /**
     * 
     * @param handler
     */
    public void registerHandler(MessageHandler handler)
    {
        handlers.add(handler);
    }

    public boolean canHandle(final String message) {
        return (handlers != null);
    }

    public String handle(final String message, final String user) {
        String result = "I don't understand that...";
        
        for (MessageHandler handler : handlers) {
            if (handler.canHandle(message)) {
                logger.debug("Processing message \"" + message
                        + "\" from user \"" + user + "\" with handler \""
                        + handler.getClass(）。getCanonicalName() + "\"");
                result = handler.handle(message, user);
                logger.debug("Returning result \"" + result + "\"");
                break;
            }
        }
        
        return result;
    }

}

				
package com.nathanagood.shopper.handlers;

import java.util.ArrayList;
import java.util.List;

/**
 * Factory for creating a {@link MessageHandler}.
 * @author Nathan A. Good
 */
public class MessageHandlerFactory {

    /**
     * Creates a {@link MessageHandler} implementation.
     * @return MessageHandler.
     */
    public static MessageHandler createMessageHandler() {
        List<MessageHandler> handlers = new ArrayList<MessageHandler>();
        handlers.add(new ShoppingListMessageHandler());
        // handlers.add(new EchoMessageHandler()); // useful for testing...
        
        DelegatingMessageHandler handler = new DelegatingMessageHandler(handlers);
        
        return handler;
    }

}

				
    public void OnImReceived(AccSession session, AccImSession imSession,
            AccParticipant participant, AccIm im) {
        String message;
        try {
            message = im.getConvertedText(PLAIN_TEXT);

            if (message.equals("goodbye")) {
                session.signOff();
            } else {

                if (messageHandler.canHandle(message)) {

                    String response = messageHandler.handle(message,
                            participant.getName());

                    im.setText(response);
                    imSession.sendIm(im);
                }
            }

        } catch (AccException e) {
            logger.error("Error receiving message.", e);
        }
    }

				
        AccImSession imSession = session.createImSession(screenname, AccImSessionType.Im);
        imSession.sendIm(session.createIm(message, "text/plain"));

				
package com.nathanagood.shopper.handlers;

import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

import com.nathanagood.shopper.persistence.ShoppingListItem;
import com.nathanagood.shopper.persistence.ShoppingListManager;

public class ShoppingListMessageHandler implements MessageHandler {

    private static final Logger logger = LogManager.getLogger(ShoppingListManager.class);
    private static final Pattern addCommandPattern = Pattern
            .compile("^\\s*add +([\\d]+)[ -]+(.*)$");

    public boolean canHandle(final String message) {
        return addCommandPattern.matcher(message）。matches();
    }

    public String handle(final String message, final String user) {
        String result = "An error occurred while adding your item.";

        try {

            if ( addCommandPattern.matcher(message）。matches() ) {
                ShoppingListManager manager = new ShoppingListManager();
                manager.addShoppingListItem(user, parse(message));
                result = "Successfully added item.";
            }

        } catch (Exception e) {
            logger.error("Error while handling item.", e);
        }

        return result;
    }

    private ShoppingListItem parse(final String value) {
        int quantity = 0;
        String description = "";
        Matcher match = addCommandPattern.matcher(value);
        
        if ( match.find() ) {
            quantity = Integer.parseInt(match.group(1));
            description = match.group(2);
        }
        
        logger.debug("Parsed item with \"" + quantity + "\" number of \"" + 
        	description + "\"");

        return new ShoppingListItem(quantity, description);
    }

}