本文实例讲述了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程序设计有所帮助。