|
|
@@ -1,7 +1,6 @@
|
|
|
package com.zksy.environmentHJ212.config;
|
|
|
|
|
|
import com.zksy.environmentHJ212.utils.MonitorDatasynch;
|
|
|
-import com.zksy.environmentHJ212.utils.SpringContextUtil;
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
|
@@ -9,16 +8,21 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import javax.annotation.PostConstruct;
|
|
|
import java.time.LocalDateTime;
|
|
|
|
|
|
@Slf4j
|
|
|
@Component
|
|
|
public class ServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
+ private static ServerHandler serverHandler;
|
|
|
+
|
|
|
@Autowired
|
|
|
private MonitorDatasynch monitorDatasynch;
|
|
|
-
|
|
|
- public ServerHandler() {
|
|
|
- this.monitorDatasynch = SpringContextUtil.getBean(MonitorDatasynch.class);
|
|
|
+ @PostConstruct
|
|
|
+ public void init() {
|
|
|
+ log.info("init()方法");
|
|
|
+ serverHandler = this;
|
|
|
+ serverHandler.monitorDatasynch = this.monitorDatasynch;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -76,7 +80,7 @@ public class ServerHandler extends ChannelInboundHandlerAdapter {
|
|
|
String msg = new String(req);
|
|
|
System.out.println(msg+"==============");
|
|
|
log.info("==========数据已接收,接收时间:==========" + LocalDateTime.now());
|
|
|
- String pushMonitorDataStr = monitorDatasynch.pushMonitorData(channelHandlerContext,msg);
|
|
|
+ String pushMonitorDataStr = serverHandler.monitorDatasynch.pushMonitorData(channelHandlerContext,msg);
|
|
|
} catch (Exception e) {
|
|
|
log.info("==========数据入库失败==========");
|
|
|
e.printStackTrace();
|