事前标记

src/main/java/com/cn/esermis/model/BaseUser.java

@@ -0,0 +1,17 @@
+package com.cn.esermis.model;
+
+import lombok.Data;
+
+@Data
+public class BaseUser {
+
+
+    private String userId;
+
+    private String companyId;
+
+    private String factoryId;
+
+
+
+}

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -112,61 +112,10 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                     dataMap.put(ctx.channel().id().toString(), startStr);
                 }
             }
-//            System.out.println("-----------"+adapter.redisQueueService.receiveMessage(Constant.SERVER));
-
-//            ctx.writeAndFlush(Unpooled.copiedBuffer(message, CharsetUtil.UTF_8));
-//            //转成String
-//            String data = (String) msg;
-//            //替换掉 换行 和 空格
-//            data = data.replaceAll("\r|\n", "");
-//            //获取通道ID 并打印
-//            String channelId = ctx.channel().id().toString();
-//            System.out.println("channelId=" + channelId + "data=" + data);
-//
-//
-//            // 这里我将通道id作为code来使用，实际是需要msg里来摘取的客户端数据里的唯一值的
-//
-//            // 如果没有则创建 如果有，更新data值
-//            BootNettyChannel b = BootNettyChannelCache.get("server:" + channelId);
-//            if (b == null) {
-//                //创建通道
-//                BootNettyChannel bnc = new BootNettyChannel();
-//                bnc.setChannel(ctx.channel());
-//                //设置通道编码
-//                bnc.setCode("server:" + channelId);
-//                bnc.setReport_last_data(data);
-//                //保存通道
-//                BootNettyChannelCache.save("server:" + channelId, bnc);
-//            } else {
-//                //更新data值什么意思呢？
-//                b.setReport_last_data(data);
-//            }
-//            //回写给客户端
-//            ctx.writeAndFlush(Unpooled.buffer().writeBytes(("server:" + channelId).getBytes()));
-//            // netty的编码已经指定，因此可以不需要再次确认编码
-//            // ctx.writeAndFlush(Unpooled.buffer().writeBytes(channelId.getBytes(CharsetUtil.UTF_8)));
-//
-//            //直接这样写入也可以
-//            //ctx.write("我是服务端，我收到你的消息了！");
-//            //ctx.flush();
-//            in.release();
         } catch (Exception e) {
             System.out.println("channelRead--" + e.toString());
         }
     }
-
-    public String convertByteBufToString(ByteBuf buf) {
-        String str;
-        if (buf.hasArray()) { // 处理堆缓冲区
-            str = new String(buf.array(), buf.arrayOffset() + buf.readerIndex(), buf.readableBytes());
-        } else { // 处理直接缓冲区以及复合缓冲区
-            byte[] bytes = new byte[buf.readableBytes()];
-            buf.getBytes(buf.readerIndex(), bytes);
-            str = new String(bytes, 0, buf.readableBytes());
-        }
-        return str;
-    }
-
     /**
      * 从客户端收到新的数据、读取完成时调用
      */

src/main/java/com/cn/esermis/utils/TokenUtils.java

@@ -0,0 +1,26 @@
+package com.cn.esermis.utils;
+
+import com.auth0.jwt.JWT;
+import com.auth0.jwt.exceptions.JWTDecodeException;
+import com.auth0.jwt.interfaces.DecodedJWT;
+import com.cn.esermis.model.BaseUser;
+
+public class TokenUtils {
+
+    public static BaseUser getUserInfo(String token) {
+        try {
+            DecodedJWT jwt = JWT.decode(token);
+            BaseUser user = new BaseUser();
+            user.setUserId(jwt.getClaim("userId").asString());
+            user.setCompanyId(jwt.getClaim("companyId").asString());
+            user.setFactoryId(jwt.getClaim("factoryId").asString());
+            return user;
+        } catch (JWTDecodeException e) {
+            return null;
+        }
+    }
+
+    public static void main(String[] args) {
+        System.out.println(getUserInfo("eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOiIxMDAwMDAwMDEiLCJpc3MiOiJhdXRoMCIsImV4cCI6MTcyODYxMTk5NywidXNlcklkIjoiMTEwMDAwMTk3MTAxMDEwMDAwIn0.ZlKMmrDKQiU1PTxseg0qCu5Bb2LwZryBr72C9XxWpHs"));
+    }
+}