|
@@ -1,5 +1,6 @@
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import io.netty.channel.Channel;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import wei.yigulu.iec104.nettyconfig.Iec104SlaverBuilder;
|
|
|
import wei.yigulu.iec104.util.SendDataFrameHelper;
|
|
|
|
|
@@ -8,6 +9,7 @@ import java.io.File;
|
|
|
import java.io.FileInputStream;
|
|
|
import java.io.InputStreamReader;
|
|
|
|
|
|
+@Slf4j
|
|
|
public class StartHttpServer {
|
|
|
public static void main(String[] args) throws Exception {
|
|
|
//104端口
|
|
@@ -56,6 +58,13 @@ public class StartHttpServer {
|
|
|
port2 = tem2;
|
|
|
}
|
|
|
Iec104SlaverBuilder iec104SlaverBuilder = new Iec104SlaverBuilder(port1);
|
|
|
+ iec104SlaverBuilder.getConnectFilterManager().appendFilter((c)-> {
|
|
|
+ if (iec104SlaverBuilder.getChannels().size() >= 1) {
|
|
|
+ log.warn("已有一个主站连接,拒绝新连接联入");
|
|
|
+ return -1;
|
|
|
+ }
|
|
|
+ return 1;
|
|
|
+ });
|
|
|
iec104SlaverBuilder.createByUnBlock();
|
|
|
RecurringTaskContainer.getInstance().addRecurringTask(60, "向对端发送突发上送", () -> {
|
|
|
if (iec104SlaverBuilder.getChannels().size() > 0) {
|