目前&＃xff0c;三大运营商都提供了自己的短信相关协议&＃xff0c;比如联通的SGIP协议、移动的CMPP协议、电信的SMPP协议&＃xff0c;发送和接收短信、彩信可以根据运营商提供的接口&＃xff0c;编写相应的程序&＃xff0c;以达到想要的功能。下面简单介绍一下工作中遇到的使用联通SGIP协议的问题。
发送短信比较简单&＃xff0c;客户端建立socket&＃xff0c;先发送一个Bind请求&＃xff0c;解析收到的BindResp包&＃xff0c;正常连接后可以使用submit命令发送短信&＃xff0c;获取解析收到的submitresp包&＃xff0c;发送成功后调用unbind命令断开连接&＃xff0c;解析收到的UnbindResp&＃xff0c;如果命令操作正常就关闭socket&＃xff0c;这就是一个发送短信的过程。
接收短信比较复杂一些&＃xff0c;下图为联通SGIP接收短信的流程
需要写一个服务器端程序&＃xff0c;实时的监听联通分配的某个端口&＃xff0c;如果有数据来&＃xff0c;就建立一个socket&＃xff0c;遵循上面的协议&＃xff0c;打开连接&＃xff0c;获取数据并解析&＃xff0c;最后关闭socket。
具体的程序代码如下所示&＃xff1a;
public void receiveMsg() {ServerSocket serversocket&＃61;null;Socket so&＃61;null;OutputStream output&＃61;null;InputStream input&＃61;null;SGIP_Command command&＃61;null;logger.info("Receive.receiveMsg执行...");try {serversocket&＃61;new ServerSocket(this.request.iLocalPort);SGIP_Command tmpCMD&＃61;null;Deliver deliver&＃61;null;DeliverResp deliverresp &＃61; null;Report report&＃61;null;ReportResp reportresp&＃61;null;Userrpt userrpt &＃61; null;UserrptResp userrptresp &＃61; null;Bind active&＃61;null;Unbind term&＃61;null;BindResp resp&＃61;null;UnbindResp Unresp&＃61;null;boolean loop &＃61; true;int lastSeq &＃61; 0;List recVec &＃61; null;MobileSMTool tool &＃61; new MobileSMTool();logger.info("监听端口发来的信息...");while(true){//服务器端程序一直监听端口so&＃61;serversocket.accept();logger.info("接收到客户端的一个连接..");command&＃61;new SGIP_Command();input&＃61;new DataInputStream(so.getInputStream());output&＃61;new DataOutputStream(so.getOutputStream());loop &＃61; true;recVec &＃61; new ArrayList();while(loop) {tmpCMD&＃61;command.read(input);//接收sgip消息logger.info("CommandID&＃61;" &＃43; command.getCommandID());switch (command.getCommandID()) {case SGIP_Command.ID_SGIP_BIND : {logger.info("SGIP_Command.ID_SGIP_BIND...");active&＃61;(Bind)tmpCMD;//强制转换int result&＃61;active.readbody();//解包logger.info("result&＃61;" &＃43; result);resp&＃61;new BindResp(this.request.iSrcNode,0);resp.write(output);logger.info("BIND_RESP完成");break;}case SGIP_Command.ID_SGIP_UNBIND : {logger.info("SGIP_Command.ID_SGIP_UNBIND...");term&＃61;(Unbind)tmpCMD;//强制转换Unresp&＃61;new UnbindResp(this.request.iSrcNode);Unresp.write(output);//该会话结束loop&＃61;false;break;}case SGIP_Command.ID_SGIP_DELIVER: {logger.info("SGIP_Command.ID_SGIP_DELIVER...");deliver&＃61;(Deliver)tmpCMD;//强制转换deliver.readbody();//解包if(deliver.getSeqno_3() !&＃61; lastSeq){SMSReceiveInfo rec &＃61; new SMSReceiveInfo();String content &＃61; "";if(deliver.getMessageCoding() &＃61;&＃61; 8){content &＃61; new String(deliver.getMessageByte(), "UTF-16BE");}else if(deliver.getMessageCoding() &＃61;&＃61; 0 || deliver.getMessageCoding() &＃61;&＃61; 15){content &＃61; new String(deliver.getMessageByte(), "GB2312");content &＃61; new String(content.getBytes("gb2312"), "utf8");}else{content &＃61; deliver.getMessageContent();}rec.setContent(content);rec.setEncoding(deliver.getMessageCoding());rec.setLength(deliver.getMessageLength());rec.setNumber(deliver.getUserNumber());recVec.add(rec);lastSeq &＃61; deliver.getSeqno_3();}else{loop &＃61; false;}deliverresp &＃61; new DeliverResp(this.request.iSrcNode,0);deliverresp.SetResult(0);deliverresp.write(output);break;}case SGIP_Command.ID_SGIP_REPORT: {logger.info("SGIP_Command.ID_SGIP_REPORT...");report&＃61;(Report)tmpCMD;//强制转换report.readbody();//解包reportresp &＃61; new ReportResp(this.request.iSrcNode,0);reportresp.write(output);break;}case SGIP_Command.ID_SGIP_USERRPT: {logger.info("SGIP_Command.ID_SGIP_USERRPT...");userrpt&＃61;(Userrpt)tmpCMD;//强制转换userrpt.readbody(); //解包userrptresp&＃61; new UserrptResp(this.request.iSrcNode,0);userrptresp.SetResult(12);userrptresp.write(output);break;}}Thread.sleep(1*500);}logger.info("一个会话结束...");output.close();input.close();so.close();if(recVec !&＃61; null && recVec.size() > 0){tool.dealReceiveMsg(recVec);}}} catch (SGIP_Exception e) {logger.error(e.toString());} catch (Exception ex) {logger.error(ex.toString());} finally {try {if(output !&＃61; null){output.close();}if(input !&＃61; null){input.close();}if(so !&＃61; null){so.close();}} catch (Exception s) {logger.error(s.toString());}}}
京公网安备 11010802041100号