2026-04-20-1

project_version=4.4.14.19
* 修复clear指令构建命令时抛出转型异常导致无法正确发送指令
* 修复ChangePolicy增加和减小index写反的问题

.github/workflows/build-and-release.yml

@@ -2,16 +2,16 @@ name: Build and Release
 
 on:
   push:
-    tags:
+    branches:
-      - 'build*'   # 当推送以 build:开头的 tag 时触发，比如 buildXXXX
+      - "rebuild-develop"   # develop 分支只构建
+      - "rebuild-release"   # release 分支构建 + 发布
   workflow_dispatch: # 允许手动触发
 
 jobs:
   build:
     runs-on: ubuntu-latest
-
     steps:
-      - name: Checkout repository #在 GitHub Actions 的虚拟机上，把仓库里的代码拉下来
+      - name: Checkout repository
         uses: actions/checkout@v3
 
       - name: Set up JDK 17
@@ -26,36 +26,54 @@ jobs:
       - name: Build with Gradle
         run: ./gradlew clean build
 
-      - name: Upload build artifacts
+      - name: Upload common jar
-        uses: actions/upload-artifact@v3
+        uses: actions/upload-artifact@v4
         with:
-          name: my-build
+          name: Common
-          path: '**/build/libs/*.jar'
+          path: Common/build/libs/*.jar
+
+      - name: Upload common api jar
+        uses: actions/upload-artifact@v4
+        with:
+          name: CommonApi
+          path: CommonApi/build/libs/*.jar
 
   release:
-    needs: build  # 这个 job 依赖于上一个 job build 完成。
+    needs: build
     runs-on: ubuntu-latest
-    steps:
-      - name: Download build artifact # 把上一个 job 上传的构建产物下载到当前 job 的 runner 上。
-        uses: actions/download-artifact@v3
-        with:
-          name: my-build
-          path: ./build-artifacts
 
-      - name: Create GitHub Release # 在 GitHub 上创建一个新的 Release（版本发布）
+    if: github.ref_name == 'rebuild-release'  # 仅在 release 分支执行 release job
+    steps:
+      # 下载构建产物
+      - name: Download Common artifact
+        uses: actions/download-artifact@v4
+        with:
+          name: Common
+          path: ./build-artifacts/Common
+
+      - name: Download CommonApi artifact
+        uses: actions/download-artifact@v4
+        with:
+          name: CommonApi
+          path: ./build-artifacts/CommonApi
+
+      # 创建 GitHub Release
+      - name: Create GitHub Release
         id: create_release
         uses: softprops/action-gh-release@v1
         with:
-          tag_name: ${{ github.ref_name }}
+          tag_name: "release-${{ github.run_number }}"  # 可用 run_number 或自定义版本号
-          name: Release ${{ github.ref_name }}
+          name: Release ${{ github.run_number }}
-          body: |
+          body: 自动发布所有子项目构建产物
-            自动发布所有子项目构建产物。
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
-      - name: Upload artifact to Release # 上传构建产物到 Release
+      # 上传子项目 JAR
-        uses: softprops/action-gh-release@v1
+      - name: Upload jars to Release
-        with:
+        run: |
-          files: ./build-artifacts/**/*.jar
+          for file in ./build-artifacts/**/*.jar; do
+            echo "Uploading $file"
+            gh release upload "release-${GITHUB_RUN_NUMBER}" "$file" --repo "${GITHUB_REPOSITORY}" --clobber
+          done
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.idea/intellij-javadocs-4.0.1.xml

@@ -0,0 +1,204 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="JavaDocConfiguration">
+    <GENERAL>
+      <MODE>UPDATE</MODE>
+      <OVERRIDDEN_METHODS>false</OVERRIDDEN_METHODS>
+      <SPLITTED_CLASS_NAME>true</SPLITTED_CLASS_NAME>
+      <LEVELS>
+        <LEVEL>TYPE</LEVEL>
+        <LEVEL>METHOD</LEVEL>
+        <LEVEL>FIELD</LEVEL>
+      </LEVELS>
+      <VISIBILITIES>
+        <VISIBILITY>PUBLIC</VISIBILITY>
+        <VISIBILITY>DEFAULT</VISIBILITY>
+        <VISIBILITY>PROTECTED</VISIBILITY>
+      </VISIBILITIES>
+    </GENERAL>
+    <TEMPLATES>
+      <CLASSES>
+        <CLASS>
+          <KEY>^.*(public|protected|private)*.+interface\s+\w+.*</KEY>
+          <VALUE>/**\n
+ * The interface ${name}.\n
+&lt;#if element.typeParameters?has_content&gt;        * \n
+&lt;/#if&gt;
+&lt;#list element.typeParameters as typeParameter&gt;
+        * @param &lt;${typeParameter.name}&gt; the type parameter\n
+&lt;/#list&gt;
+ */</VALUE>
+        </CLASS>
+        <CLASS>
+          <KEY>^.*(public|protected|private)*.+enum\s+\w+.*</KEY>
+          <VALUE>/**\n
+ * The enum ${name}.\n
+ */</VALUE>
+        </CLASS>
+        <CLASS>
+          <KEY>^.*(public|protected|private)*.+class\s+\w+.*</KEY>
+          <VALUE>/**\n
+ * The type ${name}.\n
+&lt;#if element.typeParameters?has_content&gt;        * \n
+&lt;/#if&gt;
+&lt;#list element.typeParameters as typeParameter&gt;
+        * @param &lt;${typeParameter.name}&gt; the type parameter\n
+&lt;/#list&gt;
+ */</VALUE>
+        </CLASS>
+        <CLASS>
+          <KEY>.+</KEY>
+          <VALUE>/**\n
+ * The type ${name}.\n
+ */</VALUE>
+        </CLASS>
+      </CLASSES>
+      <CONSTRUCTORS>
+        <CONSTRUCTOR>
+          <KEY>.+</KEY>
+          <VALUE>/**\n
+ * Instantiates a new ${name}.\n
+&lt;#if element.parameterList.parameters?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.parameterList.parameters as parameter&gt;
+         * @param ${parameter.name} the ${paramNames[parameter.name]}\n
+&lt;/#list&gt;
+&lt;#if element.throwsList.referenceElements?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.throwsList.referenceElements as exception&gt;
+         * @throws ${exception.referenceName} the ${exceptionNames[exception.referenceName]}\n
+&lt;/#list&gt;
+ */</VALUE>
+        </CONSTRUCTOR>
+      </CONSTRUCTORS>
+      <METHODS>
+        <METHOD>
+          <KEY>^.*(public|protected|private)*\s*.*(\w(\s*&lt;.+&gt;)*)+\s+get\w+\s*\(.*\).+</KEY>
+          <VALUE>/**\n
+ * Gets ${partName}.\n
+&lt;#if element.typeParameters?has_content&gt;         * \n
+&lt;/#if&gt;
+&lt;#list element.typeParameters as typeParameter&gt;
+         * @param &lt;${typeParameter.name}&gt; the type parameter\n
+&lt;/#list&gt;
+&lt;#if element.parameterList.parameters?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.parameterList.parameters as parameter&gt;
+         * @param ${parameter.name} the ${paramNames[parameter.name]}\n
+&lt;/#list&gt;
+&lt;#if isNotVoid&gt;
+         *\n
+         * @return the ${partName}\n
+&lt;/#if&gt;
+&lt;#if element.throwsList.referenceElements?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.throwsList.referenceElements as exception&gt;
+         * @throws ${exception.referenceName} the ${exceptionNames[exception.referenceName]}\n
+&lt;/#list&gt;
+ */</VALUE>
+        </METHOD>
+        <METHOD>
+          <KEY>^.*(public|protected|private)*\s*.*(void|\w(\s*&lt;.+&gt;)*)+\s+set\w+\s*\(.*\).+</KEY>
+          <VALUE>/**\n
+ * Sets ${partName}.\n
+&lt;#if element.typeParameters?has_content&gt;         * \n
+&lt;/#if&gt;
+&lt;#list element.typeParameters as typeParameter&gt;
+         * @param &lt;${typeParameter.name}&gt; the type parameter\n
+&lt;/#list&gt;
+&lt;#if element.parameterList.parameters?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.parameterList.parameters as parameter&gt;
+         * @param ${parameter.name} the ${paramNames[parameter.name]}\n
+&lt;/#list&gt;
+&lt;#if isNotVoid&gt;
+         *\n
+         * @return the ${partName}\n
+&lt;/#if&gt;
+&lt;#if element.throwsList.referenceElements?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.throwsList.referenceElements as exception&gt;
+         * @throws ${exception.referenceName} the ${exceptionNames[exception.referenceName]}\n
+&lt;/#list&gt;
+ */</VALUE>
+        </METHOD>
+        <METHOD>
+          <KEY>^.*((public\s+static)|(static\s+public))\s+void\s+main\s*\(\s*String\s*(\[\s*\]|\.\.\.)\s+\w+\s*\).+</KEY>
+          <VALUE>/**\n
+ * The entry point of application.\n
+
+     &lt;#if element.parameterList.parameters?has_content&gt;
+         *\n
+&lt;/#if&gt;
+     * @param ${element.parameterList.parameters[0].name} the input arguments\n
+&lt;#if element.throwsList.referenceElements?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.throwsList.referenceElements as exception&gt;
+         * @throws ${exception.referenceName} the ${exceptionNames[exception.referenceName]}\n
+&lt;/#list&gt;
+ */</VALUE>
+        </METHOD>
+        <METHOD>
+          <KEY>.+</KEY>
+          <VALUE>/**\n
+ * ${name}&lt;#if isNotVoid&gt; ${return}&lt;/#if&gt;.\n
+&lt;#if element.typeParameters?has_content&gt;         * \n
+&lt;/#if&gt;
+&lt;#list element.typeParameters as typeParameter&gt;
+         * @param &lt;${typeParameter.name}&gt; the type parameter\n
+&lt;/#list&gt;
+&lt;#if element.parameterList.parameters?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.parameterList.parameters as parameter&gt;
+         * @param ${parameter.name} the ${paramNames[parameter.name]}\n
+&lt;/#list&gt;
+&lt;#if isNotVoid&gt;
+         *\n
+         * @return the ${return}\n
+&lt;/#if&gt;
+&lt;#if element.throwsList.referenceElements?has_content&gt;
+         *\n
+&lt;/#if&gt;
+&lt;#list element.throwsList.referenceElements as exception&gt;
+         * @throws ${exception.referenceName} the ${exceptionNames[exception.referenceName]}\n
+&lt;/#list&gt;
+ */</VALUE>
+        </METHOD>
+      </METHODS>
+      <FIELDS>
+        <FIELD>
+          <KEY>^.*(public|protected|private)*.+static.*(\w\s\w)+.+</KEY>
+          <VALUE>/**\n
+ * The constant ${element.getName()}.\n
+ */</VALUE>
+        </FIELD>
+        <FIELD>
+          <KEY>^.*(public|protected|private)*.*(\w\s\w)+.+</KEY>
+          <VALUE>/**\n
+    &lt;#if element.parent.isInterface()&gt;
+        * The constant ${element.getName()}.\n
+&lt;#else&gt;
+        * The ${name}.\n
+&lt;/#if&gt; */</VALUE>
+        </FIELD>
+        <FIELD>
+          <KEY>.+</KEY>
+          <VALUE>/**\n
+    &lt;#if element.parent.isEnum()&gt;
+        *${name} ${typeName}.\n
+&lt;#else&gt;
+        * The ${name}.\n
+&lt;/#if&gt;*/</VALUE>
+        </FIELD>
+      </FIELDS>
+    </TEMPLATES>
+  </component>
+</project>

.idea/misc.xml

@@ -1,4 +1,3 @@
-<?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="ASMIdeaPluginConfiguration">
     <asm skipDebug="false" skipFrames="false" skipCode="false" expandFrames="false" />

.idea/uiDesigner.xml

@@ -0,0 +1,124 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Palette2">
+    <group name="Swing">
+      <item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
+      </item>
+      <item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
+        <default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
+        <initial-values>
+          <property name="text" value="Button" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="RadioButton" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="CheckBox" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="Label" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
+          <preferred-size width="-1" height="20" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
+      </item>
+    </group>
+  </component>
+</project>

Common/build.gradle

@@ -21,33 +21,27 @@ base {
 repositories {
     mavenCentral()
 }
+javadoc {
+    options.encoding = 'UTF-8'
+    options.charSet = 'UTF-8'
+    // 添加以下选项以减少警告
+    options.addBooleanOption('Xdoclint:none', true)
+    options.addStringOption('Xmaxwarns', '10')
+}
 
 dependencies {
     // Common 依赖 CommonApi
     api project(':CommonApi')
-
-    implementation 'org.apache.logging.log4j:log4j-core:2.23.1'
-    implementation 'org.apache.logging.log4j:log4j-api:2.23.1'
-    implementation 'org.apache.logging.log4j:log4j-slf4j2-impl:2.23.1'
-    implementation 'org.realityforge.org.jetbrains.annotations:org.jetbrains.annotations:1.7.0'
-    implementation 'org.apache.commons:commons-lang3:3.17.0'
-    implementation 'com.google.guava:guava:33.3.0-jre'
-    implementation 'io.netty:netty-all:4.1.109.Final'
-    implementation 'com.google.code.gson:gson:2.10.1'
-    implementation 'org.slf4j:slf4j-api:2.0.16'
-
-    testImplementation platform('org.junit:junit-bom:5.10.0')
-    testImplementation 'org.junit.jupiter:junit-jupiter'
 }
 
 // Sources JAR
-task sourcesJar(type: Jar) {
+tasks.register('sourcesJar', Jar) {
     from sourceSets.main.allSource
     archiveClassifier = 'sources'
 }
 
 // Javadoc JAR
-task javadocJar(type: Jar) {
+tasks.register('javadocJar', Jar) {
     dependsOn javadoc
     from javadoc.destinationDir
     archiveClassifier = 'javadoc'
@@ -82,9 +76,22 @@ publishing {
             artifact shadowJar
             artifact sourcesJar
             artifact javadocJar
-            groupId = project.group.toString()
+            pom {
-            artifactId = base.archivesName.get()
+                name = "${project_name}"
-            version = project.version.toString()
+                description = "${project_name}"
+                url = "https://github.com/3944Realms/DG_LAB_DEVELOP"
+
+                licenses {
+                    license {
+                        name = 'Apache License 2.0'
+                        url = 'https://www.apache.org/licenses/LICENSE-2.0.html'
+                    }
+                }
+                issueManagement {
+                    system = 'GitHub Issues'
+                    url = 'https://github.com/3944Realms/DG_LAB_DEVELOP/issues'
+                }
+            }
         }
     }
 }

Common/src/main/java/com/r3944realms/dg_lab/manager/DGPBClientManager.java

@@ -16,9 +16,10 @@
 
 package com.r3944realms.dg_lab.manager;
 
+import com.r3944realms.dg_lab.api.manager.IDGLabManager;
 import com.r3944realms.dg_lab.api.manager.Status;
-import com.r3944realms.dg_lab.websocket.PowerBoxWSClient;
 import com.r3944realms.dg_lab.api.websocket.message.Message;
+import com.r3944realms.dg_lab.websocket.PowerBoxWSClient;
 import com.r3944realms.dg_lab.websocket.sharedData.ClientPowerBoxSharedData;
 
 /**

Common/src/main/java/com/r3944realms/dg_lab/manager/DGPBServerManager.java

@@ -18,8 +18,8 @@ package com.r3944realms.dg_lab.manager;
 
 import com.r3944realms.dg_lab.api.manager.IDGLabManager;
 import com.r3944realms.dg_lab.api.manager.Status;
-import com.r3944realms.dg_lab.websocket.PowerBoxWSServer;
 import com.r3944realms.dg_lab.api.websocket.message.Message;
+import com.r3944realms.dg_lab.websocket.PowerBoxWSServer;
 import com.r3944realms.dg_lab.websocket.sharedData.ServerPowerBoxSharedData;
 
 /**

Common/src/main/java/com/r3944realms/dg_lab/utils/timeTask/DgLabTimerTask.java

@@ -17,11 +17,11 @@
 package com.r3944realms.dg_lab.utils.timeTask;
 
 
-import com.r3944realms.dg_lab.utils.annoation.NeedCompletedInFuture;
 import com.r3944realms.dg_lab.api.websocket.message.Message;
 import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
 import com.r3944realms.dg_lab.api.websocket.message.role.PlaceholderRole;
 import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketClientRole;
+import com.r3944realms.dg_lab.utils.annoation.NeedCompletedInFuture;
 import io.netty.channel.ChannelHandlerContext;
 
 import java.util.TimerTask;

Common/src/main/java/com/r3944realms/dg_lab/websocket/AbstractWebSocketClient.java

@@ -18,9 +18,9 @@ package com.r3944realms.dg_lab.websocket;
 
 import com.r3944realms.dg_lab.DgLab;
 import com.r3944realms.dg_lab.api.manager.Status;
+import com.r3944realms.dg_lab.api.websocket.IWebsocketClient;
 import com.r3944realms.dg_lab.utils.stringUtils.StringHandlerUtil;
 import com.r3944realms.dg_lab.utils.stringUtils.UrlValidator;
-import com.r3944realms.dg_lab.api.websocket.message.Message;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
@@ -32,9 +32,14 @@ import io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory;
 import io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler;
 import io.netty.handler.codec.http.websocketx.WebSocketFrameAggregator;
 import io.netty.handler.codec.http.websocketx.WebSocketVersion;
+import io.netty.handler.ssl.SslContext;
+import io.netty.handler.ssl.SslContextBuilder;
+import org.jetbrains.annotations.Nullable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.net.ssl.SSLException;
+import java.io.File;
 import java.net.InetAddress;
 import java.net.URI;
 import java.net.UnknownHostException;
@@ -43,7 +48,7 @@ import java.util.concurrent.CompletableFuture;
 /**
  * 主要是处理netty逻辑以建立客户端
  */
-public abstract class AbstractWebSocketClient {
+public abstract class AbstractWebSocketClient implements IWebsocketClient {
     /**
      * 日志
      */
@@ -51,29 +56,61 @@ public abstract class AbstractWebSocketClient {
     /**
      * 地址
      */
-    protected volatile String Address;
+    protected volatile String address;
     /**
      * 端口
      */
-    protected volatile int Port;
+    protected volatile int port;
+
+    /**
+     * 启用 SSL
+     */
+    public void enableSSL() {
+       enableSSL(null);
+    }
+
+    /**
+     * 启用 SSL
+     * @param certFile 可选证书文件
+     */
+    public void enableSSL(@Nullable File certFile) {
+        this.sslEnabled = true;
+        this.certFile = certFile;
+    }
+
+    /**
+     * 禁用SSL
+     */
+    public void disableSSL() {
+        this.sslEnabled = false;
+    }
+
+    /**
+     * 是否启用 SSL
+     */
+    boolean sslEnabled;
+    /**
+     * 客户端可选信任证书
+     */
+    File certFile;
     /**
      * 客户端启动类
      */
-    private Bootstrap ClientBootstrap;
+    private Bootstrap clientBootstrap;
     /**
      * 客户端事件线程组
      */
-    private EventLoopGroup ClientEventLoopGroup;
+    private EventLoopGroup clientEventLoopGroup;
     /**
      * The Client channel.
      */
-    protected Channel ClientChannel;
+    protected Channel clientChannel;
 
-    private Thread WebSocketClientThread;
+    private Thread webSocketClientThread;
     /**
      * The Client status.
      */
-    protected volatile Status ClientStatus = Status.WAITING_FOR_INIT;
+    protected volatile Status clientStatus = Status.WAITING_FOR_INIT;
 
     /**
      * Gets status.
@@ -81,7 +118,17 @@ public abstract class AbstractWebSocketClient {
      * @return the status
      */
     public Status getStatus() {
-        return this.ClientStatus;
+        return this.clientStatus;
+    }
+
+    /**
+     * 是否启用 SSL
+     *
+     * @return enable
+     */
+    @Override
+    public boolean isSSLEnabled() {
+        return sslEnabled;
     }
 
     /**
@@ -90,7 +137,7 @@ public abstract class AbstractWebSocketClient {
      * @param status the status
      */
     public void setStatus(Status status) {
-        this.ClientStatus = status;
+        this.clientStatus = status;
     }
 
     /**
@@ -98,8 +145,8 @@ public abstract class AbstractWebSocketClient {
      */
     protected AbstractWebSocketClient() {
         try {
-            this.Address = InetAddress.getLocalHost().getHostAddress();
+            this.address = InetAddress.getLocalHost().getHostAddress();
-            this.Port = 9000;
+            this.port = 9000;
         } catch (UnknownHostException e) {
             logger.error(e.getMessage());
         }
@@ -113,8 +160,8 @@ public abstract class AbstractWebSocketClient {
     protected AbstractWebSocketClient(int port) {
         try {
             InetAddress localHost = InetAddress.getLocalHost();
-            this.Address = localHost.getHostAddress();
+            this.address = localHost.getHostAddress();
-            this.Port = UrlValidator.isValidPort(port) ? port : 9000;
+            this.port = UrlValidator.isValidPort(port) ? port : 9000;
         } catch (UnknownHostException e) {
             logger.error(e.getMessage());
         }
@@ -128,24 +175,35 @@ public abstract class AbstractWebSocketClient {
      */
     protected AbstractWebSocketClient(String address, int port) {
         try {
-            this.Address = UrlValidator.isValidAddress(address) ? address : InetAddress.getLocalHost().getHostAddress();
+            this.address = UrlValidator.isValidAddress(address) ? address : InetAddress.getLocalHost().getHostAddress();
-            this.Port = UrlValidator.isValidPort(port) ? port : 9000;
+            this.port = UrlValidator.isValidPort(port) ? port : 9000;
         } catch (UnknownHostException e) {
             logger.error(e.getMessage());
         }
     }
 
+    @Override
+    public int getPort() {
+        return port;
+    }
+
     /**
      * Sets port.
      *
      * @param port the port
      */
+    @Override
     public void setPort(int port) {
-        if (this.ClientStatus != Status.WAITING_FOR_INIT && this.ClientStatus != Status.STOPPED) {
+        if (this.clientStatus != Status.WAITING_FOR_INIT && this.clientStatus != Status.STOPPED) {
             logger.error("Unable to change port to {}", port);
             return;
         }
-        this.Port = UrlValidator.isValidPort(port) ? port : 9000;
+        this.port = UrlValidator.isValidPort(port) ? port : 9000;
+    }
+
+    @Override
+    public String getAddress() {
+        return address;
     }
 
     /**
@@ -154,12 +212,12 @@ public abstract class AbstractWebSocketClient {
      * @param address the address
      */
     public void setAddress(String address) {
-        if (this.ClientStatus != Status.WAITING_FOR_INIT && this.ClientStatus != Status.STOPPED) {
+        if (this.clientStatus != Status.WAITING_FOR_INIT && this.clientStatus != Status.STOPPED) {
             logger.error("Unable to change address to {}", address);
             return;
         }
         try {
-            this.Address = UrlValidator.isValidAddress(address) ? address : InetAddress.getLocalHost().getHostAddress();
+            this.address = UrlValidator.isValidAddress(address) ? address : InetAddress.getLocalHost().getHostAddress();
         } catch (UnknownHostException e) {
             throw new RuntimeException(e);
         }
@@ -186,7 +244,7 @@ public abstract class AbstractWebSocketClient {
      * @return the url
      */
     public String getUrl() {
-        return StringHandlerUtil.buildWebSocketURL(Address, Port, false);
+        return StringHandlerUtil.buildWebSocketURL(address, port, false);
     }
 
     /**
@@ -205,22 +263,36 @@ public abstract class AbstractWebSocketClient {
      * Init thread.
      */
     protected final void initThread() {
-        ClientEventLoopGroup = new NioEventLoopGroup();
+        init();
-        WebSocketClientThread = new Thread(() -> {
+        clientEventLoopGroup = new NioEventLoopGroup();
-            ClientStatus = Status.STARTING;
+        webSocketClientThread = new Thread(() -> {
-            ClientBootstrap = new Bootstrap();
+            clientStatus = Status.STARTING;
-            ClientBootstrap.group(ClientEventLoopGroup);
+            clientBootstrap = new Bootstrap();
-            ClientBootstrap.channel(NioSocketChannel.class);
+            clientBootstrap.group(clientEventLoopGroup);
-            ClientBootstrap.handler(new ChannelInitializer<NioSocketChannel>() {
+            clientBootstrap.channel(NioSocketChannel.class);
+            clientBootstrap.handler(new ChannelInitializer<NioSocketChannel>() {
                 @Override
-                protected void initChannel(NioSocketChannel ch) {
+                protected void initChannel(NioSocketChannel ch) throws SSLException {
                     ChannelPipeline pipeline = ch.pipeline();
+                    // SSL 支持
+                    if (sslEnabled) {
+                        SslContext sslCtx;
+                        if (certFile != null && certFile.exists()) {
+                            sslCtx = SslContextBuilder.forClient()
+                                    .trustManager(certFile)
+                                    .build();
+                        } else {
+                            // 默认信任所有受信任的 CA
+                            sslCtx = SslContextBuilder.forClient().build();
+                        }
+                        pipeline.addFirst(sslCtx.newHandler(ch.alloc(), address, port));
+                    }
                     pipeline.addLast(DgLab.LOGGING_HANDLER,
                             new HttpClientCodec(),
                             new HttpObjectAggregator(65536),
                             new WebSocketClientProtocolHandler(
                                     WebSocketClientHandshakerFactory.newHandshaker(
-                                            URI.create(StringHandlerUtil.buildWebSocketURL(Address, Port, false)),
+                                            URI.create(StringHandlerUtil.buildWebSocketURL(address, port, false)),
                                             WebSocketVersion.V13,
                                             null,
                                             false,
@@ -232,17 +304,17 @@ public abstract class AbstractWebSocketClient {
                 }
             });
             try {
-                ChannelFuture channelFuture = ClientBootstrap.connect(Address, Port);
+                ChannelFuture channelFuture = clientBootstrap.connect(address, port);
-                ClientStatus = Status.RUNNING;
+                clientStatus = Status.RUNNING;
-                started();
+                onStarted();
-                ClientChannel = channelFuture.sync().channel();
+                clientChannel = channelFuture.sync().channel();
-                ClientChannel.closeFuture().sync();
+                clientChannel.closeFuture().sync();
             } catch (Exception e) {
-                startingError();
+                onStartingError("Catch Exception: " + e.getMessage());
-                ClientStatus = Status.ERROR;
+                clientStatus = Status.ERROR;
                 logger.error(e.getMessage());
             } finally {
-                if(ClientStatus == Status.ERROR || ClientStatus == Status.RUNNING) stop();
+                if(clientStatus == Status.ERROR || clientStatus == Status.RUNNING) stop();
             }
 
         }, "WebSocketClient");
@@ -258,23 +330,23 @@ public abstract class AbstractWebSocketClient {
      * Start.
      */
     public final void start() {
-        starting();
+        onStarting();
-        switch (ClientStatus) {
+        switch (clientStatus) {
             case STARTING -> {
-                startingError();
+                onStartingError("Client is already onStarting");
-                logger.info("Client is already starting.");
+                logger.info("Client is already onStarting.");
             }
             case RUNNING -> {
-                startingError();
+                onStartingError("Client is already running.");
                 logger.info("Client is already running.");
             }
             case STOPPING -> {
-                startingError();
+                onStartingError("Client is onStopping");
-                logger.info("Client is stopping");
+                logger.info("Client is onStopping");
             }
             case STOPPED, WAITING_FOR_INIT -> {
                 initThread();
-                WebSocketClientThread.start();
+                webSocketClientThread.start();
                 start0();
             }
         }
@@ -289,96 +361,58 @@ public abstract class AbstractWebSocketClient {
         return CompletableFuture.runAsync(() -> {});
     }
 
-    /**
-     * Starting.
-     */
-    protected abstract void starting();
-
-    /**
-     * Starting error.
-     */
-    protected abstract void startingError();
-
-    /**
-     * Started.
-     */
-    protected abstract void started();
-
-    /**
-     * Stopping.
-     */
-    protected abstract void stopping();
-
-    /**
-     * Stopping error.
-     */
-    protected abstract void stoppingError();
-
-    /**
-     * Stopped.
-     */
-    protected abstract void stopped();
 
     /**
      * Stop.
      */
     public final void stop() {
-        stopping();
+        onStopping();
-        switch (ClientStatus) {
+        switch (clientStatus) {
-            case WAITING_FOR_INIT -> {
-                stoppingError();
-                logger.warn("Not Init. (It shouldn't be happened)");
-            }
             case STARTING -> {
-                stoppingError();
+                onStoppingError("Client is already onStarting.");
-                logger.info("Client is starting, please waiting.");
+                logger.info("Client is onStarting, please waiting.");
             }
             case RUNNING, ERROR -> {
-                ClientStatus = Status.STOPPING;
+                clientStatus = Status.STOPPING;
                 CompletableFuture<Void> CliChanClose = CompletableFuture.runAsync(() -> {
-                    if (ClientChannel != null && ClientChannel.isOpen()) {
+                    if (clientChannel != null && clientChannel.isOpen()) {
                         try {
-                            ClientChannel.close().sync();
+                            clientChannel.close().sync();
                         } catch (InterruptedException e) {
                             logger.error(e.getMessage());
                         } finally {
-                            ClientChannel = null;
+                            clientChannel = null;
                         }
                     }
                 });
                 CompletableFuture<Void> CliEvenClose = CliChanClose.thenRunAsync(() -> {
-                    if (ClientEventLoopGroup != null) {
+                    if (clientEventLoopGroup != null) {
                         try {
-                            ClientEventLoopGroup.shutdownGracefully().sync();
+                            clientEventLoopGroup.shutdownGracefully().sync();
                         } catch (InterruptedException e) {
                             logger.error(e.getMessage());
                         } finally {
-                            ClientEventLoopGroup = null;
+                            clientEventLoopGroup = null;
                         }
                     }
                 });
                 CliEvenClose.thenCombineAsync(stop0(), (a, b) -> {
-                    ClientStatus = Status.STOPPED;
+                    clientStatus = Status.STOPPED;
-                    ClientBootstrap = null;
+                    clientBootstrap = null;
-                    stopped();
+                    onStopped();
                     return null;
                 });
             }
             case STOPPING -> {
-                stoppingError();
+                onStoppingError("Client is already onStopping.");
-                logger.info("Client is already stopping");
+                logger.info("Client is already onStopping");
             }
-            case STOPPED -> {
+            case STOPPED, WAITING_FOR_INIT -> {
-                stoppingError();
+                onStoppingError("Client has been onStopped.");
-                logger.info("Client has stopped");
+                logger.info("Client has onStopped");
             }
         }
     }
 
-    /**
+
-     * 向所连接的服务器发送消息
-     *
-     * @param message 消息
-     */
-    public abstract void send(Message message);
 }

Common/src/main/java/com/r3944realms/dg_lab/websocket/AbstractWebSocketServer.java

@@ -19,9 +19,10 @@ package com.r3944realms.dg_lab.websocket;
 
 import com.r3944realms.dg_lab.DgLab;
 import com.r3944realms.dg_lab.api.manager.Status;
+import com.r3944realms.dg_lab.api.websocket.IWebSocketServer;
+import com.r3944realms.dg_lab.api.websocket.message.Message;
 import com.r3944realms.dg_lab.utils.stringUtils.UrlValidator;
 import com.r3944realms.dg_lab.websocket.handler.server.HttpRequestHandler;
-import com.r3944realms.dg_lab.api.websocket.message.Message;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
@@ -31,55 +32,81 @@ import io.netty.handler.codec.http.HttpObjectAggregator;
 import io.netty.handler.codec.http.HttpServerCodec;
 import io.netty.handler.codec.http.websocketx.WebSocketFrameAggregator;
 import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
+import io.netty.handler.ssl.SslContext;
+import io.netty.handler.ssl.SslContextBuilder;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.net.ssl.SSLException;
+import java.io.File;
 import java.util.concurrent.CompletableFuture;
 
 /**
  * 主要是处理netty逻辑以建立服务端
  */
 @SuppressWarnings({"DuplicatedCode", "LoggingSimilarMessage"})
-public abstract class AbstractWebSocketServer {
+public abstract class AbstractWebSocketServer implements IWebSocketServer {
 
     /**
      * The constant logger.
      */
     protected static final Logger logger =  LoggerFactory.getLogger(AbstractWebSocketServer.class);
 
-    private int Port;
+    /**
+     * Should enable SSL
+     */
+    boolean sslEnabled;
+    /**
+     * SSL 密码
+     */
+    String sslPassword;
+    /**
+     * 证书文件
+     */
+    File certFile;
+
+    /**
+     * 私钥文件
+     */
+    File keyFile;
+
+    private String listenAddress;
+
+    private int port;
 
     /**
      * The Server bootstrap.
      */
-    protected ServerBootstrap ServerBootstrap;
+    protected ServerBootstrap serverBootstrap;
     /**
      * The Boss group.
      */
-    protected EventLoopGroup BossGroup,
+    protected EventLoopGroup bossGroup,
     /**
      * The Worker group.
      */
-    WorkerGroup;
+    workerGroup;
     /**
      * The Server channel.
      */
-    protected Channel ServerChannel;
+    protected Channel serverChannel;
 
     /**
      * The Websocket server thread.
      */
-    protected Thread WebsocketServerThread;
+    protected Thread websocketServerThread;
     /**
      * The Server status.
      */
-    protected volatile Status ServerStatus = Status.WAITING_FOR_INIT;
+    protected volatile Status serverStatus = Status.WAITING_FOR_INIT;
 
     /**
      * Instantiates a new Abstract web socket server.
      */
     protected AbstractWebSocketServer() {
-        Port = 9000;
+        port = 9000;
     }
 
     /**
@@ -88,47 +115,61 @@ public abstract class AbstractWebSocketServer {
      * @param port the port
      */
     protected AbstractWebSocketServer(int port) {
-        Port = port;
+        this.port = port;
+    }
+
+    @Override
+    public void setListenedAddress(String address) {
+        this.listenAddress = address;
+    }
+
+    @Override
+    public String getListenedAddress() {
+        return listenAddress == null ? "0.0.0.0" : listenAddress;
     }
 
-    /**
-     * Gets status.
-     *
-     * @return the status
-     */
     public Status getStatus() {
-        return this.ServerStatus;
+        return this.serverStatus;
     }
 
-    /**
+
-     * Sets status.
-     *
-     * @param status the status
-     */
     public void setStatus(Status status) {
-        this.ServerStatus = status;
+        this.serverStatus = status;
     }
 
-    /**
+
-     * Sets port.
-     *
-     * @param port the port
-     */
     public void setPort(int port) {
-        if(this.ServerStatus != Status.WAITING_FOR_INIT && this.ServerStatus != Status.STOPPED) {
+        if(this.serverStatus != Status.WAITING_FOR_INIT && this.serverStatus != Status.STOPPED) {
             logger.error("Unable to Change Port to {}", port);
             return;
         }
-        this.Port = UrlValidator.isValidPort(port) ? port : 9000;
+        this.port = UrlValidator.isValidPort(port) ? port : 9000;
     }
 
-    /**
+
-     * Gets port.
-     *
-     * @return the port
-     */
     public int getPort() {
-        return Port;
+        return port;
+    }
+
+    public boolean isSSLEnabled() {
+        return sslEnabled;
+    }
+
+
+    public void enableSSL(@NotNull File certFile, @NotNull File keyFile) {
+        enableSSL(certFile, keyFile, null);
+    }
+
+    public void enableSSL(@NotNull File certFile, @NotNull File keyFile, @Nullable String password) {
+        this.sslEnabled = true;
+        this.certFile = certFile;
+        this.keyFile = keyFile;
+        this.sslPassword = password;
+    }
+
+
+    public void disableSSL() {
+        this.sslEnabled = false;
     }
 
     /**
@@ -147,20 +188,26 @@ public abstract class AbstractWebSocketServer {
      * Init thread.
      */
     protected final void initThread() {
-        BossGroup = new NioEventLoopGroup();
+        init();
-        WorkerGroup = new NioEventLoopGroup();
+        bossGroup = new NioEventLoopGroup();
-        WebsocketServerThread = new Thread(() ->{
+        workerGroup = new NioEventLoopGroup();
+        websocketServerThread = new Thread(() ->{
             try {
-                ServerBootstrap = new ServerBootstrap();
+                serverBootstrap = new ServerBootstrap();
-                ServerStatus = Status.STARTING;
+                serverStatus = Status.STARTING;
-                ServerBootstrap.option(ChannelOption.SO_BACKLOG, 1024)
+                serverBootstrap.option(ChannelOption.SO_BACKLOG, 1024)
                         .childOption(ChannelOption.SO_KEEPALIVE, true);
-                ServerBootstrap.group(BossGroup, WorkerGroup);
+                serverBootstrap.group(bossGroup, workerGroup);
-                ServerBootstrap.channel(NioServerSocketChannel.class);
+                serverBootstrap.channel(NioServerSocketChannel.class);
-                ServerBootstrap.childHandler(new ChannelInitializer<NioSocketChannel>() {
+                serverBootstrap.childHandler(new ChannelInitializer<NioSocketChannel>() {
                     @Override
-                    protected void initChannel(NioSocketChannel ch) {
+                    protected void initChannel(NioSocketChannel ch) throws SSLException {
                         ChannelPipeline pipeline = ch.pipeline();
+                        // 根据配置启用 SSL
+                        if (sslEnabled) {
+                            SslContext sslCtx = SslContextBuilder.forServer(certFile, keyFile, sslPassword).build();
+                            pipeline.addFirst(sslCtx.newHandler(ch.alloc()));
+                        }
                         pipeline.addLast(DgLab.LOGGING_HANDLER);
                         pipeline.addLast(new HttpServerCodec());
                         pipeline.addLast(new HttpObjectAggregator(65536));
@@ -171,55 +218,25 @@ public abstract class AbstractWebSocketServer {
                     }
                 });
                 logger.debug("WebSocketServer try binding port ... ");
-                ChannelFuture channelFuture = ServerBootstrap.bind("0.0.0.0",Port);
+                ChannelFuture channelFuture = serverBootstrap.bind(getListenedAddress(), port);
                 channelFuture.sync();
-                ServerChannel = channelFuture.channel();
+                serverChannel = channelFuture.channel();
-                ServerStatus = Status.RUNNING;
+                serverStatus = Status.RUNNING;
-                started();
+                onStarted();
-                logger.info("WebSocketServer start on the port of {}", Port);
+                logger.info("WebSocketServer start on the port of {}{}", port, sslEnabled ? " (SSL)" : "");
-                logger.debug("WebSocketServer listening on port {}", Port);
+                logger.debug("WebSocketServer listening on port {}", port);
                 channelFuture.channel().closeFuture().sync();
             } catch (Exception e) {
-                ServerStatus = Status.ERROR;
+                serverStatus = Status.ERROR;
-                stoppingError();
+                onStoppingError("Catch Exception:" + e.getMessage());
                 logger.error(e.getMessage());
             } finally {
-                if(ServerStatus == Status.ERROR || ServerStatus == Status.RUNNING) stop();
+                if(serverStatus == Status.ERROR || serverStatus == Status.RUNNING) stop();
             }
         }, "WebSocketServer");
         initThread0();
     }
 
-    /**
-     * Starting.
-     */
-    protected abstract void starting();
-
-    /**
-     * Starting error.
-     */
-    protected abstract void startingError();
-
-    /**
-     * Started.
-     */
-    protected abstract void started();
-
-    /**
-     * Stopping.
-     */
-    protected abstract void stopping();
-
-    /**
-     * Stopping error.
-     */
-    protected abstract void stoppingError();
-
-    /**
-     * Stopped.
-     */
-    protected abstract void stopped();
-
     /**
      * 自定义Start后续逻辑
      */
@@ -231,23 +248,23 @@ public abstract class AbstractWebSocketServer {
      * Start.
      */
     public final void start() {
-        starting();
+        onStarting();
-        switch (ServerStatus) {
+        switch (serverStatus) {
             case STARTING -> {
-                startingError();
+                onStartingError("Server is already onStarting.");
-                logger.info("Server is already starting.");
+                logger.info("Server is already onStarting.");
             }
             case RUNNING -> {
-                startingError();
+                onStartingError("Server is already running.");
                 logger.info("Server is already running.");
             }
             case STOPPING -> {
-                startingError();
+                onStartingError("Server is onStopping");
-                logger.info("Server is stopping");
+                logger.info("Server is onStopping");
             }
             case STOPPED, WAITING_FOR_INIT -> {
                 initThread();
-                WebsocketServerThread.start();
+                websocketServerThread.start();
                 start0();
             }
         }
@@ -266,80 +283,68 @@ public abstract class AbstractWebSocketServer {
      * Stop.
      */
     public final void stop() {
-        stopping();
+        onStopping();
-        switch (ServerStatus) {
+        switch (serverStatus) {
-            case WAITING_FOR_INIT -> {
-                stoppingError();
-                logger.warn("Not Init. (It shouldn't be happened)");
-            }
             case STARTING -> {
-                stoppingError();
+                onStoppingError("Server is onStarting, please waiting.");
-                logger.info("Server is starting, please waiting.");
+                logger.info("Server is onStarting, please waiting.");
             }
             case RUNNING -> {
-                ServerStatus = Status.STOPPING;
+                serverStatus = Status.STOPPING;
                 // Close the server channel if it's open
                 CompletableFuture<Void> SerChanClose = CompletableFuture.runAsync(() -> {
-                    if (ServerChannel != null && ServerChannel.isOpen()) {
+                    if (serverChannel != null && serverChannel.isOpen()) {
                         try {
-                            ServerChannel.close().sync();
+                            serverChannel.close().sync();
                         } catch (InterruptedException e) {
                             logger.error(e.getMessage());
                         } finally {
-                            ServerChannel = null;
+                            serverChannel = null;
                         }
                     }
                 });
                 // Shutdown the event loop groups
                 CompletableFuture<Void> BosGroClose = SerChanClose.thenRunAsync(() -> {
-                            if (BossGroup != null) {
+                            if (bossGroup != null) {
                                 try {
-                                    BossGroup.shutdownGracefully().sync();
+                                    bossGroup.shutdownGracefully().sync();
                                 } catch (InterruptedException e) {
                                     logger.error(e.getMessage());
                                 } finally {
-                                    BossGroup = null;
+                                    bossGroup = null;
                                 }
                             }
                         }
                 );
                 CompletableFuture<Void> WorGroClose = SerChanClose.thenRunAsync(() -> {
-                    if (WorkerGroup != null) {
+                    if (workerGroup != null) {
                         try {
-                            WorkerGroup.shutdownGracefully().sync();
+                            workerGroup.shutdownGracefully().sync();
                         } catch (InterruptedException e) {
                             logger.error(e.getMessage());
                         } finally {
-                            WorkerGroup = null;
+                            workerGroup = null;
                         }
                     }
                 });
                 BosGroClose.thenCombineAsync(WorGroClose, (a,b) -> {
                     stop0().thenRunAsync(() -> {
-                        ServerStatus = Status.STOPPED;
+                        serverStatus = Status.STOPPED;
-                        ServerBootstrap = null;
+                        serverBootstrap = null;
-                        stopped();
+                        onStopped();
                     });
                     return null;
                 });
 
             }
             case STOPPING -> {
-                stoppingError();
+                onStoppingError("Server is already onStopping");
-                logger.info("Server is already stopping");
+                logger.info("Server is already onStopping");
             }
             case STOPPED -> {
-                stoppingError();
+                onStoppingError("Server has onStopped");
-                logger.info("Server has stopped");
+                logger.info("Server has onStopped");
             }
         }
     }
-
-    /**
-     * 向指定的客户端发送消息
-     *
-     * @param clientId 客户端UUID
-     * @param message  消息
-     */
-    public abstract void send(String clientId, Message message);
 }

Common/src/main/java/com/r3944realms/dg_lab/websocket/PowerBoxWSClient.java

@@ -17,12 +17,12 @@
 package com.r3944realms.dg_lab.websocket;
 
 import com.r3944realms.dg_lab.api.operation.ClientOperation;
-import com.r3944realms.dg_lab.websocket.handler.client.ClientDLPBHandler;
-import com.r3944realms.dg_lab.websocket.handler.client.ClientDLPBHandlerContextWrapper;
-import com.r3944realms.dg_lab.websocket.handler.client.DefaultClientOperation;
 import com.r3944realms.dg_lab.api.websocket.message.Message;
 import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
 import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketClientRole;
+import com.r3944realms.dg_lab.websocket.handler.client.ClientDLPBHandler;
+import com.r3944realms.dg_lab.websocket.handler.client.ClientDLPBHandlerContextWrapper;
+import com.r3944realms.dg_lab.websocket.handler.client.DefaultClientOperation;
 import com.r3944realms.dg_lab.websocket.sharedData.ClientPowerBoxSharedData;
 import io.netty.channel.ChannelPipeline;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
@@ -62,8 +62,8 @@ public class PowerBoxWSClient extends AbstractWebSocketClient {
         this.sharedData = sharedData;
         this.operation = operation;
         this.role = role;
-        sharedData.address = this.Address;
+        sharedData.address = this.address;
-        sharedData.port = this.Port;
+        sharedData.port = this.port;
         contextWrapper = new ClientDLPBHandlerContextWrapper(sharedData, role, operation, false);
     }
 
@@ -82,8 +82,8 @@ public class PowerBoxWSClient extends AbstractWebSocketClient {
         this.sharedData = sharedData;
         this.operation = operation;
         this.role = role;
-        sharedData.address = this.Address;
+        sharedData.address = this.address;
-        sharedData.port = this.Port;
+        sharedData.port = this.port;
         contextWrapper = new ClientDLPBHandlerContextWrapper(sharedData, role, operation, false);
     }
 
@@ -123,8 +123,8 @@ public class PowerBoxWSClient extends AbstractWebSocketClient {
         this.sharedData = sharedData;
         this.operation = operation;
         this.role = role;
-        sharedData.address = this.Address;
+        sharedData.address = this.address;
-        sharedData.port = this.Port;
+        sharedData.port = this.port;
         contextWrapper = new ClientDLPBHandlerContextWrapper(sharedData, role, operation, useRoleMsgMode);
     }
 
@@ -144,8 +144,8 @@ public class PowerBoxWSClient extends AbstractWebSocketClient {
         this.sharedData = sharedData;
         this.operation = operation;
         this.role = role;
-        sharedData.address = this.Address;
+        sharedData.address = this.address;
-        sharedData.port = this.Port;
+        sharedData.port = this.port;
         contextWrapper = new ClientDLPBHandlerContextWrapper(sharedData, role, operation, useRoleMsgMode);
     }
 
@@ -178,39 +178,59 @@ public class PowerBoxWSClient extends AbstractWebSocketClient {
     }
 
     @Override
-    protected void starting() {
+    public void init() {
+
+    }
+
+    @Override
+    public void onStarting() {
         operation.ClientStartingHandler();
     }
 
     @Override
-    protected void startingError() {
+    public void onStartingError(String msg) {
-        operation.ClientStartingErrorHandler();
+        operation.ClientStartingErrorHandler(msg);
     }
 
     @Override
-    protected void started() {
+    public void onStarted() {
         operation.ClientStartedHandler();
     }
 
     @Override
-    protected void stopping() {
+    public void onStopping() {
         operation.ClientStoppingHandler();
     }
 
     @Override
-    protected void stoppingError() {
+    public void onStoppingError(String msg) {
-        operation.ClientStoppingErrorHandler();
+        operation.ClientStoppingErrorHandler(msg);
     }
 
     @Override
-    protected void stopped() {
+    public void onStopped() {
         operation.ClientStoppedHandler();
     }
 
+
+    @Override
+    public void enableSSL() {
+        super.enableSSL();
+        sharedData.isEnableSsl = true;
+    }
+
+    @Override
+    public void disableSSL() {
+        super.disableSSL();
+        sharedData.isEnableSsl = false;
+    }
+
+
+
     @Override
     public void send(Message message) {
         if(message instanceof PowerBoxMessage PBMessage) {
-            this.ClientChannel.writeAndFlush(new TextWebSocketFrame(PBMessage.getMsgJson()));
+            this.clientChannel.writeAndFlush(new TextWebSocketFrame(PBMessage.getMsgJson()));
         } else {
             logger.error("Message is not a PowerBoxMessage");
         }

Common/src/main/java/com/r3944realms/dg_lab/websocket/PowerBoxWSServer.java

@@ -17,12 +17,13 @@
 package com.r3944realms.dg_lab.websocket;
 
 import com.r3944realms.dg_lab.api.operation.ServerOperation;
+import com.r3944realms.dg_lab.api.websocket.message.Message;
+import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
+import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxDataType;
+import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketServerRole;
 import com.r3944realms.dg_lab.websocket.handler.server.DefaultServerOperation;
 import com.r3944realms.dg_lab.websocket.handler.server.ServerDLPBHandler;
 import com.r3944realms.dg_lab.websocket.handler.server.ServerDLPBHandlerContextWrapper;
-import com.r3944realms.dg_lab.api.websocket.message.Message;
-import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
-import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketServerRole;
 import com.r3944realms.dg_lab.websocket.sharedData.ServerPowerBoxSharedData;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
@@ -38,7 +39,7 @@ public class PowerBoxWSServer extends AbstractWebSocketServer {
     /**
      * The Shared data.
      */
-    protected final ServerPowerBoxSharedData SharedData;
+    protected final ServerPowerBoxSharedData sharedData;
     /**
      * The Role.
      */
@@ -57,7 +58,7 @@ public class PowerBoxWSServer extends AbstractWebSocketServer {
      * @param operation  the operation
      */
     public PowerBoxWSServer(ServerPowerBoxSharedData sharedData, WebSocketServerRole role, ServerOperation operation) {
-        this.SharedData = sharedData;
+        this.sharedData = sharedData;
         this.role = role;
         this.operation = operation;
         contextWrapper = new ServerDLPBHandlerContextWrapper(
@@ -77,7 +78,7 @@ public class PowerBoxWSServer extends AbstractWebSocketServer {
      */
     public PowerBoxWSServer(ServerPowerBoxSharedData sharedData, WebSocketServerRole role, ServerOperation operation, int port) {
         super(port);
-        this.SharedData = sharedData;
+        this.sharedData = sharedData;
         this.role = role;
         this.operation = operation;
         contextWrapper = new ServerDLPBHandlerContextWrapper(
@@ -114,51 +115,63 @@ public class PowerBoxWSServer extends AbstractWebSocketServer {
     }
 
     @Override
-    protected void starting() {
+    public void init() {
+
+    }
+
+    @Override
+    public void onStarting() {
         operation.ServerStartingHandler();
     }
 
+
     @Override
-    protected void startingError() {
+    public void onStartingError(String error) {
-        operation.ServerStartingErrorHandler();
+        operation.ServerStartingErrorHandler(error);
     }
 
     @Override
-    protected void started() {
+    public void onStarted() {
         operation.ServerStartedHandler();
     }
 
     @Override
-    protected void stopping() {
+    public void onStopping() {
         operation.ServerStoppingHandler();
     }
 
     @Override
-    protected void stoppingError() {
+    public void onStoppingError(String error) {
-        operation.ServerStoppingErrorHandler();
+        operation.ServerStoppingErrorHandler(error);
     }
 
     @Override
-    protected void stopped() {
+    public void onStopped() {
         operation.ServerStoppedHandler();
     }
 
     @Override
     public void send(String connectId, Message message) {
         if(message instanceof PowerBoxMessage PBMessage) {
-            ChannelHandlerContext context = SharedData.connections.get(connectId);//获取连接连接的Context
+            ChannelHandlerContext context = sharedData.connections.get(connectId);//获取连接连接的Context
             if(context != null) {
-                String targetId = SharedData.relations.get(connectId);
+                String targetId = sharedData.relations.get(connectId);
-                if(targetId.isEmpty()) { //该上下文为客户端
+                if(targetId != null) {
-                    context.writeAndFlush(new TextWebSocketFrame(PBMessage.getMsgJson()));//发送给客户端
+                    if (targetId.isEmpty()) { //该上下文为客户端
-                    ChannelHandlerContext appContext = SharedData.connections.get(targetId);
+                        context.writeAndFlush(new TextWebSocketFrame(PBMessage.getMsgJson()));//发送给客户端
-                    appContext.writeAndFlush(new TextWebSocketFrame(PBMessage.getDataJson()));//发送给APP端
+                        ChannelHandlerContext appContext = sharedData.connections.get(targetId);
-                } else if(SharedData.relations.containsValue(targetId)){  // 绑定状态的APP端
+                        appContext.writeAndFlush(new TextWebSocketFrame(PBMessage.getDataJson()));//发送给APP端
-                    //仅对APP发信息
+                    } else if(sharedData.relations.containsValue(targetId)){  // 绑定状态的APP端
-                    context.writeAndFlush(new TextWebSocketFrame(PBMessage.getDataJson()));
+                        //仅对APP发信息
-
+                        context.writeAndFlush(new TextWebSocketFrame(PBMessage.getDataJson()));
+                    } else { // 未绑定状态（不可发送消息）
+                        logger.error("Can't send Msg to no relationship obj.");
+                    }
+                } else if (PBMessage.commandType == PowerBoxDataType._NC_BIND_) {
+                    //客户端写入绑定消息
+                    context.writeAndFlush(new TextWebSocketFrame(PBMessage.getMsgJson()));
                 } else { // 未绑定状态（不可发送消息）
-                    logger.error("Can't send Msg to no relationship obj.");
+                    logger.error("Can't send Non-Binding Msg to no relationship obj.");
                 }
             } else {
                 logger.error("Find that Target is invalid.");
@@ -174,7 +187,7 @@ public class PowerBoxWSServer extends AbstractWebSocketServer {
      * @return the shared data
      */
     public ServerPowerBoxSharedData getSharedData() {
-        return SharedData;
+        return sharedData;
     }
 
     @Override

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/client/ClientDLPBHandler.java

@@ -16,9 +16,9 @@
 
 package com.r3944realms.dg_lab.websocket.handler.client;
 
+import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
 import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandler;
 import com.r3944realms.dg_lab.websocket.handler.IAttachSharedData;
-import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
 import io.netty.channel.ChannelHandler;
 
 /**

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/client/ClientDLPBHandlerContextWrapper.java

@@ -18,15 +18,15 @@ package com.r3944realms.dg_lab.websocket.handler.client;
 
 import com.r3944realms.dg_lab.api.operation.ClientOperation;
 import com.r3944realms.dg_lab.api.operation.IOperation;
-import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandlerContextWrapper;
 import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
 import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxData;
 import com.r3944realms.dg_lab.api.websocket.message.role.Role;
 import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketClientRole;
 import com.r3944realms.dg_lab.api.websocket.message.role.WebSocketServerRole;
 import com.r3944realms.dg_lab.api.websocket.message.role.type.RoleType;
-import com.r3944realms.dg_lab.websocket.sharedData.ClientPowerBoxSharedData;
 import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
+import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandlerContextWrapper;
+import com.r3944realms.dg_lab.websocket.sharedData.ClientPowerBoxSharedData;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
 
@@ -115,7 +115,7 @@ public class ClientDLPBHandlerContextWrapper extends AbstractDgLabPowerBoxHandle
             //通过构造开启且如果有目标（即连上了APP端）则开启Message对象校验，只有通过校验才能进读取data(雾)
             dataMsg = PowerBoxMessage.getNullMessage().getMessage(json);
             //发送对象必须是服务器类型 且 接收者（本客户端）为占位对象类型 或 本客户端对象（名字类型相同），这里取反，只有满足条件才能进入 else读取 data
-            if(
+            if (
                     dataMsg.direction.sender().type != RoleType.T_SERVER
                             &&
                             !(
@@ -145,6 +145,7 @@ public class ClientDLPBHandlerContextWrapper extends AbstractDgLabPowerBoxHandle
                     ((ClientPowerBoxSharedData)sharedData).connectionId = data.getClientId();
                     logger.info("收到clientId: {}", ConnectionId());
                     String qrCodeContext = "https://www.dungeon-lab.com/app-download.php#DGLAB-SOCKET#" + ((ClientPowerBoxSharedData)sharedData).getUrl()  + ConnectionId();
+                    ((ClientPowerBoxSharedData) sharedData).rqCodeUrl = qrCodeContext;
                     TryCatch(i -> ((ClientOperation)operation).QrCodeUrlHandler(qrCodeContext));
                     TryCatch(i -> ((ClientOperation)operation).ShowQrCodeHandler());
                     logger.debug("重新生成QrCodeContext: {}",qrCodeContext);

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/client/DefaultClientOperation.java

@@ -34,8 +34,8 @@ public class DefaultClientOperation implements ClientOperation {
     }
 
     @Override
-    public void ClientStartingErrorHandler() {
+    public void ClientStartingErrorHandler(String errorMsg) {
-        //NOOP
+
     }
 
     @Override
@@ -43,11 +43,13 @@ public class DefaultClientOperation implements ClientOperation {
         //NOOP
     }
 
+
     @Override
-    public void ClientStoppingErrorHandler() {
+    public void ClientStoppingErrorHandler(String errorMsg) {
         //NOOP
     }
 
+
     @Override
     public void ClientStoppedHandler() {
         //NOOP

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/server/DefaultServerOperation.java

@@ -74,8 +74,8 @@ public class DefaultServerOperation implements ServerOperation {
     }
 
     @Override
-    public void ServerStartingErrorHandler() {
+    public void ServerStartingErrorHandler(String errorMessage) {
-
+        //NOOP
     }
 
     @Override
@@ -89,8 +89,8 @@ public class DefaultServerOperation implements ServerOperation {
     }
 
     @Override
-    public void ServerStoppingErrorHandler() {
+    public void ServerStoppingErrorHandler(String errorMessage) {
-
+        //NOOP
     }
 
     @Override
@@ -98,6 +98,11 @@ public class DefaultServerOperation implements ServerOperation {
         //NOOP
     }
 
+    @Override
+    public void ClientSessionBuildInHandler(String clientId) {
+        //NOOP
+    }
+
     @Override
     public void InactiveConnectionRemoveHandler(String clientId) {
         //NOOP

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/server/ServerDLPBHandler.java

@@ -16,10 +16,10 @@
 
 package com.r3944realms.dg_lab.websocket.handler.server;
 
+import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
 import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandler;
 import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandlerContextWrapper;
 import com.r3944realms.dg_lab.websocket.handler.IAttachSharedData;
-import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
 import io.netty.channel.ChannelHandler;
 
 

Common/src/main/java/com/r3944realms/dg_lab/websocket/handler/server/ServerDLPBHandlerContextWrapper.java

@@ -18,17 +18,17 @@ package com.r3944realms.dg_lab.websocket.handler.server;
 
 import com.google.gson.JsonSyntaxException;
 import com.r3944realms.dg_lab.api.operation.ServerOperation;
-import com.r3944realms.dg_lab.api.websocket.message.role.*;
-import com.r3944realms.dg_lab.utils.stringUtils.StringHandlerUtil;
-import com.r3944realms.dg_lab.utils.timeTask.DgLabTimerTask;
-import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandlerContextWrapper;
 import com.r3944realms.dg_lab.api.websocket.message.Message;
 import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
 import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxData;
 import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxDataWithSingleAttachment;
 import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxDataType;
 import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxStatusCode;
+import com.r3944realms.dg_lab.api.websocket.message.role.*;
 import com.r3944realms.dg_lab.api.websocket.message.role.type.RoleType;
+import com.r3944realms.dg_lab.utils.stringUtils.StringHandlerUtil;
+import com.r3944realms.dg_lab.utils.timeTask.DgLabTimerTask;
+import com.r3944realms.dg_lab.websocket.handler.AbstractDgLabPowerBoxHandlerContextWrapper;
 import com.r3944realms.dg_lab.websocket.sharedData.ServerPowerBoxSharedData;
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
@@ -78,6 +78,8 @@ public class ServerDLPBHandlerContextWrapper extends AbstractDgLabPowerBoxHandle
         Channel().add(session.channel());
         Connections().put(clientId, session);
         logger.info("新的 webSocket 连接已建立, 标识符为{}", clientId);
+        String finalClientId = clientId;
+        TryCatch(n -> ((ServerOperation)operation).ClientSessionBuildInHandler(finalClientId));
     }
 
     @Override
@@ -297,7 +299,7 @@ public class ServerDLPBHandlerContextWrapper extends AbstractDgLabPowerBoxHandle
                     case CLEAR -> {
                         if (Connections().containsKey(targetId)) {
                             ChannelHandlerContext client = Connections().get(targetId);
-                            String Channel = ((String[])argsArray)[0];
+                            Integer Channel = ((Integer[])argsArray)[0];
                             String messageCommand = "clear-" + Channel;
                             PowerBoxMessage strengthUpdate = PowerBoxMessage.createPowerBoxMessage("msg", clientId, targetId, messageCommand, role, new WebSocketApplicationRole("Ap" + targetId));
                             TryCatch(n -> ((ServerOperation)operation).ClearMessageHandler(strengthUpdate));

Common/src/main/java/com/r3944realms/dg_lab/websocket/sharedData/ClientPowerBoxSharedData.java

@@ -16,8 +16,8 @@
 
 package com.r3944realms.dg_lab.websocket.sharedData;
 
-import com.r3944realms.dg_lab.utils.stringUtils.StringHandlerUtil;
 import com.r3944realms.dg_lab.api.websocket.sharedData.ISharedData;
+import com.r3944realms.dg_lab.utils.stringUtils.StringHandlerUtil;
 
 import java.util.Timer;
 
@@ -34,6 +34,7 @@ public class ClientPowerBoxSharedData implements ISharedData {
         clone.delay = delay;
         clone.address = address;
         clone.port = port;
+        clone.rqCodeUrl = rqCodeUrl;
         return clone;
     }
 
@@ -70,6 +71,14 @@ public class ClientPowerBoxSharedData implements ISharedData {
      * The Follow b strength.
      */
     public final boolean followBStrength = false;
+    /**
+     * 二维码
+     */
+    public String rqCodeUrl = "";
+    /**
+     * 是否启用 SSL
+     */
+    public boolean isEnableSsl = false;
 
     /**
      * Instantiates a new Client power box shared data.
@@ -91,7 +100,7 @@ public class ClientPowerBoxSharedData implements ISharedData {
      * @return the url
      */
     public String getUrl() {
-        return StringHandlerUtil.buildWebSocketURL(address, port, false);
+        return StringHandlerUtil.buildWebSocketURL(address, port, isEnableSsl);
     }
 
 

CommonApi/build.gradle

@@ -33,18 +33,16 @@ sourceSets {
 }
 
 dependencies {
-    implementation 'org.apache.logging.log4j:log4j-core:2.23.1'
-    implementation 'org.apache.logging.log4j:log4j-api:2.23.1'
-    implementation 'org.apache.logging.log4j:log4j-slf4j2-impl:2.23.1'
-    implementation group: 'org.realityforge.org.jetbrains.annotations', name: 'org.jetbrains.annotations', version: '1.7.0'
-    implementation group: 'org.apache.commons', name: 'commons-lang3', version: '3.17.0'
-    implementation group: 'com.google.guava', name: 'guava', version: '33.3.0-jre'
-    implementation group: 'io.netty', name: 'netty-all', version: '4.1.109.Final'
-    implementation group: 'com.google.code.gson', name: 'gson', version: '2.10.1'
-    testImplementation platform('org.junit:junit-bom:5.10.0')
-    testImplementation 'org.junit.jupiter:junit-jupiter'
-    implementation group: 'org.slf4j', name: 'slf4j-api', version: '2.0.16'
 }
+javadoc {
+    options.encoding = 'UTF-8'
+    options.charSet = 'UTF-8'
+    // 添加以下选项以减少警告
+    options.addBooleanOption('Xdoclint:none', true)
+    options.addStringOption('Xmaxwarns', '10')
+}
+
+
 tasks.register('sourcesJar', Jar) {
     archiveClassifier.set('sources')
     from sourceSets.main.allSource
@@ -81,6 +79,21 @@ publishing {
             from components.java
             artifact(tasks.named("sourcesJar"))
             artifact(tasks.named("javadocJar"))
+            pom {
+                name = "${project_name}"
+                description = "The API for ${project_name}"
+                url = "https://github.com/3944Realms/DG_LAB_DEVELOP"
+                licenses {
+                    license {
+                        name = 'Apache License 2.0'
+                        url = 'https://www.apache.org/licenses/LICENSE-2.0.html'
+                    }
+                }
+                issueManagement {
+                    system = 'GitHub Issues'
+                    url = 'https://github.com/3944Realms/DG_LAB_DEVELOP/issues'
+                }
+            }
         }
     }
 }

CommonApi/src/main/java/com/r3944realms/dg_lab/api/manager/IDGLabManager.java

@@ -39,6 +39,7 @@ public interface IDGLabManager {
      * @return the shared data
      */
     ISharedData getSharedData();
+
     /**
      * 获取当前单例实例运行
      *

CommonApi/src/main/java/com/r3944realms/dg_lab/api/message/IPowerBoxMsg.java

@@ -25,8 +25,8 @@ import com.r3944realms.dg_lab.api.message.data.PulseWaveList;
 import com.r3944realms.dg_lab.api.message.data.PulseWaveListGenerator;
 import com.r3944realms.dg_lab.api.websocket.message.MessageDirection;
 import com.r3944realms.dg_lab.api.websocket.message.PowerBoxMessage;
-import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxDataWithSingleAttachment;
 import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxData;
+import com.r3944realms.dg_lab.api.websocket.message.data.PowerBoxDataWithSingleAttachment;
 import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxDataType;
 import com.r3944realms.dg_lab.api.websocket.message.role.Role;
 

CommonApi/src/main/java/com/r3944realms/dg_lab/api/message/argType/ChangePolicy.java

@@ -20,14 +20,14 @@ package com.r3944realms.dg_lab.api.message.argType;
  * 修改策略
  */
 public enum ChangePolicy {
-    /**
-     * 增加
-     */
-    INCREASE(0),
     /**
      * 减少
      */
-    DECREASE(1),
+    DECREASE(0),
+    /**
+     * 增加
+     */
+    INCREASE(1),
     /**
      * 转变
      */

CommonApi/src/main/java/com/r3944realms/dg_lab/api/operation/ClientOperation.java

@@ -34,8 +34,10 @@ public interface ClientOperation  extends IOperation {
 
     /**
      * 客户端启动遇到错误后处理
+     *
+     * @param errorMsg 错误消息
      */
-    void ClientStartingErrorHandler();
+    void ClientStartingErrorHandler(String errorMsg);
 
     /**
      * 客户端线程关闭中处理
@@ -44,8 +46,10 @@ public interface ClientOperation  extends IOperation {
 
     /**
      * 客户端线程关闭中遇到错误后处理
+     *
+     * @param errorMsg 错误消息
      */
-    void ClientStoppingErrorHandler();
+    void ClientStoppingErrorHandler(String errorMsg);
 
     /**
      * 客户端线程完全关闭后处理

CommonApi/src/main/java/com/r3944realms/dg_lab/api/operation/ServerOperation.java

@@ -31,8 +31,10 @@ public interface ServerOperation extends IOperation {
 
     /**
      * 服务器线程开启中遇到错误后处理
+     *
+     * @param errorMessage 错误消息
      */
-    void ServerStartingErrorHandler();
+    void ServerStartingErrorHandler(String errorMessage);
 
     /**
      * 服务器线程开启后处理
@@ -46,14 +48,23 @@ public interface ServerOperation extends IOperation {
 
     /**
      * 服务器线程关闭中遇到错误后处理
+     *
+     * @param errorMessage 错误消息
      */
-    void ServerStoppingErrorHandler();
+    void ServerStoppingErrorHandler(String errorMessage);
 
     /**
      * 服务器线程完全关闭后处理
      */
     void ServerStoppedHandler();
 
+    /**
+     * 客户端会话连接触发器
+     *
+     * @param clientId the client id
+     */
+    void ClientSessionBuildInHandler(String clientId);
+
     /**
      * 在定时器里即将被移除的UUID处理
      *

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/IWebSocketServer.java

@@ -0,0 +1,79 @@
+package com.r3944realms.dg_lab.api.websocket;
+
+import com.r3944realms.dg_lab.api.websocket.message.Message;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+import java.io.File;
+
+/**
+ * The interface Web socket server.
+ */
+public interface IWebSocketServer extends IWebsocketSide {
+    /**
+     * Gets listened address.
+     *
+     * @return the listened address
+     */
+    String getListenedAddress();
+
+    /**
+     * Sets listened address.
+     *
+     * @param address the address
+     */
+    void setListenedAddress(String address);
+
+    /**
+     * 获取监听端口
+     *
+     * @return 端口 port
+     */
+    int getPort();
+
+    /**
+     * 设置监听端口
+     *
+     * @param port 端口
+     */
+    void setPort(int port);
+
+    /**
+     * 启用SSL
+     *
+     * @param certificateFile 证书文件
+     * @param keyFile         私钥文件
+     */
+    default void enableSSL(@NotNull File certificateFile, @NotNull File keyFile) {
+        enableSSL(certificateFile, keyFile,null);
+    }
+
+    /**
+     * 启用SSL
+     *
+     * @param certificateFile 证书文件
+     * @param keyFile         私钥文件
+     * @param password        ssl密码
+     */
+    void enableSSL(@NotNull File certificateFile, @NotNull File keyFile, @Nullable String password);
+
+    /**
+     * 禁用SSL
+     */
+    void disableSSL();
+
+    /**
+     * 获取SSL是否开启
+     *
+     * @return enable boolean
+     */
+    boolean isSSLEnabled();
+
+    /**
+     * 向指定的客户端发送消息
+     *
+     * @param connectId 客户端UUID
+     * @param message   消息
+     */
+    void send(String connectId, Message message);
+}

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/IWebsocketClient.java

@@ -0,0 +1,72 @@
+package com.r3944realms.dg_lab.api.websocket;
+
+import com.r3944realms.dg_lab.api.websocket.message.Message;
+import org.jetbrains.annotations.Nullable;
+
+import java.io.File;
+
+/**
+ * The interface Websocket client.
+ */
+public interface IWebsocketClient extends IWebsocketSide {
+    /**
+     * Gets address.
+     *
+     * @return the address
+     */
+    String getAddress();
+
+    /**
+     * Sets address.
+     *
+     * @param address the address
+     */
+    void setAddress(String address);
+
+    /**
+     * Gets port.
+     *
+     * @return the port
+     */
+    int getPort();
+
+    /**
+     * Sets port.
+     *
+     * @param port the port
+     */
+    void setPort(int port);
+
+    /**
+     * Enable ssl.
+     */
+    default void enableSSL() {
+        enableSSL(null);
+    }
+
+    /**
+     * Enable ssl.
+     *
+     * @param certificateFile the certificate file
+     */
+    void enableSSL(@Nullable File certificateFile);
+
+    /**
+     * Disable ssl.
+     */
+    void disableSSL();
+
+    /**
+     * Is ssl enabled boolean.
+     *
+     * @return the boolean
+     */
+    boolean isSSLEnabled();
+
+    /**
+     * 向所连接的服务器发送消息
+     *
+     * @param message 消息
+     */
+    void send(Message message);
+}

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/IWebsocketSide.java

@@ -0,0 +1,72 @@
+package com.r3944realms.dg_lab.api.websocket;
+
+import com.r3944realms.dg_lab.api.manager.Status;
+
+/**
+ * The interface Websocket side.
+ */
+public interface IWebsocketSide {
+    /**
+     * 获取状态
+     *
+     * @return the status
+     */
+    Status getStatus();
+
+    /**
+     * 设置状态
+     *
+     * @param status 状态
+     */
+    void setStatus(Status status);
+
+    /**
+     * Init.
+     */
+    void init();
+
+    /**
+     * Start.
+     */
+    void start();
+
+    /**
+     * Stop.
+     */
+    void stop();
+
+    /**
+     * On starting.
+     */
+    void onStarting();
+
+    /**
+     * On stopping.
+     */
+    void onStopping();
+
+    /**
+     * On starting error.
+     *
+     * @param msg the msg
+     */
+    void onStartingError(String msg);
+
+    /**
+     * On stopping error.
+     *
+     * @param msg the msg
+     */
+    void onStoppingError(String msg);
+
+    /**
+     * On started.
+     */
+    void onStarted();
+
+    /**
+     * On stopped.
+     */
+    void onStopped();
+
+}

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/Message.java

@@ -19,14 +19,19 @@ package com.r3944realms.dg_lab.api.websocket.message;
 
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
+import com.google.gson.TypeAdapter;
 import com.google.gson.annotations.Expose;
+import com.google.gson.stream.JsonReader;
+import com.google.gson.stream.JsonWriter;
 import com.r3944realms.dg_lab.api.websocket.message.data.IData;
 import com.r3944realms.dg_lab.api.websocket.message.data.adapter.IDataTypeAdapterFactory;
 import com.r3944realms.dg_lab.api.websocket.message.role.Role;
 import com.r3944realms.dg_lab.api.websocket.message.role.RoleDeserializer;
 
+import java.io.IOException;
 import java.io.Serial;
 import java.io.Serializable;
+import java.util.concurrent.atomic.AtomicReference;
 
 /**
  * 消息，带有方向和有效负载消息
@@ -52,6 +57,24 @@ public abstract class Message implements Serializable {
         gsonBuilder.registerTypeAdapter(Role.class, new RoleDeserializer());
         gsonBuilder.registerTypeAdapter(MessageDirection.class, new MessageDirectionDeserializer());
         gsonBuilder.registerTypeAdapterFactory(new IDataTypeAdapterFactory());
+        // 注册 AtomicReference 的适配器
+        gsonBuilder.registerTypeAdapter(AtomicReference.class, new TypeAdapter<AtomicReference<?>>() {
+            @Override
+            public void write(JsonWriter out, AtomicReference<?> value) throws IOException {
+                if (value == null || value.get() == null) {
+                    out.nullValue();
+                } else {
+                    gson.toJson(value.get(), value.get().getClass(), out);
+                }
+            }
+
+            @Override
+            public AtomicReference<?> read(JsonReader in) throws IOException {
+                Object obj = gson.fromJson(in, Object.class);
+                return new AtomicReference<>(obj);
+            }
+        });
+
         gson = gsonBuilder.create();
     }
 

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/MessageDirection.java

@@ -18,7 +18,6 @@ package com.r3944realms.dg_lab.api.websocket.message;
 
 import com.r3944realms.dg_lab.api.websocket.message.role.*;
 
-
 import java.io.Serializable;
 
 /**

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/PowerBoxMessage.java

@@ -38,7 +38,14 @@ public class PowerBoxMessage extends Message {
     /**
      * The Invalid message json.
      */
-    static final String INVALID_MESSAGE_JSON = gson.toJson(PowerBoxData.createPowerBoxData("error","","",""));
+
+    private static class LazyInvalidJsonHolder {
+        /**
+         * The Value.
+         */
+        static final String VALUE =
+                gson.toJson(PowerBoxData.createPowerBoxData("error", "", "", ""));
+    }
 
     /**
      * Instantiates a new Power box message.
@@ -168,7 +175,7 @@ public class PowerBoxMessage extends Message {
 
     @Override
     public String getInvalidMessageJson() {
-        return INVALID_MESSAGE_JSON;
+        return  LazyInvalidJsonHolder.VALUE;
     }
 
     @Override

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/data/DataType.java

@@ -16,6 +16,9 @@
 
 package com.r3944realms.dg_lab.api.websocket.message.data;
 
+/**
+ * The enum Data type.
+ */
 public enum DataType {
     /**
      * Power box att data type.
@@ -29,6 +32,7 @@ public enum DataType {
      * Power box data type.
      */
     POWER_BOX;
+
     /**
      * Gets type from string.
      *

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/data/IData.java

@@ -16,6 +16,9 @@
 
 package com.r3944realms.dg_lab.api.websocket.message.data;
 
+/**
+ * The interface Data.
+ */
 public interface IData {
 
     /**

CommonApi/src/main/java/com/r3944realms/dg_lab/api/websocket/message/data/PowerBoxData.java

@@ -16,6 +16,7 @@
 
 package com.r3944realms.dg_lab.api.websocket.message.data;
 
+import com.google.gson.annotations.Expose;
 import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxDataType;
 import com.r3944realms.dg_lab.api.websocket.message.data.type.PowerBoxStatusCode;
 
@@ -35,7 +36,9 @@ public class PowerBoxData implements IData {
     private final String clientId;
     private final String targetId;
     private final String message;
-    AtomicReference<String> inValidReason = new AtomicReference<>(getInvalidReason());
+    @Expose(serialize = false, deserialize = false)
+    private final transient AtomicReference<String> inValidReason = new AtomicReference<>(getInvalidReason());
+
     /**
      * Instantiates a new Power box data.
      *

build.gradle

@@ -4,8 +4,8 @@ plugins {
     id("maven-publish")
 }
 
-group = "top.r3944realms.superleadrope"
+group = "${project_version}"
-version = "1.0-SNAPSHOT"
+version = "${project_version}"
 
 allprojects {
     repositories {
@@ -16,6 +16,7 @@ allprojects {
 subprojects {
     apply {
         plugin('java')
+        plugin("maven-publish")
     }
 
     java {
@@ -25,11 +26,42 @@ subprojects {
     }
 
     dependencies {
-        testImplementation(platform("org.junit:junit-bom:5.10.0"))
+        implementation 'org.realityforge.org.jetbrains.annotations:org.jetbrains.annotations:1.7.0'
-        testImplementation("org.junit.jupiter:junit-jupiter")
+        implementation 'org.apache.logging.log4j:log4j-core:2.23.1'
+        implementation 'org.apache.logging.log4j:log4j-api:2.23.1'
+        implementation 'org.apache.logging.log4j:log4j-slf4j2-impl:2.23.1'
+        implementation 'org.apache.commons:commons-lang3:3.17.0'
+        implementation 'com.google.guava:guava:33.3.0-jre'
+        implementation 'io.netty:netty-all:4.1.109.Final'
+        implementation 'com.google.code.gson:gson:2.10.1'
+        implementation 'org.slf4j:slf4j-api:2.0.16'
+
+        testImplementation platform('org.junit:junit-bom:5.10.0')
+        testImplementation 'org.junit.jupiter:junit-jupiter'
     }
 
     tasks.test {
         useJUnitPlatform()
     }
+
+    tasks.withType(PublishToMavenRepository) {
+        dependsOn assemble
+    }
+
+    publishing {
+        repositories {
+            maven {
+                name = "local"
+                url = layout.buildDirectory.dir("repo")
+            }
+            maven {
+                name = 'LTDNexus'
+                url = 'https://nexus.bot.leisuretimedock.top/repository/maven-releases/'
+                credentials {
+                    username = System.getenv('LTDNexusUsername') ?: ''
+                    password = System.getenv('LTDNexusPassword') ?: ''
+                }
+            }
+        }
+    }
 }

gradle.properties

@@ -1,13 +1,13 @@
 # Gradle settings
 org.gradle.jvmargs=-Xmx3G
-org.gradle.daemon=true
+org.gradle.daemon=false
 org.gradle.configureondemand=true
-org.gradle.caching=true
+org.gradle.caching=false
-org.gradle.configuration-cache=true
+org.gradle.configuration-cache=false
 org.gradle.configuration-cache.problems=warn
 # ROOT
 project_name=DgLab
-project_version=4.2.8.16
+project_version=4.4.14.19
 project_group=top.r3944realms.dg_lab
 
 # API

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,7 @@
-#Sun Sep 22 17:25:46 CST 2024
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://mirrors.cloud.tencent.com/gradle/gradle-8.12-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.12-bin.zip
+networkTimeout=10000
+validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

gradlew

@@ -0,0 +1,251 @@
+#!/bin/sh
+
+#
+# Copyright © 2015-2021 the original authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+
+##############################################################################
+#
+#   Gradle start up script for POSIX generated by Gradle.
+#
+#   Important for running:
+#
+#   (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
+#       noncompliant, but you have some other compliant shell such as ksh or
+#       bash, then to run this script, type that shell name before the whole
+#       command line, like:
+#
+#           ksh Gradle
+#
+#       Busybox and similar reduced shells will NOT work, because this script
+#       requires all of these POSIX shell features:
+#         * functions;
+#         * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
+#           «${var#prefix}», «${var%suffix}», and «$( cmd )»;
+#         * compound commands having a testable exit status, especially «case»;
+#         * various built-in commands including «command», «set», and «ulimit».
+#
+#   Important for patching:
+#
+#   (2) This script targets any POSIX shell, so it avoids extensions provided
+#       by Bash, Ksh, etc; in particular arrays are avoided.
+#
+#       The "traditional" practice of packing multiple parameters into a
+#       space-separated string is a well documented source of bugs and security
+#       problems, so this is (mostly) avoided, by progressively accumulating
+#       options in "$@", and eventually passing that to Java.
+#
+#       Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
+#       and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
+#       see the in-line comments for details.
+#
+#       There are tweaks for specific operating systems such as AIX, CygWin,
+#       Darwin, MinGW, and NonStop.
+#
+#   (3) This script is generated from the Groovy template
+#       https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       within the Gradle project.
+#
+#       You can find Gradle at https://github.com/gradle/gradle/.
+#
+##############################################################################
+
+# Attempt to set APP_HOME
+
+# Resolve links: $0 may be a link
+app_path=$0
+
+# Need this for daisy-chained symlinks.
+while
+    APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
+    [ -h "$app_path" ]
+do
+    ls=$( ls -ld "$app_path" )
+    link=${ls#*' -> '}
+    case $link in             #(
+      /*)   app_path=$link ;; #(
+      *)    app_path=$APP_HOME$link ;;
+    esac
+done
+
+# This is normally unused
+# shellcheck disable=SC2034
+APP_BASE_NAME=${0##*/}
+# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
+APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD=maximum
+
+warn () {
+    echo "$*"
+} >&2
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+} >&2
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "$( uname )" in                #(
+  CYGWIN* )         cygwin=true  ;; #(
+  Darwin* )         darwin=true  ;; #(
+  MSYS* | MINGW* )  msys=true    ;; #(
+  NONSTOP* )        nonstop=true ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD=$JAVA_HOME/jre/sh/java
+    else
+        JAVACMD=$JAVA_HOME/bin/java
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD=java
+    if ! command -v java >/dev/null 2>&1
+    then
+        die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+fi
+
+# Increase the maximum file descriptors if we can.
+if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
+    case $MAX_FD in #(
+      max*)
+        # In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        MAX_FD=$( ulimit -H -n ) ||
+            warn "Could not query maximum file descriptor limit"
+    esac
+    case $MAX_FD in  #(
+      '' | soft) :;; #(
+      *)
+        # In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
+        # shellcheck disable=SC2039,SC3045
+        ulimit -n "$MAX_FD" ||
+            warn "Could not set maximum file descriptor limit to $MAX_FD"
+    esac
+fi
+
+# Collect all arguments for the java command, stacking in reverse order:
+#   * args from the command line
+#   * the main class name
+#   * -classpath
+#   * -D...appname settings
+#   * --module-path (only if needed)
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if "$cygwin" || "$msys" ; then
+    APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
+    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
+
+    JAVACMD=$( cygpath --unix "$JAVACMD" )
+
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    for arg do
+        if
+            case $arg in                                #(
+              -*)   false ;;                            # don't mess with options #(
+              /?*)  t=${arg#/} t=/${t%%/*}              # looks like a POSIX filepath
+                    [ -e "$t" ] ;;                      #(
+              *)    false ;;
+            esac
+        then
+            arg=$( cygpath --path --ignore --mixed "$arg" )
+        fi
+        # Roll the args list around exactly as many times as the number of
+        # args, so each arg winds up back in the position where it started, but
+        # possibly modified.
+        #
+        # NB: a `for` loop captures its iteration list before it begins, so
+        # changing the positional parameters here affects neither the number of
+        # iterations, nor the values presented in `arg`.
+        shift                   # remove old arg
+        set -- "$@" "$arg"      # push replacement arg
+    done
+fi
+
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Collect all arguments for the java command:
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
+#     and any embedded shellness will be escaped.
+#   * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
+#     treated as '${Hostname}' itself on the command line.
+
+set -- \
+        "-Dorg.gradle.appname=$APP_BASE_NAME" \
+        -classpath "$CLASSPATH" \
+        org.gradle.wrapper.GradleWrapperMain \
+        "$@"
+
+# Stop when "xargs" is not available.
+if ! command -v xargs >/dev/null 2>&1
+then
+    die "xargs is not available"
+fi
+
+# Use "xargs" to parse quoted args.
+#
+# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
+#
+# In Bash we could simply go:
+#
+#   readarray ARGS < <( xargs -n1 <<<"$var" ) &&
+#   set -- "${ARGS[@]}" "$@"
+#
+# but POSIX shell has neither arrays nor command substitution, so instead we
+# post-process each arg (as a line of input to sed) to backslash-escape any
+# character that might be a shell metacharacter, then use eval to reverse
+# that process (while maintaining the separation between arguments), and wrap
+# the whole thing up as a single "set" statement.
+#
+# This will of course break if any of these variables contains a newline or
+# an unmatched quote.
+#
+
+eval "set -- $(
+        printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
+        xargs -n1 |
+        sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
+        tr '\n' ' '
+    )" '"$@"'
+
+exec "$JAVACMD" "$@"

gradlew.bat

@@ -0,0 +1,94 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+@rem SPDX-License-Identifier: Apache-2.0
+@rem
+
+@if "%DEBUG%"=="" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%"=="" set DIRNAME=.
+@rem This is normally unused
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if %ERRORLEVEL% equ 0 goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo. 1>&2
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
+echo. 1>&2
+echo Please set the JAVA_HOME variable in your environment to match the 1>&2
+echo location of your Java installation. 1>&2
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if %ERRORLEVEL% equ 0 goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+set EXIT_CODE=%ERRORLEVEL%
+if %EXIT_CODE% equ 0 set EXIT_CODE=1
+if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
+exit /b %EXIT_CODE%
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

versionlog.txt

@@ -2,6 +2,44 @@
 统一用4位版本，对于测试性更新统一在其后加-Beta。
 修复问题更新为加0.0.0.1，添加/移除新特性加0.0.1.0，小部分重构更新加0.1.0.0，大量重构加1.0.0.0
 
+2026-04-20-1
+project_version=4.4.14.19
+* 修复clear指令构建命令时抛出转型异常导致无法正确发送指令
+* 修复ChangePolicy增加和减小index写反的问题
+
+2025-09-29-1
+project_version=4.4.14.18
+* 提取Server/Client接口
+* 重命名方法starting 变为 onStarting等
+* Server添加设置监听地址功能
+
+2025-09-29-1
+project_version=4.3.12.18
+* 新增操作ServerOperation类中方法会话建立Handler，已在与客户端会话创建后可进行操作
+* 修改错误消息提醒
+
+2025-09-23-1
+project_version=4.3.11.18
+* 添加操作Operation类的Error方法错误的参数，同时移除无参方法
+
+2025-09-21-4
+project_version=4.2.11.18
+* 添加服务器对SSL密码参数支持
+
+2025-09-21-3
+project_version=4.2.10.18
+* 添加ClientPowerBoxSharedData添加新字段 isEnableSsl,用于WS地址协议头判断
+* 让PowerBoxWSClient继承了父类的#enableSSL #disableSSL方法以适配添加ClientPowerBoxSharedData添加新字段的字段 isEnableSsl
+
+2025-09-21-2
+project_version=4.2.10.17
+* 修正 DGPBClientManager 的实现接口为com.r3944realms.dg_lab.api.manager.IDGLabManager
+* 在ClientPowerBoxSharedData添加新字段rqCodeUrl用于辅助访问二维码Url
+
+2025-09-21-1
+project_version=4.2.9.16
+* 添加了SSL支持
+
 2025-09-13-1
 project_version=4.2.8.16
 * 重构项目结构