亚洲免费乱码视频,日韩 欧美 国产 动漫 一区,97在线观看免费视频播国产,中文字幕亚洲图片

      1. <legend id="ppnor"></legend>

      2. 
        
        <sup id="ppnor"><input id="ppnor"></input></sup>
        <s id="ppnor"></s>

        ServerTransportmodel

        字號(hào):

        介紹
            Server Transport 即傳輸層,是建立在通信信道建立成功和傳輸指令交互成功的基礎(chǔ)上的一層用于傳送數(shù)據(jù)的層,類似TCP、UDP,它的主要的作用就是輸送我們定義的數(shù)據(jù),數(shù)據(jù)格式的數(shù)據(jù)結(jié)構(gòu)則可以自己進(jìn)行約定,如字符流、字節(jié)流等,也可以為XML或其他數(shù)據(jù)結(jié)構(gòu)實(shí)現(xiàn)的數(shù)據(jù)格式。
            在Transport建立過(guò)程中,Server與Client端需要持有一些數(shù)據(jù)成員,如對(duì)方的信任信息、連接地址等socket參數(shù)、操作柄的代理工廠。
            這樣建立Transport后則可以實(shí)現(xiàn)數(shù)據(jù)傳輸、指令下達(dá)、報(bào)告提交等功能。
            部分代碼
            package thread;
            import java.util.concurrent.LinkedBlockingQueue;
            import java.util.concurrent.ThreadPoolExecutor;
            import java.util.concurrent.TimeUnit;
            import org.apache.commons.logging.Log;
            import org.apache.commons.logging.LogFactory;
            /**
            * This ServerTransport is work in multi thread env
            *
            *
            */
            public class ServerTransport {
            private static final Log _log = LogFactory.getLog(ServerTransport.class);
            private final Object _lock = new Object();
            private boolean _readyFlag = false;
            private boolean _stopFlag;
            private final AsynchronousCaller _asyncCaller;
            /**
            * Initialization AsynchronousCaller
            * @param asyncThreadPoolSize
            */
            public ServerTransport(int asyncThreadPoolSize) {
            if(asyncThreadPoolSize<0){
            throw new IllegalArgumentException("illegal Server Transport poolSize: "+asyncThreadPoolSize);
            }
            _asyncCaller = new AsynchronousCaller(asyncThreadPoolSize);
            //Do some other things about each transport!
            }
            /*
            * Operate Handler
            */
            //check ready
            public boolean isReady(){
            synchronized(_lock){
            return _readyFlag;
            }
            }
            //start
            public void start() throws Exception {
            if (isStopped()) {
            return;
            }
            _asyncCaller.start();
            setReady(true);
            }
            //stop
            public void stop() {
            _asyncCaller.stop();
            setReady(false);
            setStop(false);
            }
            //set ready
            private void setReady(boolean b) {
            synchronized(_lock){
            _readyFlag = b;
            }
            }
            //set ready
            private void setStop(boolean b) {
            synchronized(_lock){
            _stopFlag = b;
            }
            }