停止跟踪

protocol-iec104/src/test/java/MasterTest.java

@@ -1,43 +0,0 @@
-import io.netty.util.ResourceLeakDetector;
-import wei.yigulu.iec104.apdumodel.Apdu;
-import wei.yigulu.iec104.apdumodel.Asdu;
-import wei.yigulu.iec104.asdudataframe.TotalSummonType;
-import wei.yigulu.iec104.nettyconfig.Iec104HSMasterBuilder;
-import wei.yigulu.iec104.nettyconfig.Iec104MasterBuilder;
-
-import java.util.concurrent.Executors;
-import java.util.concurrent.TimeUnit;
-
-/**
- * dad
- *
- * @author 修唯xiuwei
- * @create 2019-03-14 16:46
- * @Email 524710549@qq.com
- **/
-public class MasterTest {
-
-	public static void main(String[] args) throws Exception {
-		ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.ADVANCED);
-		Iec104HSMasterBuilder masterBuilder = new Iec104HSMasterBuilder("127.0.0.1", 2404);
-
-		masterBuilder.createByUnBlock();
-		Executors.newScheduledThreadPool(5).schedule(()->{
-			if (!masterBuilder.getFuture().channel().isActive()){
-				System.out.println("---------------");
-				masterBuilder.create();
-			}
-		},2, TimeUnit.MINUTES);
-	/*	//创建总召唤类型I帧
-		TotalSummonType totalSummonType = new TotalSummonType();
-		//反向生成asdu
-		Asdu asdu = totalSummonType.generateBack();
-		//配置总召唤发送原因
-		asdu.setNot(6);
-		//配置公共地址位
-		asdu.setCommonAddress(1);
-		Apdu apdu = new Apdu().setAsdu(asdu);
-		masterBuilder.sendFrameToOpposite(apdu.encode());*/
-
-	}
-}

protocol-modbus/src/test/java/TestRtuMaster.java

@@ -1,53 +0,0 @@
-import lombok.extern.slf4j.Slf4j;
-import wei.yigulu.modbus.domain.FunctionCode;
-import wei.yigulu.modbus.domain.Obj4RequestRegister;
-import wei.yigulu.modbus.domain.datatype.IModbusDataType;
-import wei.yigulu.modbus.domain.datatype.ModbusDataTypeEnum;
-import wei.yigulu.modbus.domain.datatype.NumericModbusData;
-import wei.yigulu.modbus.exceptiom.ModbusException;
-import wei.yigulu.modbus.netty.ModbusRtuMasterBuilder;
-import wei.yigulu.modbus.utils.ModbusRequestDataUtils;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * @author: xiuwei
- * @version:
- */
-@Slf4j
-public class TestRtuMaster {
-	public static void main(String[] args) throws InterruptedException, ModbusException {
-		ModbusRtuMasterBuilder master = new ModbusRtuMasterBuilder("COM1");
-		master.setBaudRate(9600);
-		master.createByUnBlock();
-/*
-		ModbusRtuMasterBuilder master1 = new ModbusRtuMasterBuilder("COM3");
-		master1.createByUnBlock();
-		ModbusRtuMasterBuilder master2 = new ModbusRtuMasterBuilder("COM5");
-		master2.createByUnBlock();
-		ModbusRtuMasterBuilder master3 = new ModbusRtuMasterBuilder("COM7");
-		master3.createByUnBlock();*/
-		Thread.sleep(5000L);
-		Map<Integer, ModbusDataTypeEnum> map = new HashMap<>();
-		for (int i = 0; i < 10; i+=2) {
-			map.put(i , ModbusDataTypeEnum.CDAB);
-		}
-		List<Obj4RequestRegister> ll = ModbusRequestDataUtils.splitModbusRequest(map, 1, FunctionCode.READ_HOLDING_REGISTERS);
-
-		for (; ; ) {
-			try {
-				Map<Integer, IModbusDataType> map1 = ModbusRequestDataUtils.getRegisterData(master, ll);
-				for (Integer i : map1.keySet()) {
-					System.out.println(i + " ============ " + ((NumericModbusData) map1.get(i)).getValue());
-				}
-			} catch (ModbusException e) {
-				System.out.println(e.getMsg());
-			}
-			Thread.sleep(1000L);
-		}
-
-
-	}
-}