mmlcommandhandler.java

java实现的socket连接池,使用了apache的objectpool

// $dateCreated:2006-6-30-16:11:50 userCreated:pippo
package com.vms.ts.simulator.mmlserver;

import java.io.IOException;
import java.net.SocketTimeoutException;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quickserver.net.server.ClientCommandHandler;
import org.quickserver.net.server.ClientHandler;

/**
 * @author pippo
 */
public class MMLCommandHandler implements ClientCommandHandler {

    private static final Log logger = LogFactory.getLog(MMLCommandHandler.class);

    private static final String RETURN_MESSAGE = "`SC`00741.00internal     PPS12345678DLGCON000058752727 TXBEG0000TEST:TEST MML COMMAND:RETN=0,DESC=\"command test success!\",  93E6D3BF";

    private static final byte[] RETURN_MESSAGE_Byte = RETURN_MESSAGE.getBytes();

    /**
     * default constructor
     */
    public MMLCommandHandler() {
        super();
        if (logger.isDebugEnabled())
            logger.debug("create new MMLCommandHandler instance");
    }

    /*
     * （非 Javadoc）
     *
     * @see org.quickserver.net.server.ClientCommandHandler#handleCommand(org.quickserver.net.server.ClientHandler,
     *      java.lang.String)
     */
    public void handleCommand(ClientHandler handler, String command) throws SocketTimeoutException, IOException {
        if (logger.isDebugEnabled())
            logger.debug("the input string is:" + command);
        MMLData date = (MMLData) handler.getClientData();
        date.setReturnCommand(RETURN_MESSAGE);
        handler.sendClientBinary(RETURN_MESSAGE_Byte);
    }
}