cmccservlet.java

SMS短信编程,该软件实现短信发送和接收的测试

package cmcctest;

import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.util.*;
import com.bhb.sms.server.service.rmi.MessageServer;
import com.bhb.sms.server.service.cmpp30.CMPP_MTData;
import java.rmi.Naming;
import java.lang.Thread;
public class cmccServlet extends HttpServlet {
 private static final String CONTENT_TYPE = "text/plain; charset=ISO8859_1";
  //Initialize global variables
  private static String rmiURL = "//192.168.0.1:6666/rmiGatewayServer";
  private  static  MessageServer rmiService = null;//
  private  static  boolean rmiServiceStatus = false;

  public void init() throws ServletException {
    //initEnv();
  }

  private void initEnv()
  {
    try {
      if (rmiService == null || rmiServiceStatus == false) {
        rmiService = (MessageServer) Naming.lookup(rmiURL);
        rmiServiceStatus = true;
        System.out.println("连接网关--->成功");
      }
    }
    catch (Exception e) {
      System.out.println("连接网关--->失败,cause:" + e.getMessage());
      rmiService = null;
      rmiServiceStatus = false;

    }
  }

  public  boolean sendMsg(CMPP_MTData mt) {
   try {
     if(rmiServiceStatus == false)
     {
       initEnv();
     }
     rmiService.send(mt);
     return true;
   }
   catch (Exception e) {
     System.out.println(e.getMessage());
     rmiService = null;
     rmiServiceStatus = false;
     return false;
   }
 }
  //Process the HTTP Post request
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    response.setContentType(CONTENT_TYPE);
    PrintWriter out = response.getWriter();
    String pkTotal    = request.getParameter("pkTotal");
    String pkNumber   = request.getParameter("pkNumber");
    String registered = request.getParameter("registered");
    String gwID       = request.getParameter("gwID");
    String msgLevel   = request.getParameter("msgLevel");
    String serviceType= request.getParameter("serviceType");
    String feeUserType= request.getParameter("feeUserType");
    String feeTerminalID = request.getParameter("feeTerminalId");
    String feeTerminalType = request.getParameter("feeTerminalType");
    String tpUdhi          = request.getParameter("tpUdhi");
    String tpPid           = request.getParameter("tpPid");
    String msgSrc          = request.getParameter("msgSrc");
    String feeType         = request.getParameter("feeType");
    String feeCode         = request.getParameter("feeCode");
    String srcId           = request.getParameter("srcId");
    String destTerminalId  = request.getParameter("destTerminalId");
    String destTerminalType= request.getParameter("destTerminalType");
    String msgContent      = request.getParameter("msgContent");
    String linkID          = request.getParameter("linkID");
    String msgFmt          = request.getParameter("msgFmt");
    CMPP_MTData mt = new CMPP_MTData();
    long time = System.currentTimeMillis();
    mt.setGwID(gwID.trim());
    mt.setMsg_Fmt(Integer.parseInt(msgFmt));
    mt.setAt_Time(new Date(time + 24*60*60*1000));
    mt.setRegistered_Delivery(Integer.parseInt(registered.trim()));
    mt.setMsg_Level(Integer.parseInt(msgLevel.trim()));
    mt.setService_Id(serviceType.trim());
    mt.setFee_UserType(Integer.parseInt(feeUserType.trim()));
    mt.setFee_Terminal_Id(feeTerminalID.trim());
    mt.setFee_Terminal_Type(Integer.parseInt(feeTerminalType.trim()));
    mt.setTp_Pid(Integer.parseInt(tpPid.trim()));
    mt.setTp_Udhi(Integer.parseInt(tpUdhi.trim()));
    mt.setMsg_Src(msgSrc.trim());
    mt.setFee_Type(feeType.trim());
    mt.setFee_Code(feeCode.trim());
    mt.setSrc_Id(srcId.trim());
    String destAddr[] = new String[1];
    destAddr[0] = destTerminalId.trim();
    mt.setDest_Terminal_Id(destAddr);
    mt.setDest_Terminal_Type(Integer.parseInt(destTerminalType.trim()));
    mt.setLinkID(linkID.trim());
    mt.setUpMsgid("");

    mt.setPkTotal(Integer.parseInt(pkTotal));
    mt.setPkNumber(Integer.parseInt(pkNumber));
    boolean sucFlag = false;
    if(mt.getMsg_Fmt() == 4)
    {
      byte[] bt = Base64.decode(msgContent.trim());
      mt.setMsg_Content(bt);
      mt.setBinaryFlag(true);
    }else
    {
      mt.setMsg_Content(msgContent.trim().getBytes());
      mt.setBinaryFlag(false);
    }

    sucFlag = this.sendMsg(mt);
    out.println("<html>");
    out.println("<head><title>CMPP3.0接口测试</title></head>");
    out.println("<body bgcolor=\"#ffffff\">");
    if(sucFlag)
    {
      out.println("<p>消息已经提交到网关</p>");
    }else{
      out.println("<p>消息发送失败</p>");
    }
    out.println("</body></html>");
  }
  //Clean up resources
  public void destroy() {
  }
}