crbtserver.java

中国联通炫铃业务接口开发

package com.wireless.crbt.gwif.global.pub;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.Vector;

import net.gleamynode.netty2.IoProcessor;
import net.gleamynode.netty2.MessageRecognizer;
import net.gleamynode.netty2.OrderedEventDispatcher;
import net.gleamynode.netty2.SessionServer;
import net.gleamynode.netty2.ThreadPooledEventDispatcher;

import org.apache.log4j.Logger;

//import com.wireless.sms.pub.net.netty2.MOMTMessageRecognizer;

public class CRBTServer {
	private SessionServer server = null;
	private int SERVER_PORT = 0;
	private static final int DISPATCHER_THREAD_POOL_SIZE = 32;
	private Vector allowclient = null;
	private Logger log=Logger.getLogger(CRBTServer.class);
	private CRBTCenterGlobalInterface global = null;

	  private CRBTServer(){
	  }
	  /**
	   * 构造方法
	   * @param server_port int
	   * @param allowclient Vector
	   * @param global CenterGlobalInterface
	   * @param log Logger
	   */
	  public CRBTServer(int server_port, Vector allowclient, CRBTCenterGlobalInterface global, Logger log ){
	    this.SERVER_PORT = server_port;
	    this.allowclient = allowclient;
	    this.log = log;
	    this.global = global;
	    System.out.println("接入端口 ------- " + server_port);
	  }
	  /**
	   * 首先生成一个SessionServer 然后启动
	   */
	  public void start() {
	          try {
	            // initialize I/O processor and event dispatcher
	            IoProcessor ioProcessor = new IoProcessor();
	            ThreadPooledEventDispatcher eventDispatcher = new
	                OrderedEventDispatcher();

	            // start with the default number of I/O worker threads
	            ioProcessor.start();

	            // start with a few event dispatcher threads
	            eventDispatcher.setThreadPoolSize(DISPATCHER_THREAD_POOL_SIZE);
	            eventDispatcher.start();

	            // prepare message recognizer
	            MessageRecognizer recognizer = new CRBTMessageRecognizer(
	                CRBTMessageRecognizer.CRBT);

	            // prepare session event listener which will provide communication workflow.
	            CRBTServerSessionListener listener = new CRBTServerSessionListener(allowclient, global, log);

	            // prepare session server
	            server = new SessionServer();
	            server.setIoProcessor(ioProcessor);
	            server.setEventDispatcher(eventDispatcher);
	            server.setMessageRecognizer(recognizer);

	            server.addSessionListener(listener);
	            server.setBindAddress(new InetSocketAddress(SERVER_PORT));

	            // open the server port, accept connections, and start communication
	            log.debug("Listening on port " + SERVER_PORT);
	            //System.out.println("Listening on port " + SERVER_PORT);
	            server.start();
	          }
	          catch (IOException ex) {
	            ex.printStackTrace();
	          }
	  }

	  public void stop(){
	    server.stop();
	  }

}