java實現基于SGIP協議開發(fā)聯通短信的方法
更新時間:2015年07月14日 15:14:03 作者:tianshanfeike
這篇文章主要介紹了java實現基于SGIP協議開發(fā)聯通短信的方法,涉及java短信發(fā)送的相關實現技巧,具有一定參考借鑒價值,需要的朋友可以參考下
本文實例講述了java實現基于SGIP協議開發(fā)聯通短信的方法。分享給大家供大家參考。具體如下:
近段時間,由于公司的業(yè)務需要,開發(fā)出了聯通短信.此文章的編寫也是根據網上的一些示例來完成的.閑話少說,下面來看代碼:(運行此程序的時候需要導入華為的開發(fā)包,此包可以到網上下載)
下行:
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 = "*****";
// 企業(yè)代碼
private static String login_Name = "**";
// 登陸名
private static String login_PassWord = "***";
// 登陸密碼
public static void main(String[] args) throws UnsupportedEncodingException {
int srcnode = new BigInteger("*******").intValue();
//源節(jié)點編號(nodeid),這一步非常重要,華為包中,該字段類型為int,而接入協議中要求在企業(yè)代碼前加上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發(fā)送Bind命令消息。
//如果發(fā)送消息超時或通信異常則拋出異常,需要調用者捕獲處理。
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 = "聯通短信發(fā)送成功";
byte[] MessageContent = content.getBytes("GB2312");
System.out.println("短信內容: "+content);
try {
// 下發(fā)短息
SGIPSubmitMessage sgipsubmit = new SGIPSubmitMessage(
SPNumber, // SP的接入號碼
ChargeNumber, // 付費號碼 string
UserNumber, // 接收該短消息的手機號,最多100個號碼 string[]
CorpId, // 企業(yè)代碼,取值范圍為0~99999 string
ServiceType, // 業(yè)務代碼,由SP定義 stirng
03, // 計費類型 int
"0", // 該條短消息的收費值 stirng
"0", // 贈送用戶的話費 string
0, // 代收費標志0:應收1:實收 int
0, // 引起MT消息的原因 int
06, // 優(yōu)先級0~9從低 到高,默認為0 int
null, // 短消息壽命的終止時間 date
null, // 短消息定時發(fā)送的時間 date
1, // 狀態(tài)報告標記 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("消息發(fā)送成功..........");
} else {
System.out.println("消息發(fā)送失敗..........");
}
} 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("發(fā)送成功:::");
}
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("進入啟動監(jiān)聽........");
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("返回下發(fā)短信的相應消息");
}
if (msg instanceof SGIPDeliverMessage) {
// 收到用戶發(fā)送的短信(上行)
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程序設計有所幫助。
相關文章
Java畢業(yè)設計實戰(zhàn)之線上水果超市商城的實現
這是一個使用了java+SSM+springboot+redis開發(fā)的網上水果超市商城,是一個畢業(yè)設計的實戰(zhàn)練習,具有水果超市商城該有的所有功能,感興趣的朋友快來看看吧2022-01-01
Spring Boot 中的 CommandLineRunner 原理及使用示例
CommandLineRunner 是 Spring Boot 提供的一個非常有用的接口,可以幫助你在應用程序啟動后執(zhí)行初始化任務,本文通過多個示例詳細介紹了如何在實際項目中使用 CommandLineRunner,感興趣的朋友一起看看吧2025-04-04

