rename package

README.md

@@ -8,12 +8,11 @@
 * TCP协议服务端开发
 
 ## 代码仓库
- * Gitee仓库地址：[https://gitee.com/yezhihao/netmc/tree/master](https://gitee.com/yezhihao/netmc/tree/master)
+ * Gitee仓库地址：[http://115.29.108.160:3000/TripartiteOpenSource/netmc](http://115.29.108.160:3000/TripartiteOpenSource/netmc)
- * Github仓库地址：[https://github.com/yezhihao/netmc/tree/master](https://github.com/yezhihao/netmc/tree/master)
+ * Github仓库地址：[http://115.29.108.160:3000/TripartiteOpenSource/netmc](http://115.29.108.160:3000/TripartiteOpenSource/netmc)
 
 ## 下载方式
- * Gitee下载命令：`git clone https://gitee.com/yezhihao/netmc -b master`
+ * Git下载命令：`git clone http://115.29.108.160:3000/TripartiteOpenSource/netmc.git -b master`
- * Github下载命令：`git clone https://github.com/yezhihao/netmc -b master`
 
 ## 项目结构
 ```sh
@@ -72,10 +71,4 @@ public class JT808Endpoint {
 
 详细的例子请参考Test目录
 
-使用该组件的项目：[https://gitee.com/yezhihao/jt808-server/tree/master](https://gitee.com/yezhihao/jt808-server/tree/master)
+当前项目是Fork [剑器近](https://gitee.com/yezhihao) 的 [netmc](https://gitee.com/yezhihao/netmc?_from=gitee_search)
-
-项目会不定期进行更新，建议star和watch一份，您的支持是我最大的动力。
-
-如有任何疑问或者BUG，请联系我，非常感谢。
-
-技术交流QQ群：[906230542]

pom.xml

@@ -177,11 +177,13 @@
             <distributionManagement>
                 <repository>
                     <id>nexus-release</id>
-                    <url>https://oss.sonatype.org/service/local/staging/deploy/maven2</url>
+                    <name>Nexus Release Repository</name>
+                    <url>http://113.250.52.44:8081/repository/maven-releases/</url>
                 </repository>
                 <snapshotRepository>
-                    <id>nexus-snapshot</id>
+                    <id>nexus-snapshots</id>
-                    <url>https://oss.sonatype.org/content/repositories/snapshots</url>
+                    <name>Nexus Release Repository</name>
+                    <url>http://113.250.52.44:8081/repository/maven-snapshots/</url>
                 </snapshotRepository>
             </distributionManagement>
         </profile>
@@ -189,13 +191,16 @@
 
     <repositories>
         <repository>
-            <id>central</id>
+            <id>deployer</id>
-            <name>Maven Central</name>
+            <name>deployer</name>
-            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
+            <url>http://113.250.52.44:8081/repository/maven-public/</url>
             <layout>default</layout>
             <releases>
                 <enabled>true</enabled>
             </releases>
+            <snapshots>
+                <enabled>true</enabled>
+            </snapshots>
         </repository>
     </repositories>
 </project>

src/main/java/com/dust/tripartite/netmc/NettyConfig.java

@@ -1,13 +1,13 @@
-package io.github.yezhihao.netmc;
+package com.dust.tripartite.netmc;
 
-import io.github.yezhihao.netmc.codec.Delimiter;
+import com.dust.tripartite.netmc.codec.LengthField;
-import io.github.yezhihao.netmc.codec.LengthField;
+import com.dust.tripartite.netmc.codec.MessageEncoder;
-import io.github.yezhihao.netmc.codec.MessageDecoder;
+import com.dust.tripartite.netmc.core.HandlerInterceptor;
-import io.github.yezhihao.netmc.codec.MessageEncoder;
+import com.dust.tripartite.netmc.core.HandlerMapping;
-import io.github.yezhihao.netmc.core.HandlerInterceptor;
+import com.dust.tripartite.netmc.session.SessionListener;
-import io.github.yezhihao.netmc.core.HandlerMapping;
+import com.dust.tripartite.netmc.codec.Delimiter;
-import io.github.yezhihao.netmc.session.SessionListener;
+import com.dust.tripartite.netmc.codec.MessageDecoder;
-import io.github.yezhihao.netmc.session.SessionManager;
+import com.dust.tripartite.netmc.session.SessionManager;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 
 /**

src/main/java/com/dust/tripartite/netmc/TCPServer.java

@@ -1,9 +1,9 @@
-package io.github.yezhihao.netmc;
+package com.dust.tripartite.netmc;
 
-import io.github.yezhihao.netmc.codec.DelimiterBasedFrameDecoder;
+import com.dust.tripartite.netmc.codec.DelimiterBasedFrameDecoder;
-import io.github.yezhihao.netmc.codec.LengthFieldAndDelimiterFrameDecoder;
+import com.dust.tripartite.netmc.codec.LengthFieldAndDelimiterFrameDecoder;
-import io.github.yezhihao.netmc.codec.MessageDecoderWrapper;
+import com.dust.tripartite.netmc.codec.MessageDecoderWrapper;
-import io.github.yezhihao.netmc.codec.MessageEncoderWrapper;
+import com.dust.tripartite.netmc.codec.MessageEncoderWrapper;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelInitializer;
@@ -20,6 +20,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
  * @author yezhihao
@@ -28,7 +29,7 @@ import java.util.concurrent.TimeUnit;
 public class TCPServer {
 
     private static final Logger log = LoggerFactory.getLogger(TCPServer.class);
-    private volatile boolean isRunning = false;
+    private final AtomicBoolean isRunning = new AtomicBoolean(false);
 
     private EventLoopGroup bossGroup = null;
     private EventLoopGroup workerGroup = null;
@@ -83,29 +84,27 @@ public class TCPServer {
         return new LengthFieldAndDelimiterFrameDecoder(config.maxFrameLength, config.lengthField, config.delimiter);
     }
 
-    public synchronized void start() {
+    public void start() {
-        if (this.isRunning) {
+        if (!isRunning.compareAndSet(false, true)) {
             log.warn("==={}已经启动, port={}===", name, config.port);
             return;
         }
-        this.isRunning = true;
+        new Thread(this::startInternal).start();
-        new Thread(() -> startInternal()).start();
     }
 
-    public synchronized void stop() {
+    public void stop() {
-        if (!this.isRunning) {
+        if (!isRunning.compareAndSet(true, false)) {
             log.warn("==={}已经停止, port={}===", name, config.port);
+            return;
         }
-        this.isRunning = false;
+        Future<?> future = this.bossGroup.shutdownGracefully();
-
+        if (!future.isSuccess()) {
-        Future future = this.bossGroup.shutdownGracefully();
-        if (!future.isSuccess())
             log.warn("bossGroup 无法正常停止", future.cause());
-
+        }
         future = this.workerGroup.shutdownGracefully();
-        if (!future.isSuccess())
+        if (!future.isSuccess()) {
             log.warn("workerGroup 无法正常停止", future.cause());
-
+        }
         log.warn("==={}已经停止, port={}===", name, config.port);
     }
 }

src/main/java/com/dust/tripartite/netmc/TCPServerHandler.java

@@ -1,12 +1,12 @@
-package io.github.yezhihao.netmc;
+package com.dust.tripartite.netmc;
 
-import io.github.yezhihao.netmc.core.HandlerInterceptor;
+import com.dust.tripartite.netmc.core.HandlerInterceptor;
-import io.github.yezhihao.netmc.core.HandlerMapping;
+import com.dust.tripartite.netmc.core.HandlerMapping;
-import io.github.yezhihao.netmc.core.handler.Handler;
+import com.dust.tripartite.netmc.core.handler.Handler;
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
-import io.github.yezhihao.netmc.session.SessionListener;
+import com.dust.tripartite.netmc.session.SessionListener;
-import io.github.yezhihao.netmc.session.SessionManager;
+import com.dust.tripartite.netmc.session.SessionManager;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;

src/main/java/com/dust/tripartite/netmc/codec/Delimiter.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
 public class Delimiter {
     protected byte[] value;

src/main/java/com/dust/tripartite/netmc/codec/DelimiterBasedFrameDecoder.java

@@ -1,11 +1,11 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
 import io.netty.handler.codec.TooLongFrameException;
 import io.netty.util.internal.ObjectUtil;
-import io.github.yezhihao.netmc.util.ByteBufUtils;
+import com.dust.tripartite.netmc.util.ByteBufUtils;
 
 import java.util.List;
 

src/main/java/com/dust/tripartite/netmc/codec/LengthField.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
 import static io.netty.util.internal.ObjectUtil.checkPositive;
 import static io.netty.util.internal.ObjectUtil.checkPositiveOrZero;

src/main/java/com/dust/tripartite/netmc/codec/LengthFieldAndDelimiterFrameDecoder.java

@@ -1,12 +1,12 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
+import com.dust.tripartite.netmc.util.ByteBufUtils;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.CorruptedFrameException;
 import io.netty.handler.codec.DecoderException;
 import io.netty.handler.codec.TooLongFrameException;
 import io.netty.util.internal.ObjectUtil;
-import io.github.yezhihao.netmc.util.ByteBufUtils;
 
 import java.util.List;
 

src/main/java/com/dust/tripartite/netmc/codec/MessageDecoder.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 
 /**

src/main/java/com/dust/tripartite/netmc/codec/MessageDecoderWrapper.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
 import io.netty.channel.ChannelHandler;

src/main/java/com/dust/tripartite/netmc/codec/MessageEncoder.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 
 /**

src/main/java/com/dust/tripartite/netmc/codec/MessageEncoderWrapper.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelHandler;

src/main/java/com/dust/tripartite/netmc/core/AbstractHandlerMapping.java

@@ -1,10 +1,10 @@
-package io.github.yezhihao.netmc.core;
+package com.dust.tripartite.netmc.core;
 
-import io.github.yezhihao.netmc.core.annotation.AsyncBatch;
+import com.dust.tripartite.netmc.core.annotation.AsyncBatch;
-import io.github.yezhihao.netmc.core.annotation.Mapping;
+import com.dust.tripartite.netmc.core.annotation.Mapping;
-import io.github.yezhihao.netmc.core.handler.AsyncBatchHandler;
+import com.dust.tripartite.netmc.core.handler.AsyncBatchHandler;
-import io.github.yezhihao.netmc.core.handler.Handler;
+import com.dust.tripartite.netmc.core.handler.Handler;
-import io.github.yezhihao.netmc.core.handler.SimpleHandler;
+import com.dust.tripartite.netmc.core.handler.SimpleHandler;
 
 import java.lang.reflect.Method;
 import java.util.HashMap;

src/main/java/com/dust/tripartite/netmc/core/DefaultHandlerMapping.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.core;
+package com.dust.tripartite.netmc.core;
 
-import io.github.yezhihao.netmc.core.annotation.Endpoint;
+import com.dust.tripartite.netmc.util.ClassUtils;
-import io.github.yezhihao.netmc.util.ClassUtils;
+import com.dust.tripartite.netmc.core.annotation.Endpoint;
 
 import java.util.List;
 

src/main/java/com/dust/tripartite/netmc/core/HandlerInterceptor.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.core;
+package com.dust.tripartite.netmc.core;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 
 /**
  * 消息拦截器

src/main/java/com/dust/tripartite/netmc/core/HandlerMapping.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.core;
+package com.dust.tripartite.netmc.core;
 
-import io.github.yezhihao.netmc.core.handler.Handler;
+import com.dust.tripartite.netmc.core.handler.Handler;
 
 /**
  * 消息映射接口

src/main/java/com/dust/tripartite/netmc/core/SpringHandlerMapping.java

@@ -1,6 +1,6 @@
-package io.github.yezhihao.netmc.core;
+package com.dust.tripartite.netmc.core;
 
-import io.github.yezhihao.netmc.core.annotation.Endpoint;
+import com.dust.tripartite.netmc.core.annotation.Endpoint;
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;

src/main/java/com/dust/tripartite/netmc/core/annotation/AsyncBatch.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.core.annotation;
+package com.dust.tripartite.netmc.core.annotation;
 
 import java.lang.annotation.*;
 

src/main/java/com/dust/tripartite/netmc/core/annotation/Endpoint.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.core.annotation;
+package com.dust.tripartite.netmc.core.annotation;
 
 import java.lang.annotation.*;
 

src/main/java/com/dust/tripartite/netmc/core/annotation/Mapping.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.core.annotation;
+package com.dust.tripartite.netmc.core.annotation;
 
 import java.lang.annotation.*;
 

src/main/java/com/dust/tripartite/netmc/core/handler/AsyncBatchHandler.java

@@ -1,9 +1,9 @@
-package io.github.yezhihao.netmc.core.handler;
+package com.dust.tripartite.netmc.core.handler;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
-import io.github.yezhihao.netmc.util.BasicThreadFactory;
+import com.dust.tripartite.netmc.util.BasicThreadFactory;
-import io.github.yezhihao.netmc.util.VirtualList;
+import com.dust.tripartite.netmc.util.VirtualList;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

src/main/java/com/dust/tripartite/netmc/core/handler/Handler.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.core.handler;
+package com.dust.tripartite.netmc.core.handler;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import sun.reflect.generics.reflectiveObjects.ParameterizedTypeImpl;
 
 import java.lang.reflect.Method;

src/main/java/com/dust/tripartite/netmc/core/handler/SimpleHandler.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.core.handler;
+package com.dust.tripartite.netmc.core.handler;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 
 import java.lang.reflect.Method;
 

src/main/java/com/dust/tripartite/netmc/core/model/Message.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.core.model;
+package com.dust.tripartite.netmc.core.model;
 
 import java.io.Serializable;
 

src/main/java/com/dust/tripartite/netmc/core/model/Response.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.core.model;
+package com.dust.tripartite.netmc.core.model;
 
 /**
  * @author yezhihao

src/main/java/com/dust/tripartite/netmc/session/Session.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.session;
+package com.dust.tripartite.netmc.session;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.core.model.Response;
+import com.dust.tripartite.netmc.core.model.Response;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;

src/main/java/com/dust/tripartite/netmc/session/SessionListener.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.session;
+package com.dust.tripartite.netmc.session;
 
 /**
  * @author yezhihao

src/main/java/com/dust/tripartite/netmc/session/SessionManager.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.session;
+package com.dust.tripartite.netmc.session;
 
 import com.github.benmanes.caffeine.cache.Cache;
 import com.github.benmanes.caffeine.cache.Caffeine;

src/main/java/com/dust/tripartite/netmc/util/AdapterCollection.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.util.AbstractCollection;
 import java.util.Collection;

src/main/java/com/dust/tripartite/netmc/util/AdapterList.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.util.AbstractList;
 import java.util.List;

src/main/java/com/dust/tripartite/netmc/util/AdapterMap.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.util.AbstractMap;
 import java.util.Map;

src/main/java/com/dust/tripartite/netmc/util/AdapterSet.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.util.AbstractSet;
 import java.util.Iterator;

src/main/java/com/dust/tripartite/netmc/util/BasicThreadFactory.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;

src/main/java/com/dust/tripartite/netmc/util/ByteBufUtils.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import io.netty.buffer.ByteBuf;
 

src/main/java/com/dust/tripartite/netmc/util/ClassUtils.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

src/main/java/com/dust/tripartite/netmc/util/VirtualList.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.util;
+package com.dust.tripartite.netmc.util;
 
 import java.io.Serializable;
 import java.util.*;

src/test/java/com/dust/tripartite/netmc/QuickStart.java

@@ -1,10 +1,10 @@
-package io.github.yezhihao.netmc;
+package com.dust.tripartite.netmc;
 
-import io.github.yezhihao.netmc.core.DefaultHandlerMapping;
+import com.dust.tripartite.netmc.codec.MyMessageDecoder;
-import io.github.yezhihao.netmc.endpoint.MyHandlerInterceptor;
+import com.dust.tripartite.netmc.codec.MyMessageEncoder;
-import io.github.yezhihao.netmc.codec.MyMessageDecoder;
+import com.dust.tripartite.netmc.core.DefaultHandlerMapping;
-import io.github.yezhihao.netmc.codec.MyMessageEncoder;
+import com.dust.tripartite.netmc.endpoint.MyHandlerInterceptor;
-import io.github.yezhihao.netmc.session.SessionManager;
+import com.dust.tripartite.netmc.session.SessionManager;
 
 import java.nio.charset.StandardCharsets;
 

src/test/java/com/dust/tripartite/netmc/Test.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc;
+package com.dust.tripartite.netmc;
 
 import io.netty.buffer.ByteBufUtil;
 

src/test/java/com/dust/tripartite/netmc/codec/MyMessageDecoder.java

@@ -1,8 +1,8 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.model.MyHeader;
+import com.dust.tripartite.netmc.model.MyHeader;
-import io.github.yezhihao.netmc.model.MyMessage;
+import com.dust.tripartite.netmc.model.MyMessage;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 
 import java.nio.charset.StandardCharsets;

src/test/java/com/dust/tripartite/netmc/codec/MyMessageEncoder.java

@@ -1,8 +1,8 @@
-package io.github.yezhihao.netmc.codec;
+package com.dust.tripartite.netmc.codec;
 
-import io.github.yezhihao.netmc.model.MyHeader;
+import com.dust.tripartite.netmc.model.MyHeader;
-import io.github.yezhihao.netmc.model.MyMessage;
+import com.dust.tripartite.netmc.model.MyMessage;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 

src/test/java/com/dust/tripartite/netmc/endpoint/MyEndpoint.java

@@ -0,0 +1,15 @@
+package com.dust.tripartite.netmc.endpoint;
+
+import com.dust.tripartite.netmc.core.annotation.Endpoint;
+import com.dust.tripartite.netmc.core.annotation.Mapping;
+import com.dust.tripartite.netmc.model.MyMessage;
+import com.dust.tripartite.netmc.session.Session;
+
+@Endpoint
+public class MyEndpoint {
+
+    @Mapping(types = 1, desc = "注册")
+    public void register(MyMessage request, Session session) {
+        System.out.println(request);
+    }
+}

src/test/java/com/dust/tripartite/netmc/endpoint/MyHandlerInterceptor.java

@@ -1,9 +1,9 @@
-package io.github.yezhihao.netmc.endpoint;
+package com.dust.tripartite.netmc.endpoint;
 
-import io.github.yezhihao.netmc.core.HandlerInterceptor;
+import com.dust.tripartite.netmc.core.HandlerInterceptor;
-import io.github.yezhihao.netmc.model.MyHeader;
+import com.dust.tripartite.netmc.model.MyHeader;
-import io.github.yezhihao.netmc.model.MyMessage;
+import com.dust.tripartite.netmc.model.MyMessage;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

src/test/java/com/dust/tripartite/netmc/model/MyHeader.java

@@ -1,4 +1,4 @@
-package io.github.yezhihao.netmc.model;
+package com.dust.tripartite.netmc.model;
 
 public class MyHeader {
 

src/test/java/com/dust/tripartite/netmc/model/MyMessage.java

@@ -1,7 +1,7 @@
-package io.github.yezhihao.netmc.model;
+package com.dust.tripartite.netmc.model;
 
-import io.github.yezhihao.netmc.core.model.Message;
+import com.dust.tripartite.netmc.core.model.Message;
-import io.github.yezhihao.netmc.session.Session;
+import com.dust.tripartite.netmc.session.Session;
 
 public class MyMessage implements Message {
 

src/test/java/io/github/yezhihao/netmc/endpoint/MyEndpoint.java

@@ -1,15 +0,0 @@
-package io.github.yezhihao.netmc.endpoint;
-
-import io.github.yezhihao.netmc.core.annotation.Endpoint;
-import io.github.yezhihao.netmc.core.annotation.Mapping;
-import io.github.yezhihao.netmc.model.MyMessage;
-import io.github.yezhihao.netmc.session.Session;
-
-@Endpoint
-public class MyEndpoint {
-
-    @Mapping(types = 1, desc = "注册")
-    public void register(MyMessage request, Session session) {
-        System.out.println(request);
-    }
-}