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）