package com.comtop.lcam.fwms.managementkey.socket;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import java.nio.charset.StandardCharsets;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import javax.annotation.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.comtop.lcam.fwms.managementkey.dto.EslcsKeyDTO;
import com.comtop.lcam.fwms.managementkey.dto.EslcsLockLogDTO;
import com.comtop.lcam.fwms.managementkey.facade.internal.EslcsKeyFacade;
import com.comtop.lcam.fwms.managementkey.facade.internal.EslcsLockLogFacade;
import com.comtop.sproc.core.base.util.SprocApplicationContextUtil;
/**
* 服务端处理通道
*/
@ChannelHandler.Sharable
public class EslcsSocketHandler extends ChannelInboundHandlerAdapter {
static private ConcurrentMap<String, EslcsSoketKeyInfo> keyMap = new ConcurrentHashMap<>();
static private int count_89 = 0;
/** 异常输出 */
private static final Logger LOGGER = LoggerFactory.getLogger(EslcsSocketHandler.class);
/** 开锁日志管理服务 */
@Resource
private EslcsLockLogFacade eslcsLockLogFacade = SprocApplicationContextUtil.getContext().getBean(EslcsLockLogFacade.class);
/** 钥匙管理服务 */
@Resource
private EslcsKeyFacade eslcsKeyFacade = SprocApplicationContextUtil.getContext().getBean(EslcsKeyFacade.class);
/***
* 这个方法会在发生异常时触发
*/
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
LOGGER.error("--------Netty Exception ExceptionCaught :" + ctx.channel().id().asShortText() + " " + cause.getMessage()
+ "=======================");
ctx.close();
}
/**
* 连接断开处理事件
*/
@Override
public void channelInactive(ChannelHandlerContext ctx) {
count_89 = 0;
LOGGER.error("--------Netty Disconnect Client IP is :" + ctx.channel().id().asShortText() + " " + ctx.channel().remoteAddress() + "--------");
ctx.close();
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
LOGGER.error("--------Netty Client IP is :" + ctx.channel().remoteAddress() + "--------");
String str = EslcsSocketConstants.SERVICE_SEND_0X70
+ EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(EslcsSocketConstants.SERVICE_SEND_0X70)) + EslcsSocketConstants.Constants_endIndex;
ctx.channel().writeAndFlush(EslcsSocketHexUtil.HexToByteArr(str));
LOGGER.error("--------Netty Service " + ctx.channel().id().asShortText() + " " + str + "---------");
}
/**
* 功能：读取服务器发送过来的信息NB-BlueTLock V1.0 L18.1119.1 861964040627338 89860436101880120304
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
String channelId = ctx.channel().id().asShortText();
ByteBuf buf = (ByteBuf) msg;
byte[] con = new byte[buf.readableBytes()];
buf.readBytes(con);
String str = EslcsSocketHexUtil.byteArrayToHex(con);
LOGGER.error("--------Netty Client " + ctx.channel().id().asShortText() + " " + str + "---------");
EslcsSoketObject eslcsSoketObject = new EslcsSoketObject();
String cmdValue = str.substring(4, 6);
String cmdValueId = str.substring(6, 14);
String eEffData = str.substring(16, str.length() - 4);
String effDataLength = str.substring(2, 4);
String xorCheck = str.substring(str.length() - 4, str.length() - 2);
// 进行异或校验
String getXor = EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(str.substring(0, str.length() - 4)));
if (xorCheck.toUpperCase().equals(getXor.toUpperCase())) {
eslcsSoketObject.setBeginIndex(str.substring(0, 2));
eslcsSoketObject.setEffDataLength(effDataLength);
eslcsSoketObject.setCmdValue(cmdValue);
eslcsSoketObject.setCmdValueId(cmdValueId);
eslcsSoketObject.setResponse(str.substring(14, 16));
eslcsSoketObject.setEffData(eEffData);
eslcsSoketObject.setXorCheck(xorCheck);
eslcsSoketObject.setEndIndex(str.substring(str.length() - 2, str.length()));
if (EslcsSocketConstants.Constants_70.equals(cmdValue)) {
EslcsSoketKeyInfo eslcsSoketKeyInfo = new EslcsSoketKeyInfo();
eslcsSoketKeyInfo.setChannelId(channelId);
eslcsSoketKeyInfo.setKey(new String(EslcsSocketHexUtil.HexToByteArr(eEffData)));
eslcsSoketKeyInfo.setHex(str);
eslcsSoketKeyInfo.setUpdate(new Date());
keyMap.put(channelId, eslcsSoketKeyInfo);
} else if (EslcsSocketConstants.Constants_25.equals(cmdValue)) {
String msg_25 = "aa0125000000010100";
ctx.channel().writeAndFlush(
EslcsSocketHexUtil.HexToByteArr(msg_25 + EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_25))
+ EslcsSocketConstants.Constants_endIndex));
LOGGER.error("--------Netty Service " + ctx.channel().id().asShortText() + " " + msg_25
+ EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_25)) + EslcsSocketConstants.Constants_endIndex + "---------");
Thread.sleep(500);
// 继续在下发钥匙管理
String msg_89 = "aa1b890000000100013132333435363132333431323334" + EslcsSocketUtcUtil.getNowDateBCD() + "303132333400";
ctx.channel().writeAndFlush(
EslcsSocketHexUtil.HexToByteArr(msg_89 + EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_89))
+ EslcsSocketConstants.Constants_endIndex));
LOGGER.error("--------Netty Service " + ctx.channel().id().asShortText() + " " + msg_89
+ EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_89)) + EslcsSocketConstants.Constants_endIndex + "---------");
} else if (EslcsSocketConstants.Constants_89.equals(cmdValue)) {
if (count_89 == 0) {
String msg_89 = "AA0a890000000101ffffffffffffffffffff";
ctx.channel().writeAndFlush(
EslcsSocketHexUtil.HexToByteArr(msg_89 + EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_89))
+ EslcsSocketConstants.Constants_endIndex));
LOGGER.error("--------Netty Service " + ctx.channel().id().asShortText() + " " + msg_89
+ EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_89)) + EslcsSocketConstants.Constants_endIndex + "---------");
}
count_89++;
} else if (EslcsSocketConstants.Constants_80.equals(cmdValue) || EslcsSocketConstants.Constants_81.equals(cmdValue)) {// 开 -关
if (!str.toUpperCase().equals("AA0A800000000100FFFFFFFFFFFFFFFFFFFF2155")) {
analyseDate(channelId, EslcsSocketConstants.Constants_80, eEffData, effDataLength);
}
String msg_8081 = EslcsSocketConstants.Constants_beginIndex + "01" + cmdValue + cmdValueId + "0100";
ctx.channel().writeAndFlush(
EslcsSocketHexUtil.HexToByteArr(msg_8081 + EslcsSocketHexUtil.Byte2Hex(EslcsSocketHexUtil.xor(msg_8081))
+ EslcsSocketConstants.Constants_endIndex));
LOGGER.error("--------Netty Service " + ctx
基于netty编写的socket服务端 （188个子文件） 
EslcsSocketHandler.class 11KB EslcsLockController.class 10KB EslcsKeyController.class 9KB EslcsLockController.class 8KB EslcsStationHouseController.class 8KB EslcsKeyController.class 8KB EslcsLockFacade.class 6KB EslcsKeyFacade.class 6KB EslcsLockDTO.class 5KB EslcsStationHouseController.class 5KB E.class 5KB EslcsLockVO.class 4KB EslcsStationHouseVO.class 4KB EslcsStationHouseDTO.class 4KB ImDataUtil.class 3KB EslcsKeyPreVO.class 3KB EslcsSocketHexUtil.class 3KB EslcsKeyPreDTO.class 3KB EslcsSocketUtcUtil.class 3KB EslcsKeyDTO.class 3KB EslcsKeyPreFacade.class 3KB EslcsSocketService.class 3KB EslcsSoketObject.class 3KB FbeeUTCUtil.class 2KB EslcsStationHouseFacade.class 2KB EslcsSoketObject.class 2KB Text.class 2KB EslcsKeyVO.class 2KB EslcsLockLogFacade.class 2KB EslcsLockPermissionFacade.class 2KB EslcsLockLogVO.class 2KB EslcsLockPermissionAssembler.class 2KB EslcsStationHouseAssembler.class 2KB EslcsLockAppService.class 2KB EslcsKeyAppService.class 2KB EslcsSocketChannel.class 2KB EslcsSoketEffData.class 2KB EslcsLockLogAssembler.class 2KB EslcsKeyPreAssembler.class 2KB EslcsLockAssembler.class 2KB EslcsKeyAssembler.class 2KB EslcsLockPermissionVO.class 2KB EslcsLockLogDTO.class 2KB EslcsKeyPreAppService.class 2KB EslcsStationHouseAppService.class 2KB EslcsLockPermissionDTO.class 1KB EslcsSoketKeyInfo.class 1KB CheckUtil.class 1KB EslcsLockLogAppService.class 1KB EslcsLockPermissionAppService.class 1KB EslcsKeyService.class 1KB SoketListener.class 1005B EslcsSoketEffData.class 917B EslcsKeyPreService.class 832B EslcsSocketConstants.class 757B EslcsLockService.class 725B EslcsStationHouseService.class 722B EslcsKeyPreConstant.class 691B EslcsLockConstant.class 668B EslcsKeyConstant.class 656B EslcsLockLogService.class 570B EslcsLockLogConstant.class 567B EslcsStationHouseConstant.class 563B EslcsLockPermissionService.class 556B EslcsLockPermissionConstant.class 522B .classpath 60KB .classpath 60KB
managementkey-service-1.0.1-SNAPSHOT.jar 66KB managementkey-webapp-1.0.1-SNAPSHOT.jar 66KB managementkey-service-1.0.1-SNAPSHOT-sdk.jar 5KB managementkey-webapp-1.0.1-SNAPSHOT-sdk.jar 5KB EslcsSocketHandler.java 12KB EslcsLockController.java 11KB EslcsKeyController.java 8KB E.java 8KB EslcsKeyFacade.java 7KB EslcsLockDTO.java 7KB EslcsLockFacade.java 7KB EslcsStationHouseVO.java 7KB EslcsStationHouseDTO.java 7KB EslcsLockVO.java 6KB ImDataUtil.java 6KB EslcsSocketHexUtil.java 5KB EslcsStationHouseController.java 5KB EslcsKeyPreDTO.java 5KB EslcsKeyPreVO.java 5KB EslcsSocketUtcUtil.java 5KB EslcsKeyDTO.java 4KB FbeeUTCUtil.java 4KB EslcsSoketObject.java 4KB EslcsSoketObject.java 4KB EslcsKeyVO.java 4KB EslcsSoketEffData.java 3KB EslcsKeyPreFacade.java 3KB EslcsLockLogVO.java 3KB Text.java 3KB EslcsLockLogDTO.java 3KB EslcsLockLogFacade.java 3KB EslcsStationHouseFacade.java 3KB EslcsLockAppService.java 2KB共 188 条
- 1
- 2
资源评论
women0292019-09-08不错，还行，挺好- star0x2022-01-11资源不错，稍微改改自己就能用了，五星好评
一度人生2019-04-25不错！救急！！！
薛1232019-03-18基于Netty编写的Socket服务端
David锋
- 粉丝: 6
- 资源: 2
最新资源
- Prophet时间序列预测入门.ipynb
- 一款由Java写的射击游戏.zip算法资源
- 一些java的小游戏项目，贪吃蛇啥的.zip用户手册
- 在线实时的斗兽棋游戏，时间赶，粗暴的使用jQuery + websoket 实现实时H5对战游戏 + java.zip课程设计
- HTML5酒店网站模板.zip
- 基于SpringBoot开发的支付系统（包括支付宝支付，微信支付，订单系统）.zip
- C基于Qt的学生成绩管理系统.zip毕业设计
- 基于深度卷积神经网络（CNN）模型的图像着色研究与应用系统实现
- Java Web实验报告五：基于JSP的留言本
- Java Web实验报告四：基于AJAX的级联下拉菜单
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
