mmldata.java.svn-base

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

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

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.pool.BasePoolableObjectFactory;
import org.apache.commons.pool.PoolableObjectFactory;
import org.quickserver.net.server.ClientData;
import org.quickserver.net.server.ClientIdentifiable;
import org.quickserver.util.pool.PoolableObject;

/**
 * @author pippo
 */
public class MMLData implements ClientData, ClientIdentifiable, PoolableObject {

    private static final long serialVersionUID = 165043402504365654L;

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

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

    /**
     * 收到的命令
     */
    private String sendCommand;

    /**
     * 返回的命令
     */
    private String returnCommand;

    /**
     * @return 返回 returnCommand。
     */
    public String getReturnCommand() {
        return this.returnCommand;
    }

    /**
     * @param returnCommand 要设置的 returnCommand。
     */
    public void setReturnCommand(String returnCommand) {
        this.returnCommand = returnCommand;
    }

    /**
     * @return 返回 sendCommand。
     */
    public String getSendCommand() {
        return this.sendCommand;
    }

    /**
     * @param sendCommand 要设置的 sendCommand。
     */
    public void setSendCommand(String sendCommand) {
        this.sendCommand = sendCommand;
    }

    /**
     * 清理
     */
    public void clean() {
        this.sendCommand = null;
        this.returnCommand = null;
    }

    /*
     * （非 Javadoc）
     * 
     * @see org.quickserver.util.pool.PoolableObject#isPoolable()
     */
    public boolean isPoolable() {
        return true;
    }

    /*
     * （非 Javadoc）
     * 
     * @see org.quickserver.util.pool.PoolableObject#getPoolableObjectFactory()
     */
    public PoolableObjectFactory getPoolableObjectFactory() {
        return new BasePoolableObjectFactory() {

            /*
             * （非 Javadoc）
             * 
             * @see org.apache.commons.pool.PoolableObjectFactory#makeObject()
             */
            public Object makeObject() {
                return new MMLData();
            }

            /*
             * （非 Javadoc）
             * 
             * @see org.apache.commons.pool.PoolableObjectFactory#passivateObject(java.lang.Object)
             */
            public void passivateObject(Object obj) {
                MMLData ed = (MMLData) obj;
                ed.clean();
            }

            /*
             * （非 Javadoc）
             * 
             * @see org.apache.commons.pool.PoolableObjectFactory#destroyObject(java.lang.Object)
             */
            public void destroyObject(Object obj) {
                if (obj == null)
                    return;
                passivateObject(obj);
                obj = null;
            }

            /*
             * （非 Javadoc）
             * 
             * @see org.apache.commons.pool.PoolableObjectFactory#validateObject(java.lang.Object)
             */
            public boolean validateObject(Object obj) {
                if (obj == null)
                    return false;
                else
                    return true;
            }
        };
    }

    /*
     * （非 Javadoc）
     * 
     * @see org.quickserver.net.server.ClientIdentifiable#getClientId()
     */
    public String getClientId() {
        return new String(System.currentTimeMillis() + "");
    }

    /*
     * （非 Javadoc）
     * 
     * @see org.quickserver.net.server.ClientIdentifiable#getClientKey()
     */
    public String getClientKey() {
        return new String(System.currentTimeMillis() + "");
    }

    /*
     * （非 Javadoc）
     * 
     * @see org.quickserver.net.server.ClientIdentifiable#getClientInfo()
     */
    public String getClientInfo() {
        return new String(System.currentTimeMillis() + "");
    }

}