consoleserver.java

Java Mail Server JAVA编写的邮件服务器

/****************************************************************
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.     *
 *                                                              *
 * Copyright 2008 Jun Li(SiChuan University, the School of      *
 * Software Engineering). All rights reserved.                  *
 *                                                              *
 * Licensed to the JMS under one  or more contributor license   *
 * agreements.  See the LICENCE file  distributed with this     *
 * work for additional information regarding copyright          *
 * ownership.  The JMS licenses this file  you may not use this *
 * file except in compliance  with the License.                 *
 *                                                              *
 * Unless required by applicable law or agreed to in writing,   *
 * software distributed under the License is distributed on an  *
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY       *
 * KIND, either express or implied.  See the License for the    *
 * specific language governing permissions and limitations      *
 * under the License.                                           *
 ****************************************************************/
package org.jpxx.mail.plugin.console;

import java.io.IOException;
import java.net.ServerSocket;
import org.apache.log4j.Logger;
import org.jpxx.mail.Config.SysConfig;
import org.jpxx.mail.Factory;
import org.jpxx.mail.Service.AbstractServer;

/**
 * <p><code>ConsoleServer</code> is to manage JMS.<p>
 * 
 * @author Jun Li
 * @version $Revision: 0.0.3 $, $Date: 2008/10/25 $
 * @since JMS 0.0.3
 */
public class ConsoleServer extends AbstractServer {

    /**
     * Instance of SmtpServer.
     */
    private static ConsoleServer singletonInstance = null;
    /**
     * Creates an instance of Logger and initializes it. 
     * It is to write log for <code>ConsoleServer</code>.
     */
    private Logger log = Factory.getSingletonInstance().getLogger(this);

    private ConsoleServer() {
    }

    /**
     * Gets singleton instance of ConsoleServer.
     * @return singleton instance of ConsoleServer
     */
    public static ConsoleServer getSingletonInstance() {
        if (singletonInstance == null) {
            singletonInstance = new ConsoleServer();
        }
        return singletonInstance;
    }

    /**
     * Start console server.
     */
    public void start() {
        SysConfig sc = new SysConfig();
        int port = sc.getConsolePort();
        try {
            ConsoleServerHandler handler = new ConsoleServerHandler(port);
            handler.start();
            service.addService("CONSOLE_SERVICES", handler);
        } catch (IOException ioe) {
            log.info("Console server start at port error: " + port + "; " + ioe);
        }
    }

    /**
     * Stop console server.
     */
    public void stop() {
        ConsoleServerHandler handler = (ConsoleServerHandler) service
                .getService().get("CONSOLE_SERVICES");
        ServerSocket ss = handler.getServerSocket();
        try {
            if (!ss.isClosed()) {
                ss.close();
                log.error("Stop Console Server: " + ss.getLocalPort());
            }
        } catch (Exception e) {
            log.error("Close Console Server Error!" + e.getMessage());
        }
    }
}