springboot smpp demo 短信通信协议
springboot smpp server demo
1.依赖项
首先，您需要使用以下Maven依赖项之一创建Spring Boot项目：
<dependency>
<groupId>com.cloudhopper</groupId>
<artifactId>ch-smpp</artifactId>
<version>5.0.7</version>
</dependency>
2.代码
创建一个名为SmppServerApplication的类，并使用@SpringBootApplication注释它以启用Spring Boot：
@SpringBootApplication
public class SmppServerApplication {
public static void main(String[] args) {
SpringApplication.run(SmppServerApplication.class, args);
}
}
下一步是创建一个名为SmppServerConfiguration的类，并使用@Configuration注释它。在此类中，您将使用@Bean注释定义SMPP服务器。
@Configuration
public class SmppServerConfiguration {
@Bean
public SmppServer smppServer() throws SmppInvalidArgumentException {
DefaultSmppServerConfiguration configuration = new DefaultSmppServerConfiguration();
configuration.setPort(2776); // SMPP服务器端口
configuration.setMaxConnectionSize(10); // 最大连接数
configuration.setDefaultWindowSize(10); // 每条SMPP会话的默认窗口大小
configuration.setDefaultRequestExpiryTimeout(30000L); // 每个SMPP请求的默认到期时间（以毫秒为单位）
configuration.setDefaultWindowMonitorInterval(15000L); // 窗口监视器运行的默认时间（以毫秒为单位）
configuration.setDefaultSessionCountersEnabled(true); // 默认启用会话计数器
configuration.setNonBlockingSocketsEnabled(true); // 禁用阻塞式SOCKET
return new DefaultSmppServer(configuration, new SmppServerHandler());
}
}
在此示例中，我们使用端口号2776在默认配置下创建SMPP服务器并将其连接到SmppServerHandler类实例。在下一步中，我们将创建一个名为SmppServerHandler的类。
在SmppServerHandler类中，我们将实现SmppSessionHandler接口。这个接口具有许多方法，如firePduReceived，fireExpectedPduResponseReceived，fireChannelUnexpectedlyClosed等等。我们的任务是为以下方法提供适当的处理：
public class SmppServerHandler implements SmppSessionHandler {
private Logger logger = LoggerFactory.getLogger(SmppServerHandler.class);
public boolean firePduReceived(Pdu pdu) {
logger.info("收到请求: {}", pdu);
try {
this.getContext().serverSession().sendPdu(pdu.createResponse());
} catch (Exception e) {
logger.error("发送响应时出错:", e);
return false;
}
return true;
}
public void fireExpectedPduResponseReceived(Pdu pdu, Pdu response) {
logger.info("收到响应: {}, 相应: {}", pdu, response);
}
public void fireChannelUnexpectedlyClosed() {
logger.info("连接关闭");
}
public void firePduRequestExpired(Pdu pdu) {
logger.warn("请求 {} 到期", pdu);
}
public void fireExpectedPduRequestExpired(Pdu pdu) {
logger.warn("期望的请求 {} 到期", pdu);
}
public void fireUnrecoverablePduException(Throwab
以上实现中的firePduReceived方法从收到的PDU中发送一个响应。其他方法可根据您的要求进行更改和实现。
3.测试
现在，您已经准备好为SMPP服务器编写Junit测试用例。以下是一个基本测试：
@SpringBootTest
class SmppServerApplicationTests {
@Autowired
SmppServer smppServer;
@Test
void contextLoads() throws Exception {
assertNotNull(smppServer);
logger.info("SMPP服务器已启动并运行中 ...");
}
}
在此示例中，我们使用@Autowired注释注入SMPP服务器，并检查变量是否为null。然后，我们记录一条消息以指示SMPP服务器已成功启动。
4.部署
最后，您可以使用Maven构建并打包项目：
mvn clean package
完成后，您可以将jar文件移到另一个服务器，并使用以下命令运行它：
java -jar smpp-server.jar
恭喜！您已成功创建了一个使用Spring Boot和CloudHopper SMPP库的SMPP服务器。
springboot smpp client demo
- 依赖项
您需要使用以下Maven依赖项之一来创建Spring Boot项目：
<dependency>
<groupId>com.cloudhopper</groupId>
<artifactId>ch-smpp</artifactId>
<version>5.0.7</version>
</dependency>
- 代码
首先，您需要创建一个名为SmppClientConfiguration的类，并使用@Configuration注释它。在此类中，您将使用@Bean注释定义SMPP客户端。
@Configuration
public class SmppClientConfiguration {
@Value("${smpp.host}")
private String host;
@Value("${smpp.port}")
private Integer port;
@Value("${smpp.systemId}")
private String systemId;
@Value("${smpp.password}")
private String password;
@Bean(initMethod = "start", destroyMethod = "stop")
public SmppClient smppClient() throws SmppInvalidArgumentException {
DefaultSmppSessionHandler handler = new ClientSmppSessionHandler();
DefaultSmppSessionConfiguration sessionConfig = new DefaultSmppSessionConfiguration();
sessionConfig.setType(SmppBindType.TRANSCEIVER);
sessionConfig.setHost(host);
sessionConfig.setPort(port);
sessionConfig.setSystemId(systemId);
sessionConfig.setPassword(password);
sessionConfig.setRequestExpiryTimeout(30000L);
sessionConfig.setWindowSize(100);
sessionConfig.setConnectTimeout(10000L);
sessionConfig.setCountersEnabled(true);
SmppSession session = new DefaultSmppClient(sessionConfig, handler).bind();
log.info("绑定到SMPP服务器{}", session.getConfiguration().getHost());
return new SmppClient(session);
}
}
该类使用注释@Value从配置文件中获取主机名，端口，系统ID和密码，并使用这些信息创建一个DefaultSmppSessionConfiguration。使用这的信息创建的DefaultSmppSessionConfiguration是一个创建SMTP客户端的做法。
下一步是创建一个名为ClientSmppSessionHandler的类，并实现SmppSessionHandler接口，实现以下方法：
public class ClientSmppSessionHandler implements SmppSessionHandler {
private Logger logger = LoggerFactory.getLogger(ClientSmppSessionHandler.class);
public boolean firePduReceived(Pdu pdu) {
logger.info("客户端接收到请求：{}", pdu);
return true;
}
public void fireExpectedPduResponseReceived(Pdu pdu, Pdu response) {
logger.info("客户端接收到响应：{}，响应：{}", pdu, response);
}
public void fireChannelUnexpectedlyClosed() {
logger.info("客户端连接关闭");
}
public void firePduRequestExpired(Pdu pdu) {
logger.warn("客户端请求 {} 到期", pdu);
}
public void fireExpectedPduRequestExpired(Pdu pdu) {
logger.warn("客户端期望的请求 {} 到期", pdu);
}
public void fireUnrecoverablePduException(Throwable e) {
logger.error("客户端异常出现", e);
}
}
在此示例中，我们只是记录了一些日志信息，并且没有实际的业务逻辑。
- 测试
现在，您已经准备好为SMPP客户端编写Junit测试用例。以下是一个基本测试：
@SpringBootTest
public class SmppClientApplicationTests {
@Autowired
private SmppClient smppClient;
@Test
public void contextLoadsTest() {
assertNotNull(smppClient);
}
}
在这个例子中，我们使用@Autowired注解注入SmppClient，并检查其是否为null。
- 部署
最后，您可以使用Maven构建并打包项目：
mvn clean package
完成后，您可以将jar文件移到另一个服务器，并使用以下命令运行它：
java -jar smpp-client.jar
恭喜！您已成功创建了一个使用Spring Boot和CloudHopper SMPP库的SMPP客户端。