本文實例講述了java實現基於SGIP協議開發聯通短信的方法。分享給大家供大家參考。具體如下:
近段時間,由於公司的業務需要,開發出了聯通短信.此文章的編寫也是根據網上的一些示例來完成的.閒話少說,下面來看代碼:(運行此程序的時候需要導入華為的開發包,此包可以到網上下載)
下行:
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(); } } } }}
希望本文所述對大家的java程序設計有所幫助。