#

luxiaotao1123

2020-08-05 521f00d3f07453dd8e65cc501babc8b551c22ec4

#

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -37,16 +37,17 @@
            for (Slave crn : slaveProperties.getCrn()) {
                CrnThread crnThread = new CrnThread(crn);
                new Thread(crnThread).start();
                CrnConnection.put(crn.getId());
                CrnConnection.put(ThreadHandler.CRN_PREFIX + crn.getId(), crnThread);
            }
        }
//        // 初始化站点线程
//        if (!Cools.isEmpty(slaveProperties.getDevp())) {
//            for (Slave devo : slaveProperties.getDevp()) {
//                DevpThread devpThread = new DevpThread(crn);
//                new Thread(devpThread).start();
//            }
//        }

        // 初始化站点线程
        if (!Cools.isEmpty(slaveProperties.getDevp())) {
            for (Slave devo : slaveProperties.getDevp()) {
                DevpThread devpThread = new DevpThread(devo);
                new Thread(devpThread).start();
            }
        }

    }


 src/main/java/com/zy/core/ThreadHandler.java

@@ -2,6 +2,10 @@

public interface ThreadHandler {

    String CRN_PREFIX = "CRN_";

    String DEVP_PREFIX = "DEVP_";

    void close();

}

 src/main/java/com/zy/core/cache/CrnConnection.java

@@ -10,10 +10,6 @@
 */
public class CrnConnection {

    public static final String CRN_PREFIX = "CRN_";

    public static final String DEVP_PREFIX = "DEVP_";

    private static Map<String, ThreadHandler> conContain = new ConcurrentHashMap<>();

    public static void put(String key, ThreadHandler threadHandler) {

 src/main/java/com/zy/core/thread/CrnThread.java

@@ -15,12 +15,25 @@
    }

    @Override
    @SuppressWarnings("InfiniteLoopStatement")
    public void run() {
        while (true) {
            try {
                System.out.println("线程"+slave.getId()+"正在运行");





                Thread.sleep(1000);
            } catch (Exception e) {
                e.printStackTrace();
            }

        }
    }

    @Override
    public void close() {

    }
}

 src/main/java/com/zy/core/thread/DevpThread.java

@@ -1,13 +1,25 @@
package com.zy.core.thread;

import com.zy.core.Slave;
import com.zy.core.ThreadHandler;

/**
 * Created by vincent on 2020/8/4
 */
public class DevpThread implements Runnable {
public class DevpThread implements Runnable, ThreadHandler {

    private Slave slave;

    public DevpThread(Slave slave) {
        this.slave = slave;
    }

    @Override
    public void run() {

    }

    @Override
    public void close() {

    }
}

 src/main/resources/application.yml

@@ -41,11 +41,11 @@
    ip: 192.168.1.1
    port: 8888
  crn[1]:
    id: 1
    id: 2
    ip: 192.168.1.1
    port: 8888
  crn[2]:
    id: 1
    id: 3
    ip: 192.168.1.1
    port: 8888
  # 站点