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

吉安网站建设jxthw如何在虚拟机中建设网站

news 2025/10/25 14:20:19

吉安网站建设jxthw,如何在虚拟机中建设网站,如何做泛解析网站,定制网站的制作流程前言短信网关是企业和组织发送短信的重要工具，而 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;
}