diff --git a/.github/workflows/phpstan.yml b/.github/workflows/phpstan.yml
index bcebbf6..e011290 100644
--- a/.github/workflows/phpstan.yml
+++ b/.github/workflows/phpstan.yml
@@ -4,19 +4,22 @@ on:
   push:
   pull_request:
 
+concurrency:
+  group: phpstan-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   tests:
     name: PHP${{ matrix.php-version }} Static Code Analysis on Linux
-    runs-on: "${{ matrix.os }}"
+    runs-on: ubuntu-latest
     strategy:
       matrix:
-        os: [ ubuntu-latest ]
-        php-version: [ '7.2', '7.3', '7.4', '8.0', '8.1' ]
+        php-version: [ '8.0', '8.1', '8.2', '8.3', '8.4' ]
       max-parallel: 5
       fail-fast: false
     steps:
       - name: Checkout
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
 
       - name: Setup PHP
         uses: shivammathur/setup-php@v2
@@ -27,10 +30,10 @@ jobs:
 
       - name: Setup Dependencies
         env:
-          COMPOSER_ROOT_VERSION: 1.4-dev
+          COMPOSER_ROOT_VERSION: 1.x-dev
         run:
           composer install -o
 
       - name: Run Analysis
-        run: |
+        run:
           composer analyse
diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml
index 35f4eb0..ebdf88e 100644
--- a/.github/workflows/test.yml
+++ b/.github/workflows/test.yml
@@ -2,110 +2,46 @@ name: PHPUnit for MQTT
 
 on:
   push:
+    branches:
+      - master
+      - ci
   pull_request:
+    branches:
+      - master
   schedule:
     - cron: '11 2 * * 1'
 
-jobs:
-  linux:
-    name: PHP${{ matrix.php-version }} Swoole-${{ matrix.swoole-version }} Test on Linux
-    runs-on: "${{ matrix.os }}"
-    strategy:
-      matrix:
-        os: [ubuntu-latest]
-        php-version: ['7.2', '7.3', '7.4', '8.0']
-        swoole-version: ['v4.4.26', 'v4.5.11', 'v4.6.7', 'v4.7.1', 'v4.8.7', 'master']
-        exclude:
-            - php-version: '8.0'
-              swoole-version: 'v4.4.26'
-            - php-version: '7.2'
-              swoole-version: 'master'
-            - php-version: '7.3'
-              swoole-version: 'master'
-            - php-version: '7.4'
-              swoole-version: 'master'
-        include:
-          - os: ubuntu-latest
-            php-version: '8.1'
-            swoole-version: 'master'
-          - os: ubuntu-latest
-            php-version: '8.1'
-            swoole-version: 'v4.8.7'
-      max-parallel: 15
-      fail-fast: false
-    env:
-      SWOOLE_VERSION: ${{ matrix.swoole-version }}
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v2
+concurrency:
+  group: test-${{ github.ref }}
+  cancel-in-progress: true
 
-      - name: Setup PHP
-        uses: shivammathur/setup-php@v2
-        with:
-          php-version: ${{ matrix.php-version }}
-          tools: phpize
-          ini-values: extension=swoole
-          coverage: none
-
-      - name: Build Swoole
-        run: |
-          wget https://github.com/swoole/swoole-src/archive/${SWOOLE_VERSION}.tar.gz -O swoole.tar.gz
-          mkdir -p swoole
-          tar -xf swoole.tar.gz -C swoole --strip-components=1
-          rm swoole.tar.gz
-          cd swoole
-          phpize
-          ./configure --enable-openssl --enable-mysqlnd --enable-http2
-          make -j$(nproc)
-          sudo make install
-          php --ri swoole
-
-      - name: Setup Dependencies
-        env:
-          COMPOSER_ROOT_VERSION: 1.4-dev
-        run:
-          composer install -o
-
-      - name: Coding Standards Check
-        if: matrix.php-version != '8.1'
-        run: |
-          composer cs-check
-
-      - name: Run Test Cases
-        run: |
-          composer test
-
-  macos:
-    name: PHP${{ matrix.php-version }} Swoole-${{ matrix.swoole-version }} Test on macOS
-    runs-on: "${{ matrix.os }}"
+jobs:
+  test:
+    name: PHP${{ matrix.php-version }} Swoole-${{ matrix.swoole-version }} Test on ${{ matrix.os }}
+    runs-on: ${{ matrix.os }}
     strategy:
       matrix:
-        os: [macos-latest]
-        php-version: ['7.2', '7.3', '7.4', '8.0']
-        swoole-version: ['v4.4.26', 'v4.5.11', 'v4.6.7', 'v4.7.1', 'v4.8.7', 'master']
+        os: [ubuntu-latest, macos-latest]
+        php-version: [ '8.0', '8.1', '8.2', '8.3', '8.4' ]
+        swoole-version: [ 'v4.8.13', 'v5.1.6', 'v6.0.0', 'master' ]
         exclude:
+          - php-version: '8.4'
+            swoole-version: 'v5.1.6'
+          - php-version: '8.4'
+            swoole-version: 'v4.8.13'
+          - php-version: '8.3'
+            swoole-version: 'v4.8.13'
+          - php-version: '8.0'
+            swoole-version: 'v6.0.0'
           - php-version: '8.0'
-            swoole-version: 'v4.4.26'
-          - php-version: '7.2'
-            swoole-version: 'master'
-          - php-version: '7.3'
-            swoole-version: 'master'
-          - php-version: '7.4'
-            swoole-version: 'master'
-        include:
-          - os: macos-latest
-            php-version: '8.1'
             swoole-version: 'master'
-          - os: macos-latest
-            php-version: '8.1'
-            swoole-version: 'v4.8.7'
-      max-parallel: 15
+      max-parallel: 10
       fail-fast: false
     env:
       SWOOLE_VERSION: ${{ matrix.swoole-version }}
     steps:
       - name: Checkout
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
 
       - name: Setup PHP
         uses: shivammathur/setup-php@v2
@@ -115,35 +51,41 @@ jobs:
           ini-values: extension=swoole
           coverage: none
 
-      - name: Install Swoole Dependencies
-        run: |
-          brew install openssl
-          brew link openssl
-
       - name: Build Swoole
         run: |
-          wget https://github.com/swoole/swoole-src/archive/${SWOOLE_VERSION}.tar.gz -O swoole.tar.gz
-          mkdir -p swoole
-          tar -xf swoole.tar.gz -C swoole --strip-components=1
-          rm swoole.tar.gz
-          cd swoole
-          phpize
-          ./configure --enable-openssl --with-openssl-dir=/usr/local/opt/openssl@1.1 --enable-mysqlnd --enable-http2
-          make -j$(sysctl -n hw.logicalcpu)
-          sudo make install
-          php --ri swoole
+          if [ "${{ matrix.os }}" == "ubuntu-latest" ]; then
+            wget https://github.com/swoole/swoole-src/archive/${SWOOLE_VERSION}.tar.gz -O swoole.tar.gz
+            mkdir -p swoole
+            tar -xf swoole.tar.gz -C swoole --strip-components=1
+            rm swoole.tar.gz
+            cd swoole
+            phpize
+            ./configure --enable-openssl --enable-http2
+            make -j$(nproc)
+            sudo make install
+            php --ri swoole
+          else
+            export CPPFLAGS="$CPPFLAGS -I$(brew --prefix pcre2)/include -L$(brew --prefix pcre2)/lib"
+            wget https://github.com/swoole/swoole-src/archive/${SWOOLE_VERSION}.tar.gz -O swoole.tar.gz
+            mkdir -p swoole
+            tar -xf swoole.tar.gz -C swoole --strip-components=1
+            rm swoole.tar.gz
+            cd swoole
+            phpize
+            ./configure --enable-openssl --with-openssl-dir=$(brew --prefix openssl) --enable-http2
+            make -j$(sysctl -n hw.logicalcpu)
+            sudo make install
+            php --ri swoole
+          fi
 
       - name: Setup Dependencies
         env:
-          COMPOSER_ROOT_VERSION: 1.4-dev
-        run:
-          composer install -o
+          COMPOSER_ROOT_VERSION: 1.x-dev
+        run: composer install -o
 
       - name: Coding Standards Check
-        if: matrix.php-version != '8.1'
-        run: |
-          composer cs-check
+        if: matrix.php-version == '8.1'
+        run: composer cs-check
 
       - name: Run Test Cases
-        run: |
-          composer test
+        run: composer test
diff --git a/README-CN.md b/README-CN.md
index 89b77af..1f0ab9f 100644
--- a/README-CN.md
+++ b/README-CN.md
@@ -17,7 +17,7 @@
 [![GitHub Actions](https://github.com/simps/mqtt/workflows/PHPUnit%20for%20MQTT/badge.svg)](https://github.com/simps/mqtt/actions)
 [![Static Code Analysis](https://github.com/simps/mqtt/actions/workflows/phpstan.yml/badge.svg)](https://github.com/simps/mqtt/actions/workflows/phpstan.yml)
 [![Gitee Star](https://gitee.com/phpmqtt/mqtt/badge/star.svg?theme=dark)](https://gitee.com/phpmqtt/mqtt/stargazers)
-[![Simps 交流群](https://img.shields.io/badge/QQ%E7%BE%A4-983679945-orange)](https://shang.qq.com/wpa/qunwpa?idkey=587be6cdd66b437f2306b1a6d7263fd8096b70ef1db716a259485219f28d41a3)
+[![MQTT 交流群](https://img.shields.io/badge/QQ%E7%BE%A4-983679945-orange)](https://go.qq52o.me/qm/mqtt)
 
 ## 安装
 
diff --git a/README.md b/README.md
index 89bc593..cbac750 100644
--- a/README.md
+++ b/README.md
@@ -19,7 +19,7 @@ Support for `QoS 0`, `QoS 1`, `QoS 2`.
 [![GitHub Actions](https://github.com/simps/mqtt/workflows/PHPUnit%20for%20MQTT/badge.svg)](https://github.com/simps/mqtt/actions)
 [![Static Code Analysis](https://github.com/simps/mqtt/actions/workflows/phpstan.yml/badge.svg)](https://github.com/simps/mqtt/actions/workflows/phpstan.yml)
 [![Gitee Star](https://gitee.com/phpmqtt/mqtt/badge/star.svg?theme=dark)](https://gitee.com/phpmqtt/mqtt/stargazers)
-[![Simps 交流群](https://img.shields.io/badge/QQ%E7%BE%A4-983679945-orange)](https://shang.qq.com/wpa/qunwpa?idkey=587be6cdd66b437f2306b1a6d7263fd8096b70ef1db716a259485219f28d41a3)
+[![MQTT 交流群](https://img.shields.io/badge/QQ%E7%BE%A4-983679945-orange)](https://go.qq52o.me/qm/mqtt)
 
 ## Install
 
diff --git a/bin/copyright-code b/bin/copyright-code
new file mode 100755
index 0000000..c94c239
--- /dev/null
+++ b/bin/copyright-code
@@ -0,0 +1,47 @@
+#!/usr/bin/env php
+<?php
+
+include 'vendor/autoload.php';
+
+use Symfony\Component\Finder\Finder;
+
+$files = Finder::create()
+    ->in(dirname(__DIR__))
+    ->exclude(['bin', 'docs', 'tests', 'examples'])
+    ->ignoreDotFiles(true)
+    ->ignoreVCSIgnored(true)
+    ->notName(['test.php', 'code.txt'])
+    ->name('*.php')
+    ->sortByName()
+    ->files();
+
+file_put_contents('code.txt', '');
+
+foreach ($files as $file) {
+    file_put_contents('code.txt', removeCommentsAndEmptyLines($file), FILE_APPEND);
+}
+
+function removeCommentsAndEmptyLines($filePath)
+{
+    $cleanCode = '';
+    $fileLines = file($filePath);
+
+    foreach ($fileLines as $line) {
+        $trimmedLine = trim($line);
+
+        // Skip comment lines
+        if (strpos($trimmedLine, '//') === 0 || strpos($trimmedLine, '/*') === 0 || strpos(
+                $trimmedLine,
+                '*'
+            ) === 0 || strpos($trimmedLine, '*/') === 0) {
+            continue;
+        }
+
+        // Skip empty lines
+        if ($trimmedLine !== '') {
+            $cleanCode .= $line;
+        }
+    }
+
+    return $cleanCode;
+}
diff --git a/bin/gen-property b/bin/gen-property
new file mode 100644
index 0000000..0ce9946
--- /dev/null
+++ b/bin/gen-property
@@ -0,0 +1,49 @@
+#!/usr/bin/env php
+<?php
+
+include 'vendor/autoload.php';
+
+use Simps\MQTT\Hex\Property;
+
+function getConstants(string $objectOrClass)
+{
+    $objClass = new \ReflectionClass($objectOrClass);
+
+    return $objClass->getConstants();
+}
+
+function genData(array $constants, string $prefix = '')
+{
+    $data = '';
+    foreach ($constants as $name => $value) {
+        $value = strtolower($name);
+        $data .= "public const {$name} = '{$value}';\n\n";
+    }
+
+    return $data;
+}
+
+$constants = '<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Simps.
+ *
+ * @link     https://github.com/simps/mqtt
+ * @contact  Lu Fei <lufei@simps.io>
+ *
+ * For the full copyright and license information,
+ * please view the LICENSE file that was distributed with this source code.
+ */
+namespace Simps\\MQTT\\Constant;
+
+class Property
+{
+%s
+}
+';
+
+$propertyConstants = getConstants(Property::class);
+$constants = sprintf($constants, genData($propertyConstants));
+
+file_put_contents('src/Constant/Property.php', $constants);
diff --git a/composer.json b/composer.json
index a1299df..600f7e3 100644
--- a/composer.json
+++ b/composer.json
@@ -55,7 +55,7 @@
   },
   "extra": {
     "branch-alias": {
-      "dev-master": "1.4-dev"
+      "dev-master": "1.x-dev"
     }
   }
 }
diff --git a/docs/_coverpage.md b/docs/_coverpage.md
index ac3f262..e64f1c8 100644
--- a/docs/_coverpage.md
+++ b/docs/_coverpage.md
@@ -1,4 +1,4 @@
-![](https://cdn.jsdelivr.net/gh/simple-swoole/docs/docs/logo.png ':size=200x200')
+![](https://github.com/simps.png ':size=200x200')
 
 # PHP MQTT
 
diff --git a/docs/index.html b/docs/index.html
index 1367ff4..25bed47 100644
--- a/docs/index.html
+++ b/docs/index.html
@@ -7,7 +7,7 @@
   <meta name="description" content="由 Simps 提供的适用于 PHP 的 MQTT 协议解析和协程客户端">
   <meta name="keywords" content="mqtt,phpmqtt,mqtt3.1,mqtt5.0,mqtt客户端,mqtt协程客户端,mqtt协议,mqtt协议解析">
   <meta name="viewport" content="width=device-width, initial-scale=1.0, minimum-scale=1.0">
-  <link rel="stylesheet" href="//cdn.jsdelivr.net/gh/sy-records/docsify-nightly/lib/themes/vue.css">
+  <link rel="stylesheet" href="//unpkg.com/docsify@4/themes/vue.css">
   <style>
     .app-name-link img {
       width: 50%;
@@ -23,7 +23,7 @@
       homepage: 'zh-cn/README.md',
       loadSidebar: true,
       subMaxLevel: 3,
-      logo: 'https://cdn.jsdelivr.net/gh/sy-records/staticfile@master/images/simps.png',
+      logo: 'https://raw.githubusercontent.com/sy-records/staticfile/master/images/simps.png',
       themeColor: '#5C9DFF',
       loadNavbar: true,
       auto2top: true,
@@ -71,9 +71,24 @@
       ],
     }
   </script>
-  <script src="//cdn.jsdelivr.net/gh/sy-records/docsify-nightly/lib/docsify.min.js"></script>
-  <script src="//cdn.jsdelivr.net/gh/sy-records/docsify-nightly/lib/plugins/search.min.js"></script>
-  <script src="//cdn.jsdelivr.net/npm/prismjs/components/prism-php.min.js"></script>
-  <script src="//cdn.jsdelivr.net/npm/pangu@4.0.7/dist/browser/pangu.min.js"></script>
+  <script src="//unpkg.com/docsify@4/lib/docsify.min.js"></script>
+  <script src="//unpkg.com/docsify@4/lib/plugins/search.min.js"></script>
+  <script src="//unpkg.com/prismjs/components/prism-php.min.js"></script>
+  <script src="//unpkg.com/pangu@4.0.7/dist/browser/pangu.min.js"></script>
+  <script src="//unpkg.com/docsify-copy-code@2/dist/docsify-copy-code.min.js"></script>
+  <script>
+    var _hmt = _hmt || [];
+    _hmt.push(['_requirePlugin', 'UrlChangeTracker', {
+      shouldTrackUrlChange: function (newPath, oldPath) {
+        return newPath && oldPath;
+      }}
+    ]);
+    (function() {
+      var hm = document.createElement("script");
+      hm.src = "https://hm.baidu.com/hm.js?e451f878e32de0e912cbbd4887bf43aa";
+      var s = document.getElementsByTagName("script")[0]; 
+      s.parentNode.insertBefore(hm, s);
+    })();
+  </script>
 </body>
 </html>
diff --git a/examples/bootstrap.php b/examples/bootstrap.php
index 30c35f3..8434eb3 100644
--- a/examples/bootstrap.php
+++ b/examples/bootstrap.php
@@ -17,7 +17,7 @@
     ] as $file
 ) {
     if (file_exists($file)) {
-        require $file;
+        require_once $file;
         break;
     }
 }
diff --git a/examples/getLevel.php b/examples/getLevel.php
index 975e911..5629c32 100644
--- a/examples/getLevel.php
+++ b/examples/getLevel.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Protocol\Types;
 use Simps\MQTT\Protocol\V3;
@@ -31,7 +31,7 @@
     echo "Client #{$fd}: Connect.\n";
 });
 
-$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) {
+$server->on('receive', function (Swoole\Server $server, $fd, $reactorId, $data) {
     $type = UnPackTool::getType($data);
     if ($type === Types::CONNECT) {
         $level = UnPackTool::getLevel($data);
diff --git a/examples/message/server.php b/examples/message/server.php
index 3906903..a61df8e 100644
--- a/examples/message/server.php
+++ b/examples/message/server.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Protocol\Types;
 use Simps\MQTT\Protocol\V3;
@@ -35,7 +35,7 @@
     echo "Client #{$fd}: Connect.\n";
 });
 
-$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) {
+$server->on('receive', function (Swoole\Server $server, $fd, $reactorId, $data) {
     try {
         // debug
 //        Common::printf($data);
@@ -90,7 +90,7 @@
                     break;
                 case Types::SUBSCRIBE:
                     $payload = [];
-                    foreach ($data['topics'] as $k => $qos) {
+                    foreach ($data['topics'] as $qos) {
                         if (is_numeric($qos) && $qos < 3) {
                             $payload[] = $qos;
                         } else {
diff --git a/examples/publish.php b/examples/publish.php
index 4632e9e..04af34b 100644
--- a/examples/publish.php
+++ b/examples/publish.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 use Swoole\Coroutine;
diff --git a/examples/publish_fpm.php b/examples/publish_fpm.php
index 3db9410..b6be133 100644
--- a/examples/publish_fpm.php
+++ b/examples/publish_fpm.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 
diff --git a/examples/server.php b/examples/server.php
index 619d2b5..7ec1139 100644
--- a/examples/server.php
+++ b/examples/server.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Protocol\Types;
 use Simps\MQTT\Protocol\V3;
@@ -29,7 +29,7 @@
     echo "Client #{$fd}: Connect.\n";
 });
 
-$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) {
+$server->on('receive', function (Swoole\Server $server, $fd, $reactorId, $data) {
     try {
         // debug
 //        Common::printf($data);
@@ -101,7 +101,7 @@
                     break;
                 case Types::SUBSCRIBE:
                     $payload = [];
-                    foreach ($data['topics'] as $k => $qos) {
+                    foreach ($data['topics'] as $qos) {
                         if (is_numeric($qos) && $qos < 3) {
                             $payload[] = $qos;
                         } else {
diff --git a/examples/ssl_ca.php b/examples/ssl_ca.php
index a895481..61af0ea 100644
--- a/examples/ssl_ca.php
+++ b/examples/ssl_ca.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 use Simps\MQTT\Config\ClientConfig;
diff --git a/examples/ssl_ca_client.php b/examples/ssl_ca_client.php
index d90f97f..6acef3f 100644
--- a/examples/ssl_ca_client.php
+++ b/examples/ssl_ca_client.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 use Simps\MQTT\Config\ClientConfig;
diff --git a/examples/subscribe.php b/examples/subscribe.php
index ab5bfa3..3e19311 100644
--- a/examples/subscribe.php
+++ b/examples/subscribe.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 use Simps\MQTT\Protocol\Types;
diff --git a/examples/unsubscribe.php b/examples/unsubscribe.php
index f375575..9822cc8 100644
--- a/examples/unsubscribe.php
+++ b/examples/unsubscribe.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/bootstrap.php';
+include_once __DIR__ . '/bootstrap.php';
 
 use Simps\MQTT\Client;
 use Swoole\Coroutine;
diff --git a/examples/v5/publish.php b/examples/v5/publish.php
index a427edb..0ad0f6d 100644
--- a/examples/v5/publish.php
+++ b/examples/v5/publish.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Client;
 use Swoole\Coroutine;
diff --git a/examples/v5/publish_fpm.php b/examples/v5/publish_fpm.php
index 6e7c22f..cdc69d1 100644
--- a/examples/v5/publish_fpm.php
+++ b/examples/v5/publish_fpm.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Client;
 
diff --git a/examples/v5/server.php b/examples/v5/server.php
index d4411b9..c117c10 100644
--- a/examples/v5/server.php
+++ b/examples/v5/server.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Protocol\Types;
 use Simps\MQTT\Protocol\V5;
@@ -29,7 +29,7 @@
     echo "Client #{$fd}: Connect.\n";
 });
 
-$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) {
+$server->on('receive', function (Swoole\Server $server, $fd, $reactorId, $data) {
     try {
         // debug
 //        Common::printf($data);
@@ -130,7 +130,7 @@
                     break;
                 case Types::UNSUBSCRIBE:
                     $payload = [];
-                    foreach ($data['topics'] as $k => $qos) {
+                    foreach ($data['topics'] as $qos) {
                         if (is_numeric($qos) && $qos < 3) {
                             $payload[] = $qos;
                         } else {
diff --git a/examples/v5/subscribe.php b/examples/v5/subscribe.php
index a11c4f6..492b602 100644
--- a/examples/v5/subscribe.php
+++ b/examples/v5/subscribe.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Client;
 use Simps\MQTT\Hex\ReasonCode;
diff --git a/examples/v5/unsubscribe.php b/examples/v5/unsubscribe.php
index 1eb390d..75bf767 100644
--- a/examples/v5/unsubscribe.php
+++ b/examples/v5/unsubscribe.php
@@ -9,7 +9,7 @@
  * please view the LICENSE file that was distributed with this source code.
  */
 
-include __DIR__ . '/../bootstrap.php';
+include_once __DIR__ . '/../bootstrap.php';
 
 use Simps\MQTT\Client;
 use Swoole\Coroutine;
diff --git a/examples/wildcard.php b/examples/wildcard.php
new file mode 100644
index 0000000..dce4d58
--- /dev/null
+++ b/examples/wildcard.php
@@ -0,0 +1,62 @@
+<?php
+/**
+ * This file is part of Simps.
+ *
+ * @link     https://github.com/simps/mqtt
+ * @contact  Lu Fei <lufei@simps.io>
+ *
+ * For the full copyright and license information,
+ * please view the LICENSE file that was distributed with this source code.
+ */
+
+include_once __DIR__ . '/bootstrap.php';
+
+use Simps\MQTT\Client;
+use Simps\MQTT\Protocol\Types;
+use Swoole\Coroutine;
+
+Coroutine\run(function () {
+    $client = new Client(SIMPS_MQTT_REMOTE_HOST, SIMPS_MQTT_PORT, getTestConnectConfig());
+    $will = [
+        'topic' => 'simps-mqtt/users/byebye',
+        'qos' => 0,
+        'retain' => 0,
+        'message' => 'byebye',
+    ];
+    $client->connect(true, $will);
+    $topics['simps-mqtt/users/#'] = 0;
+    $client->subscribe($topics);
+    $timeSincePing = time();
+    while (true) {
+        try {
+            $buffer = $client->recv();
+            if ($buffer && $buffer !== true) {
+                var_dump($buffer);
+                // QoS1 PUBACK
+                if ($buffer['type'] === Types::PUBLISH && $buffer['qos'] === 1) {
+                    $client->send(
+                        [
+                            'type' => Types::PUBACK,
+                            'message_id' => $buffer['message_id'],
+                        ],
+                        false
+                    );
+                }
+                if ($buffer['type'] === Types::DISCONNECT) {
+                    echo "Broker is disconnected\n";
+                    $client->close();
+                    break;
+                }
+            }
+            if ($timeSincePing <= (time() - $client->getConfig()->getKeepAlive())) {
+                $buffer = $client->ping();
+                if ($buffer) {
+                    echo 'send ping success' . PHP_EOL;
+                    $timeSincePing = time();
+                }
+            }
+        } catch (\Throwable $e) {
+            throw $e;
+        }
+    }
+});
diff --git a/src/Client.php b/src/Client.php
index c206300..a6f112a 100644
--- a/src/Client.php
+++ b/src/Client.php
@@ -229,7 +229,7 @@ public function recv()
             $this->connect($this->getConnectData('clean_session') ?? true, $this->getConnectData('will') ?? []);
         } elseif ($response === false && $this->client->errCode !== SOCKET_ETIMEDOUT) {
             $this->handleException();
-        } elseif (is_string($response) && strlen($response) > 0) {
+        } elseif (is_string($response) && strlen($response) !== 0) {
             $this->handleVerbose($response);
 
             if ($this->getConfig()->isMQTT5()) {
diff --git a/src/Constant/Property.php b/src/Constant/Property.php
new file mode 100644
index 0000000..0edfd6d
--- /dev/null
+++ b/src/Constant/Property.php
@@ -0,0 +1,70 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Simps.
+ *
+ * @link     https://github.com/simps/mqtt
+ * @contact  Lu Fei <lufei@simps.io>
+ *
+ * For the full copyright and license information,
+ * please view the LICENSE file that was distributed with this source code.
+ */
+namespace Simps\MQTT\Constant;
+
+class Property
+{
+    public const PAYLOAD_FORMAT_INDICATOR = 'payload_format_indicator';
+
+    public const MESSAGE_EXPIRY_INTERVAL = 'message_expiry_interval';
+
+    public const CONTENT_TYPE = 'content_type';
+
+    public const RESPONSE_TOPIC = 'response_topic';
+
+    public const CORRELATION_DATA = 'correlation_data';
+
+    public const SUBSCRIPTION_IDENTIFIER = 'subscription_identifier';
+
+    public const SESSION_EXPIRY_INTERVAL = 'session_expiry_interval';
+
+    public const ASSIGNED_CLIENT_IDENTIFIER = 'assigned_client_identifier';
+
+    public const SERVER_KEEP_ALIVE = 'server_keep_alive';
+
+    public const AUTHENTICATION_METHOD = 'authentication_method';
+
+    public const AUTHENTICATION_DATA = 'authentication_data';
+
+    public const REQUEST_PROBLEM_INFORMATION = 'request_problem_information';
+
+    public const WILL_DELAY_INTERVAL = 'will_delay_interval';
+
+    public const REQUEST_RESPONSE_INFORMATION = 'request_response_information';
+
+    public const RESPONSE_INFORMATION = 'response_information';
+
+    public const SERVER_REFERENCE = 'server_reference';
+
+    public const REASON_STRING = 'reason_string';
+
+    public const RECEIVE_MAXIMUM = 'receive_maximum';
+
+    public const TOPIC_ALIAS_MAXIMUM = 'topic_alias_maximum';
+
+    public const TOPIC_ALIAS = 'topic_alias';
+
+    public const MAXIMUM_QOS = 'maximum_qos';
+
+    public const RETAIN_AVAILABLE = 'retain_available';
+
+    public const USER_PROPERTY = 'user_property';
+
+    public const MAXIMUM_PACKET_SIZE = 'maximum_packet_size';
+
+    public const WILDCARD_SUBSCRIPTION_AVAILABLE = 'wildcard_subscription_available';
+
+    public const SUBSCRIPTION_IDENTIFIER_AVAILABLE = 'subscription_identifier_available';
+
+    public const SHARED_SUBSCRIPTION_AVAILABLE = 'shared_subscription_available';
+}
diff --git a/src/Message/AbstractMessage.php b/src/Message/AbstractMessage.php
index a796b67..0b51d57 100644
--- a/src/Message/AbstractMessage.php
+++ b/src/Message/AbstractMessage.php
@@ -26,7 +26,7 @@ public function __construct(array $data = [])
             $methodName = 'set' . ucfirst($k);
             if (method_exists($this, $methodName)) {
                 $this->{$methodName}($v);
-            } else {
+            } elseif (isset($this->{$k})) {
                 $this->{$k} = $v;
             }
         }
diff --git a/src/Packet/UnPackV5.php b/src/Packet/UnPackV5.php
index c3e33ac..74277e3 100644
--- a/src/Packet/UnPackV5.php
+++ b/src/Packet/UnPackV5.php
@@ -62,6 +62,7 @@ public static function connect(string $remaining): array
             'user_name' => $userName,
             'password' => $password,
             'keep_alive' => $keepAlive,
+            'client_id' => $clientId,
         ];
 
         if ($propertiesTotalLength) {
@@ -70,8 +71,6 @@ public static function connect(string $remaining): array
             unset($package['properties']);
         }
 
-        $package['client_id'] = $clientId;
-
         if ($willFlag) {
             if ($willPropertiesTotalLength) {
                 $package['will']['properties'] = $willProperties;
diff --git a/src/Property/PackProperty.php b/src/Property/PackProperty.php
index 01cc1f5..4a4b221 100644
--- a/src/Property/PackProperty.php
+++ b/src/Property/PackProperty.php
@@ -19,7 +19,6 @@ class PackProperty
 {
     public static function connect(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $connect = array_flip(PacketMap::$connect);
         foreach ($data as $key => $item) {
@@ -28,43 +27,34 @@ public static function connect(array $data): string
                 $tmpBody .= chr($property);
                 switch ($property) {
                     case Property::SESSION_EXPIRY_INTERVAL:
-                        $length += 5;
+                    case Property::MAXIMUM_PACKET_SIZE:
                         $tmpBody .= PackTool::longInt($item);
                         break;
                     case Property::AUTHENTICATION_METHOD:
                     case Property::AUTHENTICATION_DATA:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                     case Property::REQUEST_PROBLEM_INFORMATION:
                     case Property::REQUEST_RESPONSE_INFORMATION:
-                        $length += 2;
                         $tmpBody .= chr((int) $item);
                         break;
                     case Property::RECEIVE_MAXIMUM:
                     case Property::TOPIC_ALIAS_MAXIMUM:
-                    case Property::MAXIMUM_PACKET_SIZE:
-                        $length += 3;
                         $tmpBody .= PackTool::shortInt($item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($connect['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function willProperties(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $willProperties = array_flip(PacketMap::$willProperties);
         foreach ($data as $key => $item) {
@@ -74,37 +64,29 @@ public static function willProperties(array $data): string
                 switch ($property) {
                     case Property::MESSAGE_EXPIRY_INTERVAL:
                     case Property::WILL_DELAY_INTERVAL:
-                        $length += 5;
                         $tmpBody .= PackTool::longInt($item);
                         break;
                     case Property::CONTENT_TYPE:
                     case Property::RESPONSE_TOPIC:
                     case Property::CORRELATION_DATA:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                     case Property::PAYLOAD_FORMAT_INDICATOR:
-                        $length += 2;
                         $tmpBody .= chr((int) $item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($willProperties['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function connAck(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $connAck = array_flip(PacketMap::$connAck);
         foreach ($data as $key => $item) {
@@ -114,13 +96,11 @@ public static function connAck(array $data): string
                 switch ($property) {
                     case Property::SESSION_EXPIRY_INTERVAL:
                     case Property::MAXIMUM_PACKET_SIZE:
-                        $length += 5;
                         $tmpBody .= PackTool::longInt($item);
                         break;
                     case Property::SERVER_KEEP_ALIVE:
                     case Property::RECEIVE_MAXIMUM:
                     case Property::TOPIC_ALIAS_MAXIMUM:
-                        $length += 3;
                         $tmpBody .= PackTool::shortInt($item);
                         break;
                     case Property::ASSIGNED_CLIENT_IDENTIFIER:
@@ -129,8 +109,6 @@ public static function connAck(array $data): string
                     case Property::RESPONSE_INFORMATION:
                     case Property::SERVER_REFERENCE:
                     case Property::REASON_STRING:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                     case Property::MAXIMUM_QOS:
@@ -138,26 +116,21 @@ public static function connAck(array $data): string
                     case Property::WILDCARD_SUBSCRIPTION_AVAILABLE:
                     case Property::SUBSCRIPTION_IDENTIFIER_AVAILABLE:
                     case Property::SHARED_SUBSCRIPTION_AVAILABLE:
-                        $length += 2;
                         $tmpBody .= chr((int) $item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($connAck['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function publish(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $publish = array_flip(PacketMap::$publish);
         foreach ($data as $key => $item) {
@@ -166,47 +139,35 @@ public static function publish(array $data): string
                 $tmpBody .= chr($property);
                 switch ($property) {
                     case Property::MESSAGE_EXPIRY_INTERVAL:
-                        $length += 5;
                         $tmpBody .= PackTool::longInt($item);
                         break;
                     case Property::TOPIC_ALIAS:
-                        $length += 3;
                         $tmpBody .= PackTool::shortInt($item);
                         break;
                     case Property::CONTENT_TYPE:
                     case Property::RESPONSE_TOPIC:
                     case Property::CORRELATION_DATA:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                     case Property::PAYLOAD_FORMAT_INDICATOR:
-                        $length += 2;
                         $tmpBody .= chr((int) $item);
                         break;
                     case Property::SUBSCRIPTION_IDENTIFIER:
-                        $length += 1;
-                        $value = PackTool::varInt((int) $item);
-                        $length += strlen($value);
-                        $tmpBody .= $value;
+                        $tmpBody .= PackTool::varInt((int) $item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($publish['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function pubAndSub(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $pubAndSub = array_flip(PacketMap::$pubAndSub);
         foreach ($data as $key => $item) {
@@ -215,27 +176,21 @@ public static function pubAndSub(array $data): string
                 $tmpBody .= chr($property);
                 switch ($property) {
                     case Property::REASON_STRING:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($pubAndSub['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function subscribe(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $subscribe = array_flip(PacketMap::$subscribe);
         foreach ($data as $key => $item) {
@@ -244,45 +199,34 @@ public static function subscribe(array $data): string
                 $tmpBody .= chr($property);
                 switch ($property) {
                     case Property::SUBSCRIPTION_IDENTIFIER:
-                        $length += 1;
-                        $value = PackTool::varInt((int) $item);
-                        $length += strlen($value);
-                        $tmpBody .= $value;
+                        $tmpBody .= PackTool::varInt((int) $item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($subscribe['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function unSubscribe(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $unSubscribe = array_flip(PacketMap::$unSubscribe);
         foreach ($data as $key => $item) {
             // Property::USER_PROPERTY
-            $length += 5;
-            $length += strlen((string) $key);
-            $length += strlen((string) $item);
             $tmpBody .= chr($unSubscribe['user_property']);
             $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function disConnect(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $disConnect = array_flip(PacketMap::$disConnect);
         foreach ($data as $key => $item) {
@@ -291,32 +235,25 @@ public static function disConnect(array $data): string
                 $tmpBody .= chr($property);
                 switch ($property) {
                     case Property::SESSION_EXPIRY_INTERVAL:
-                        $length += 5;
                         $tmpBody .= PackTool::longInt($item);
                         break;
                     case Property::SERVER_REFERENCE:
                     case Property::REASON_STRING:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($disConnect['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 
     public static function auth(array $data): string
     {
-        $length = 0;
         $tmpBody = '';
         $auth = array_flip(PacketMap::$auth);
         foreach ($data as $key => $item) {
@@ -327,21 +264,16 @@ public static function auth(array $data): string
                     case Property::AUTHENTICATION_METHOD:
                     case Property::AUTHENTICATION_DATA:
                     case Property::REASON_STRING:
-                        $length += 3;
-                        $length += strlen($item);
                         $tmpBody .= PackTool::string($item);
                         break;
                 }
             } else {
                 // Property::USER_PROPERTY
-                $length += 5;
-                $length += strlen((string) $key);
-                $length += strlen((string) $item);
                 $tmpBody .= chr($auth['user_property']);
                 $tmpBody .= PackTool::stringPair((string) $key, (string) $item);
             }
         }
 
-        return chr($length) . $tmpBody;
+        return PackTool::genProperties($tmpBody);
     }
 }
diff --git a/src/Property/UnPackProperty.php b/src/Property/UnPackProperty.php
index 1c00f4d..ffec78b 100644
--- a/src/Property/UnPackProperty.php
+++ b/src/Property/UnPackProperty.php
@@ -28,6 +28,7 @@ public static function connect(int $length, string &$remaining): array
                 $remaining = substr($remaining, 1);
                 switch ($property) {
                     case Property::SESSION_EXPIRY_INTERVAL:
+                    case Property::MAXIMUM_PACKET_SIZE:
                         $properties[$key] = UnPackTool::longInt($remaining);
                         $length -= 5;
                         break;
@@ -44,7 +45,6 @@ public static function connect(int $length, string &$remaining): array
                         break;
                     case Property::RECEIVE_MAXIMUM:
                     case Property::TOPIC_ALIAS_MAXIMUM:
-                    case Property::MAXIMUM_PACKET_SIZE:
                         $properties[$key] = UnPackTool::shortInt($remaining);
                         $length -= 3;
                         break;
diff --git a/src/Tools/PackTool.php b/src/Tools/PackTool.php
index 133c989..1ec2ddd 100644
--- a/src/Tools/PackTool.php
+++ b/src/Tools/PackTool.php
@@ -57,6 +57,11 @@ public static function packHeader(int $type, int $bodyLength, int $dup = 0, int
         return chr($type) . static::packRemainingLength($bodyLength);
     }
 
+    public static function genProperties(string $body): string
+    {
+        return static::packRemainingLength(strlen($body)) . $body;
+    }
+
     protected static function packRemainingLength(int $bodyLength): string
     {
         $string = '';
diff --git a/tests/Unit/ClientConfigTest.php b/tests/Unit/ClientConfigTest.php
index 006f05f..58602d1 100644
--- a/tests/Unit/ClientConfigTest.php
+++ b/tests/Unit/ClientConfigTest.php
@@ -31,34 +31,29 @@ public function testIsMQTT5()
             ->setDelay(3000)
             ->setMaxAttempts(5)
             ->setSwooleConfig(SWOOLE_MQTT_CONFIG);
-        $this->assertEquals($config->getUserName(), '');
-        $this->assertEquals($config->getPassword(), '');
+        $this->assertEquals('', $config->getUserName());
+        $this->assertEquals('', $config->getPassword());
         $this->assertFalse($config->isMQTT5());
-        $this->assertEquals($config->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1, $config->getProtocolLevel());
 
         $config->setProperties(['receive_maximum' => 65535]);
         $this->assertTrue($config->isMQTT5());
-        $this->assertEquals($config->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0, $config->getProtocolLevel());
 
         $config->setProtocolLevel(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1);
         $this->assertTrue($config->isMQTT5());
-        $this->assertEquals($config->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0, $config->getProtocolLevel());
     }
 
     public function testSwooleDefaultConfig()
     {
         $config = new ClientConfig();
         $config->setSwooleConfig([]);
-        $this->assertEquals($config->getSwooleConfig(), [
-            'open_mqtt_protocol' => true,
-        ]);
+        $this->assertEquals(['open_mqtt_protocol' => true], $config->getSwooleConfig());
         $config->setSwooleConfig([
             'open_mqtt_protocol' => false,
             'package_max_length' => 2 * 1024 * 1024,
         ]);
-        $this->assertEquals($config->getSwooleConfig(), [
-            'open_mqtt_protocol' => false,
-            'package_max_length' => 2 * 1024 * 1024,
-        ]);
+        $this->assertEquals(['open_mqtt_protocol' => false,  'package_max_length' => 2 * 1024 * 1024], $config->getSwooleConfig());
     }
 }
diff --git a/tests/Unit/ClientTest.php b/tests/Unit/ClientTest.php
index 9a02555..37f3a24 100644
--- a/tests/Unit/ClientTest.php
+++ b/tests/Unit/ClientTest.php
@@ -40,20 +40,22 @@ public function testBase64()
     {
         $topic = 'simps-mqtt/test/base64';
         $base64 = base64_encode(file_get_contents(TESTS_DIR . '/files/wechat.jpg'));
-        $client = new MQTTClient(SIMPS_MQTT_REMOTE_HOST, SIMPS_MQTT_PORT, getTestConnectConfig());
+        $config = getTestConnectConfig();
+        $config->setSwooleConfig(['read_timeout' => 10.0]);
+        $client = new MQTTClient('test.mosquitto.org', SIMPS_MQTT_PORT, $config);
         $client->connect(false);
         $client->subscribe([$topic => 0]);
 
         Coroutine::create(function () use ($topic, $base64) {
-            $client = new MQTTClient(SIMPS_MQTT_REMOTE_HOST, SIMPS_MQTT_PORT, getTestConnectConfig());
+            $client = new MQTTClient('test.mosquitto.org', SIMPS_MQTT_PORT, getTestConnectConfig());
             $client->connect();
             $client->publish($topic, $base64);
         });
 
         $buffer = $client->recv();
-        $this->assertSame($buffer['type'], Types::PUBLISH);
-        $this->assertSame($buffer['topic'], $topic);
-        $this->assertSame(strlen($buffer['message']), strlen($base64));
+        $this->assertSame(Types::PUBLISH, $buffer['type']);
+        $this->assertSame($topic, $buffer['topic']);
+        $this->assertSame(strlen($base64), strlen($buffer['message']));
     }
 
     public function testNonWillWithProtocolException()
@@ -69,7 +71,7 @@ public function testNonWillWithProtocolException()
             $client->connect(false, $will);
         } catch (\Throwable $ex) {
             $this->assertInstanceOf(ProtocolException::class, $ex);
-            $this->assertSame($ex->getMessage(), 'Topic cannot be empty');
+            $this->assertSame('Topic cannot be empty', $ex->getMessage());
         }
     }
 
diff --git a/tests/Unit/MessageTest.php b/tests/Unit/MessageTest.php
index a95aa68..428b08b 100644
--- a/tests/Unit/MessageTest.php
+++ b/tests/Unit/MessageTest.php
@@ -35,8 +35,8 @@ public function testPublishMessage()
             ->setMessageId(1)
             ->setProperties(['message_expiry_interval' => 100]);
         $this->assertEquals(
-            $message->getContents(),
             (string) $message,
+            $message->getContents(),
             'The results of getContents and toString should be the same'
         );
         $this->assertIsArray($message->getContents(true));
@@ -57,7 +57,7 @@ public function testPingRespMessage()
             'The results of getContents and toString should be the same'
         );
         $this->assertIsArray($message->getContents(true));
-        $this->assertEquals($message->getContents(true)['type'], Types::PINGRESP);
+        $this->assertEquals(Types::PINGRESP, $message->getContents(true)['type']);
         $this->assertIsArray($message->toArray());
         $this->assertEquals(
             $message->toArray(),
@@ -93,14 +93,14 @@ public function testIsMQTT5()
             ->setMessageId(1);
 
         $this->assertFalse($message->isMQTT5());
-        $this->assertEquals($message->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1, $message->getProtocolLevel());
 
         $message->setProperties(['message_expiry_interval' => 100]);
         $this->assertTrue($message->isMQTT5());
-        $this->assertEquals($message->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0, $message->getProtocolLevel());
 
         $message->setProtocolLevel(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1);
         $this->assertTrue($message->isMQTT5());
-        $this->assertEquals($message->getProtocolLevel(), ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0);
+        $this->assertEquals(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0, $message->getProtocolLevel());
     }
 }
diff --git a/tests/Unit/ToolsTest.php b/tests/Unit/ToolsTest.php
index 082da01..9747761 100644
--- a/tests/Unit/ToolsTest.php
+++ b/tests/Unit/ToolsTest.php
@@ -29,9 +29,9 @@ public function testGetLevel()
         $connect_31 = '104400064d51497364700306000a001353696d70735f36313362316164323236626334001973696d70732d6d7174742f757365723030312f64656c6574650006627965627965';
         $connect_311 = '104200044d5154540406000a001353696d70735f36313362313830323035636633001973696d70732d6d7174742f757365723030312f64656c6574650006627965627965';
         $connect_50 = '106200044d515454050e000a0b110000003c21ffff22ffff001353696d70735f3631336231613330313962663213180000003c020000003c030004746573740101001973696d70732d6d7174742f757365723030312f64656c6574650006627965627965';
-        $this->assertSame(UnPackTool::getLevel(hex2bin($connect_31)), ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1);
-        $this->assertSame(UnPackTool::getLevel(hex2bin($connect_311)), ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1);
-        $this->assertSame(UnPackTool::getLevel(hex2bin($connect_50)), ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0);
+        $this->assertSame(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1, UnPackTool::getLevel(hex2bin($connect_31)));
+        $this->assertSame(ProtocolInterface::MQTT_PROTOCOL_LEVEL_3_1_1, UnPackTool::getLevel(hex2bin($connect_311)));
+        $this->assertSame(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0, UnPackTool::getLevel(hex2bin($connect_50)));
     }
 
     public function testInvalidGetLevel()
@@ -41,7 +41,7 @@ public function testInvalidGetLevel()
             UnPackTool::getLevel(hex2bin($connAck));
         } catch (\Throwable $ex) {
             $this->assertInstanceOf(InvalidArgumentException::class, $ex);
-            $this->assertSame($ex->getMessage(), 'packet must be of type connect, connack given');
+            $this->assertSame('packet must be of type connect, connack given', $ex->getMessage());
         }
     }
 
@@ -56,9 +56,8 @@ public function testDebug2HexDump()
 00000050    65 72 30 30 31 2f 64 65 6c 65 74 65 00 06 62 79 
 00000060    65 62 79 65                                     ';
         $bin = hex2bin($hex);
-        $debug = new Debug($bin);
-        $this->assertSame($debug->hexDump(), $string);
-        $this->assertSame(UnPackTool::hexDump($bin), $string);
+        $this->assertSame($string, (new Debug($bin))->hexDump());
+        $this->assertSame($string, UnPackTool::hexDump($bin));
     }
 
     public function testDebug2hexDumpAscii()
@@ -72,27 +71,24 @@ public function testDebug2hexDumpAscii()
 00000050    65 72 30 30 31 2f 64 65 6c 65 74 65 00 06 62 79    er001/delete..by
 00000060    65 62 79 65                                        ebye';
         $bin = hex2bin($hex);
-        $debug = new Debug($bin);
-        $this->assertSame($debug->hexDumpAscii(), $string);
-        $this->assertSame(UnPackTool::hexDumpAscii($bin), $string);
+        $this->assertSame($string, (new Debug($bin))->hexDumpAscii());
+        $this->assertSame($string, UnPackTool::hexDumpAscii($bin));
     }
 
     public function testDebug2PrintableText()
     {
         $hex = '106200044d515454050e000a0b110000003c21ffff22ffff001353696d70735f3631336231613330313962663213180000003c020000003c030004746573740101001973696d70732d6d7174742f757365723030312f64656c6574650006627965627965';
         $bin = hex2bin($hex);
-        $debug = new Debug($bin);
-        $this->assertSame($debug->printableText(), $bin);
-        $this->assertSame(UnPackTool::printableText($bin), $bin);
+        $this->assertSame($bin, (new Debug($bin))->printableText());
+        $this->assertSame($bin, UnPackTool::printableText($bin));
     }
 
     public function testDebug2HexStream()
     {
         $hex = '106200044d515454050e000a0b110000003c21ffff22ffff001353696d70735f3631336231613330313962663213180000003c020000003c030004746573740101001973696d70732d6d7174742f757365723030312f64656c6574650006627965627965';
         $bin = hex2bin($hex);
-        $debug = new Debug($bin);
-        $this->assertSame($debug->hexStream(), $hex);
-        $this->assertSame(UnPackTool::hexStream($bin), $hex);
+        $this->assertSame($hex, (new Debug($bin))->hexStream());
+        $this->assertSame($hex, UnPackTool::hexStream($bin));
     }
 
     public function testDebug2Ascii()
@@ -106,8 +102,7 @@ public function testDebug2Ascii()
 00000050    er001/delete..by
 00000060    ebye';
         $bin = hex2bin($hex);
-        $debug = new Debug($bin);
-        $this->assertSame($debug->ascii(), $string);
-        $this->assertSame(UnPackTool::ascii($bin), $string);
+        $this->assertSame($string, (new Debug($bin))->ascii());
+        $this->assertSame($string, UnPackTool::ascii($bin));
     }
 }
diff --git a/tests/V3/PacketTest.php b/tests/V3/PacketTest.php
index e41fc5a..c6123af 100644
--- a/tests/V3/PacketTest.php
+++ b/tests/V3/PacketTest.php
@@ -44,7 +44,7 @@ public function testConnect()
     {
         $res = self::$client->connect();
         $this->assertIsArray($res);
-        $this->assertSame($res['type'], Types::CONNACK);
+        $this->assertSame(Types::CONNACK, $res['type']);
     }
 
     /**
@@ -55,8 +55,8 @@ public function testSubscribe()
         $topics[self::$topic] = 1;
         $res = self::$client->subscribe($topics);
         $this->assertIsArray($res);
-        $this->assertSame($res['type'], Types::SUBACK);
-        $this->assertSame($res['codes'][0], ReasonCode::GRANTED_QOS_1);
+        $this->assertSame(Types::SUBACK, $res['type']);
+        $this->assertSame(ReasonCode::GRANTED_QOS_1, $res['codes'][0]);
     }
 
     /**
@@ -66,7 +66,7 @@ public function testPublish()
     {
         $buffer = self::$client->publish(self::$topic, 'hello,simps', 1);
         $this->assertIsArray($buffer);
-        $this->assertSame($buffer['type'], Types::PUBACK);
+        $this->assertSame(Types::PUBACK, $buffer['type']);
     }
 
     /**
@@ -76,9 +76,9 @@ public function testRecv()
     {
         $buffer = self::$client->recv();
         $this->assertIsArray($buffer);
-        $this->assertSame($buffer['type'], Types::PUBLISH);
-        $this->assertSame($buffer['topic'], self::$topic);
-        $this->assertSame($buffer['message'], 'hello,simps');
+        $this->assertSame(Types::PUBLISH, $buffer['type']);
+        $this->assertSame(self::$topic, $buffer['topic']);
+        $this->assertSame('hello,simps', $buffer['message']);
     }
 
     /**
@@ -88,7 +88,7 @@ public function testPing()
     {
         $buffer = self::$client->ping();
         $this->assertIsArray($buffer);
-        $this->assertSame($buffer['type'], Types::PINGRESP);
+        $this->assertSame(Types::PINGRESP, $buffer['type']);
     }
 
     /**
@@ -98,7 +98,7 @@ public function testUnsubscribe()
     {
         $status = self::$client->unSubscribe([self::$topic]);
         $this->assertIsArray($status);
-        $this->assertSame($status['type'], Types::UNSUBACK);
+        $this->assertSame(Types::UNSUBACK, $status['type']);
     }
 
     /**
diff --git a/tests/V5/PacketTest.php b/tests/V5/PacketTest.php
index e9c18ae..89a45e6 100644
--- a/tests/V5/PacketTest.php
+++ b/tests/V5/PacketTest.php
@@ -17,6 +17,7 @@
 use Simps\MQTT\Exception\ProtocolException;
 use Simps\MQTT\Hex\ReasonCode;
 use Simps\MQTT\Protocol\Types;
+use Swoole\Coroutine;
 
 /**
  * @internal
@@ -44,7 +45,7 @@ public function testConnect()
     {
         $res = self::$client->connect();
         $this->assertIsArray($res);
-        $this->assertSame($res['type'], Types::CONNACK);
+        $this->assertSame(Types::CONNACK, $res['type']);
     }
 
     /**
@@ -68,10 +69,10 @@ public function testSubscribe()
         ];
         $res = self::$client->subscribe($topics);
         $this->assertIsArray($res);
-        $this->assertSame($res['type'], Types::SUBACK);
+        $this->assertSame(Types::SUBACK, $res['type']);
         $this->assertIsArray($res['codes']);
-        $this->assertSame($res['codes'][0], ReasonCode::GRANTED_QOS_1);
-        $this->assertSame($res['codes'][1], ReasonCode::GRANTED_QOS_2);
+        $this->assertSame(ReasonCode::GRANTED_QOS_1, $res['codes'][0]);
+        $this->assertSame(ReasonCode::GRANTED_QOS_2, $res['codes'][1]);
     }
 
     /**
@@ -79,14 +80,14 @@ public function testSubscribe()
      */
     public function testPublish()
     {
-        go(function () {
+        Coroutine::create(function () {
             $client = new Client(SIMPS_MQTT_REMOTE_HOST, SIMPS_MQTT_PORT, getTestMQTT5ConnectConfig());
             $res = $client->connect();
             $this->assertIsArray($res);
             $buffer = $client->publish(self::$topic . '/get', 'hello,simps', 1);
             $this->assertIsArray($buffer);
-            $this->assertSame($buffer['type'], Types::PUBACK);
-            $this->assertSame(ReasonCode::getReasonPhrase($buffer['code']), 'Success');
+            $this->assertSame(Types::PUBACK, $buffer['type']);
+            $this->assertSame('Success', ReasonCode::getReasonPhrase($buffer['code']));
         });
     }
 
@@ -97,9 +98,9 @@ public function testRecv()
     {
         $buffer = self::$client->recv();
         $this->assertIsArray($buffer);
-        $this->assertSame($buffer['type'], Types::PUBLISH);
-        $this->assertSame($buffer['topic'], self::$topic . '/get');
-        $this->assertSame($buffer['message'], 'hello,simps');
+        $this->assertSame(Types::PUBLISH, $buffer['type']);
+        $this->assertSame(self::$topic . '/get', $buffer['topic']);
+        $this->assertSame('hello,simps', $buffer['message']);
     }
 
     /**
@@ -109,7 +110,7 @@ public function testPing()
     {
         $buffer = self::$client->ping();
         $this->assertIsArray($buffer);
-        $this->assertSame($buffer['type'], Types::PINGRESP);
+        $this->assertSame(Types::PINGRESP, $buffer['type']);
     }
 
     /**
@@ -119,9 +120,9 @@ public function testUnsubscribe()
     {
         $status = self::$client->unSubscribe([self::$topic . '/get', self::$topic . '/update']);
         $this->assertIsArray($status);
-        $this->assertSame($status['type'], Types::UNSUBACK);
-        $this->assertSame(ReasonCode::getReasonPhrase($status['codes'][0]), 'Success');
-        $this->assertSame(ReasonCode::getReasonPhrase($status['codes'][1]), 'Success');
+        $this->assertSame(Types::UNSUBACK, $status['type']);
+        $this->assertSame('Success', ReasonCode::getReasonPhrase($status['codes'][0]));
+        $this->assertSame('Success', ReasonCode::getReasonPhrase($status['codes'][1]));
     }
 
     /**