Merge branch 'main' into feat_storage

This commit is contained in:
godotg authored and GitHub committed 2023-09-13 20:52:20 +08:00
commit eaef89afa0
668 files changed
+1062 -814

No files matched your search

+115 -14
View File
@@ -6,42 +6,31 @@
<groupId>com.zfoo</groupId>
<artifactId>protocol</artifactId>
<version>3.0</version>
<version>3.1.0</version>
<packaging>jar</packaging>
<properties>
<zfoo.version>3.0</zfoo.version>
<zfoo.version>3.1.0</zfoo.version>
<!-- spring and spring boot -->
<spring.version>6.0.11</spring.version>
<spring.boot.version>3.1.3</spring.boot.version>
<junit.version>4.12</junit.version>
<!-- bytecode enhancement(字节码增强) -->
<javassist.version>3.29.2-GA</javassist.version>
<bytebuddy.version>1.14.6</bytebuddy.version>
<!-- network framework -->
<netty.version>4.1.97.Final</netty.version>
<!-- zookeeper -->
<curator.version>5.5.0</curator.version>
<!-- hardware detection(硬件检测) -->
<oshi.version>6.4.5</oshi.version>
<!-- database and cache -->
<mongodb-driver-sync.version>4.10.2</mongodb-driver-sync.version>
<caffeine.version>3.1.8</caffeine.version>
<!-- Office document parsing(office文档解析包) -->
<poi.version>5.2.3</poi.version>
<csv.version>1.10.0</csv.version>
<java.version>17</java.version>
<file.encoding>UTF-8</file.encoding>
<!-- maven core plugin(maven核心插件) -->
<maven-clean-plugin.version>3.3.1</maven-clean-plugin.version>
<maven-resources-plugin.version>3.3.1</maven-resources-plugin.version>
@@ -49,10 +38,12 @@
<maven-surefire-plugin.version>3.1.2</maven-surefire-plugin.version>
<maven-jar-plugin.version>3.3.0</maven-jar-plugin.version>
<maven-shade-plugin.version>3.5.0</maven-shade-plugin.version>
<maven-deploy-plugin.version>3.1.1</maven-deploy-plugin.version>
<versions-maven-plugin.version>2.16.0</versions-maven-plugin.version>
<project.build.sourceEncoding>${file.encoding}</project.build.sourceEncoding>
<maven.compiler.encoding>${file.encoding}</maven.compiler.encoding>
<java.version>17</java.version>
<file.encoding>UTF-8</file.encoding>
</properties>
<dependencies>
@@ -214,7 +205,117 @@
<artifactId>maven-jar-plugin</artifactId>
<version>${maven-jar-plugin.version}</version>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-deploy-plugin</artifactId>
<version>${maven-deploy-plugin.version}</version>
</plugin>
</plugins>
</build>
<name>protocol</name>
<description>zfoo protocol</description>
<url>https://github.com/zfoo-project/zfoo</url>
<developers>
<developer>
<name>jaysunxiao</name>
<email>jaysunxiao@gmail.com</email>
<url>https://github.com/godotg</url>
</developer>
</developers>
<organization>
<name>The zfoo Authors</name>
<url>https://github.com/zfoo-project/zfoo</url>
</organization>
<licenses>
<license>
<name>The Apache Software License, Version 2.0</name>
<url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
</license>
</licenses>
<scm>
<connection>https://github.com/zfoo-project/zfoo.git</connection>
<developerConnection>scm:git:ssh://git@github.com:zfoo-project/zfoo.git</developerConnection>
<url>https://github.com/zfoo-project/zfoo</url>
</scm>
<profiles>
<profile>
<id>ossrh</id>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
<build>
<plugins>
<plugin>
<groupId>org.sonatype.plugins</groupId>
<artifactId>nexus-staging-maven-plugin</artifactId>
<version>1.6.13</version>
<extensions>true</extensions>
<configuration>
<serverId>ossrh</serverId>
<nexusUrl>https://s01.oss.sonatype.org/</nexusUrl>
<autoReleaseAfterClose>true</autoReleaseAfterClose>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
<version>3.3.0</version>
<executions>
<execution>
<id>attach-sources</id>
<goals>
<goal>jar-no-fork</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<id>attach-javadocs</id>
<goals>
<goal>jar</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-gpg-plugin</artifactId>
<version>3.1.0</version>
<executions>
<execution>
<id>sign-artifacts</id>
<phase>verify</phase>
<goals>
<goal>sign</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
<distributionManagement>
<repository>
<id>ossrh</id>
<url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
</repository>
</distributionManagement>
</profile>
</profiles>
</project>
@@ -26,7 +26,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ProtocolManager {
@@ -16,7 +16,6 @@ import java.lang.annotation.*;
/**
* @author godotg
* @version 3.0
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@@ -16,7 +16,6 @@ import java.lang.annotation.*;
/**
* @author meiw
* @version 3.0
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@@ -16,7 +16,6 @@ import java.lang.annotation.*;
/**
* @author meiw
* @version 3.0
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@@ -32,7 +32,6 @@ import java.util.Set;
* “可变长字节码算法”的压缩数据的算法,压缩数据和减少磁盘IO。google的ProtocolBuf和Facebook的thrift底层的通信协议都是由这个算法实现
*
* @author godotg
* @version 3.0
*/
public abstract class ByteBufUtils {
@@ -21,7 +21,6 @@ import java.nio.ByteBuffer;
* 自定义私有协议格式,可以针对性的对存在性能瓶颈的数据结构做特定优化
*
* @author godotg
* @version 3.0
*/
public abstract class CustomByteBuf {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListBoolean implements List<Boolean> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListByte implements List<Byte> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListDouble implements List<Double> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListFloat implements List<Float> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListInt implements List<Integer> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListLong implements List<Long> {
@@ -16,7 +16,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class ArrayListShort implements List<Short> {
@@ -21,7 +21,6 @@ import java.util.List;
/**
* @author godotg
* @version 3.0
*/
public abstract class ArrayUtils {
@@ -22,7 +22,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public abstract class CollectionUtils {
@@ -21,7 +21,6 @@ import java.util.*;
/**
* @author godotg
* @version 3.0
*/
public class HashMapIntInt implements Map<Integer, Integer> {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.collection.HashMapIntInt.*;
/**
* @author godotg
* @version 3.0
*/
public class HashMapIntLong implements Map<Integer, Long> {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.collection.HashMapIntInt.*;
/**
* @author godotg
* @version 3.0
*/
public class HashMapIntShort implements Map<Integer, Short> {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.collection.HashMapIntInt.*;
/**
* @author godotg
* @version 3.0
*/
public class HashMapLongInt implements Map<Long, Integer> {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.collection.HashMapIntInt.*;
/**
* @author godotg
* @version 3.0
*/
public class HashMapLongLong implements Map<Long, Long> {
@@ -20,7 +20,6 @@ import java.util.Objects;
/**
* @author godotg
* @version 3.0
*/
public class HashSetByte extends AbstractSet<Byte> {
@@ -20,7 +20,6 @@ import java.util.Objects;
/**
* @author godotg
* @version 3.0
*/
public class HashSetInt extends AbstractSet<Integer> {
@@ -20,7 +20,6 @@ import java.util.Objects;
/**
* @author godotg
* @version 3.0
*/
public class HashSetLong extends AbstractSet<Long> {
@@ -20,7 +20,6 @@ import java.util.Objects;
/**
* @author godotg
* @version 3.0
*/
public class HashSetShort extends AbstractSet<Short> {
@@ -17,7 +17,6 @@ import java.util.concurrent.locks.ReentrantLock;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentArrayList<E> implements List<E> {
@@ -23,7 +23,6 @@ import java.util.function.Consumer;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentHashMapLongObject<V> implements Map<Long, V> {
@@ -19,7 +19,6 @@ import java.util.concurrent.ConcurrentHashMap;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentHashSet<E> extends AbstractSet<E> {
@@ -21,7 +21,6 @@ import java.util.concurrent.locks.ReentrantLock;
/**
* @author godotg
* @version 3.0
*/
public class CopyOnWriteHashMapLongObject<V> implements Map<Long, V> {
@@ -20,7 +20,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentFileChannelHeapMap<V> implements LpMap<V>, Closeable {
@@ -19,7 +19,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentFileChannelMap<V> implements LpMap<V>, Closeable {
@@ -19,7 +19,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class ConcurrentHeapMap<V> implements LpMap<V> {
@@ -19,7 +19,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class FileChannelHeapMap<V> implements LpMap<V>, Closeable {
@@ -34,7 +34,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class FileChannelMap<V> implements LpMap<V>, Closeable {
@@ -31,7 +31,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class FileHeapMap<V> implements LpMap<V> {
@@ -18,7 +18,6 @@ import java.util.function.BiConsumer;
/**
* @author godotg
* @version 3.0
*/
public class HeapMap<V> implements LpMap<V> {
@@ -21,7 +21,6 @@ import java.util.function.BiConsumer;
* 其中long必须大于等于0,value可以为null
*
* @author godotg
* @version 3.0
*/
public interface LpMap<V> {
@@ -18,7 +18,6 @@ import com.zfoo.protocol.util.StringUtils;
* 多叉树
*
* @author godotg
* @version 3.0
*/
public class GeneralTree<T> {
@@ -21,7 +21,6 @@ import java.util.List;
/**
* @author godotg
* @version 3.0
*/
public class TreeNode<T> {
@@ -16,7 +16,6 @@ import com.zfoo.protocol.util.StringUtils;
/**
* @author godotg
* @version 3.0
*/
public class AssertException extends RuntimeException {
@@ -16,7 +16,6 @@ import com.zfoo.protocol.util.StringUtils;
/**
* @author godotg
* @version 3.0
*/
public class RunException extends RuntimeException {
@@ -16,7 +16,6 @@ import com.zfoo.protocol.util.StringUtils;
/**
* @author godotg
* @version 3.0
*/
public class UnknownException extends RuntimeException {
@@ -24,7 +24,6 @@ import java.util.Set;
* CN: 创建协议文件的操作类
*
* @author godotg
* @version 3.0
*/
public class GenerateOperation {
@@ -41,7 +41,6 @@ import static com.zfoo.protocol.util.StringUtils.TAB_ASCII;
/**
* @author godotg
* @version 3.0
*/
public abstract class GenerateProtocolFile {
@@ -32,7 +32,6 @@ import java.util.Map;
* CN: 生成协议的时候,协议的文档注释和字段注释会使用这个类
*
* @author godotg
* @version 3.0
*/
public abstract class GenerateProtocolNote {
@@ -28,7 +28,6 @@ import java.util.*;
* CN: 生成协议的时候,协议的最终生成路径会使用这个类
*
* @author godotg
* @version 3.0
*/
public abstract class GenerateProtocolPath {
@@ -21,7 +21,6 @@ import java.util.Objects;
* @param <K> 键类型
* @param <V> 值类型
* @author godotg
* @version 3.0
*/
public class Pair<K, V> {
@@ -17,7 +17,6 @@ package com.zfoo.protocol.model;
* T cardinal number that is the sum of three and one.
*
* @author godotg
* @version 3.0
*/
public class Quaternion<A, B, C, D> {
@@ -17,7 +17,6 @@ package com.zfoo.protocol.model;
* A triple consisting of three elements. It refers to the elements as 'left', 'middle' and 'right'.
*
* @author godotg
* @version 3.0
*/
public class Triple<L, M, R> {
@@ -35,7 +35,6 @@ import java.util.*;
* 对应于ProtocolRegistration
*
* @author godotg
* @version 3.0
*/
public abstract class EnhanceUtils {
@@ -19,7 +19,6 @@ import java.lang.reflect.Constructor;
/**
* @author godotg
* @version 3.0
*/
public interface IProtocolRegistration {
@@ -47,7 +47,6 @@ import static com.zfoo.protocol.ProtocolManager.*;
/**
* @author godotg
* @version 3.0
*/
public class ProtocolAnalysis {
@@ -19,7 +19,6 @@ import com.zfoo.protocol.util.StringUtils;
* 模块id和模块名的封装
*
* @author godotg
* @version 3.0
*/
public class ProtocolModule {
@@ -25,7 +25,6 @@ import java.lang.reflect.Field;
/**
* @author godotg
* @version 3.0
*/
public class ProtocolRegistration implements IProtocolRegistration {
@@ -18,7 +18,6 @@ import com.zfoo.protocol.serializer.reflect.ISerializer;
/**
* @author godotg
* @version 3.0
*/
public class ArrayField implements IFieldRegistration {
@@ -20,7 +20,6 @@ import com.zfoo.protocol.serializer.reflect.ISerializer;
* 描述boolean,byte,short,int,long,float,double,char,String等基本序列化器
*
* @author godotg
* @version 3.0
*/
public class BaseField implements IFieldRegistration {
@@ -19,7 +19,6 @@ import com.zfoo.protocol.serializer.reflect.ISerializer;
* 标记性接口,所有协议里描述变量都要实现这个接口
*
* @author godotg
* @version 3.0
*/
public interface IFieldRegistration {
@@ -20,7 +20,6 @@ import java.lang.reflect.Type;
/**
* @author godotg
* @version 3.0
*/
public class ListField implements IFieldRegistration {
@@ -20,7 +20,6 @@ import java.lang.reflect.Type;
/**
* @author godotg
* @version 3.0
*/
public class MapField implements IFieldRegistration {
@@ -18,7 +18,6 @@ import com.zfoo.protocol.serializer.reflect.ObjectProtocolSerializer;
/**
* @author godotg
* @version 3.0
*/
public class ObjectProtocolField implements IFieldRegistration {
@@ -20,7 +20,6 @@ import java.lang.reflect.Type;
/**
* @author godotg
* @version 3.0
*/
public class SetField implements IFieldRegistration {
@@ -14,7 +14,6 @@ package com.zfoo.protocol.serializer;
/**
* @author godotg
* @version 3.0
*/
public enum CodeLanguage {
@@ -27,7 +27,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CutDownArraySerializer implements ICutDownSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CutDownListSerializer implements ICutDownSerializer {
@@ -31,7 +31,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CutDownMapSerializer implements ICutDownSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CutDownSetSerializer implements ICutDownSerializer {
@@ -20,7 +20,6 @@ import java.lang.reflect.Field;
* 减少生成的字节码和代码的体积,即使不调用这个方法,程序也依然能够正常运行
*
* @author godotg
* @version 3.0
*/
public interface ICutDownSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppArraySerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppBooleanSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppByteSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppCharSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppDoubleSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppFloatSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppIntSerializer implements ICppSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppListSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppLongSerializer implements ICppSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppMapSerializer implements ICppSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppObjectProtocolSerializer implements ICppSerializer {
@@ -28,7 +28,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppSetSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppShortSerializer implements ICppSerializer {
@@ -24,7 +24,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CppStringSerializer implements ICppSerializer {
@@ -45,7 +45,6 @@ import static com.zfoo.protocol.util.StringUtils.TAB;
/**
* @author godotg
* @version 3.0
*/
public abstract class GenerateCppUtils {
@@ -20,7 +20,6 @@ import java.lang.reflect.Field;
/**
* @author godotg
* @version 3.0
*/
public interface ICppSerializer {
@@ -26,7 +26,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsArraySerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsBooleanSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsByteSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsCharSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsDoubleSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsFloatSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsIntSerializer implements ICsSerializer {
@@ -26,7 +26,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsListSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsLongSerializer implements ICsSerializer {
@@ -26,7 +26,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsMapSerializer implements ICsSerializer {
@@ -26,7 +26,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsObjectProtocolSerializer implements ICsSerializer {
@@ -26,7 +26,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsSetSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsShortSerializer implements ICsSerializer {
@@ -23,7 +23,6 @@ import static com.zfoo.protocol.util.FileUtils.LS;
/**
* @author godotg
* @version 3.0
*/
public class CsStringSerializer implements ICsSerializer {
@@ -40,7 +40,6 @@ import static com.zfoo.protocol.util.StringUtils.TAB;
/**
* @author godotg
* @version 3.0
*/
public abstract class GenerateCsUtils {
@@ -19,7 +19,6 @@ import java.lang.reflect.Field;
/**
* @author godotg
* @version 3.0
*/
public interface ICsSerializer {
@@ -25,7 +25,6 @@ import java.lang.reflect.Field;
/**
* @author godotg
* @version 3.0
*/
public class EnhanceArraySerializer implements IEnhanceSerializer {
Loaded 100 of 668 files, more files were not shown because too many files have changed in this diff. Show more