​SMPP协议在短信网关中的应用与迁移指南​附上文档地址（另外有个包内的方法，我使用的版本是又问题的，文章已经附

​前言

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

---

​目录 SMPP 协议简介SMPP 协议的核心组件代码解析：SMPP 协议在 Java 中的实现迁移指南：从 Unsupported Connector 到新的解决方案总结与最佳实践

---

​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() { @Override public DataSmResult onAcceptDataSm(DataSm dataSm, Session session) throws ProcessRequestException { return null; } @Override public void onAcceptDeliverSm(DeliverSm deliverSm) throws ProcessRequestException {} @Override public 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; } 过程判断一直过不去，重新的包已经附件上传 ​3.2 代码优化建议 ​参数校验：在解析参数时，增加对空值和异常值的校验。​日志记录：在关键步骤中添加详细的日志记录，便于排查问题。​异常处理：细化异常处理逻辑，针对不同类型的异常采取不同的处理策略。​性能优化：优化短信分块发送逻辑，减少网络延迟对性能的影响。

---

​4. 迁移指南：从 Unsupported Connector 到新的解决方案

根据 Adobe Campaign Classic 的文档，迁移 Unsupported Connector 到新的解决方案需要以下步骤：

​4.1 评估现有功能 确定当前使用的功能和配置（如 SMPP 版本、编码方式、消息类型等）。分析现有代码的逻辑和依赖关系。 ​4.2 选择新的解决方案 选择支持 SMPP 协议的短信网关解决方案（如 Adobe Campaign Classic 支持的连接器）。确保新解决方案兼容现有的短信中心和设备。 ​4.3 迁移代码 将现有代码中的 Unsupported Connector 替换为新的连接器。测试新代码的功能和性能，确保迁移后短信发送的稳定性和可靠性。 ​4.4 验证与测试 在测试环境中验证新解决方案的功能。监控短信发送的成功率和延迟，确保满足业务需求。

---

​5. 总结与最佳实践 ​总结 SMPP 协议是短信网关与短信中心之间通信的重要标准，具有高效、灵活和可靠的特点。在迁移 Unsupported Connector 时，需要评估现有功能、选择新的解决方案、迁移代码并验证测试。通过优化代码和遵循最佳实践，可以提升短信发送的效率和稳定性。 ​最佳实践 ​参数校验：确保输入参数的有效性和安全性。​日志记录：在关键步骤中添加详细的日志记录。​异常处理：细化异常处理逻辑，提高代码的健壮性。​性能优化：优化短信分块发送逻辑，减少网络延迟的影响。 ​参考资料 Adobe Campaign Classic 文档（）SMPP 协议规范Java SMPP 实现（不支持的短信连接器迁移 | Adobe Campaign）