autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-07-09 00:18:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

使用ChannelHandlerContext

Browse Source
This commit is contained in:
Guoqs
2024-08-01 11:51:27 +08:00
parent 3ac1d5752c
commit 0ad35c9300
3 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jsowell-netty/src/main/java/com/jsowell/netty/handler/electricbicycles/AbstractHandler.java
View File

@@ -26,7 +26,7 @@ public abstract class AbstractHandler implements InitializingBean {
* 执行逻辑 * 执行逻辑
* 有应答 * 有应答
*/ */
public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, Channel channel) { public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) {
throw new UnsupportedOperationException(); throw new UnsupportedOperationException();
} }

5
jsowell-netty/src/main/java/com/jsowell/netty/service/electricbicycles/YKCBusinessService.java
View File

@@ -1,6 +1,7 @@
package com.jsowell.netty.service.electricbicycles; package com.jsowell.netty.service.electricbicycles;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelId; import io.netty.channel.ChannelId;
/** /**
@@ -12,10 +13,10 @@ public interface YKCBusinessService {
* 处理桩发来的请求 * 处理桩发来的请求
* 不需要应答的返回null * 不需要应答的返回null
* @param msg 请求报文 * @param msg 请求报文
* @param channel 通道信息 * @param ctx 通道信息
* @return 结果 * @return 结果
*/ */
byte[] process(byte[] msg, Channel channel); byte[] process(byte[] msg, ChannelHandlerContext ctx);
/** /**
* 桩退出 * 桩退出

5
jsowell-netty/src/main/java/com/jsowell/netty/service/electricbicycles/impl/YKCBusinessServiceImpl2.java
View File

@@ -14,6 +14,7 @@ import com.jsowell.pile.service.PileConnectorInfoService;
import com.jsowell.pile.service.PileMsgRecordService; import com.jsowell.pile.service.PileMsgRecordService;
import com.jsowell.pile.service.YKCPushCommandService; import com.jsowell.pile.service.YKCPushCommandService;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelId; import io.netty.channel.ChannelId;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -36,7 +37,7 @@ public class YKCBusinessServiceImpl2 implements YKCBusinessService {
private YKCPushCommandService ykcPushCommandService; private YKCPushCommandService ykcPushCommandService;
@Override @Override
public byte[] process(byte[] msg, Channel channel) { public byte[] process(byte[] msg, ChannelHandlerContext ctx) {
if (!YKCUtils.checkMsg(msg)) { if (!YKCUtils.checkMsg(msg)) {
// 校验不通过，丢弃消息 // 校验不通过，丢弃消息
return null; return null;
@@ -46,7 +47,7 @@ public class YKCBusinessServiceImpl2 implements YKCBusinessService {
String frameType = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType()); String frameType = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType());
// 获取业务处理handler // 获取业务处理handler
AbstractHandler invokeStrategy = YKCOperateFactory.getInvokeStrategy(frameType); AbstractHandler invokeStrategy = YKCOperateFactory.getInvokeStrategy(frameType);
return invokeStrategy.supplyProcess(ykcDataProtocol, channel); return invokeStrategy.supplyProcess(ykcDataProtocol, ctx);
} }
@Override @Override