java实现基于SGIP协议开发联通短信的方法

java实现基于SGIP协议开发联通短信的方法

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。