SMPP Java示例(客户端)
这篇文章通过创建一个简单的SMPP客户端向移动用户发送短信来提供SMPP Java示例,使用该客户端我们可以简单地提交以向单个移动用户发送消息,也可以一次将消息广播给多个移动用户。另外,我们将验证交货收据。 出于客户端的目的,我们将使用现有的Java SMPP客户端库– jSMPP
什么是SMPP
SMPP代表短消息对等。 它是一种开放的行业标准协议,旨在为短消息数据的传输提供灵活的数据通信接口。大多数时候,SMPP用于批量传送短消息,您可以一次将消息广播给数千个订户。不仅限于短消息,我们还可以携带语音邮件通知,小区广播,WAP消息(包括WAP Push消息)
SMPP操作
SMPP使用客户机/服务器操作模型。在向SMPP提交任何消息之前,我们发送一个bind命令。 在此示例中,我们将发送bind_transmitter,因为我们仅对向服务器提交消息感兴趣。 除了bind_transmitter以外,其他bind命令是bind_receiver,意味着客户端将只接收消息,bind_transceiver允许双向消息传输。
SMPP操作的完整细节不在本文讨论范围之内。 如果您想详细了解操作,请访问– SMPP Wiki
使用jSMPP
要开始使用SMPP客户端,我们将使用jSMPP。 要将jSMPP包含在您的项目中,请将以下maven依赖项添加到pom.xml中
pom.xml
<dependency><groupId>org.jsmpp</groupId><artifactId>jsmpp</artifactId><version>2.3.5</version>
</dependency>
SMPP多次提交示例
正如我们讨论的那样,SMPP可用于向单个或多个订户发送消息。以下是向多个移动订户发送消息的示例。第一步是使用主机名,用户名和密码向服务器发送绑定命令。 我们正在initSession()中执行此操作。 完成此操作后,将创建SMPP会话,然后我们可以使用此会话发送消息。
相应的提供程序将提供不同的参数,例如ip,主机,用户名,密码。
MultipleSubmitExample.java
public class MultipleSubmitExample {private static final Logger LOGGER = LoggerFactory.getLogger(MultipleSubmitExample.class);private static final TimeFormatter TIME_FORMATTER = new AbsoluteTimeFormatter();private final String smppIp = "127.0.0.1";private int port = 8086;private final String username = "localhost";private final String password = "password";private final String address = "AX-DEV";private static final String SERVICE_TYPE = "CMT";public void broadcastMessage(String message, List numbers) {LOGGER.info("Broadcasting sms");SubmitMultiResult result = null;Address[] addresses = prepareAddress(numbers);SMPPSession session = initSession();if(session != null) {try {result = session.submitMultiple(SERVICE_TYPE, TypeOfNumber.NATIONAL, NumberingPlanIndicator.UNKNOWN, address,addresses, new ESMClass(), (byte) 0, (byte) 1, TIME_FORMATTER.format(new Date()), null,new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE), ReplaceIfPresentFlag.REPLACE,new GeneralDataCoding(Alphabet.ALPHA_DEFAULT, MessageClass.CLASS1, false), (byte) 0,message.getBytes());LOGGER.info("Messages submitted, result is {}", result);Thread.sleep(1000);} catch (PDUException e) {LOGGER.error("Invalid PDU parameter", e);} catch (ResponseTimeoutException e) {LOGGER.error("Response timeout", e);} catch (InvalidResponseException e) {LOGGER.error("Receive invalid response", e);} catch (NegativeResponseException e) {LOGGER.error("Receive negative response", e);} catch (IOException e) {LOGGER.error("I/O error occured", e);} catch (Exception e) {LOGGER.error("Exception occured submitting SMPP request", e);}}else {LOGGER.error("Session creation failed with SMPP broker.");}if(result != null && result.getUnsuccessDeliveries() != null && result.getUnsuccessDeliveries().length > 0) {LOGGER.error(DeliveryReceiptState.getDescription(result.getUnsuccessDeliveries()[0].getErrorStatusCode()).description() + " - " +result.getMessageId());}else {LOGGER.info("Pushed message to broker successfully");}if(session != null) {session.unbindAndClose();}}private Address[] prepareAddress(List numbers) {Address[] addresses = new Address[numbers.size()];for(int i = 0; i< numbers.size(); i++){addresses[i] = new Address(TypeOfNumber.NATIONAL, NumberingPlanIndicator.UNKNOWN, numbers.get(i));}return addresses;}private SMPPSession initSession() {SMPPSession session = new SMPPSession();try {session.setMessageReceiverListener(new MessageReceiverListenerImpl());String systemId = session.connectAndBind(smppIp, Integer.valueOf(port), new BindParameter(BindType.BIND_TX, username, password, "cp", TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN, null));LOGGER.info("Connected with SMPP with system id {}", systemId);} catch (IOException e) {LOGGER.error("I/O error occured", e);session = null;}return session;}public static void main(String[] args) {MultipleSubmitExample multiSubmit = new MultipleSubmitExample();multiSubmit.broadcastMessage("Test message from devglan", Arrays.asList("9513059515", "8884377251"));}
}
在创建SMPP会话时,我们已经注册了消息接收方侦听器,该侦听器将用于获取消息的传递收据。 以下是示例。
MessageReceiverListenerImpl.java
public class MessageReceiverListenerImpl implements MessageReceiverListener {private static final Logger LOGGER = LoggerFactory.getLogger(MessageReceiverListenerImpl.class);private static final String DATASM_NOT_IMPLEMENTED = "data_sm not implemented";public void onAcceptDeliverSm(DeliverSm deliverSm) throws ProcessRequestException {if (MessageType.SMSC_DEL_RECEIPT.containedIn(deliverSm.getEsmClass())) {try {DeliveryReceipt delReceipt = deliverSm.getShortMessageAsDeliveryReceipt();long id = Long.parseLong(delReceipt.getId()) & 0xffffffff;String messageId = Long.toString(id, 16).toUpperCase();LOGGER.info("Receiving delivery receipt for message '{}' from {} to {}: {}",messageId, deliverSm.getSourceAddr(), deliverSm.getDestAddress(), delReceipt);} catch (InvalidDeliveryReceiptException e) {LOGGER.error("Failed getting delivery receipt", e);}}}public void onAcceptAlertNotification(AlertNotification alertNotification) {LOGGER.info("AlertNotification not implemented");}public DataSmResult onAcceptDataSm(DataSm dataSm, Session source)throws ProcessRequestException {LOGGER.info("DataSm not implemented");throw new ProcessRequestException(DATASM_NOT_IMPLEMENTED, SMPPConstant.STAT_ESME_RINVCMDID);}
}
SMPP交货收据
SMPP提供了许多标准的交货收据错误代码来标识交货收据。 我们几乎没有采取任何措施来识别实际的收货信息。有关完整的详尽清单,请遵循– smpperrorcodes
DeliveryReceiptState.java
package com.devglan.smpp;public enum DeliveryReceiptState {ESME_ROK(0, "Ok - Message Acceptable"),ESME_RINVMSGLEN(1, "Invalid Message Length"),ESME_RINVCMDLEN(2, "Invalid Command Length"),ESME_RINVCMDID(3, "Invalid Command ID"),ESME_RINVBNDSTS(4, "Invalid bind status"),ESME_RALYBND(5, "Bind attempted when already bound"),ESME_RINVPRTFLG(6, "Invalid priority flag"),ESME_RINVREGDLVFLG(7, "Invalid registered-delivery flag"),ESME_RSYSERR(8, "SMSC system error"),ESME_RINVSRCADR(9, "Invalid source address"),ESME_RINVDSTADR(11, "Invalid destination address"),ESME_RINVMSGID(12, "Invalid message-id"),NOT_FOUND(000, "Couldn't resolve.Ask admin to add.");private int value;private String description;DeliveryReceiptState(int value, String description) {this.value = value;this.description = description;}public static DeliveryReceiptState getDescription(int value) {for (DeliveryReceiptState item : values()) {if (item.value() == value) {return item;}}return NOT_FOUND;}public int value() {return value;}public String description() {return description;}}
SMPP单一提交示例
jSMPP为单个提交提供了commitShortMessage()。以下是实现。 源代码中提供了完整的实现。
String messageId = session.submitShortMessage(SERVICE_TYPE,TypeOfNumber.NATIONAL, NumberingPlanIndicator.UNKNOWN, address,TypeOfNumber.NATIONAL, NumberingPlanIndicator.UNKNOWN, number,new ESMClass(), (byte)0, (byte)1, TIME_FORMATTER.format(new Date()), null,new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE), (byte)0, new GeneralDataCoding(Alphabet.ALPHA_DEFAULT, MessageClass.CLASS1, false), (byte)0,message.getBytes());
结论
这是Java中SMPP客户端实现的简单示例。 在下一篇文章中,我们将讨论其模拟器。
翻译自: https://www.javacodegeeks.com/2018/03/smpp-java-exampleclient.html
SMPP Java示例(客户端)相关推荐
- smpp客户端_SMPP Java示例(客户端)
smpp客户端 这篇文章通过创建一个简单的SMPP客户端向移动用户发送短信来提供SMPP Java示例,使用该客户端我们可以简单地提交以将消息发送给单个移动用户,也可以一次将消息广播给多个移动用户.另 ...
- ZooKeeper Java示例
ZooKeeper Java示例 简单的手表客户端 要求 程序设计 执行者类 DataMonitor类 完整的源列表 简单的手表客户端 为了向您介绍ZooKeeper Java API,我们在这里开发 ...
- 利用Kafka发送/消费消息-Java示例
利用Kafka发送/消费消息-Java示例 当使用命令行工具把基本的组件运行起来后,再使用Java client就很简单,这里是入门的第一个Java客户端程序,有很多需要深入理解的地方. 依赖配置 & ...
- 阿里云短信官方的java示例是错误的
阿里云短信前身是大鱼,现在移入了阿里云短信. 下载了官方sdk发现一大坨.我不需要啊. 下面自己精简一下,写一个. 谁知道一直提示签名不正确. 看了官网的示例然后对比了一下官方的php sdk 这,j ...
- java 示例_功能Java示例 第5部分–将I / O移到外部
java 示例 这是称为" Functional Java by Example"的系列文章的第5部分. 在上一部分中,我们停止了对文档的变异,并返回了数据的副本. 现在,我们需要 ...
- java 示例_功能Java示例 第4部分–首选不变性
java 示例 这是称为" Functional Java by Example"的系列文章的第4部分. 在上一部分中,我们讨论了一些副作用,并且我想进一步详细说明如何通过将不可变 ...
- java 示例_功能Java示例 第3部分–不要使用异常来控制流程
java 示例 这是称为" Functional Java by Example"的系列文章的第3部分. 我在本系列的每个部分中开发的示例是某种"提要处理程序" ...
- java 示例_功能Java示例 第2部分–讲故事
java 示例 这是称为" Functional Java by Example"的系列文章的第2部分. 我在本系列的每个部分中开发的示例是某种"提要处理程序" ...
- java ssh客户端_简单的Java SSH客户端
java ssh客户端 可以使用jcabi-ssh在Java中通过几行代码通过SSH执行shell命令: String hello = new Shell.Plain(new SSH("ss ...
最新文章
- postgresql 分组查询第一条数据
- 交换链表的奇数节点和偶数节点
- DateEdit如果开启Vista模式并显示日期+时间模式
- 我早年在Google学到的10条经验
- 安装 | Window下Visual Studio VS2015 VS2017 各版本下载地址
- Akka并发编程——第七节:Actor模型(六)
- 数据库-Oracle【Oracle数据库设置默认表空间问题及Oracle,SQL,MySQL的自增变量设置】...
- 无侵入性的在日志中打印对象的关键字段
- java基础- 与null的区别
- go java 垃圾回收_JAVA什么时候执行垃圾回收以及回收流程-Go语言中文社区
- windows 驱动开发 DDK与WDK WDM的区别
- 少儿计算机编程都学什么,少儿编程课是学什么的?
- 如何清除系统垃圾 介绍几大方法【图解】
- python 千位分隔符_千位分隔符的完整攻略
- (转)一位资深程序员大牛给予Java初学者的学习路线建议
- 高仿京东商城app、集成react-native热更新功能
- ENVI 混合像元分解
- python操作键盘输入中文_python模拟鼠标点击和键盘输入的操作
- MTK之Flash篇一
- 读书笔记-《赢在用户:Web人物角色创建和应用实践指南》