java实现基于SGIP协议开发联通短信的方法

亦凉 2022-09-26 03:59 195阅读 0赞

本文实例讲述了java实现基于SGIP协议开发联通短信的方法。分享给大家供大家参考。具体如下：

近段时间,由于公司的业务需要,开发出了联通短信.此文章的编写也是根据网上的一些示例来完成的.闲话少说,下面来看代码:(运行此程序的时候使用了华为的开发包，搜"smproxy.jar"即可，填上接入号等信息后编译运行，出现以下调试及异常信息)

下行:

public class Mt {
     private static String SPNumber = "**********";
     //接入号码 
     private static String ChargeNumber = "000000000000000000000";
     // 计费号码，白名单 
     private static String ServiceType = "";
     //服务类型 
     private static String host = "***.***.***.***";
     // 主机名，网关IP 
     private static int port = ****;
     // 端口号 
     private static String CorpId = "*****";
     // 企业代码 
     private static String login_Name = "**";
     // 登陆名 
     private static String login_PassWord = "***";
     // 登陆密码 
      public static void main(String[] args) throws UnsupportedEncodingException {
      int srcnode = new BigInteger("*******").intValue();
      //源节点编号(nodeid)，这一步非常重要，华为包中，该字段类型为int，而接入协议中要求在企业代码前加上30000，这样就超过了int的取值范围，所以需要用BigInteger转一下就可以了
       Args argstr = new Args();//设定连接参数
       argstr.set("host", host);
       argstr.set("port", port);
       argstr.set("transaction-timeout", 10);
       // 操作超时时间(单位：秒)
       argstr.set("read-timeout", 15);
       // 物理连接读操作超时时间(单位：秒)
       argstr.set("source-addr", srcnode);
       // SP…ID(最大为六位字符)
       argstr.set("login-name", login_Name);
       argstr.set("login-pass", login_PassWord);
       argstr.set("debug", "false");
       // 连接登陆
       SGIPSMProxy sgipsmp = new SGIPSMProxy(argstr);
       // 这里 连接到短信息网关
       try {
        //connect表示向SMG登陆,登录名与密码分别是SMG向SP分配的用户名与密码,调用这个接口方法，向SMG发送Bind命令消息。
        //如果发送消息超时或通信异常则抛出异常，需要调用者捕获处理。
        boolean reslut = sgipsmp.connect(login_Name, login_PassWord);
        // 登陆得到true和false
        if (reslut) {
         System.out.println("连接成功...........");
        } else {
         System.out.println("连接失败(用户名或密码错误)...........");
         return;
        }
       } catch (Exception ex) {
        System.out.println("网络异常...........");
        ex.printStackTrace();
        return;
       }
       String[] UserNumber = { "8618686619970","8618686619977"};
       //接收短信的手机号码，前边要加上86
       String content = "联通短信发送成功";
       byte[] MessageContent = content.getBytes("GB2312");
        System.out.println("短信内容: "+content);
       try {
        // 下发短息
        SGIPSubmitMessage sgipsubmit = new SGIPSubmitMessage(
          SPNumber, // SP的接入号码
          ChargeNumber, // 付费号码 string
          UserNumber, // 接收该短消息的手机号，最多100个号码 string[]
          CorpId, // 企业代码，取值范围为0～99999 string
          ServiceType, // 业务代码，由SP定义 stirng
          03, // 计费类型 int
          "0", // 该条短消息的收费值 stirng
          "0", // 赠送用户的话费 string
          0, // 代收费标志0：应收1：实收 int
          0, // 引起MT消息的原因 int
          06, // 优先级0～9从低 到高，默认为0 int
          null, // 短消息寿命的终止时间 date
          null, // 短消息定时发送的时间 date
          1, // 状态报告标记 int
          0, // GSM协议类型 int
          0, // GSM协议类型 int
          15, // 短消息的编码格式 int
          0, // 信息类型 int
          MessageContent.length, // 短消息内容长度 int
          MessageContent, // 短消息的内容 btye[]
          "0" // 保留，扩展用 string
        );
        // 收到的响应消息转换成rep
        int status = ProcessSubmitRep(sgipsmp.send(sgipsubmit));
        System.out.println(status);
        if (status == 0) {
         System.out.println("消息发送成功..........");
        } else {
         System.out.println("消息发送失败..........");
        }
       } catch (Exception ex) {
        ex.printStackTrace();   
       }
      }
      private static int ProcessSubmitRep(SGIPMessage msg) {
       // 收到的响应消息转换成repMsg
       SGIPSubmitRepMessage repMsg = (SGIPSubmitRepMessage) msg;
       System.out.println(repMsg.getSrcNodeId());
       System.out.println("status:::::::" + repMsg.getResult());
       if (repMsg != null && repMsg.getResult() == 0) {
        System.out.println("发送成功：：：");
       }
       return repMsg.getResult();
      }
    }

上行:

public class Mo extends SGIPSMProxy {
     //SMG服务器信息
     private static String serHost = "***.***.***.***";
     private static int serviceport = ****;
     //本机信息
     private static String localhost = "***.***.***.***";
     private static int localport = ****; 
     public Mo(Args args) {
      super(args);
      System.out.println("进入启动监听........");
      startService(localhost, localport);
      //我想知道这里传递的host和port是本地的还是那的
     }
     public static void main(String[] args)
     {
      Args argstr = new Args();
      argstr.set("serHost", serHost);
      argstr.set("serviceport", serviceport);
      argstr.set("localhost", localhost);
      argstr.set("localport", localport);
      argstr.set("transaction-timeout", 10);
      // 操作超时时间(单位：秒)
      argstr.set("read-timeout", 15);
      // 物理连接读操作超时时间(单位：秒)
      //这里的安全认证问题如何解决?
      Mo mymo=new Mo(argstr);  
     }
     public SGIPMessage onDeliver(SGIPDeliverMessage msg) {
      ProcessRecvDeliverMsg(msg);
      System.out.println("正在等待接收.......");
      return super.onDeliver(msg);
     }
     public void ProcessRecvDeliverMsg(SGIPMessage msg) {
      if (msg instanceof SGIPSubmitRepMessage) {
      //是否是类的实例
       System.out.println("返回下发短信的相应消息");
      }
      if (msg instanceof SGIPDeliverMessage) {
       // 收到用户发送的短信(上行)
       SGIPDeliverMessage deliverMsg = (SGIPDeliverMessage) msg;
       String userNumber = deliverMsg.getUserNumber();
       // 手机号码
       String msgContent = deliverMsg.toString();
       // 短信内容
       // byte[] msgId = deliverMsg.getMsgContent();
       System.out.println("userNumber::::::" + deliverMsg.getUserNumber());
       System.out.println("msgcontent:::::::" + deliverMsg.toString());
       System.out.println("spNumber::::::::" + deliverMsg.getSPNumber());
       //log.info("收到消息:" + deliverMsg);
       System.out.println("收到消息 ："+deliverMsg);
       int commandId = deliverMsg.getCommandId();
       // 响应类型
       System.out.println("commandId:::::::::" + commandId);
       if (commandId == 0) { //上传短信（接收）
        System.out.println("dstaddr::::::" + deliverMsg.getSPNumber());
        try {
        } catch (Exception e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
        }
       }
      }
     }
    }