1.依赖项
首先,您需要使用以下Maven依赖项之一创建Spring Boot项目:
com.cloudhopper ch-smpp 5.0.7
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 {@Beanpublic 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); // 禁用阻塞式SOCKETreturn 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 {@AutowiredSmppServer smppServer;@Testvoid 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服务器。
您需要使用以下Maven依赖项之一来创建Spring Boot项目:
com.cloudhopper ch-smpp 5.0.7
首先,您需要创建一个名为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 {@Autowiredprivate SmppClient smppClient;@Testpublic void contextLoadsTest() {assertNotNull(smppClient);}
}
在这个例子中,我们使用@Autowired注解注入SmppClient,并检查其是否为null。
最后,您可以使用Maven构建并打包项目:
mvn clean package
完成后,您可以将jar文件移到另一个服务器,并使用以下命令运行它:
java -jar smpp-client.jar
恭喜!您已成功创建了一个使用Spring Boot和CloudHopper SMPP库的SMPP客户端。
下一篇:【C++】一文教你认识模板