java實(shí)現(xiàn)基于SGIP協(xié)議開發(fā)聯(lián)通短信的方法
本文實(shí)例講述了java實(shí)現(xiàn)基于SGIP協(xié)議開發(fā)聯(lián)通短信的方法。分享給大家供大家參考。具體如下:
近段時(shí)間,由于公司的業(yè)務(wù)需要,開發(fā)出了聯(lián)通短信.此文章的編寫也是根據(jù)網(wǎng)上的一些示例來完成的.閑話少說,下面來看代碼:(運(yùn)行此程序的時(shí)候需要導(dǎo)入華為的開發(fā)包,此包可以到網(wǎng)上下載)
下行:
public class Mt {
private static String SPNumber = "**********";
//接入號(hào)碼
private static String ChargeNumber = "000000000000000000000";
// 計(jì)費(fèi)號(hào)碼,白名單
private static String ServiceType = "";
//服務(wù)類型
private static String host = "***.***.***.***";
// 主機(jī)名,網(wǎng)關(guān)IP
private static int port = ****;
// 端口號(hào)
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é)點(diǎn)編號(hào)(nodeid),這一步非常重要,華為包中,該字段類型為int,而接入?yún)f(xié)議中要求在企業(yè)代碼前加上30000,這樣就超過了int的取值范圍,所以需要用BigInteger轉(zhuǎn)一下就可以了
Args argstr = new Args();//設(shè)定連接參數(shù)
argstr.set("host", host);
argstr.set("port", port);
argstr.set("transaction-timeout", 10);
// 操作超時(shí)時(shí)間(單位:秒)
argstr.set("read-timeout", 15);
// 物理連接讀操作超時(shí)時(shí)間(單位:秒)
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);
// 這里 連接到短信息網(wǎng)關(guān)
try {
//connect表示向SMG登陸,登錄名與密碼分別是SMG向SP分配的用戶名與密碼,調(diào)用這個(gè)接口方法,向SMG發(fā)送Bind命令消息。
//如果發(fā)送消息超時(shí)或通信異常則拋出異常,需要調(diào)用者捕獲處理。
boolean reslut = sgipsmp.connect(login_Name, login_PassWord);
// 登陸得到true和false
if (reslut) {
System.out.println("連接成功...........");
} else {
System.out.println("連接失敗(用戶名或密碼錯(cuò)誤)...........");
return;
}
} catch (Exception ex) {
System.out.println("網(wǎng)絡(luò)異常...........");
ex.printStackTrace();
return;
}
String[] UserNumber = { "8618686619970","8618686619977"};
//接收短信的手機(jī)號(hào)碼,前邊要加上86
String content = "聯(lián)通短信發(fā)送成功";
byte[] MessageContent = content.getBytes("GB2312");
System.out.println("短信內(nèi)容: "+content);
try {
// 下發(fā)短息
SGIPSubmitMessage sgipsubmit = new SGIPSubmitMessage(
SPNumber, // SP的接入號(hào)碼
ChargeNumber, // 付費(fèi)號(hào)碼 string
UserNumber, // 接收該短消息的手機(jī)號(hào),最多100個(gè)號(hào)碼 string[]
CorpId, // 企業(yè)代碼,取值范圍為0~99999 string
ServiceType, // 業(yè)務(wù)代碼,由SP定義 stirng
03, // 計(jì)費(fèi)類型 int
"0", // 該條短消息的收費(fèi)值 stirng
"0", // 贈(zèng)送用戶的話費(fèi) string
0, // 代收費(fèi)標(biāo)志0:應(yīng)收1:實(shí)收 int
0, // 引起MT消息的原因 int
06, // 優(yōu)先級(jí)0~9從低 到高,默認(rèn)為0 int
null, // 短消息壽命的終止時(shí)間 date
null, // 短消息定時(shí)發(fā)送的時(shí)間 date
1, // 狀態(tài)報(bào)告標(biāo)記 int
0, // GSM協(xié)議類型 int
0, // GSM協(xié)議類型 int
15, // 短消息的編碼格式 int
0, // 信息類型 int
MessageContent.length, // 短消息內(nèi)容長(zhǎng)度 int
MessageContent, // 短消息的內(nèi)容 btye[]
"0" // 保留,擴(kuò)展用 string
);
// 收到的響應(yīng)消息轉(zhuǎn)換成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) {
// 收到的響應(yīng)消息轉(zhuǎn)換成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服務(wù)器信息
private static String serHost = "***.***.***.***";
private static int serviceport = ****;
//本機(jī)信息
private static String localhost = "***.***.***.***";
private static int localport = ****;
public Mo(Args args) {
super(args);
System.out.println("進(jìn)入啟動(dòng)監(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);
// 操作超時(shí)時(shí)間(單位:秒)
argstr.set("read-timeout", 15);
// 物理連接讀操作超時(shí)時(shí)間(單位:秒)
//這里的安全認(rèn)證問題如何解決?
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) {
//是否是類的實(shí)例
System.out.println("返回下發(fā)短信的相應(yīng)消息");
}
if (msg instanceof SGIPDeliverMessage) {
// 收到用戶發(fā)送的短信(上行)
SGIPDeliverMessage deliverMsg = (SGIPDeliverMessage) msg;
String userNumber = deliverMsg.getUserNumber();
// 手機(jī)號(hào)碼
String msgContent = deliverMsg.toString();
// 短信內(nèi)容
// 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();
// 響應(yīng)類型
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();
}
}
}
}
}
希望本文所述對(duì)大家的java程序設(shè)計(jì)有所幫助。
- Java基于UDP協(xié)議實(shí)現(xiàn)簡(jiǎn)單的聊天室程序
- java使用Socket實(shí)現(xiàn)SMTP協(xié)議發(fā)送郵件
- javaweb中Http協(xié)議詳解
- Java URL自定義私有網(wǎng)絡(luò)協(xié)議
- 使用Java通過OAuth協(xié)議驗(yàn)證發(fā)送微博的教程
- java編程實(shí)現(xiàn)基于UDP協(xié)議傳輸數(shù)據(jù)的方法
- Java基于socket服務(wù)實(shí)現(xiàn)UDP協(xié)議的方法
- Java基于Tcp協(xié)議的socket編程實(shí)例
- 基于JAVA中Jersey處理Http協(xié)議中的Multipart的詳解
- 使用java實(shí)現(xiàn)Xmodem協(xié)議
相關(guān)文章
Java畢業(yè)設(shè)計(jì)實(shí)戰(zhàn)之線上水果超市商城的實(shí)現(xiàn)
這是一個(gè)使用了java+SSM+springboot+redis開發(fā)的網(wǎng)上水果超市商城,是一個(gè)畢業(yè)設(shè)計(jì)的實(shí)戰(zhàn)練習(xí),具有水果超市商城該有的所有功能,感興趣的朋友快來看看吧2022-01-01
java寫卷積神經(jīng)網(wǎng)絡(luò)(CupCnn簡(jiǎn)介)
這篇文章主要介紹了java寫卷積神經(jīng)網(wǎng)絡(luò)(CupCnn簡(jiǎn)介),小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-04-04
springCloud gateWay 統(tǒng)一鑒權(quán)的實(shí)現(xiàn)代碼
這篇文章主要介紹了springCloud gateWay 統(tǒng)一鑒權(quán)的實(shí)現(xiàn)代碼,統(tǒng)一鑒權(quán)包括鑒權(quán)邏輯和代碼實(shí)現(xiàn),本文給大家介紹的非常詳細(xì),需要的朋友可以參考下2022-02-02
Java那點(diǎn)兒事之Map集合不為人知的秘密有哪些
Map用于保存具有映射關(guān)系的數(shù)據(jù),Map集合里保存著兩組值,一組用于保存Map的key,另一組保存著Map的value,和查字典類似,通過key找到對(duì)應(yīng)的value,通過頁(yè)數(shù)找到對(duì)應(yīng)的信息。用學(xué)生類來說,key相當(dāng)于學(xué)號(hào),value對(duì)應(yīng)name,age,sex等信息。用這種對(duì)應(yīng)關(guān)系方便查找2021-10-10
Spring Boot 中的 CommandLineRunner 原理及使用示例
CommandLineRunner 是 Spring Boot 提供的一個(gè)非常有用的接口,可以幫助你在應(yīng)用程序啟動(dòng)后執(zhí)行初始化任務(wù),本文通過多個(gè)示例詳細(xì)介紹了如何在實(shí)際項(xiàng)目中使用 CommandLineRunner,感興趣的朋友一起看看吧2025-04-04
springmvc+shiro自定義過濾器的實(shí)現(xiàn)代碼
這篇文章主要介紹了springmvc+shiro自定義過濾器的實(shí)現(xiàn)方法,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-10-10
Java如何利用線程池和Redis實(shí)現(xiàn)高效數(shù)據(jù)入庫(kù)
文章介紹了如何利用線程池和Redis在高并發(fā)環(huán)境中實(shí)現(xiàn)高效的數(shù)據(jù)入庫(kù),通過將數(shù)據(jù)首先存儲(chǔ)在Redis緩存中,然后利用線程池定期批量入庫(kù)處理,確保系統(tǒng)的性能和穩(wěn)定性,主要組件包括BatchDataStorageService、CacheService和RedisUtils等2025-02-02

