Skip to content

Commit 22beb61

Browse files
VancySavokiVancySavoki
committed
Change eureka registry server to single ZooKeeper
1 parent 21d172c commit 22beb61

File tree

5 files changed

+334
-308
lines changed

5 files changed

+334
-308
lines changed

‎moss-adapter/pom.xml‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,10 @@
1313
<version>1.0.0.RELEASE</version>
1414
<packaging>pom</packaging>
1515
<modules>
16-
<module>moss-adapter-single-eureka</module>
16+
<!--<module>moss-adapter-single-eureka</module>-->
1717
<module>moss-adapter-single-nacos</module>
1818
<module>moss-adapter-multi-eureka</module>
19+
<module>moss-adapter-multi-zookeeper</module>
1920
<module>moss-adapter-cloud</module>
2021
<!-- <module>moss-adapter-multi-nacos</module>-->
2122
</modules>

‎moss-service/pom.xml‎

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
<artifactId>moss-service</artifactId>
1212

1313
<name>moss-service</name>
14-
14+
1515
<dependencies>
1616

1717
<dependency>
@@ -68,9 +68,14 @@
6868

6969
<dependency>
7070
<groupId>org.xujin.moss</groupId>
71-
<artifactId>moss-adapter-multi-eureka</artifactId>
71+
<artifactId>moss-adapter-multi-zookeeper</artifactId>
7272
<version>1.0.0.RELEASE</version>
7373
</dependency>
74+
<!--<dependency>-->
75+
<!--<groupId>org.xujin.moss</groupId>-->
76+
<!--<artifactId>moss-adapter-multi-eureka</artifactId>-->
77+
<!--<version>1.0.0.RELEASE</version>-->
78+
<!--</dependency>-->
7479
</dependencies>
7580

7681
</project>

‎moss-service/src/main/java/org/xujin/moss/service/impl/RegisterCenterServiceImpl.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.baomidou.mybatisplus.core.metadata.IPage;
55
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
66
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
7-
import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterServerMgmtConfig;
7+
// import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterServerMgmtConfig;
88
import org.springframework.beans.factory.annotation.Autowired;
99
import org.springframework.stereotype.Service;
1010
import org.springframework.transaction.annotation.Transactional;
@@ -24,8 +24,8 @@
2424
@Service
2525
public class RegisterCenterServiceImpl implements RegisterCenterService {
2626

27-
@Autowired
28-
private MultRegisterCenterServerMgmtConfig multEurekaServerMgmtConfig;
27+
// @Autowired
28+
// private MultRegisterCenterServerMgmtConfig multEurekaServerMgmtConfig;
2929

3030
@Autowired
3131
private RegisterCenterMapper registerCenterMapper;
@@ -41,10 +41,10 @@ public ResultData addRegisterCenter(RegisterCenterModel model) {
4141
model.setGmtCreate(new Timestamp(System.currentTimeMillis()));
4242
model.setGmtModified(new Timestamp(System.currentTimeMillis()));
4343
registerCenterMapper.insert(BeanMapper.map(model, RegisterCenter.class));
44-
//当状态是启用的时候动态添加
45-
if (Constants.REGISTER_CENTER_ENABLE==model.getStatus()) {
46-
multEurekaServerMgmtConfig.addEureka(model.getCode(),model.getUrl());
47-
}
44+
// //当状态是启用的时候动态添加
45+
// if (Constants.REGISTER_CENTER_ENABLE==model.getStatus()) {
46+
// multEurekaServerMgmtConfig.addEureka(model.getCode(),model.getUrl());
47+
// }
4848
return ResultData.builder().build();
4949
}
5050

@@ -80,12 +80,12 @@ public void update(RegisterCenterModel model) {
8080
}
8181
registerCenter.setGmtModified(new Timestamp(System.currentTimeMillis()));
8282
registerCenterMapper.updateById(BeanMapper.map(model,RegisterCenter.class));
83-
//当状态是启用的时候动态添加
84-
if (Constants.REGISTER_CENTER_ENABLE==model.getStatus()) {
85-
multEurekaServerMgmtConfig.addEureka(model.getCode(),model.getUrl());
86-
}else{
87-
multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());
88-
}
83+
// //当状态是启用的时候动态添加
84+
// if (Constants.REGISTER_CENTER_ENABLE==model.getStatus()) {
85+
// multEurekaServerMgmtConfig.addEureka(model.getCode(),model.getUrl());
86+
// }else{
87+
// multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());
88+
// }
8989

9090
}
9191

@@ -98,7 +98,7 @@ public void deleteRegisterCenterById(Long id) {
9898
}
9999
registerCenter.setIsDeleted(Constants.IS_DELETE_TRUE);
100100
registerCenterMapper.updateById(registerCenter);
101-
multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());
101+
// multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());
102102

103103
}
104104

‎moss-service/src/main/java/org/xujin/moss/service/impl/SwitchMultEurekaServiceImpl.java‎

Lines changed: 32 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -1,32 +1,32 @@
1-
package org.xujin.moss.service.impl;
2-
3-
import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterService;
4-
import org.springframework.beans.factory.annotation.Autowired;
5-
import org.springframework.stereotype.Service;
6-
import org.xujin.moss.constant.Constants;
7-
import org.xujin.moss.entity.RegisterCenter;
8-
import org.xujin.moss.mapper.RegisterCenterMapper;
9-
10-
import java.util.HashMap;
11-
import java.util.List;
12-
import java.util.Map;
13-
14-
@Service
15-
public class SwitchMultEurekaServiceImpl implements MultRegisterCenterService {
16-
17-
@Autowired
18-
private RegisterCenterMapper registerCenterMapper;
19-
20-
@Override
21-
public Map<String, String> getRegisterCenterList() {
22-
23-
Map<String, String> map=new HashMap<>();
24-
List<RegisterCenter> registerCenters= registerCenterMapper.findRegisterCenterListByStatus(Constants.REGISTER_CENTER_ENABLE);
25-
for (RegisterCenter registerCenter:registerCenters) {
26-
map.put(registerCenter.getCode(),registerCenter.getUrl());
27-
}
28-
return map;
29-
}
30-
31-
32-
}
1+
//package org.xujin.moss.service.impl;
2+
//
3+
//import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterService;
4+
//import org.springframework.beans.factory.annotation.Autowired;
5+
//import org.springframework.stereotype.Service;
6+
//import org.xujin.moss.constant.Constants;
7+
//import org.xujin.moss.entity.RegisterCenter;
8+
//import org.xujin.moss.mapper.RegisterCenterMapper;
9+
//
10+
//import java.util.HashMap;
11+
//import java.util.List;
12+
//import java.util.Map;
13+
//
14+
//@Service
15+
//public class SwitchMultEurekaServiceImpl implements MultRegisterCenterService {
16+
//
17+
// @Autowired
18+
// private RegisterCenterMapper registerCenterMapper;
19+
//
20+
// @Override
21+
// public Map<String, String> getRegisterCenterList() {
22+
//
23+
// Map<String, String> map=new HashMap<>();
24+
// List<RegisterCenter> registerCenters= registerCenterMapper.findRegisterCenterListByStatus(Constants.REGISTER_CENTER_ENABLE);
25+
// for (RegisterCenter registerCenter:registerCenters) {
26+
// map.put(registerCenter.getCode(),registerCenter.getUrl());
27+
// }
28+
// return map;
29+
// }
30+
//
31+
//
32+
//}

0 commit comments

Comments
 (0)