From f1db38a302d295599b71ecacc30b6a9e4901dc9a Mon Sep 17 00:00:00 2001 From: Looly Date: Thu, 9 Nov 2023 17:35:47 +0800 Subject: [PATCH] add Z85Codec --- .../hutool/core/codec/binary/Base16Codec.java | 5 +- .../hutool/core/codec/binary/Base32Codec.java | 4 +- .../hutool/core/codec/binary/Base58Codec.java | 4 +- .../core/codec/binary/Base64Decoder.java | 5 +- .../hutool/core/codec/binary/Z85Codec.java | 127 ++++++++++++++++++ 5 files changed, 141 insertions(+), 4 deletions(-) create mode 100644 hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Z85Codec.java diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base16Codec.java b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base16Codec.java index 2e413f274..3d60322e5 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base16Codec.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base16Codec.java @@ -17,6 +17,8 @@ import org.dromara.hutool.core.codec.Encoder; import org.dromara.hutool.core.exception.HutoolException; import org.dromara.hutool.core.text.StrUtil; +import java.io.Serializable; + /** * Base16（Hex）编码解码器
* 十六进制（简写为hex或下标16）在数学中是一种逢16进1的进位制，一般用数字0到9和字母A到F表示（其中:A~F即10~15）。
@@ -25,7 +27,8 @@ import org.dromara.hutool.core.text.StrUtil; * @author looly * @since 5.7.23 */ -public class Base16Codec implements Encoder, Decoder { +public class Base16Codec implements Encoder, Decoder, Serializable { + private static final long serialVersionUID = 1L; /** * 编码解码器：小写 diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base32Codec.java b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base32Codec.java index 8976d5576..dd0549577 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base32Codec.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base32Codec.java @@ -15,6 +15,7 @@ package org.dromara.hutool.core.codec.binary; import org.dromara.hutool.core.codec.Decoder; import org.dromara.hutool.core.codec.Encoder; +import java.io.Serializable; import java.util.Arrays; /** @@ -31,7 +32,8 @@ import java.util.Arrays; * @author Looly * @since 5.8.0 */ -public class Base32Codec implements Encoder, Decoder { +public class Base32Codec implements Encoder, Decoder, Serializable { + private static final long serialVersionUID = 1L; /** * 单例对象 diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base58Codec.java b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base58Codec.java index 1d80123b5..c76c0f93f 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base58Codec.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base58Codec.java @@ -16,6 +16,7 @@ import org.dromara.hutool.core.codec.Decoder; import org.dromara.hutool.core.codec.Encoder; import org.dromara.hutool.core.text.StrUtil; +import java.io.Serializable; import java.util.Arrays; /** @@ -25,7 +26,8 @@ import java.util.Arrays; * @author lin， looly * @since 5.7.22 */ -public class Base58Codec implements Encoder, Decoder { +public class Base58Codec implements Encoder, Decoder, Serializable { + private static final long serialVersionUID = 1L; /** * 单例 diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base64Decoder.java b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base64Decoder.java index 4eef3cf82..e8c809d0a 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base64Decoder.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Base64Decoder.java @@ -16,6 +16,8 @@ import org.dromara.hutool.core.codec.Decoder; import org.dromara.hutool.core.lang.mutable.MutableInt; import org.dromara.hutool.core.array.ArrayUtil; +import java.io.Serializable; + /** * Base64解码实现
* 此解码保留的原因是，JDK提供的解码需要指定是否为URL安全的或是否换行，此解码无需区分 @@ -23,7 +25,8 @@ import org.dromara.hutool.core.array.ArrayUtil; * @author looly * */ -public class Base64Decoder implements Decoder { +public class Base64Decoder implements Decoder, Serializable { + private static final long serialVersionUID = 1L; /** * 单例对象 diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Z85Codec.java b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Z85Codec.java new file mode 100644 index 000000000..5267a92a3 --- /dev/null +++ b/hutool-core/src/main/java/org/dromara/hutool/core/codec/binary/Z85Codec.java @@ -0,0 +1,127 @@ +/* + * Copyright (c) 2023. looly(loolly@aliyun.com) + * Hutool is licensed under Mulan PSL v2. + * You can use this software according to the terms and conditions of the Mulan PSL v2. + * You may obtain a copy of Mulan PSL v2 at: + * https://license.coscl.org.cn/MulanPSL2 + * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND, + * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT, + * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE. + * See the Mulan PSL v2 for more details. + */ + +package org.dromara.hutool.core.codec.binary; + +import org.dromara.hutool.core.codec.Decoder; +import org.dromara.hutool.core.codec.Encoder; + +import java.io.Serializable; + +/** + * ZeroMQ Z85实现，
+ * 定义见：ZeroMQ Z85
+ * + * 参考实现：https://github.com/cometd/cometd/blob/6.0.x/cometd-java/cometd-java-common/src/main/java/org/cometd/common/Z85.java + * + * @author cometd-java + */ +public class Z85Codec implements Encoder, Decoder, Serializable { + private static final long serialVersionUID = 1L; + + private static final char[] encodeTable = new char[]{ + '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', + 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', + 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', + 'u', 'v', 'w', 'x', 'y', 'z', 'A', 'B', 'C', 'D', + 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', + 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', + 'Y', 'Z', '.', '-', ':', '+', '=', '^', '!', '/', + '*', '?', '&', '<', '>', '(', ')', '[', ']', '{', + '}', '@', '%', '$', '#' + }; + private static final int[] decodeTable = new int[]{ + 0x00, 0x44, 0x00, 0x54, 0x53, 0x52, 0x48, 0x00, + 0x4B, 0x4C, 0x46, 0x41, 0x00, 0x3F, 0x3E, 0x45, + 0x00, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, + 0x08, 0x09, 0x40, 0x00, 0x49, 0x42, 0x4A, 0x47, + 0x51, 0x24, 0x25, 0x26, 0x27, 0x28, 0x29, 0x2A, + 0x2B, 0x2C, 0x2D, 0x2E, 0x2F, 0x30, 0x31, 0x32, + 0x33, 0x34, 0x35, 0x36, 0x37, 0x38, 0x39, 0x3A, + 0x3B, 0x3C, 0x3D, 0x4D, 0x00, 0x4E, 0x43, 0x00, + 0x00, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F, 0x10, + 0x11, 0x12, 0x13, 0x14, 0x15, 0x16, 0x17, 0x18, + 0x19, 0x1A, 0x1B, 0x1C, 0x1D, 0x1E, 0x1F, 0x20, + 0x21, 0x22, 0x23, 0x4F, 0x00, 0x50, 0x00, 0x00 + }; + + + @Override + public String encode(final byte[] data) { + // SPEC: The binary frame SHALL have a length that is divisible by 4 with no remainder. + final int length = data.length; + final int remainder = length & 3; // Equivalent to length % 4. + // Support inputs that are not divisible by 4 with no remainder. + final int padding = 4 - (remainder == 0 ? 4 : remainder); + + // SPEC: 4 octets convert into 5 printable characters. + // char.length = length + 1/4 length == 5/4 length. + final char[] chars = new char[length + (length >>> 2) + (remainder == 0 ? 0 : 1)]; + int idx = 0; + long value = 0; + for (int i = 0; i < length + padding; ++i) { + // Accumulate the octets into a long. + final boolean isPadBlock = i >= length; + value = (value << 8) + (isPadBlock ? 0 : data[i] & 0xFF); + + // Decode every 4 octets into 5 characters. + if (((i + 1) & 3) == 0) { + for (int j = 0; j < 5; ++j) { + if (j > 0) { + value /= 85; + } + if (!isPadBlock || j >= padding) { + final int code = (int)(value % 85); + chars[idx + 4 - j] = encodeTable[code]; + } + } + idx += 5; + value = 0; + } + } + return new String(chars); + } + + @Override + public byte[] decode(String encoded) { + final int remainder = encoded.length() % 5; + final int padding = 5 - (remainder == 0 ? 5 : remainder); + final StringBuilder encodedBuilder = new StringBuilder(encoded); + for (int p = 0; p < padding; ++p) { + encodedBuilder.append(encodeTable[encodeTable.length - 1]); + } + encoded = encodedBuilder.toString(); + final int length = encoded.length(); + final byte[] bytes = new byte[((length << 2) / 5) - padding]; + long value = 0; + int index = 0; + for (int i = 0; i < length; ++i) { + // Accumulate the characters into a long. + final int code = encoded.charAt(i) - 32; + value = value * 85 + decodeTable[code]; + + // Encode every 5 characters into 4 octets. + if ((i + 1) % 5 == 0) { + for (int j = 0; j < 4; ++j) { + final int idx = index + 3 - j; + if (idx < bytes.length) { + bytes[idx] = (byte)(value & 0xFF); + } + value >>>= 8; + } + index += 4; + value = 0; + } + } + return bytes; + } +}