diff --git a/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/broker/topic/TopicMatcherTest.java b/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/broker/topic/TopicMatcherTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..1cf9ac6efc5d296dc4298e2e2e89c58372eca53a
--- /dev/null
+++ b/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/broker/topic/TopicMatcherTest.java
@@ -0,0 +1,68 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
+package org.smartboot.mqtt.broker.topic;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.smartboot.mqtt.broker.BrokerTopic;
+import org.smartboot.mqtt.common.TopicToken;
+import org.smartboot.mqtt.common.util.MqttUtil;
+
+/**
+ * @author 三刀（zhengjunweimail@163.com）
+ * @version V1.0 , 2022/4/3
+ */
+public class TopicMatcherTest {
+
+ @Test
+ public void testMatcher() {
+ BrokerTopic topic = new BrokerTopic("/a");
+ TopicToken topicToken = new TopicToken("#");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a");
+ topicToken = new TopicToken("/#");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a");
+ topicToken = new TopicToken("+/#");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a/b/c");
+ topicToken = new TopicToken("/#");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a/b/c");
+ topicToken = new TopicToken("#");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a/b/c");
+ topicToken = new TopicToken("/a/b/c");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a/b/c");
+ topicToken = new TopicToken("a/b/c");
+ Assert.assertFalse(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a/b/c");
+ topicToken = new TopicToken("/+/b/+");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a");
+ topicToken = new TopicToken("/+");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+
+ topic = new BrokerTopic("/a");
+ topicToken = new TopicToken("+/+");
+ Assert.assertTrue(MqttUtil.match(topic.getTopicToken(), topicToken));
+ }
+
+}
diff --git a/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/enterprise/topic/TopicMatcherTest.java b/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/enterprise/topic/TopicMatcherTest.java
deleted file mode 100644
index cb6325bcdcba2c5874e51fadb7324168271cc2ca..0000000000000000000000000000000000000000
--- a/smart-mqtt-broker/src/test/java/org/smartboot/mqtt/enterprise/topic/TopicMatcherTest.java
+++ /dev/null
@@ -1,58 +0,0 @@
-package org.smartboot.mqtt.enterprise.topic;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.smartboot.mqtt.common.Topic;
-import org.smartboot.mqtt.common.TopicToken;
-import org.smartboot.mqtt.common.util.TopicTokenUtil;
-
-/**
- * @author 三刀（zhengjunweimail@163.com）
- * @version V1.0 , 2022/4/3
- */
-public class TopicMatcherTest {
-
- @Test
- public void testMatcher() {
- Topic topic = new Topic("/a");
- TopicToken topicToken = new TopicToken("#");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a");
- topicToken = new TopicToken("/#");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a");
- topicToken = new TopicToken("+/#");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a/b/c");
- topicToken = new TopicToken("/#");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a/b/c");
- topicToken = new TopicToken("#");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a/b/c");
- topicToken = new TopicToken("/a/b/c");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a/b/c");
- topicToken = new TopicToken("a/b/c");
- Assert.assertFalse(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a/b/c");
- topicToken = new TopicToken("/+/b/+");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a");
- topicToken = new TopicToken("/+");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
-
- topic = new Topic("/a");
- topicToken = new TopicToken("+/+");
- Assert.assertTrue(TopicTokenUtil.match(topic.getTopicToken(), topicToken));
- }
-
-}
diff --git a/smart-mqtt-client/pom.xml b/smart-mqtt-client/pom.xml
index 3715956da47803f2fe8179334b7749c2b22053d3..6350be7a88bbd8302f9e726ae31454c91906bd2e 100644
--- a/smart-mqtt-client/pom.xml
+++ b/smart-mqtt-client/pom.xml
@@ -5,7 +5,7 @@
smart-mqtt
org.smartboot.mqtt
- 0.17
+ 0.18
../pom.xml
4.0.0
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClient.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClient.java
index 19918d9d8df91dfcffb8ec39a2ceacc06f1132a6..a8688d273ce0a6b81ea2dca19098846ca2cac55f 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClient.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClient.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client;
import org.apache.commons.lang.StringUtils;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientConfigure.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientConfigure.java
index 98c8755956ba3ff2173134349ebfafd2081444a7..965aad455d545f653f0cf84fc0102e2873701c50 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientConfigure.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientConfigure.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client;
import org.smartboot.mqtt.common.enums.MqttQoS;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientProcessor.java
index b89238bb82fd3f07a8f430b52621f1217aa236fa..cb87d9b03be49ff9522a264e072fb0ecc5adf9b6 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/MqttClientProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client;
import org.slf4j.Logger;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/Subscribe.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/Subscribe.java
index 3375a1320000583e2be2cf6bc0e0c58dd586814a..620ce7ef075d327b93838c05c2208185cf9efaca 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/Subscribe.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/Subscribe.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client;
import org.smartboot.mqtt.common.enums.MqttQoS;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/TopicListener.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/TopicListener.java
index 48a723719e374220c7b54d0e5ac80057bd27ecf1..7b602079b3133112fb7e1157f25f879ad29987d1 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/TopicListener.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/TopicListener.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client;
import org.smartboot.mqtt.common.enums.MqttQoS;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/ConnAckProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/ConnAckProcessor.java
index e3e0e2bf97625d211c92a31f0f6520d841e91fb6..a7594af6a269f137b6ffbd1410a38ffcc87488bc 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/ConnAckProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/ConnAckProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client.processor;
import org.slf4j.Logger;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttAckProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttAckProcessor.java
index e7bef87cc63f11bf0e35242753988058d6590248..cb398df7d0c9bfb099a6026ae0cf911a7b492a81 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttAckProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttAckProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client.processor;
import org.smartboot.mqtt.client.MqttClient;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttPingRespProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttPingRespProcessor.java
index 65ae8a8b984e9fa98ff89878c722f6fd789a476c..fa224dc350055e0c2f529479e4189931fdf96622 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttPingRespProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttPingRespProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client.processor;
import org.slf4j.Logger;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttProcessor.java
index 2984a49113957aa92ae2c6dfc101d063878c0132..26bef0651295f9b5e0686e25b70e5f79bde59658 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/MqttProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client.processor;
import org.smartboot.mqtt.client.MqttClient;
diff --git a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/PublishProcessor.java b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/PublishProcessor.java
index cf3b1e87e8c14f0c920a2a534bda3d1d5fcb027c..f4559f9cc928eef254523d3c57f83b063b8d0611 100644
--- a/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/PublishProcessor.java
+++ b/smart-mqtt-client/src/main/java/org/smartboot/mqtt/client/processor/PublishProcessor.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.client.processor;
import org.slf4j.Logger;
@@ -15,7 +25,7 @@ import org.smartboot.mqtt.common.message.MqttPublishMessage;
import org.smartboot.mqtt.common.message.variable.MqttPubQosVariableHeader;
import org.smartboot.mqtt.common.message.variable.MqttPublishVariableHeader;
import org.smartboot.mqtt.common.message.variable.properties.ReasonProperties;
-import org.smartboot.mqtt.common.util.TopicTokenUtil;
+import org.smartboot.mqtt.common.util.MqttUtil;
import org.smartboot.mqtt.common.util.ValidateUtils;
/**
@@ -68,7 +78,7 @@ public class PublishProcessor implements MqttProcessor
{
private static Subscribe matchWildcardsSubscribe(MqttClient mqttClient, String topicName) {
TopicToken publicTopicToken = new TopicToken(topicName);
- TopicToken matchToken = mqttClient.getWildcardsToken().stream().filter(topicToken -> TopicTokenUtil.match(publicTopicToken, topicToken)).findFirst().orElse(null);
+ TopicToken matchToken = mqttClient.getWildcardsToken().stream().filter(topicToken -> MqttUtil.match(publicTopicToken, topicToken)).findFirst().orElse(null);
return matchToken != null ? mqttClient.getSubscribes().get(matchToken.getTopicFilter()) : null;
}
diff --git a/smart-mqtt-common/pom.xml b/smart-mqtt-common/pom.xml
index 6c75836c2044ee7e10cd7aebbc04999988185ae5..c8d8bc1ca84b60ed6048a499892d863687eb04c5 100644
--- a/smart-mqtt-common/pom.xml
+++ b/smart-mqtt-common/pom.xml
@@ -5,7 +5,7 @@
smart-mqtt
org.smartboot.mqtt
- 0.17
+ 0.18
../pom.xml
4.0.0
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AbstractSession.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AbstractSession.java
index 9089142433cc5bfb4847af040c9c5b5747983fe5..69e2ddc13dedce40c282df7ebd357c15e4dca2e0 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AbstractSession.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AbstractSession.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AsyncTask.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AsyncTask.java
index a01b536d85793c6478e696c9934428c0b6b2abf9..6822ae1a3dee1939c597e01a867abf0aa41049ef 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AsyncTask.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/AsyncTask.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/DefaultMqttWriter.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/DefaultMqttWriter.java
index 533046383a95130b9f8b96fd7219c3315dbc17a0..7b1738046b1f0e6d0ab3f782babc2b9524597f7e 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/DefaultMqttWriter.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/DefaultMqttWriter.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.smartboot.socket.transport.WriteBuffer;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightMessage.java
index 2431fb30dc1b1b0c0dda2103edd4e54e705a5925..168c10d77fbf377fc25fb38152e59822ccfb6b96 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.smartboot.mqtt.common.enums.MqttMessageType;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightQueue.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightQueue.java
index 3dd3cfb14ef3bee55f455897b18c084d7b86538d..af08078ad302f9ebe9654acbb760b1a02d248b49 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightQueue.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/InflightQueue.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/MqttWriter.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/MqttWriter.java
index ff1faf261adfbb23c08cd5f04cb85fd6ed360efe..025d0e307a1e67d8c465ead6bf2c8ec3ace87658 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/MqttWriter.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/MqttWriter.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import java.io.IOException;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosMessage.java
index aaea1551b44c46ad61d3d8329c987c4df5ad7393..fde98f7a25114a0b11bb60e4d35ecc62d9102808 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.smartboot.mqtt.common.message.MqttPacketIdentifierMessage;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosRetryPlugin.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosRetryPlugin.java
index 445451bb479e22bd0080c7342521d03dde76d06d..1f3e5ab6e634531348666690ac03e7b765066fe9 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosRetryPlugin.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/QosRetryPlugin.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.smartboot.mqtt.common.message.MqttMessage;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/ToString.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/ToString.java
index b7a38a0e86eb302ed77f1b5dacef3199d22f833a..37257fe6d87de877c6256f138eb4e1923233b2ad 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/ToString.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/ToString.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/Topic.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/Topic.java
deleted file mode 100644
index dff590d1409846b029adf8ddfd770e017a3af2c4..0000000000000000000000000000000000000000
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/Topic.java
+++ /dev/null
@@ -1,28 +0,0 @@
-package org.smartboot.mqtt.common;
-
-public class Topic extends ToString {
- /**
- * 主题名
- */
- private final String topic;
-
- private final TopicToken topicToken;
-
- public Topic(String topic) {
- this.topic = topic;
- this.topicToken = new TopicToken(topic);
- }
-
- public TopicToken getTopicToken() {
- return topicToken;
- }
-
- public String getTopic() {
- return topic;
- }
-
- @Override
- public String toString() {
- return topic;
- }
-}
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/TopicToken.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/TopicToken.java
index f83b8738caedc8b56b9917955c6411e02f4e5a94..fc007c603e787b3334c1e5f07909ce051a49f83a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/TopicToken.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/TopicToken.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common;
import org.smartboot.mqtt.common.util.ValidateUtils;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MetricTypeEnum.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MetricTypeEnum.java
index 9104f8d8a76ef9167413adb0cd12e131bad3bc9f..0553ab12543de67420265d8e4ccb1de5675b5a75 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MetricTypeEnum.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MetricTypeEnum.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReasonCode.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReasonCode.java
index b5e6c8969a7230caf52bbcf20d96a53576702546..7cf9662e14eb1b47e99d761c10f5b3bd463b3e2a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReasonCode.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReasonCode.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReturnCode.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReturnCode.java
index 322af3e1240037feab710b8e0774712064a3f77a..89b8fc156408c16d7a24fb66f2eec8099ca5764c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReturnCode.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttConnectReturnCode.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMessageType.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMessageType.java
index 03ffa051b2bb01d04b06f7e9b306015f47e16582..5e464cb40f64e4a6ada758f62a5f792c6cc251a8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMessageType.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMessageType.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMetricEnum.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMetricEnum.java
index 2c9ebe2d6cafa3f16211f71a22ad6aac5218953c..b9609df08ad6642eaa5f536a64d113c002279ca4 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMetricEnum.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttMetricEnum.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttPacketDirectionEnum.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttPacketDirectionEnum.java
index d2fe5ab95f3e4cae3257d541e14fac8f552e654f..9bf635b60fc26491d1a365f4e5ee44b3cd8c9904 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttPacketDirectionEnum.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttPacketDirectionEnum.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttProtocolEnum.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttProtocolEnum.java
index 088dbd883294f324df12d028455f9e02a5b7ed8d..1c46d55fd17c4592dc6b6f35a51bdeafe6a5ed5f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttProtocolEnum.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttProtocolEnum.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttQoS.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttQoS.java
index bbfacee53a996eb83ebbb5f261bac09d58b0a1f8..fbea20c5dcdbd332836cbc6614b2eeeaa6fe6d42 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttQoS.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttQoS.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttReasonCode.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttReasonCode.java
index aecd578d8306062ba3266cfcea5521219d9ce5cf..56b5567a3bfb65d7fdceb490815c29e0a90ea7ae 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttReasonCode.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttReasonCode.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttTopicFilterEnum.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttTopicFilterEnum.java
index a16776a5c7a0f0a1971c5eea52fec3fac86200a3..7c86b7283244703cafee062b93327c0aba13978a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttTopicFilterEnum.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttTopicFilterEnum.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttVersion.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttVersion.java
index fc242f07eb8c002d822f21565a79861281228bee..8b5c9989406f8c0b026004736626b0a01269dd80 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttVersion.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/enums/MqttVersion.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.enums;
public enum MqttVersion {
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/DisposableEventBusSubscriber.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/DisposableEventBusSubscriber.java
index e93c9d926b1d0ecc8228cf6b087086ef1fd0d29b..5fd1305d8e7a3c9c1a0ca62e665dddb79b77f8ca 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/DisposableEventBusSubscriber.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/DisposableEventBusSubscriber.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBus.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBus.java
index 6271696da281f46d3100a6e313af6a73adb6a480..d30028275c21473fbbbda88f8244d55daee74524 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBus.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBus.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
import java.util.List;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusImpl.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusImpl.java
index 6c336a323b127f67e0fc8bef8f595d5ce3f9ba33..05903810615bce16e805cad60dd99a4fd1dccd9f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusImpl.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusImpl.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusSubscriber.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusSubscriber.java
index aa099bd48cd4fd682001f41b7db3e45297146431..00984b47c816e36882248f798a3c44fda255c7b8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusSubscriber.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventBusSubscriber.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventObject.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventObject.java
index 2ed887972c951958795e4c338d1e3769981b931a..e5156fd8a9c34941dc016e1a7d03f12e15f75c42 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventObject.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventObject.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
import org.smartboot.mqtt.common.AbstractSession;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventType.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventType.java
index d61004fb4efac68409c5b18b20501e08a01209ee..f3e02c4562719686cfb82dfa560d24e611957672 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventType.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/EventType.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus;
import org.smartboot.mqtt.common.AbstractSession;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/subscriber/MessageLoggerSubscriber.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/subscriber/MessageLoggerSubscriber.java
index 0a9fda4f0c4d6c0b86a11cc14236120eae9d988f..347590a8523716ef9ee072f2abddcf99953e15d8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/subscriber/MessageLoggerSubscriber.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/eventbus/subscriber/MessageLoggerSubscriber.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.eventbus.subscriber;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/exception/MqttException.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/exception/MqttException.java
index b766b55ba23eda6562df255f94d1ff0b9f867c5f..0cf5a439ff86b05ef535bd252e5b699b80a04e6b 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/exception/MqttException.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/exception/MqttException.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.exception;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/Codec.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/Codec.java
index 8ba7a1f1f000e442bfb1639d6499e21172e9f72a..c671ae3896134fdb01ba96cc4a75bc0afa052ba7 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/Codec.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/Codec.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttCodecUtil.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttCodecUtil.java
index 5bf8d6a1ac308c772f6cc1edba424a87b8691a25..963c80367a2776aa0edcbe32d12a7cb5f8143287 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttCodecUtil.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttCodecUtil.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnAckMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnAckMessage.java
index e8e8bf3a073c0b1f750a57cf5d936a9e3bea9ce2..7be6b393b6edae64c756eb6160bbaf04ae641b7f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnAckMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnAckMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttConnectReturnCode;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnectMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnectMessage.java
index 1cf71fe16b417f4a0f7d298c38bc27e5775eac47..22a64b58147ff77b621c01ab64562c22573f99cf 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnectMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttConnectMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttProtocolEnum;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttDisconnectMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttDisconnectMessage.java
index 7735f7b6895d5c5b5e58b93044e0ab816d0a7a4d..d4ecdaa102f6e78d583b4989407ad25f907b8b1c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttDisconnectMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttDisconnectMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttFixedHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttFixedHeader.java
index 18f11280a86aed9619026f6323af67e1c6a27516..681477635c35701009ffde1d182dbeb3c8cf9438 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttFixedHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttFixedHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.ToString;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttMessage.java
index b3c21fb98277d3fbb1b8301a648d62ac518b4197..fc34070b0bd40b7d068e539674b7ae85bfed824c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPacketIdentifierMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPacketIdentifierMessage.java
index e9cb57355aaf25fed4d380d8805a5894b3c225e0..a80b38a539e8531f08554adb6ae54a05fb6448bc 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPacketIdentifierMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPacketIdentifierMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.MqttPacketIdVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingReqMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingReqMessage.java
index cf57de6df8502b1c7959bfe350f6b149df87c4cd..c35a286c62da4405cc6d04fd4a8b477c58df2dbb 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingReqMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingReqMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingRespMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingRespMessage.java
index 86fa2e758de5890082c94c6a0640f1b131cfca89..b515915bf6bc32f826975e2a14b8af03adf88454 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingRespMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPingRespMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubAckMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubAckMessage.java
index 469537e71896dd533599bbe1d7c3035715e6d965..220ccce45be09d6347aafb06ac3421dbe6885509 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubAckMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubAckMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.MqttPubQosVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubCompMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubCompMessage.java
index 9aef5a921fb56525d9d6b62f566ce1f887b0b37f..c7af306dcc1814130efcc267bb1f9c650ea11c7a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubCompMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubCompMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.MqttPubQosVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubQosMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubQosMessage.java
index ee919235b6373f41d0a137374b041e462d98e6fa..72a53dcc043ddcd0a6a5a1ad8f2955faf19f9995 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubQosMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubQosMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttVersion;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRecMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRecMessage.java
index 6e9c018ea86969e6b3deaf1af00c4f257d818032..e70873b01b5cd290a194326f7f588ed3bfe09540 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRecMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRecMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.MqttPubQosVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRelMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRelMessage.java
index 84c7f99281cb98f11234d95ecf04267572302203..112fa064905ffba5bdc60792ea7099421cf20b7f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRelMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPubRelMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.MqttPubQosVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPublishMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPublishMessage.java
index 4d6f8293c0555d44408d3f21bba3c402fc660f62..7e3af42219aef744896501a7ae7af4fac8bcb371 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPublishMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttPublishMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttVersion;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubAckMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubAckMessage.java
index 1c5b3a2fc97408a2b1bcce9b986ad7c8e5a2a4a7..58280e458e248c60d62e8a9e9e389bbcbe7f8727 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubAckMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubAckMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttVersion;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubscribeMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubscribeMessage.java
index 2132b532d1dc4ebe3fae0265408a21095420bfbd..78ee399787d69d66fd1af523c4bdc44e00439e1f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubscribeMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttSubscribeMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttQoS;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttTopicSubscription.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttTopicSubscription.java
index dd1f471d88ab3d93f3fbc0791c940bc792047e89..b43c258adc4fe118838d0a60715e224d0b5faf4d 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttTopicSubscription.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttTopicSubscription.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.ToString;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubAckMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubAckMessage.java
index ae38d852817b7492691ff2e4d22a0d70dc1c8294..dc68b4afc8e3fed07b1abaae87ba5f753a83b70a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubAckMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubAckMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.payload.Mqtt5UnsubAckPayload;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubscribeMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubscribeMessage.java
index 53c142bd2bd2822fdb10fa8721ee320ebb29cfd5..66f435eeb2ee5a2c31d9b43bb6f8dfe2b0727072 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubscribeMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttUnsubscribeMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.enums.MqttVersion;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableHeader.java
index decb8ab9d0177c3e4ed075160b31774884d9d766..2aa324ffb2fd4576fa09563332caca9d6ac4deca 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.message.variable.properties.AbstractProperties;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableMessage.java
index 98e6527e2d631c98ef173b4ba940f20f1148e886..db4dd37cefa596e35db578ac790717dda2d54607 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/MqttVariableMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/OnlyFixedHeaderMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/OnlyFixedHeaderMessage.java
index 344c9955fb044ed463ffbe2e468d49858268d825..3fd26068e89c3a6391c5d7027aa5b7e1570e97c9 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/OnlyFixedHeaderMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/OnlyFixedHeaderMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/Mqtt5UnsubAckPayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/Mqtt5UnsubAckPayload.java
index d3bd07437f0328d44e00aa81227d4b64e6f8f73f..a8773ba009338b1a4ef9a65d824e14b7069bfa4a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/Mqtt5UnsubAckPayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/Mqtt5UnsubAckPayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttConnectPayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttConnectPayload.java
index 47d22e84054db30da67b32ae2e793635027fc344..6b62a21cc2b8090a95da59f79606bd57eee02e5c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttConnectPayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttConnectPayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPayload.java
index ace3f04df3ec47ecb9c8523d37fa0dc5239d84d7..38b78d16d61a5053bc048ac5eb82a8e444bdd539 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.message.Codec;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPublishPayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPublishPayload.java
index dc46d2c4adc4a7312d8d58b89f8c72b243cea704..057ab9d74e536520963d277373235bc45d1b27d7 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPublishPayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttPublishPayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubAckPayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubAckPayload.java
index face9cda00c7ace013cca5988b87abd66d9bac86..9ad692bf09b9a9dda569d02542fb8ff10108e5dd 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubAckPayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubAckPayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubscribePayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubscribePayload.java
index c158d1bc47afb741ad5f1990b6a1e28b8c468d3d..88e4134d735d5d1e4109f6b0e97fe7e8c808cfa9 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubscribePayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttSubscribePayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttUnsubscribePayload.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttUnsubscribePayload.java
index a69bea28b9e5157b8d6561841e886c42d786a3ce..6d3b55ec368ce0cc8398e5dee513c9e0d864007c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttUnsubscribePayload.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/MqttUnsubscribePayload.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import java.util.Collections;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/WillMessage.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/WillMessage.java
index adf1a4d20941a3f6bb0b66083fe5d7e218199499..eb58f7a747c47713a20a6a0b255479a2489d4a2b 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/WillMessage.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/payload/WillMessage.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.payload;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnAckVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnAckVariableHeader.java
index aa66ed82d82f13a213582ca45b6b35342421e0f6..cc6f26a39734c29259d6c31fa5b589c6dcd50856 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnAckVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnAckVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnectVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnectVariableHeader.java
index 4b0cad1f3c4e3ac62fad25a3d911da70faf0d2ad..88d2c870c3c22d97de584100db95b8b2544263c8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnectVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttConnectVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPacketIdVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPacketIdVariableHeader.java
index 6ba963fa2159b4576ac5887cc38e13b4c6d600ab..1d112c7c001f02f3de145bd3ca5c55faf2a60635 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPacketIdVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPacketIdVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.message.MqttVariableHeader;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPubQosVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPubQosVariableHeader.java
index a0cfa3e9a07f8b1f1752ea93f7fff5254960bc81..642ea580cfdcd2e9eae9fca60804079d61cbab1c 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPubQosVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPubQosVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPublishVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPublishVariableHeader.java
index 3e17d8d8a469520cc23258a04bd8aeeec614f389..d2ff10539c3d6bce398f1d9bbc623789f31347e8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPublishVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttPublishVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttReasonVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttReasonVariableHeader.java
index c5790892a7cfd9222bb3ab16554d44ec076791f6..1bfe91596c4912a2d3a33b6d7ae81f2cf6a23a27 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttReasonVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttReasonVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttSubscribeVariableHeader.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttSubscribeVariableHeader.java
index a3f0dca43777ee5394e3c999b351083f208040f9..eb8bc74ec3f3becdc8d1c0b039593bf6913d3579 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttSubscribeVariableHeader.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/MqttSubscribeVariableHeader.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/AbstractProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/AbstractProperties.java
index d2413c6dcafdc73aa452835704b93a3e2c4ae08b..fb5f79eb67c6d856e6b32af32da49700686861df 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/AbstractProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/AbstractProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.smartboot.mqtt.common.MqttWriter;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectAckProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectAckProperties.java
index bd8091f19402dc94ae5886dedb7ae95df6faac91..9f09c8e0fc3cafa3630b8b3079c18f9dc5c4b8da 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectAckProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectAckProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import java.util.List;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectProperties.java
index 7ea0ff8afb1d540a9786443d925f26584f4b8aed..1c25e382fe495e4d691ce36d91002a812b063ee0 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ConnectProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import java.util.List;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/MqttProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/MqttProperties.java
index 0ef1d85b1f2d8de46144082186316fa665bd1dd0..0b06d5870f9b2f1ec487dfccf3c89439e4470b92 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/MqttProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/MqttProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.apache.commons.collections4.CollectionUtils;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PubAckProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PubAckProperties.java
index 6b3621bc4d602cf6c1c25dd09023cb97fee823ee..cc7e281df2cd8ee916b54b32955f269454a13d90 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PubAckProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PubAckProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.smartboot.mqtt.common.util.MqttPropertyConstant;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PublishProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PublishProperties.java
index b044da5fba94deee0c868b0874e2be99561ed146..2b35c967bc296d08d1ffbd2108647b9acdbed951 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PublishProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/PublishProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import java.util.List;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ReasonProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ReasonProperties.java
index ff628d8c78d20c144dc00bfe56ee11b8b6defdcb..cbe7efd154de181bb2cd7eae32d4f33f8ea07d20 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ReasonProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/ReasonProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.smartboot.mqtt.common.util.MqttPropertyConstant;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/SubscribeProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/SubscribeProperties.java
index cc0082eefb59245df4beeed1b536f6eb82faf008..ece301713a63a4ef22f6f80e891b6ff02475db7d 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/SubscribeProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/SubscribeProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.smartboot.mqtt.common.util.MqttPropertyConstant;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/UserProperty.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/UserProperty.java
index 9653b0596625a43c18e29001ba3623eb901610a3..f52a2822237a7668fb68216b7600533527af214e 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/UserProperty.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/UserProperty.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import org.smartboot.mqtt.common.message.MqttCodecUtil;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/WillProperties.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/WillProperties.java
index 78119485369da7e3ee182ca1693437774f6353de..e72dbc5c110d59d36cd32788a988d5bba6f03db3 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/WillProperties.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/message/variable/properties/WillProperties.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.message.variable.properties;
import java.util.List;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecodeUnit.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecodeUnit.java
index 30333ae7cf8726dfac24bef9a4c9f256da1f2533..f6958adba8b56a78012ee2d5109a9b290e93c1b8 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecodeUnit.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecodeUnit.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.protocol;
import org.smartboot.mqtt.common.message.MqttMessage;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecoderState.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecoderState.java
index 2f9e5661d6ceff5c198fee4f0bd28d0c19cd78bb..cd8deea2a8396f1bcc33f38f9fdf32d8a28ca00d 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecoderState.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/DecoderState.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.protocol;
enum DecoderState {
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttMessageFactory.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttMessageFactory.java
index 0d2e9c241642e7b245aadf2f09dde900480abe34..7d11ade5f406849df82a70b0d982a324ec58cde0 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttMessageFactory.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttMessageFactory.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.protocol;
import org.smartboot.mqtt.common.enums.MqttMessageType;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttProtocol.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttProtocol.java
index 2ac415e2561dacb3868abeeec07b00ae5022a30b..b5f1dd8cc5b4e4749c9ba619a752b2019c50f652 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttProtocol.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/protocol/MqttProtocol.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.protocol;
import org.slf4j.Logger;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricItemTO.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricItemTO.java
index eecc86ebebeb8413809fd40611eea59c93adeabb..9b031cfb45d44f1c5a100f6835852a6fd4a58a6f 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricItemTO.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricItemTO.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.to;
import com.alibaba.fastjson2.annotation.JSONField;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricTO.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricTO.java
index 195e5d0ddf3ff639b846b1eea341ad940527ffb1..17b44d0562847859b62d31eed86260dbd86bcc3b 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricTO.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/to/MetricTO.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.to;
import java.util.HashMap;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttMessageBuilders.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttMessageBuilders.java
index 0410f2ad249baf33a82f90d676e1f97251d81b18..7f7518bac6dce9a30a3d336c1b06eb69191bdd14 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttMessageBuilders.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttMessageBuilders.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.util;
import org.smartboot.mqtt.common.enums.MqttMessageType;
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttPropertyConstant.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttPropertyConstant.java
index 0531abc6403aed685abd3f18422e15cf604d4e5a..b924039e2c0d448168abfe571d6a1c3037be9e45 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttPropertyConstant.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttPropertyConstant.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.util;
/**
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttUtil.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttUtil.java
index de90f3edd7bca7bb9afc25f0a1ad53993a0d6cd4..38bf8ed32247e6930ec504003fcc359657c2f26a 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttUtil.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/MqttUtil.java
@@ -1,8 +1,20 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.util;
+import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.smartboot.mqtt.common.AbstractSession;
+import org.smartboot.mqtt.common.TopicToken;
import org.smartboot.mqtt.common.message.MqttCodecUtil;
import java.util.Map;
@@ -47,4 +59,21 @@ public class MqttUtil {
public static byte[] encodeCache(String topicName) {
return cache.computeIfAbsent(topicName, s -> MqttCodecUtil.encodeUTF8(topicName));
}
+
+ public static boolean match(TopicToken pubTopicToken, TopicToken subTopicToken) {
+ if (subTopicToken == null) {
+ return pubTopicToken == null;
+ }
+ //合法的#通配符必然存在于末端
+ if ("#".equals(subTopicToken.getNode())) {
+ return true;
+ }
+ if ("+".equals(subTopicToken.getNode())) {
+ return pubTopicToken != null && match(pubTopicToken.getNextNode(), subTopicToken.getNextNode());
+ }
+ if (pubTopicToken == null || !StringUtils.equals(pubTopicToken.getNode(), subTopicToken.getNode())) {
+ return false;
+ }
+ return match(pubTopicToken.getNextNode(), subTopicToken.getNextNode());
+ }
}
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/TopicTokenUtil.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/TopicTokenUtil.java
deleted file mode 100644
index bbf4cd414b742029305232a99d446e5291d2d1a5..0000000000000000000000000000000000000000
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/TopicTokenUtil.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package org.smartboot.mqtt.common.util;
-
-import org.apache.commons.lang.StringUtils;
-import org.smartboot.mqtt.common.TopicToken;
-
-/**
- * @author 三刀（zhengjunweimail@163.com）
- * @version V1.0 , 2022/4/3
- */
-public class TopicTokenUtil {
- public static boolean match(TopicToken pubTopicToken, TopicToken subTopicToken) {
- if (subTopicToken == null) {
- return pubTopicToken == null;
- }
- //合法的#通配符必然存在于末端
- if ("#".equals(subTopicToken.getNode())) {
- return true;
- }
- if ("+".equals(subTopicToken.getNode())) {
- return pubTopicToken != null && match(pubTopicToken.getNextNode(), subTopicToken.getNextNode());
- }
- if (pubTopicToken == null || !StringUtils.equals(pubTopicToken.getNode(), subTopicToken.getNode())) {
- return false;
- }
- return match(pubTopicToken.getNextNode(), subTopicToken.getNextNode());
- }
-}
diff --git a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/ValidateUtils.java b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/ValidateUtils.java
index 8918507f9636eda72a8790c06a566f9b6ed78a5e..e0e1d63394952efb745074b1a4f6301fc671fd1d 100644
--- a/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/ValidateUtils.java
+++ b/smart-mqtt-common/src/main/java/org/smartboot/mqtt/common/util/ValidateUtils.java
@@ -1,3 +1,13 @@
+/*
+ * Copyright (C) [2022] smartboot [zhengjunweimail@163.com]
+ *
+ * 企业用户未经smartboot组织特别许可，需遵循AGPL-3.0开源协议合理合法使用本项目。
+ *
+ * Enterprise users are required to use this project reasonably
+ * and legally in accordance with the AGPL-3.0 open source agreement
+ * without special permission from the smartboot organization.
+ */
+
package org.smartboot.mqtt.common.util;
import org.apache.commons.collections4.CollectionUtils;
diff --git "a/\345\205\263\344\272\216\345\225\206\344\270\232\346\216\210\346\235\203.md" "b/\345\205\263\344\272\216\345\225\206\344\270\232\346\216\210\346\235\203.md"
new file mode 100644
index 0000000000000000000000000000000000000000..d0141bde869979abd8b1912e206c5dc891c2a39a
--- /dev/null
+++ "b/\345\205\263\344\272\216\345\225\206\344\270\232\346\216\210\346\235\203.md"
@@ -0,0 +1,42 @@
+## 定义
+商业化限制License旨在规定smart-mqtt以及基于其所开发的软件在商业环境下的使用和分发方式以及费用结算方式等相关规定。
+
+## 授权
+本开源项目软件授权全世界的个人和组织可以在遵守以下要求的情况下对代码进行商业使用：
+
+1. 遵守该开源项目所采用的开源许可协议。
+2. 获得商业授权。
+
+## 商业授权
+商业授权允许商业使用者在商业环境中使用和分发基于该开源项目开发的软件，商业授权的获得须遵循以下规定：
+
+a) 商业使用者须向开发者申请商业授权，并支付相应的授权费用。
+
+b) 商业授权有效期视授权合同而定，授权费用应按照一定的周期支付。
+
+c) 商业授权对代码进行商业化使用的范围和方式进行约束，商业使用者不得超出商业授权规定的范围和方式使用和分发软件。
+
+### 开源协议
+开源协议规定了基于该开源项目的软件在非商业使用中的授权方式和限制，商业使用者必须遵守该协议。
+
+该开源项目使用的开源协议为：**AGPL-3.0**，商业使用者必须遵守该协议，即商业使用者必须保持代码的开源性，并且必须遵守开源协议中规定的限制。
+
+### 商业限制
+商业使用者在获得商业授权后，也需要遵守商业限制，以避免商业化使用对开源项目的侵害和商业使用者自身的损失。
+
+商业限制包括但不限于：
+
+a) 商业使用者必须获得商业授权后方可在商业环境中使用该开源项目的软件。
+
+b) 商业使用者不得超出商业授权规定的范围和方式使用和分发软件。
+
+c) 商业使用者须遵守开源协议规定的限制。
+
+## 费用结算
+商业授权的费用和结算方式由开发者在制定双协议时制定，商业使用者应按照双协议规定的约定及时支付授权费用。
+
+## 违约处理
+商业使用者如违反双协议中任何一项规定，则被视为违约，开发者有权在合法范围内采取相应措施，包括但不限于收回授权、停止技术支持和法律起诉等。
+
+## 其他约定
+双协议中未完全涉及到的事项，开发者保留相关解释和裁量权。
\ No newline at end of file