Ver código fonte

refactor:完善注释

王智勇 5 anos atrás
pai
commit
c6ade7e8fe
23 arquivos alterados com 22 adições e 88 exclusões
  1. 1 1
      dim-client/src/main/java/com/dzdy/dim/NettyClient.java
  2. 1 0
      dim-client/src/main/java/com/dzdy/dim/handler/HeartBeatResponseHandler.java
  3. 1 0
      dim-client/src/main/java/com/dzdy/dim/handler/HeartBeatTimerHandler.java
  4. 2 0
      dim-client/src/main/java/com/dzdy/dim/handler/LoginResponseHandler.java
  5. 1 0
      dim-client/src/main/java/com/dzdy/dim/handler/LogoutResponseHandler.java
  6. 2 0
      dim-client/src/main/java/com/dzdy/dim/handler/SockDataRequestHandler.java
  7. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/command/JWTUser.java
  8. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/request/ConfirmRequestPacket.java
  9. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/request/HeartBeatRequestPacket.java
  10. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/request/LoginRequestPacket.java
  11. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/request/LogoutRequestPacket.java
  12. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/response/HeartBeatResponsePacket.java
  13. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/response/LoginResponsePacket.java
  14. 1 0
      dim-common/src/main/java/com/dzdy/dim/protocol/response/LogoutResponsePacket.java
  15. 1 0
      dim-common/src/main/java/com/dzdy/dim/serialize/impl/JSONSerializer.java
  16. 1 0
      dim-service/src/main/java/com/dzdy/dim/handler/AuthHandler.java
  17. 1 0
      dim-service/src/main/java/com/dzdy/dim/handler/ConfirmRequestHandler.java
  18. 1 0
      dim-service/src/main/java/com/dzdy/dim/handler/HeartBeatRequestHandler.java
  19. 1 0
      dim-service/src/main/java/com/dzdy/dim/handler/LoginRequestHandler.java
  20. 1 0
      dim-service/src/main/java/com/dzdy/dim/handler/LogoutRequestHandler.java
  21. 0 43
      dim-service/src/main/java/com/dzdy/dim/serialize/Serializer.java
  22. 0 16
      dim-service/src/main/java/com/dzdy/dim/serialize/SerializerAlgorithm.java
  23. 0 28
      dim-service/src/main/java/com/dzdy/dim/serialize/impl/JSONSerializer.java

+ 1 - 1
dim-client/src/main/java/com/dzdy/dim/NettyClient.java

@@ -67,7 +67,7 @@ public class NettyClient {
 
     /**
      * 登录
-     *
+     * todo 登录放入token
      * @param channel
      */
     private static void login(Channel channel) {

+ 1 - 0
dim-client/src/main/java/com/dzdy/dim/handler/HeartBeatResponseHandler.java

@@ -7,6 +7,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import java.util.Date;
 
 /**
+ * 心跳返回处理器
  * @author : wangzhiyong
  * @date : 2019/6/4 15:03
  * description :

+ 1 - 0
dim-client/src/main/java/com/dzdy/dim/handler/HeartBeatTimerHandler.java

@@ -9,6 +9,7 @@ import java.util.Date;
 import java.util.concurrent.TimeUnit;
 
 /**
+ * 心跳请求定时器
  * @author : wangzhiyong
  * @date : 2019/5/28 10:54
  * description :

+ 2 - 0
dim-client/src/main/java/com/dzdy/dim/handler/LoginResponseHandler.java

@@ -10,6 +10,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import static com.dzdy.dim.NettyClient.MAX_RETRY;
 
 /**
+ * 登录返回处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 17:40
  * description :
@@ -28,6 +29,7 @@ public class LoginResponseHandler extends SimpleChannelInboundHandler<LoginRespo
     @Override
     public void channelInactive(ChannelHandlerContext ctx) {
         System.out.println("客户端连接关闭");
+        // todo 服务端断开重连
         NettyClient.connect(MAX_RETRY);
     }
 }

+ 1 - 0
dim-client/src/main/java/com/dzdy/dim/handler/LogoutResponseHandler.java

@@ -6,6 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
+ * 登出下线处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 17:57
  * description :

+ 2 - 0
dim-client/src/main/java/com/dzdy/dim/handler/SockDataRequestHandler.java

@@ -7,6 +7,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
+ * 通用消息接收处理器
  * @author : wangzhiyong
  * @date : 2019/5/29 16:39
  * description :
@@ -14,6 +15,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
 public class SockDataRequestHandler extends SimpleChannelInboundHandler<SockData> {
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, SockData sockData) {
+        // todo 判断消息类别 然后对应业务逻辑处理
         System.out.println("已接收到 消息:" + JSONObject.toJSON(sockData));
         ConfirmRequestPacket packet = new ConfirmRequestPacket();
         packet.setPacketId(sockData.getId());

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/command/JWTUser.java

@@ -7,6 +7,7 @@ import lombok.NoArgsConstructor;
 import java.util.Set;
 
 /**
+ * jwt 用户类 outh2 定义
  * @author : wangzhiyong
  * @date : 2019/5/28 16:50
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/request/ConfirmRequestPacket.java

@@ -7,6 +7,7 @@ import lombok.EqualsAndHashCode;
 import static com.dzdy.dim.protocol.command.Command.CONFIRM;
 
 /**
+ * 消息确认包
  * @author : wangzhiyong
  * @date : 2019/5/28 10:48
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/request/HeartBeatRequestPacket.java

@@ -5,6 +5,7 @@ import com.dzdy.dim.protocol.Packet;
 import static com.dzdy.dim.protocol.command.Command.HEARTBEAT_REQUEST;
 
 /**
+ * 心跳请求包
  * @author : wangzhiyong
  * @date : 2019/5/28 09:20
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/request/LoginRequestPacket.java

@@ -7,6 +7,7 @@ import lombok.EqualsAndHashCode;
 import static com.dzdy.dim.protocol.command.Command.LOGIN_REQUEST;
 
 /**
+ * 登录请求包
  * @author : wangzhiyong
  * @date : 2019/5/28 10:45
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/request/LogoutRequestPacket.java

@@ -5,6 +5,7 @@ import com.dzdy.dim.protocol.Packet;
 import static com.dzdy.dim.protocol.command.Command.LOGOUT_REQUEST;
 
 /**
+ * 登出/下线 请求包
  * @author : wangzhiyong
  * @date : 2019/5/28 17:53
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/response/HeartBeatResponsePacket.java

@@ -5,6 +5,7 @@ import com.dzdy.dim.protocol.Packet;
 import static com.dzdy.dim.protocol.command.Command.HEARTBEAT_RESPONSE;
 
 /**
+ * 心跳返回包
  * @author : wangzhiyong
  * @date : 2019/5/28 10:17
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/response/LoginResponsePacket.java

@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode;
 import static com.dzdy.dim.protocol.command.Command.LOGIN_RESPONSE;
 
 /**
+ * 登录返回包
  * @author : wangzhiyong
  * @date : 2019/5/28 10:49
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/protocol/response/LogoutResponsePacket.java

@@ -7,6 +7,7 @@ import lombok.EqualsAndHashCode;
 import static com.dzdy.dim.protocol.command.Command.LOGOUT_RESPONSE;
 
 /**
+ * 登出返回包
  * @author : wangzhiyong
  * @date : 2019/5/28 17:56
  * description :

+ 1 - 0
dim-common/src/main/java/com/dzdy/dim/serialize/impl/JSONSerializer.java

@@ -6,6 +6,7 @@ import com.dzdy.dim.serialize.Serializer;
 import com.dzdy.dim.serialize.SerializerAlgorithm;
 
 /**
+ * json 序列化
  * @author : wangzhiyong
  * @date : 2019/5/25 15:30
  * description :

+ 1 - 0
dim-service/src/main/java/com/dzdy/dim/handler/AuthHandler.java

@@ -6,6 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 
 /**
+ * 授权检查处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 14:33
  * description :

+ 1 - 0
dim-service/src/main/java/com/dzdy/dim/handler/ConfirmRequestHandler.java

@@ -6,6 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
+ * 消息确认请求处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 13:49
  * description :

+ 1 - 0
dim-service/src/main/java/com/dzdy/dim/handler/HeartBeatRequestHandler.java

@@ -9,6 +9,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import java.util.Date;
 
 /**
+ * 心跳检查请求处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 11:21
  * description :

+ 1 - 0
dim-service/src/main/java/com/dzdy/dim/handler/LoginRequestHandler.java

@@ -13,6 +13,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
+ * 登录请求处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 14:38
  * description :

+ 1 - 0
dim-service/src/main/java/com/dzdy/dim/handler/LogoutRequestHandler.java

@@ -8,6 +8,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 
 /**
+ * 登出请求处理器
  * @author : wangzhiyong
  * @date : 2019/5/28 17:53
  * description :

+ 0 - 43
dim-service/src/main/java/com/dzdy/dim/serialize/Serializer.java

@@ -1,43 +0,0 @@
-package com.dzdy.dim.serialize;
-
-import com.dzdy.dim.serialize.impl.JSONSerializer;
-
-/**
- * 序列化数据
- *
- * @author : wangzhiyong
- * @date : 2019/5/25 15:22
- * description :
- */
-public interface Serializer {
-
-    /**
-     * 默认 json序列化
-     */
-    Serializer DEFAULT = new JSONSerializer();
-
-    /**
-     * 序列化算法
-     *
-     * @return
-     */
-    byte getSerializerAlgorithm();
-
-    /**
-     * java对象 序列化为二进制
-     *
-     * @param object
-     * @return
-     */
-    byte[] serialize(Object object);
-
-    /**
-     * 二进制转换成 java对象
-     *
-     * @param bytes
-     * @param clazz
-     * @param <T>
-     * @return
-     */
-    <T> T deserialize(byte[] bytes, Class<T> clazz);
-}

+ 0 - 16
dim-service/src/main/java/com/dzdy/dim/serialize/SerializerAlgorithm.java

@@ -1,16 +0,0 @@
-package com.dzdy.dim.serialize;
-
-/**
- * 序列化算法
- *
- * @author : wangzhiyong
- * @date : 2019/5/25 15:31
- * description :
- */
-public interface SerializerAlgorithm {
-
-    /**
-     * json序列化标识
-     */
-    byte JSON = 1;
-}

+ 0 - 28
dim-service/src/main/java/com/dzdy/dim/serialize/impl/JSONSerializer.java

@@ -1,28 +0,0 @@
-package com.dzdy.dim.serialize.impl;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.dzdy.dim.serialize.Serializer;
-import com.dzdy.dim.serialize.SerializerAlgorithm;
-
-/**
- * @author : wangzhiyong
- * @date : 2019/5/25 15:30
- * description :
- */
-public class JSONSerializer implements Serializer {
-    @Override
-    public byte getSerializerAlgorithm() {
-        return SerializerAlgorithm.JSON;
-    }
-
-    @Override
-    public byte[] serialize(Object object) {
-        return JSONObject.toJSONBytes(object);
-    }
-
-    @Override
-    public <T> T deserialize(byte[] bytes, Class<T> clazz) {
-        return JSON.parseObject(bytes, clazz);
-    }
-}