✨ 调整 PayloadEncode。

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/api/MqttHttpApi.java

@@ -22,7 +22,7 @@ import net.dreamlu.iot.mqtt.codec.MqttQoS;
 import net.dreamlu.iot.mqtt.core.server.dispatcher.IMqttMessageDispatcher;
 import net.dreamlu.iot.mqtt.core.server.http.api.code.ResultCode;
 import net.dreamlu.iot.mqtt.core.server.http.api.form.BaseForm;
-import net.dreamlu.iot.mqtt.core.server.http.api.form.PayloadEncode;
+import net.dreamlu.iot.mqtt.core.util.PayloadEncode;
 import net.dreamlu.iot.mqtt.core.server.http.api.form.PublishForm;
 import net.dreamlu.iot.mqtt.core.server.http.api.form.SubscribeForm;
 import net.dreamlu.iot.mqtt.core.server.http.api.result.Result;

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/api/form/PayloadEncode.java → mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/util/PayloadEncode.java

@@ -14,9 +14,8 @@
  * limitations under the License.
  */
 
-package net.dreamlu.iot.mqtt.core.server.http.api.form;
+package net.dreamlu.iot.mqtt.core.util;
 
-import net.dreamlu.iot.mqtt.core.util.HexUtil;
 import org.tio.utils.hutool.StrUtil;
 
 import java.nio.charset.StandardCharsets;
@@ -28,28 +27,51 @@ import java.util.Base64;
  * @author L.cm
  */
 public enum PayloadEncode {
+
 	/**
 	 * 纯文本、hex、base64
 	 */
 	plain {
+		@Override
+		public String encode(byte[] data) {
+			return new String(data, StandardCharsets.UTF_8);
+		}
+
 		@Override
 		public byte[] decode(String data) {
 			return data.getBytes(StandardCharsets.UTF_8);
 		}
 	},
 	hex {
+		@Override
+		public String encode(byte[] data) {
+			return HexUtil.encodeToString(data);
+		}
+
 		@Override
 		public byte[] decode(String data) {
 			return HexUtil.decode(data);
 		}
 	},
 	base64 {
+		@Override
+		public String encode(byte[] data) {
+			return Base64.getEncoder().encodeToString(data);
+		}
+
 		@Override
 		public byte[] decode(String data) {
 			return Base64.getDecoder().decode(data);
 		}
 	};
 
+	/**
+	 * 编码
+	 *
+	 * @return byte array
+	 */
+	public abstract String encode(byte[] data);
+
 	/**
 	 * 解码
 	 *