代码拉取完成，页面将自动刷新
同步操作将从 二进制科技/短信协议中间件 强制同步，此操作会覆盖自 Fork 仓库以来所做的任何修改，且无法恢复！！！
确定后同步将在后台操作，完成时将刷新页面，请耐心等待。
此项目是基于netty的短信协议处理中间件，支持CMPP/SMGP/SGIP/SMPP等协议，集成了流速控制，实现了短信滑动窗口机制。此中间件已经成功应用在日发送量上亿的短信平台中，并且经受住了考验。
此项目为完全开源项目，您可以完全基于此开发您自己的商业项目。此项目仅仅是短信协议处理的中间件，如果您需要完整的短信解决方案，请参考我司开源的短信平台单机版 在了解此项目前，您需要熟悉相关的协议细节和短信发送流程。
github上已经有开源的短信中间件了，为什么还要再开发一套？因为我们发现好多新手包括有一定基础的开发者在内经常为短信提交速度上不去，连接莫名断开等问题困扰。 这个中间件就是要为开发者处理好这些坑点，屏蔽这些细节，让开发者更专注于业务本身。如果你不是netty老手，那选择我们的中间件吧！
此项目支持两种发送模式，一种是提供消息提供者实现，
滑动窗口是为了控制在收到对方response之前，我方系统同时发送的数据包的数量，同时也可起到平滑发送短信的目的。可类比TCP的滑动窗口原理，如下图所示：
此程序用于监听下游发送的短信请求，并向下游发送回执和上行，完整程序请参考com.drondea.sms.cmpp.CmppServerPullModeTest类
//监听端口
CmppServerSocketConfig socketConfig = new CmppServerSocketConfig("test", 7891);
//自定义实现的短信接受处理程序（会添加handler处理下游短信请求）
CmppServerCustomHandler customHandler = new CmppServerCustomHandler();
//服务器端默认版本号2.0
socketConfig.setVersion(CmppConstants.VERSION_20);
CmppServerSessionManager sessionManager = new CmppServerSessionManager(name -> {
//用户认证逻辑
if (name.startsWith("100003")) {
UserChannelConfig userChannelConfig = new UserChannelConfig();
userChannelConfig.setUserName(name);
userChannelConfig.setId(name);
//设置滑动窗口数量
userChannelConfig.setWindowSize(32);
userChannelConfig.setPassword("123123");
//设置用户限速
userChannelConfig.setQpsLimit(5000);
return userChannelConfig;
}
return null;
}, socketConfig, customHandler);
//设置消息提供者（从数据库或者缓存获取消息即可），这里获取的消息是回执或者上行短信
sessionManager.setMessageProvider(new MessageProvider() {
@Override
public List<IMessage> getTcpMessages(ChannelSession channelSession) {
int i = sum.incrementAndGet();
if (i > 2) {
return null;
}
CmppDeliverRequestMessage mo = new CmppDeliverRequestMessage();
SequenceNumber sequenceNumber = channelSession.getSequenceNumber();
mo.getHeader().setSequenceId(sequenceNumber.next());
mo.setRegisteredDelivery((short) 0);
mo.setMsgContent("TEST");
mo.setDestId("18010181663");
//收到响应的回调
mo.setMessageResponseHandler(new IMessageResponseHandler() {
@Override
public void messageComplete(IMessage request, IMessage response) {
System.out.println("完成:" + request.getSequenceId());
}
@Override
public void messageExpired(String key, IMessage request) {
System.out.println("短信超时======" + request.getSequenceId());
}
@Override
public void sendMessageFailed(IMessage request) {
System.out.println("send failure:" + request);
}
});
mo.setMsgFmt(SmsDcs.getGeneralDataCodingDcs(SmsAlphabet.RESERVED));
return CommonUtil.getLongMsgSlices(mo, channelSession.getConfiguration(), sequenceNumber);
}
@Override
public void responseMessageMatchFailed(String requestKey, IMessage response) {
}
});
sessionManager.doOpen();
此程序是向上游通道发送短信的入口程序，负责提交短信和接收上游的回执和上行短信，完整示例请参考com.drondea.sms.cmpp.CmppClientPullModeTest类
String host = "127.0.0.1";
//滑动窗口建议值为16
CmppClientSocketConfig socketConfig = new CmppClientSocketConfig("test",
10 * 1000, 16, host, 7891);
socketConfig.setChannelSize(1);
socketConfig.setUserName("100506");
socketConfig.setPassword("123123");
socketConfig.setVersion(CmppConstants.VERSION_20);
//限速 条/s
socketConfig.setQpsLimit(100);
//固定签名设置
// socketConfig.setSignatureDirection(SignatureDirection.CHANNEL_FIXED);
// socketConfig.setSignaturePosition(SignaturePosition.PREFIX);
// socketConfig.setSmsSignature("【庄点科技】");
//开启超时监控,设置监控间隔时间，这个值最好是RequestExpiryTimeout的1/2
socketConfig.setWindowMonitorInterval(10 * 1000);
//设置响应超时时间
socketConfig.setRequestExpiryTimeout(20 * 1000);
//注册通道登陆事件，添加回执和上行的处理器
CmppClientCustomHandler cmppCustomHandler = new CmppClientCustomHandler();
CmppClientSessionManager sessionManager = new CmppClientSessionManager(socketConfig, cmppCustomHandler);
//注册消息提供者，一般从MQ、缓存、数据库中获取数据
sessionManager.setMessageProvider(new MessageProvider() {
@Override
public List<IMessage> getTcpMessages(ChannelSession channelSession) {
int i = sum.incrementAndGet();
if (i > 5) {
return null;
}
CmppSubmitRequestMessage requestMessage = new CmppSubmitRequestMessage();
SequenceNumber sequenceNumber = channelSession.getSequenceNumber();
requestMessage.getHeader().setSequenceId(sequenceNumber.next());
String message = i + Math.random() + "第二次李白字太白，号青莲居士，【庄点】";
requestMessage.setMsgContent(message);
requestMessage.setServiceId("1");
requestMessage.setMsgSrc("AAAA");
requestMessage.setSrcId("" + (int) (Math.random() * 1000));
requestMessage.setRegisteredDelivery((short) 1);
requestMessage.setDestUsrTl((short) 1);
requestMessage.setDestTerminalId(new String[]{"17303110626"});
requestMessage.setSignature("【庄点科技】");
//收到响应的回调
requestMessage.setMessageResponseHandler(new IMessageResponseHandler() {
@Override
public void messageComplete(IMessage request, IMessage response) {
System.out.println("收到response:" + request.getSequenceId());
}
@Override
public void messageExpired(String key,IMessage request) {
System.out.println("短信超时======" + request.getSequenceId());
}
@Override
public void sendMessageFailed(IMessage request) {
System.out.println("短信发送失败:" + request);
}
});
requestMessage.setMsgFmt(SmsDcs.getGeneralDataCodingDcs(SmsAlphabet.RESERVED));
//长短信拆分
List<IMessage> longMsgSlices = CommonUtil.getLongMsgSlices(requestMessage, channelSession.getConfiguration(), channelSession.getSequenceNumber());
return longMsgSlices;
}
@Override
public void responseMessageMatchFailed(String requestKey, IMessage response) {
System.out.println("上游没有response的情况处理");
}
});
//创建链接
sessionManager.doOpen();
//定时检测连接，断开自动重连
sessionManager.doCheckSessions();
交流QQ群：
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。