本文实例讲述了java实现基于SGIP协议开发联通短信的方法。分享给大家供大家参考。具体如下:
近段时间,由于公司的业务需要,开发出了联通短信.此文章的编写也是根据网上的一些示例来完成的.闲话少说,下面来看代码:(运行此程序的时候需要导入华为的开发包,此包可以到网上下载)
下行:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
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(); } } |
上行:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
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程序设计有所帮助。