两个系统之间的通讯问题-hasi -JavaEye技术社区

目前直接用http传递序列化的java对象,效果还可以
下面是我的实现过程
服务器端程序主要代码
TaskListenerServlet.java

代码

public void init() throws ServletException {
    TimerTask myTask = new MyTimerTask();
    myTimer = new Timer();
    long startMin=60;
    long intervalMin=60;
    myTimer.schedule(myTask, startMin*1000, intervalMin*1000);
}

MyTimerTask类里的run()方法主要代码

代码

try {
    // 设置网络输出流,idcServletAddress为客户端的servlet地址
    URL url = new URL(idcServletAddress);
    URLConnection uc = url.openConnection();
    uc.setDoOutput(true);
    uc.setDoInput(true);
    uc.setUseCaches(false);
    uc.setRequestProperty("Content-type", "application/octet-stream");
    ObjectOutputStream requestout = new ObjectOutputStream(uc.getOutputStream());
    //发送给客户端的servlet
    IDCInfoBean idcbean = new IDCInfoBean();
    idcbean.setIdc(idc);
    requestout.writeObject(idcbean);
    requestout.flush();
    requestout.close();
    //获取返回的二进制对象流
    ObjectInputStream responsein = new ObjectInputStream(uc.getInputStream());
    //还原
    TransProgramList tpl=  (TransProgramList) responsein.readObject();
    //把数据保存到服务器端数据库里
    CollectTaskService.executeTask(idc , tpl);
    responsein.close();
}catch (Exception e) {
      throw e;
}

 

客户端servlet程序主要代码

代码

public void service(ServletRequest request, ServletResponse response) throws
    ServletException, IOException {
        //封装用于返回的对象输出流
    ObjectOutputStream out = new ObjectOutputStream(response.getOutputStream());
    //封装用于接收的对象输入流
    ObjectInputStream in = new ObjectInputStream(request.getInputStream());
    IDCInfoBean idcBean=new IDCInfoBean();
    //按指定类的格式读取对象输入流中的内容
    try {
        idcBean=(IDCInfoBean)in.readObject();
    }catch (Exception e ){
        System.out.println(e.toString());
        //
    }
    String idc = idcBean.getIdc();
    //得到客户端所有节目信息
    List programList =CollectService.collectProgram(idc) ;
    List multiList =CollectService.collectMultiProgram(idc) ;
    //把结果封装到序列化对象里
    TransProgramList tpl = new TransProgramList();
    tpl.setProgramList(programList);
    tpl.setMultiList(multiList);
    //发送对象
    out.writeObject(tpl);
}