优化协议

vince

2024-01-27 facc0ea3fa37091a98aa1e0a0d1081fd32fba28e

 src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0MessageConsumer.java

@@ -1,6 +1,7 @@
package com.fzzy.protocol.bhzn.v0.server;

import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.SpringUtil;
import com.fzzy.protocol.bhzn.v0.analysis.AnalysisService;
import com.fzzy.protocol.bhzn.v0.cmd.ReMessageBuilder;
import com.fzzy.protocol.bhzn.v0.data.IoMessage;
@@ -38,7 +39,7 @@
        BhznGrainV0ServerUtils.addHeartBeat(ioSession);

        //默认设置主通讯服务
        //BhznGrainV2ServerUtils.addSession(ioSession);
        BhznGrainV0ServerUtils.addSession(ioSession);

        try {
            String hexStr = BytesUtil.bytesToString(bytes);
@@ -48,7 +49,7 @@
            IoMessage ioMessage = ReMessageBuilder.getInstance().buildMessage(hexStr);
            ioMessage.setIp(ioSession.getAddress());
            ioMessage.setPort(ioSession.getPort());

            analysisService = SpringUtil.getBean(AnalysisService.class);
            analysisService.analysis(ioSession.getBusinessKey(), ioMessage);
        } catch (Exception e) {
            log.error(e.getMessage(), e);