From 9a968ba186af5280fcc29cc3eb04412eff204ba7 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 27 May 2021 16:37:33 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java | 14 +++++++++----- 1 files changed, 9 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java b/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java index c1fbb4c..7e76d05 100644 --- a/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java +++ b/src/main/java/com/xcong/excoin/netty/logic/impl/MsgLogicImpl.java @@ -1,9 +1,13 @@ package com.xcong.excoin.netty.logic.impl; +import cn.hutool.core.util.StrUtil; import com.xcong.excoin.netty.bean.RequestBean; +import com.xcong.excoin.netty.common.ChannelManager; import com.xcong.excoin.netty.common.Contans; +import com.xcong.excoin.netty.common.NettyTools; import com.xcong.excoin.netty.logic.MsgLogic; import com.xcong.excoin.netty.logic.WebSocketLogic; +import io.netty.channel.Channel; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -20,14 +24,14 @@ @Override public void webSocketMsgLogic(RequestBean requestBean) { + switch (requestBean.getType()) { - case Contans.WEB_REQ_CONNECTION : - webSocketLogic.webReqConnection(requestBean); + case Contans.AUTH_CHECK: + webSocketLogic.authCheck(requestBean); break; - case Contans.HOME_SYMBOLS: - webSocketLogic.reqHomeSymbols(requestBean); + case Contans.MESSAGE: + webSocketLogic.sendMsg(requestBean); default: - webSocketLogic.defaultReq(requestBean); break; } } -- Gitblit v1.9.1