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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/348067.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

mysql插入另一个表中数据_MySql中把一个表的数据插入到另一个表中的实现

mysql插入另一个表中数据_MySql中把一个表的数据插入到另一个表中的实现

1.如果2张表的字段一致&#xff0c;并且希望插入全部数据&#xff0c;可以用这种方法&#xff1a;INSERT INTO 目标表 SELECT * FROM 来源表;insert into insertTest select * from insertTest2;2.如果只希望导入指定字段&#xff0c;可以用这种方法&#xff1a;INSERT INTO 目…
阅读更多...
mysql事务中怎么更改空值_MySQL事务

mysql事务中怎么更改空值_MySQL事务

1.事务1.事务特性--ACIDAtomicity(原子性):要么全做,要么不做,不能只做一半(银行转账)Consistency(约束性):事务的前后,约束都能满足Isolation(依赖性):事务之间是独立的,互不影响的Durability(持久性):事务执行之后,事物的结果可以持久保存2.事务隔离级别:read uncommitted:可…
阅读更多...
mysql自定义函数多参数_自定义mysql函数 - 无法传递参数

mysql自定义函数多参数_自定义mysql函数 - 无法传递参数

作为标题状态。这里的功能DELIMITER //CREATE FUNCTION GetCreateValue( table_name CHAR(64), id_field CHAR(64), name_field CHAR(64), name_value CHAR(64) )RETURNS INTEGERBEGINDECLARE ret INTEGER;SELECT count(*) INTO ret FROM table_name WHERE name_field name_va…
阅读更多...
与Zapier集成

与Zapier集成

整合很无聊。 也是不可避免的。 但是我不会写有关企业集成模式的文章 。 相反&#xff0c;我将解释如何创建与Zapier集成的应用程序。 什么是Zapier &#xff1f; 它是一项服务&#xff0c;使您可以通过其API&#xff08;或协议&#xff09;连接两个&#xff08;或多个&#x…
阅读更多...
python用psf函数_python学习之-类的内置函数

python用psf函数_python学习之-类的内置函数

内置方法&#xff1a;__str__(该方法必须返回字符串类型),在对像被打印时自动触发,然后将该方法的返回值当做打印结果输出)class People:def __init__(self,name,age):self.namenameself.ageagedef __str__(self): #绑定给对象的方法return ‘‘ %(self.name,self.age) #这个方…
阅读更多...
多用户远程连接mysql_Mysql权限控制 - 允许用户远程连接

多用户远程连接mysql_Mysql权限控制 - 允许用户远程连接

Mysql为了安全性&#xff0c;在默认情况下用户只允许在本地登录&#xff0c;可是在有此情况下&#xff0c;还是需要使用用户进行远程连接&#xff0c;因此为了使其可以远程需要进行如下操作&#xff1a;一、允许root用户在任何地方进行远程登录&#xff0c;并具有所有库任何操作…
阅读更多...
cxf 服务端soap报文_使用Apache CXF开发SOAP Web服务

cxf 服务端soap报文_使用Apache CXF开发SOAP Web服务

cxf 服务端soap报文在上一篇文章中&#xff0c;我逐步介绍了使用apache CXF开发简单的RESTFull服务的步骤。 在本文中&#xff0c;我将讨论使用CXF开发SOAP Web服务。 在继续前进之前&#xff0c;让我们先了解一下构成SOAP Web服务的概念/元素 SOAP或简单对象访问协议 SOAP是一…
阅读更多...
Java 8日期和时间

Java 8日期和时间

如今&#xff0c;一些应用程序仍在使用java.util.Date和java.util.Calendar API&#xff0c;包括使我们的生活更轻松地使用这些类型的库&#xff0c;例如JodaTime。 但是&#xff0c;Java 8引入了新的API来处理日期和时间&#xff0c;这使我们可以对日期和时间表示进行更精细的…
阅读更多...
php mysql 随机字符串_MySQL_Mysql 自定义随机字符串的实现方法，前几天在开发一个系统，需要 - phpStudy...

php mysql 随机字符串_MySQL_Mysql 自定义随机字符串的实现方法，前几天在开发一个系统，需要 - phpStudy...

Mysql 自定义随机字符串的实现方法前几天在开发一个系统&#xff0c;需要用到随机字符串&#xff0c;但是mysql的库函数有没有直接提供&#xff0c;就简单的利用现有的函数东拼西凑出随机字符串来.下面简单的说下实现当时.1.简单粗暴.select ..., substring(MD5(RAND()),floor(…
阅读更多...
python哪些类型可以作为迭代器_python0.8-----set类型与迭代器

python哪些类型可以作为迭代器_python0.8-----set类型与迭代器

set:类似dict&#xff0c;是一组dict的集合&#xff0c;不存储value。本质&#xff1a;无序(没有下标)无重复的元素的集合。创建&#xff1a;创建set需要一个list或者tuple或者dict作为输入集合。重复元素在色中会被自动过滤。s1[1,2,3,4,5,6,1,2]set(s1){1,2,3,4,5,6} --表示》…
阅读更多...
线程池实现填充短信_填充一个池需要多少个线程？

线程池实现填充短信_填充一个池需要多少个线程？

线程池实现填充短信在最近几个月中&#xff0c;我们一直看到很小但持续的操作失败&#xff0c;但有一个奇怪的异常– org.springframework.jdbc.CannotGetJdbcConnectionException –“无法获得JDBC连接&#xff1b; 嵌套异常是java.sql.SQLException&#xff1a;客户端尝试检出…
阅读更多...
python线性回归x可以数量不一样吗_R和Python中的线性回归 - 在同一问题上的结果不同...

python线性回归x可以数量不一样吗_R和Python中的线性回归 - 在同一问题上的结果不同...

只是指出这一点&#xff1a; statsmodel s least squares fit does by default not include a constant. If we remove the constant from R适合&#xff0c;我们得到与Python实现非常相似的结果&#xff0c;或者相反&#xff0c;如果我们向 statsmodel -fit添加一个常量&#…
阅读更多...
PostgreSQL开放自由

PostgreSQL开放自由

Open Liberty是源自WebSphere Liberty的有趣的新型OSS Java EE应用服务器。 您可以将Open Liberty配置为使用PostgreSQL作为其默认数据源&#xff0c;如下所示&#xff1a; 将<datasource> &#xff0c; <jdbcDriver>和<library>指令添加到server.xml配置中…
阅读更多...
实现mysql百度式查询_mysql查询优化建议(百度)

实现mysql百度式查询_mysql查询优化建议(百度)

1.对查询进行优化&#xff0c;应尽量避免全表扫描&#xff0c;首先应考虑在 where 及 order by 涉及的列上建立索引。2.应尽量避免在 where 子句中使用!或<>操作符&#xff0c;否则将引擎放弃使用索引而进行全表扫描。3.应尽量避免在 where 子句中对字段进行 null 值判断…
阅读更多...
海思芯片怎么使用tde给qt加速_3519移植Qt适配附件

海思芯片怎么使用tde给qt加速_3519移植Qt适配附件

【实例简介】修改Qt5.5.1linuxfb插件代码&#xff0c;适配海思3519平台【实例截图】【核心代码】3519Qt移植.tar├── 3519Qt绉绘│ ├── linuxfb│ │ ├── include│ │ │ ├── acodec.h│ │ │ ├── fisheye_calibrate.h│ │ │ ├─…
阅读更多...
jsf标签_多个动态包含一个JSF标签

jsf标签_多个动态包含一个JSF标签

jsf标签每个JSF开发人员都知道ui&#xff1a;include和ui&#xff1a;param标签。 您可以包括一个facelet&#xff08;XHTML文件&#xff09;并传递一个对象&#xff0c;该对象将在包含的facelet中可用&#xff0c;如下所示&#xff1a; <ui:include src"/sections/co…
阅读更多...
用Java比较文件

用Java比较文件

我正在为PACKT创建一系列有关Java网络编程的视频教程。 有整节关于Java NIO。 一个示例程序是通过原始套接字连接将文件从客户端复制到服务器。 客户端从磁盘读取文件&#xff0c;服务器将到达的字节保存到磁盘。 因为这是一个演示&#xff0c;所以服务器和客户端在同一台计算机…
阅读更多...
java哈希_Java如何采用哈希码实现分类（以员工分配为例）

java哈希_Java如何采用哈希码实现分类（以员工分配为例）

5.总程序&#xff1a;下面代码是我们获取的所有的程序代码&#xff0c;如下&#xff1a;public static void main(String[] args) {Scanner scannew Scanner(System.in);System.out.println("请输入员工姓名&#xff1a;");String namescan.nextLine();System.out.pr…
阅读更多...
java反射的原理_java反射机制的实现原理

java反射的原理_java反射机制的实现原理

java反射机制的实现原理反射机制:所谓的反射机制就是java语言在运行时拥有一项自观的能力。通过这种能力可以彻底的了解自身的情况为下一步的动作做准备。下面具体介绍一下java的反射机制。这里你将颠覆原来对java的理解。Java的反射机制的实现要借助于4个类&#xff1a;class&…
阅读更多...
java linkedlist 用法_Java LinkedList addLast()用法及代码示例

java linkedlist 用法_Java LinkedList addLast()用法及代码示例

Java中的java.util.LinkedList.addLast()方法用于在LinkedList的末尾插入特定元素。用法:void addLast(Object element)参数&#xff1a;此函数接受单个参数element &#xff0c;如上面的语法所示。此参数指定的元素将附加在列表的末尾。返回值&#xff1a;此方法不返回任何值。…
阅读更多...
最新文章

Copyright @ 2022~2023