docs: 发布 v1.0.7.RELEASE 版本

Author: Amazingwujun

pom.xml

@@ -10,7 +10,7 @@
     </parent>
     <groupId>com.jun</groupId>
     <artifactId>mqttx</artifactId>
-    <version>1.0.6.RELEASE</version>
+    <version>1.0.7.RELEASE</version>
     <name>mqttx</name>
     <description>mqtt broker</description>
 

readme.md

@@ -31,6 +31,7 @@
     - [6.2 版本说明](#62-版本说明)
         - [6.2.1 v1.0](#621-v10)
         - [6.2.2 v1.1](#622-v11)
+        - [6.2.3 v2.0](#623-v20)
     - [6.3 Benchmark](#63-benchmark)
         - [6.3.1 CleanSessionTrue](#631-cleansessiontrue)
         - [6.3.2 CleanSessionFalse](#632-cleansessionfalse)
@@ -42,6 +43,8 @@
 
 ### 1.1 快速开始
 
+> 想通过 docker 快速体验？见 [docker 启动](#3-docker-启动)
+
 1. 打包
     - 测试模式：运行  `mvnw -P test -DskipTests=true clean package`
 
@@ -391,15 +394,15 @@ mqttx:
 
 ## 5 开发者说
 
-1. **bug fix and optimization**，这个会一直继续的。
-
-   > **项目将长期维护**
-
-2. 为了使 ***mqttx*** 项目变得更好，请使用及学习该项目的同学主动反馈使用情况给我（提 issue 或加群反馈）。
-
-3. 版本 `v1.0.7.alpha` 预计二月下旬发布。
-
-4. 交流群
+1. `v1.0` 版本分支将作为支持 **mqttv3.1.1** 协议版本持续迭代
+2. 为使 ***mqttx*** 项目变得更好，请使用及学习该项目的同学主动反馈使用情况给我（提 issue 或加群反馈）
+3. 后续工作
+   - [x] `v1.0.7.RELEASE` 版本 ***Benchmark***
+   - [x] `v1.0.8.RELEASE` 版本开发
+   - [x] `v2.0.0.RELEASE` 版本开发
+   - [x] bug 修复
+4. `v2.0` 版本分支将作为 **mqttv5** 协议版本开始迭代
+6. 交流群
 
 <img src="https://s1.ax1x.com/2020/10/10/0ytoSx.jpg" alt="群二维码" height="300" />
 
@@ -466,12 +469,10 @@ mqttx:
 
 #### 6.2.1 v1.0
 
-- **v1.0.8.RELEASE(待开发)**
-    - [ ] [mqtt5](http://docs.oasis-open.org/mqtt/mqtt/v5.0/csprd02/mqtt-v5.0-csprd02.html) 支持
-    - [ ] bug 修复及优化
-- **v1.0.7.RELEASE(开发中)**
-    - [x] 增加序列化框架 ***Kryo*** 的支持
+- **v1.0.8.RELEASE（开发中）**
     - [ ] 消息集中持久化到 `redis hmap` 数据结构中，`PubMsg` 仅保存 `hmap` 中的 `payloadId`, 该优化目的在于防止消息膨胀导致的 redis 内存耗用过大。（之前版本消息都是持久化到客户端各自的 `PubMsg`）
+- **v1.0.7.RELEASE**
+    - [x] 增加序列化框架 ***Kryo*** 的支持
     - [x]  系统主题新增客户端上下线通知主题
     - [x] 修复新增订阅触发 `retain` 消息后，消息分发给全部订阅者的 bug
     - [x] 修复遗嘱消息 `isWillRetain:true` 持久化的bug
@@ -504,9 +505,13 @@ mqttx:
 
 #### 6.2.2 v1.1
 
-- ***v1.1.0.RELEASE（开发中）***
+- **v1.1.0.RELEASE（停止开发）**
+  - [ ] `redis` 同步转异步实现，提升性能
+
+#### 6.2.3 v2.0
 
-    - [ ] `redis` 同步转异步实现，提升性能
+- **v2.0.0.RELEASE（开发中）**
+  - [x] [mqtt5](http://docs.oasis-open.org/mqtt/mqtt/v5.0/csprd02/mqtt-v5.0-csprd02.html) 支持
 
 ### 6.3 Benchmark
 

src/main/java/com/jun/mqttx/broker/handler/ConnectHandler.java

@@ -126,12 +126,12 @@ public void process(ChannelHandlerContext ctx, MqttMessage msg) {
         if (variableHeader.hasPassword() && variableHeader.hasUserName()) {
             authenticationService.asyncAuthenticate(
                     ClientAuthDTO.of(username, password),
-                    authentication -> proccess0(ctx, msg, authentication),
+                    authentication -> process0(ctx, msg, authentication),
                     throwable -> {
                         throw new AuthenticationException("登入失败", throwable);
                     });
         } else {
-            proccess0(ctx, msg, null);
+            process0(ctx, msg, null);
         }
     }
 
@@ -148,7 +148,7 @@ public void process(ChannelHandlerContext ctx, MqttMessage msg) {
      * @param msg  解包后的数据
      * @param auth 认证对象，见 {@link Authentication}
      */
-    private void proccess0(ChannelHandlerContext ctx, MqttMessage msg, Authentication auth) {
+    private void process0(ChannelHandlerContext ctx, MqttMessage msg, Authentication auth) {
         MqttConnectMessage mcm = (MqttConnectMessage) msg;
         MqttConnectVariableHeader variableHeader = mcm.variableHeader();
         MqttConnectPayload payload = mcm.payload();

src/main/java/com/jun/mqttx/utils/GlobalExecutor.java

@@ -29,7 +29,7 @@
  *     <li>最大线程池数量: {@link Runtime#availableProcessors()} * 2 </li>
  *     <li>空闲时线程存活时间: 60 秒</li>
  *     <li>任务队列: {@link ArrayBlockingQueue}</li>
- *     <li>拒绝策略: 抛弃任务并应答错误信息</li>
+ *     <li>拒绝策略: 抛弃任务并打印错误信息</li>
  * </ol>
  *
  * @since 1.0.7

src/main/resources/banner.txt

@@ -6,4 +6,4 @@
  |_| |_| |_|\__, |\__|\__/_/\_\
                | |
                |_|
- :: mqttx ::        (v1.0.6.RELEASE)
+ :: mqttx ::        (v1.0.7.RELEASE)