From 02e3ceb5316e77cbe3da1d19f6d847f27f1b5b43 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期三, 05 八月 2020 10:01:47 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/cache/CrnConnection.java | 5 +++-- src/main/java/com/zy/core/channel/CrnChannel.java | 7 +++++++ src/main/java/com/zy/core/thread/CrnThread.java | 4 ++++ src/main/java/com/zy/core/ServerBootstrap.java | 2 ++ 4 files changed, 16 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java index af7d7e1..0163c15 100644 --- a/src/main/java/com/zy/core/ServerBootstrap.java +++ b/src/main/java/com/zy/core/ServerBootstrap.java @@ -2,6 +2,7 @@ import com.alibaba.fastjson.JSON; import com.core.common.Cools; +import com.zy.core.cache.CrnConnection; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.CrnThread; import com.zy.core.thread.DevpThread; @@ -36,6 +37,7 @@ for (Slave crn : slaveProperties.getCrn()) { CrnThread crnThread = new CrnThread(crn); new Thread(crnThread).start(); + CrnConnection.put(crn.getId()); } } // // 鍒濆鍖栫珯鐐圭嚎绋� diff --git a/src/main/java/com/zy/core/cache/SlaveConnection.java b/src/main/java/com/zy/core/cache/CrnConnection.java similarity index 93% rename from src/main/java/com/zy/core/cache/SlaveConnection.java rename to src/main/java/com/zy/core/cache/CrnConnection.java index a3dbdea..48f3d26 100644 --- a/src/main/java/com/zy/core/cache/SlaveConnection.java +++ b/src/main/java/com/zy/core/cache/CrnConnection.java @@ -8,7 +8,7 @@ /** * Created by vincent on 2020/8/4 */ -public class SlaveConnection { +public class CrnConnection { public static final String CRN_PREFIX = "CRN_"; @@ -17,7 +17,8 @@ private static Map<String, ThreadHandler> conContain = new ConcurrentHashMap<>(); public static void put(String key, ThreadHandler threadHandler) { - + remove(key); + conContain.put(key, threadHandler); } public static ThreadHandler get(String key) { diff --git a/src/main/java/com/zy/core/channel/CrnChannel.java b/src/main/java/com/zy/core/channel/CrnChannel.java new file mode 100644 index 0000000..dcca7a5 --- /dev/null +++ b/src/main/java/com/zy/core/channel/CrnChannel.java @@ -0,0 +1,7 @@ +package com.zy.core.channel; + +/** + * Created by vincent on 2020/8/5 + */ +public class CrnChannel { +} diff --git a/src/main/java/com/zy/core/thread/CrnThread.java b/src/main/java/com/zy/core/thread/CrnThread.java index f798804..3013dfe 100644 --- a/src/main/java/com/zy/core/thread/CrnThread.java +++ b/src/main/java/com/zy/core/thread/CrnThread.java @@ -19,4 +19,8 @@ } + @Override + public void close() { + + } } -- Gitblit v1.9.1