suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: 优化mqtt 客户端配置

This commit is contained in:
zhouhao 2024-12-05 16:56:59 +08:00
parent d2772e8881
commit 13dd4e5e40
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProperties.java
View File

@ -38,7 +38,7 @@ public class MqttClientProperties extends AbstractClientNetworkConfig {
private String certId;
//最大消息长度
private int maxMessageSize = 1024*1024;
private int maxMessageSize = 0XFFFFFF;
//共享订阅前缀
private String topicPrefix;

4
jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProvider.java
View File

@ -56,6 +56,7 @@ public class MqttClientProvider implements NetworkProvider<MqttClientProperties>
// options.setReconnectAttempts(10);
template.setAutoKeepAlive(true);
template.setKeepAliveInterval(180);
template.setMaxInflightQueue(65535);
}
@Nonnull
@ -132,7 +133,7 @@ public class MqttClientProvider implements NetworkProvider<MqttClientProperties>
private Mono<MqttClientOptions> convert(MqttClientProperties config) {
MqttClientOptions options = FastBeanCopier.copy(config, new MqttClientOptions(template));
MqttClientOptions options = new MqttClientOptions(template);
String clientId = String.valueOf(config.getClientId());
@ -143,6 +144,7 @@ public class MqttClientProvider implements NetworkProvider<MqttClientProperties>
options.setClientId(clientId);
options.setPassword(password);
options.setUsername(username);
options.setMaxMessageSize(config.getMaxMessageSize());
if (config.isSecure()) {
options.setSsl(true);