moserver.java

中国联通短信通信协议

package com.wireless.sms.gwif.test.receive;

import javax.swing.JTextArea;
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.CenterGlobalInterface;
import java.io.*;

public class MOServer {

  private SessionServer server = null;
  private int SERVER_PORT = 0;
  private static final int DISPATCHER_THREAD_POOL_SIZE = 32;
  private boolean openflag;
  private JTextArea txt = null;

  private MOServer(){
  }

  public MOServer(int server_port){
    this.SERVER_PORT = server_port;
  }

  public boolean isOpenflag() {
    return openflag;
  }

  public void setOpenflag(boolean openflag) {
    this.openflag = openflag;
  }

  public void setTextArea(JTextArea txt){
      this.txt = txt;
  }


  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
            try {
              ioProcessor.start();
            }
            catch (Exception ex) {
              ex.printStackTrace();
            }
            // start with a few event dispatcher threads
            eventDispatcher.setThreadPoolSize(DISPATCHER_THREAD_POOL_SIZE);
            eventDispatcher.start();
            // prepare message recognizer
            MessageRecognizer recognizer = new MOMTMessageRecognizer();
            // prepare session event listener which will provide communication workflow.
            MOServerSessionListener listener = new MOServerSessionListener();
            listener.setTextArea(txt);
            // 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
            server.start();
            this.openflag = true;
          }
          catch (IOException ex) {
            ex.printStackTrace();
          }
  }

  public void stop(){
    server.stop();
    this.openflag = false;
  }

  public static void main(String args[]){

    MOServer server = new MOServer(8600);
    server.start();
  }

}