package com.ld.igds.protocol.bhzn.grainv1.server;
|
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.io.api.*;
|
import com.ld.io.netty.NettyServer;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* @Desc: 邦海智能纯粮情协议
|
* @author: Andy
|
* @update-time: 2023/5/11
|
*/
|
@Slf4j
|
@Service
|
public class BhznGrainV1ServerEngine {
|
|
public static final Integer PORT = 9309;
|
|
@Autowired
|
private BhznGrainV1MessageConsumer defaultMessageConsumer;
|
@Autowired
|
private BhznGrainV1SessionListener defaultSessionListener;
|
// 心跳提供
|
private static HeartbeatProvider heartbeatProvider = new BhznGrainV1HeartbeatImpl();
|
|
private IoSessionQuery sessionQuery;
|
|
public void start(Integer port) {
|
IoServerOption ioServerOption = new IoServerOption();
|
|
if (null != port) {
|
ioServerOption.setPort(port);
|
} else {
|
ioServerOption.setPort(PORT);
|
}
|
|
//确认结尾标志
|
ioServerOption.setDelimiter(BhznGrainV1ServerUtils.MSG_END.getBytes());
|
|
// 配置系统心跳间隔
|
ioServerOption.setReaderIdleTime(5 * 60);
|
|
NettyServer ioServer = new NettyServer(ioServerOption, defaultMessageConsumer, defaultSessionListener, heartbeatProvider);
|
ioServer.startup();
|
|
sessionQuery = ioServer.getSessionQuery();
|
|
|
log.info("* ");
|
log.info("* ========================");
|
log.info("* ");
|
log.info("* [GRAIN-SERVER：BHZN_GRAIN,PORT={}]", PORT);
|
log.info("* ");
|
log.info("* ========================");
|
log.info("* ");
|
|
System.out.println("* ========================");
|
System.out.println("* ");
|
System.out.println("* [GRAIN-SERVER：BHZN_GRAIN,PORT={}]" + port);
|
System.out.println("* ");
|
System.out.println("* ========================");
|
}
|
|
public IoSessionQuery getSessionQuery() {
|
return sessionQuery;
|
}
|
|
/**
|
* 发送信息
|
*
|
* @param ip
|
* @param port
|
* @param msg
|
* @return
|
*/
|
public InvokeResult push(String ip, int port, byte[] msg) {
|
IoSessionQuery sessionFactory = getSessionQuery();
|
List<IoSession> sessions = sessionFactory.getAllSession();
|
IoSession session = null;
|
for (IoSession ioSession : sessions) {
|
if (BhznGrainV1ServerUtils.getServerKey(ip, port).equals(ioSession.getBusinessKey())) {
|
session = ioSession;
|
break;
|
}
|
}
|
if (null == session) {
|
return InvokeResult.CHANNEL_CLOSED;
|
}
|
return session.invoke(msg);
|
}
|
|
|
// public InvokeResult push(String ip, int port, String hexStr) {
|
//
|
// byte[] msg = BytesUtil.hexStrToBytes(hexStr);
|
//
|
// IoSessionQuery sessionFactory = getSessionQuery();
|
// List<IoSession> sessions = sessionFactory.getAllSession();
|
// IoSession session = null;
|
// for (IoSession ioSession : sessions) {
|
// if (BhznGrainV1ServerUtils.getServerKey(ip, port).equals(ioSession.getBusinessKey())) {
|
// session = ioSession;
|
// break;
|
// }
|
// }
|
//
|
// if (null == session) {
|
// return InvokeResult.CHANNEL_CLOSED;
|
// }
|
// return session.invoke(msg);
|
// }
|
|
/**
|
* 直接使用内存的Session执行
|
*/
|
public InvokeResult pushByMin(String hexStr) {
|
|
IoSession session = BhznGrainV1ServerUtils.getSession();
|
|
if (null == session) {
|
return InvokeResult.CHANNEL_CLOSED;
|
}
|
byte[] msg = BytesUtil.hexStrToBytes(hexStr);
|
return session.invoke(msg);
|
}
|
|
}
|
