diff --git a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProperties.java b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProperties.java
index a61338e5..0606d5df 100755
--- a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProperties.java
+++ b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProperties.java
@@ -38,7 +38,7 @@ public class MqttClientProperties extends AbstractClientNetworkConfig {
     private String certId;
 
     //最大消息长度
-    private int maxMessageSize = 1024*1024;
+    private int maxMessageSize = 0XFFFFFF;
 
     //共享订阅前缀
     private String topicPrefix;
diff --git a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProvider.java b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProvider.java
index 64241f25..7491465b 100755
--- a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProvider.java
+++ b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/client/MqttClientProvider.java
@@ -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);