subscribeprocess.java

cmpp的开发的短信端口实例

package com.zhanghao.provision;

import java.io.*;
import java.net.*;

import javax.xml.soap.*;
import com.zhanghao.common.util.*;

public class SubscribeProcess extends Thread{

  public SubscribeProcess() {
  }


  public boolean scanSOAPFile(){
    boolean hasFile = false;

    try{
      File fi = new File(ProvisionParameter.SubscribeXMLFile);
      if(fi.exists()){
        hasFile =true;
      }
    }
    catch(Exception ex){
      hasFile =false;
    }

    return hasFile;
  }


  public void run(){
    //
    Debug.outInfo("[Provision]"+PublicFunction.getFormatTime()+" 反向定购服务启动...");

    while(true){
      try{
        if(scanSOAPFile()){
          File file = new File(ProvisionParameter.SubscribeXMLFile);
          FileInputStream fi = new FileInputStream(file);
          SubscribeServiceReqBean subMsgBean = new SubscribeServiceReqBean(fi);

          subMsgBean.soapMessage.writeTo(System.out);
          fi.close();
          file.delete();

          sendUnSubscribe(ProvisionParameter.Misc_Addr,subMsgBean);
        }
      }
      catch(Exception ex){
        ex.printStackTrace();
      }

      PublicFunction.sleep(1000);

    }
  }


  public String connectURL(String dest_url, String commString)
    {
        String rec_string = "";
        URL url = null;
        HttpURLConnection urlconn = null;
        try
        {
            url = new URL(dest_url);
            urlconn = (HttpURLConnection)url.openConnection();
            urlconn.setRequestProperty("content-type", "text/plain");
            urlconn.setRequestMethod("POST");
            urlconn.setDoInput(true);

            urlconn.setDoOutput(true);
            OutputStream out = urlconn.getOutputStream();
            out.write(commString.getBytes("UTF8"));
            out.flush();
            out.close();


            BufferedReader rd = new BufferedReader(new InputStreamReader(urlconn.getInputStream()));
            StringBuffer sb = new StringBuffer();
            int ch;
            while((ch = rd.read()) > -1)
                sb.append((char)ch);
            rec_string = sb.toString();
            rd.close();
            urlconn.disconnect();
            System.out.println("\n\r反相定购回应包\n\r"+sb.toString());
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        return rec_string;
    }


    public String sendUnSubscribe(String url,SubscribeServiceReqBean subMsgBean) {
      return connectURL(url,new String(subMsgBean.getBytes()));
    }
}