package com.ld.igds.protocol.quantity.shuhan.server;
|
|
import com.ld.igds.io.notify.ServerNotifyInvoker;
|
import com.ld.igds.protocol.quantity.shuhan.ShuHanUtils;
|
import com.ld.igds.util.SpringUtil;
|
import com.ld.io.api.IoSession;
|
import com.ld.io.api.IoSessionListener;
|
import lombok.extern.slf4j.Slf4j;
|
|
@Slf4j
|
public class SessionListener implements IoSessionListener {
|
|
public static final String BEAN_ID = "shly.sessionListener";
|
|
|
@Override
|
public void onCreate(IoSession session) {
|
// 添加自定义业务ID
|
session.setBusinessKey(ShuHanUtils.getServerKey(session.getAddress(), session.getPort()));
|
log.info("++++蜀汉插件服务新建连接++++-IP={}，PORT={}", session.getAddress(), session.getPort());
|
}
|
|
@Override
|
public void onDestroy(IoSession session) {
|
ServerNotifyInvoker serverNotifyInvoker = SpringUtil.getBean(ServerNotifyInvoker.class);
|
serverNotifyInvoker.connectDestory(session.getBusinessKey(),
|
session.getAddress(), session.getPort());
|
log.info("---蜀汉插件服务连接断开，系统设置设备离线-----IP={}，PORT={}，SN={}", session.getAddress(), session.getPort(), session.getBusinessKey());
|
}
|
}
|
