当前位置：首页 > news >正文

淄博网站建设优惠臻动传媒/网络营销的12种手段

news 2025/7/2 12:33:41

淄博网站建设优惠臻动传媒,网络营销的12种手段,html5手机商城网站模板,网站的数据库丢失前言短信网关是企业和组织发送短信的重要工具，而 SMPP（Short Message Peer-to-Peer）协议是短信网关与短信中心（SMSC）之间通信的标准协议。随着技术的演进，某些旧的连接器（如 Adobe Campaign…

前言

短信网关是企业和组织发送短信的重要工具，而 SMPP（Short Message Peer-to-Peer）协议是短信网关与短信中心（SMSC）之间通信的标准协议。随着技术的演进，某些旧的连接器（如 Adobe Campaign Classic 中的 Unsupported Connector）可能不再被支持，需要迁移到新的解决方案。本文将深入解析 SMPP 协议的工作原理，并结合代码示例，探讨如何在迁移过程中实现高效、可靠的短信发送；另外有个包内的方法，我使用的版本是又问题的，文章已经附上解决方式。

1. SMPP 协议简介

SMPP 是一种开放、灵活的协议，用于在短信网关和短信中心之间传输短信。它支持多种消息类型（如文本、二进制、WAP Push 等），并提供了可靠的消息传递机制。SMPP 协议的主要优势包括：

高效性：支持批量消息发送和异步通信。
灵活性：适用于多种短信应用场景。
可靠性：提供了消息确认和重试机制。

2. SMPP 协议的核心组件

2.1 会话管理

SMPP 会话是短信网关与短信中心之间的通信通道。会话的类型包括：

BIND_TRX：双向通信，支持发送和接收短信。
BIND_TX：仅支持发送短信。
BIND_RX：仅支持接收短信。

2.2 消息格式

SMPP 消息由 PDU（Protocol Data Unit）组成，常见的 PDU 类型包括：

SubmitSm：用于提交短信。
DeliverSm：用于接收短信。
DataSm：用于发送和接收数据短信。

2.3 编码与解码

SMPP 支持多种字符编码（如 GSM 7-bit、UCS-2、ISO-8859-1），开发者需要根据目标设备的语言和字符集选择合适的编码方式。

3. 代码解析：SMPP 协议在 Java 中的实现

以下是一个使用 SMPP 协议发送短信的 Java 代码示例，代码逻辑清晰，功能完整：

3.1 代码结构

java

public Map<String, Object> smsGatewaySend(Map<String, Object> params) throws IOException {Map<String, Object> result = new HashMap<>();// 解析参数String systemId = String.valueOf(params.get("user"));String password = String.valueOf(params.get("password"));String mobile = String.valueOf(params.get("mobile"));String content = String.valueOf(params.get("content"));String host = String.valueOf(params.get("ip"));int port = Integer.parseInt(params.get("port") + "");String protocol = String.valueOf(params.get("protocol"));// 密码解密逻辑if ("......".equals(password) && params.containsKey("uuid")) {String passwordEncrypt = pmcMapper.selectSmsGatewayPassByUuid(String.valueOf(params.get("uuid")));password = pmcUtil.decryptStr(passwordEncrypt);}// 初始化 SMPP 会话SMPPSession session = new SMPPSession();try {// 连接并绑定短信中心String sessionResult = session.connectAndBind(host, port, new BindParameter(BindType.BIND_TRX, systemId, password, systemType,TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.ISDN, addressRange), 10000);// 设置消息接收监听器session.setMessageReceiverListener(new MessageReceiverListener() {@Overridepublic DataSmResult onAcceptDataSm(DataSm dataSm, Session session) throws ProcessRequestException {return null;}@Overridepublic void onAcceptDeliverSm(DeliverSm deliverSm) throws ProcessRequestException {}@Overridepublic void onAcceptAlertNotification(AlertNotification alertNotification) {}});// 检查会话状态if (session.getSessionState() == SessionState.BOUND_TRX) {// 准备发送短信ESMClass eSMClass = new ESMClass();RegisteredDelivery registeredDelivery = new RegisteredDelivery();DataCoding dataCoding = new GeneralDataCoding(Alphabet.ALPHA_UCS2, GeneralDataCoding.DEFAULT.getMessageClass());log.info("================================Connection successful. Ready to send SMS================================");// 设置会话超时时间session.setTransactionTimer(50 * 1000);OptionalParameter[] optionalParameters = new OptionalParameter[]{};byte[] contentBytes = content.getBytes(StandardCharsets.UTF_16BE);List<byte[]> chunks = splitContentIntoChunks(contentBytes, Integer.parseInt(maxContentLength));// 发送短信boolean allSentSuccessfully = true;List<String> messageIdList = new ArrayList<>();for (byte[] chunk : chunks) {SubmitSmResult sendResult = session.submitShortMessage("", TypeOfNumber.ALPHANUMERIC,NumberingPlanIndicator.ISDN, "PMCTest",TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.ISDN, mobile, eSMClass,(byte) 0, (byte) 0, "", "", registeredDelivery,(byte) 0, dataCoding, (byte) 0, chunk, optionalParameters);if (sendResult == null) {allSentSuccessfully = false;break;}messageIdList.add(sendResult.getMessageId());}// 处理发送结果if (allSentSuccessfully) {result.put("success", true);result.put("messageId", messageIdList);result.put("error", "Send successfully.");} else {result.put("success", false);result.put("error", "Failed to send SMS");}} else {result.put("success", false);result.put("error", "Gateway connection failed.");}} catch (ResponseTimeoutException | PDUException | InvalidResponseException | NegativeResponseException e) {result.put("success", false);result.put("error", "Failed to send SMS");return result;} finally {session.unbindAndClose();}// 等待一段时间try {Thread.sleep(Long.parseLong(sleepTime == null || "".equals(sleepTime) ? "10" : sleepTime));} catch (InterruptedException e) {log.error("SMS Gateway Interrupted Error");}return result;
}