From 32e54be067ec2863d1c8203e07970f3ca2889249 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 02 十二月 2020 17:37:28 +0800
Subject: [PATCH] 调整序列服务到order服务中取消序列服务
---
service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java | 79 +--------------------------------------
1 files changed, 3 insertions(+), 76 deletions(-)
diff --git a/service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java b/service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java
index 66bd580..af76608 100644
--- a/service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java
+++ b/service-sequence/src/main/java/com/java110/code/CodeServiceApplicationStart.java
@@ -81,83 +81,10 @@
ServiceStartInit.initSystemConfig(context);
- //鍔犺浇workId
- loadWorkId();
-
- }
-
-
- /**
- * 鍔犺浇 workId
- */
- public static void loadWorkId() throws StartException {
- ZookeeperProperties zookeeperProperties = ApplicationContextFactory.getBean("zookeeperProperties", ZookeeperProperties.class);
-
- if (zookeeperProperties == null) {
- throw new StartException(ResponseConstant.RESULT_CODE_ERROR, "绯荤粺鍚姩澶辫触锛屾湭鍔犺浇zookeeper 閰嶇疆淇℃伅");
- }
-
- String host = null;
- try {
- host = InetAddress.getLocalHost().getHostAddress();
- } catch (UnknownHostException e) {
- throw new StartException(ResponseConstant.RESULT_CODE_ERROR, "绯荤粺鍚姩澶辫触锛岃幏鍙杊ost澶辫触" + e);
- }
-
- ServiceInfoListener serviceInfoListener = ApplicationContextFactory.getBean("serviceInfoListener", ServiceInfoListener.class);
-
- if (serviceInfoListener == null) {
- throw new StartException(ResponseConstant.RESULT_CODE_ERROR, "绯荤粺鍚姩澶辫触锛岃幏鍙栨湇鍔＄洃鍚鍙ｅけ璐�");
- }
-
- serviceInfoListener.setServiceHost(host);
-
- try {
- ZooKeeper zooKeeper = new ZooKeeper(zookeeperProperties.getZookeeperConnectString(), zookeeperProperties.getTimeOut(), new Watcher() {
-
- @Override
- public void process(WatchedEvent watchedEvent) {
-
- }
- });
-
-
- Stat stat = zooKeeper.exists(zookeeperProperties.getWorkDir(), true);
-
- if (stat == null) {
- zooKeeper.create(zookeeperProperties.getWorkDir(), "".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,
- CreateMode.PERSISTENT);
- }
- String workDir = "";
- List<String> workDirs = zooKeeper.getChildren(zookeeperProperties.getWorkDir(), true);
-
- if (workDirs != null && workDirs.size() > 0) {
- for (String workDirTemp : workDirs) {
- if (workDirTemp.startsWith(serviceInfoListener.getHostPort())) {
- workDir = workDirTemp;
- break;
- }
- }
- }
- if (StringUtil.isNullOrNone(workDir)) {
- workDir = zooKeeper.create(zookeeperProperties.getWorkDir() + "/" + serviceInfoListener.getHostPort(), "".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,
- CreateMode.PERSISTENT_SEQUENTIAL);
- }
-
- String[] pathTokens = workDir.split("/");
- if (pathTokens.length > 0
- && pathTokens[pathTokens.length - 1].contains("-")
- && pathTokens[pathTokens.length - 1].contains(":")) {
- String workId = pathTokens[pathTokens.length - 1].substring(pathTokens[pathTokens.length - 1].indexOf("-") + 1);
- serviceInfoListener.setWorkId(Long.parseLong(workId));
- }
-
- Assert.hasLength(serviceInfoListener.getWorkId() + "", "绯荤粺涓姞杞絯orkId 澶辫触");
- } catch (Exception e) {
- e.printStackTrace();
- throw new StartException(ResponseConstant.RESULT_CODE_ERROR, "绯荤粺鍚姩澶辫触锛岄摼鎺ookeeper澶辫触" + zookeeperProperties.getZookeeperConnectString());
- }
}
+
+
+
}
--
Gitblit v1.8.0