加入收藏 收藏网站 设为首页 设为首页
招生考试网
学历类| 阳光高考 研 究 生 自学考试 成人高考 专 升 本 中考会考 外语类| 四 六 级 职称英语 商务英语 公共英语 日语能力
资格类| 公 务 员 报 关 员 银行从业 司法考试 导 游 证 教师资格 财会类| 会 计 证 经 济 师 会计职称 注册会计 税 务 师
工程类| 一级建造 二级建造 造 价 师 造 价 员 咨 询 师 监 理 师 医学类| 卫生资格 执业医师 执业药师 执业护士 国际护士
计算机| 等级考试 软件水平 应用能力 其它类| 书画等级 美国高考 驾 驶 员 书法等级 少儿英语 报 检 员 单 证 员 出国留学
 招生考试网 - 计算机等级考试 - 考试辅导 - 正文

 
计算机二级:ServerTransportmodel
来源:fjzsksw.com 2009-11-8 编辑:yangmeiling 【字体:小 大】

 介绍
  Server Transport 即传输层,是建立在通信信道建立成功和传输指令交互成功的基础上的一层用于传送数据的层,类似TCP、UDP,它的主要的作用就是输送我们定义的数据,数据格式的数据结构则可以自己进行约定,如字符流、字节流等,也可以为XML或其他数据结构实现的数据格式。
  在Transport建立过程中,Server与Client端需要持有一些数据成员,如对方的信任信息、连接地址等socket参数、操作柄的代理工厂。
  这样建立Transport后则可以实现数据传输、指令下达、报告提交等功能。
  部分代码
  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;
  }
  }



 
网站版权与免责声明
①由于各方面情况的不断调整与变化,本网所提供的相关信息请以权威部门公布的正式信息为准.
②本网转载的文/图等稿件出于非商业性目的,如转载稿涉及版权等问题,请在两周内来电联系.
最新文章
热门文章

报名考试
全国 | 黑龙江 | 吉林 | 辽宁 | 内蒙古
青海 | 宁夏 | 甘肃 | 新疆 | 陕西
西藏 | 北京 | 天津 | 河北 | 山东
江苏 | 安徽 | 河南 | 上海 | 浙江
福建 | 广东 | 山西 | 湖南 | 湖北
江西 | 广西 | 海南 | 云南 | 贵州
四川 | 重庆
分省高校计算机考试
黑龙江 | 吉林 | 辽宁 | 内蒙古 | 河北
北京 | 天津 | 新疆 | 甘肃 | 宁夏
青海 | 陕西 | 山西 | 河南 | 山东
江苏 | 安徽 | 浙江 | 福建 | 广东
海南 | 广西 | 江西 | 湖北 | 湖南
四川 | 上海 | 重庆 | 贵州 | 云南
西藏
成绩查询
报考指南
试题答案
模拟试题
考试辅导
计算机一级 | 计算机二级 | 计算机三级 | 计算机四级
经验交流
高校计算机