Skip to content

Commit

Permalink
Change eureka registry server to single ZooKeeper
Browse files Browse the repository at this point in the history
  • Loading branch information
@VancySavoki
VancySavoki committed May 31, 2019
1 parent 21d172c commit 22beb61
Show file tree
Hide file tree
Showing 5 changed files with 334 additions and 308 deletions.
3 changes: 2 additions & 1 deletion moss-adapter/pom.xml
View file
Expand Up @@ -13,9 +13,10 @@
<version>1.0.0.RELEASE</version>
<packaging>pom</packaging>
<modules>
<module>moss-adapter-single-eureka</module>
<!--<module>moss-adapter-single-eureka</module>-->
<module>moss-adapter-single-nacos</module>
<module>moss-adapter-multi-eureka</module>
<module>moss-adapter-multi-zookeeper</module>
<module>moss-adapter-cloud</module>
<!-- <module>moss-adapter-multi-nacos</module>-->
</modules>
Expand Down
9 changes: 7 additions & 2 deletions moss-service/pom.xml
View file
Expand Up @@ -11,7 +11,7 @@
<artifactId>moss-service</artifactId>

<name>moss-service</name>

<dependencies>

<dependency>
Expand Down Expand Up @@ -68,9 +68,14 @@

<dependency>
<groupId>org.xujin.moss</groupId>
<artifactId>moss-adapter-multi-eureka</artifactId>
<artifactId>moss-adapter-multi-zookeeper</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
<!--<dependency>-->
<!--<groupId>org.xujin.moss</groupId>-->
<!--<artifactId>moss-adapter-multi-eureka</artifactId>-->
<!--<version>1.0.0.RELEASE</version>-->
<!--</dependency>-->
</dependencies>

</project>
28 changes: 14 additions & 14 deletions moss-service/src/main/java/org/xujin/moss/service/impl/RegisterCenterServiceImpl.java
View file
Expand Up @@ -4,7 +4,7 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterServerMgmtConfig;
// import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterServerMgmtConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
Expand All @@ -24,8 +24,8 @@
@Service
public class RegisterCenterServiceImpl implements RegisterCenterService {

@Autowired
private MultRegisterCenterServerMgmtConfig multEurekaServerMgmtConfig;
// @Autowired
// private MultRegisterCenterServerMgmtConfig multEurekaServerMgmtConfig;

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

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

}

Expand All @@ -98,7 +98,7 @@ public void deleteRegisterCenterById(Long id) {
}
registerCenter.setIsDeleted(Constants.IS_DELETE_TRUE);
registerCenterMapper.updateById(registerCenter);
multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());
// multEurekaServerMgmtConfig.revomeEureka(registerCenter.getCode());

}

Expand Down
64 changes: 32 additions & 32 deletions moss-service/src/main/java/org/xujin/moss/service/impl/SwitchMultEurekaServiceImpl.java
View file
@@ -1,32 +1,32 @@
package org.xujin.moss.service.impl;

import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.xujin.moss.constant.Constants;
import org.xujin.moss.entity.RegisterCenter;
import org.xujin.moss.mapper.RegisterCenterMapper;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class SwitchMultEurekaServiceImpl implements MultRegisterCenterService {

@Autowired
private RegisterCenterMapper registerCenterMapper;

@Override
public Map<String, String> getRegisterCenterList() {

Map<String, String> map=new HashMap<>();
List<RegisterCenter> registerCenters= registerCenterMapper.findRegisterCenterListByStatus(Constants.REGISTER_CENTER_ENABLE);
for (RegisterCenter registerCenter:registerCenters) {
map.put(registerCenter.getCode(),registerCenter.getUrl());
}
return map;
}


}
//package org.xujin.moss.service.impl;
//
//import de.codecentric.boot.admin.server.cloud.extension.MultRegisterCenterService;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//import org.xujin.moss.constant.Constants;
//import org.xujin.moss.entity.RegisterCenter;
//import org.xujin.moss.mapper.RegisterCenterMapper;
//
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//
//@Service
//public class SwitchMultEurekaServiceImpl implements MultRegisterCenterService {
//
// @Autowired
// private RegisterCenterMapper registerCenterMapper;
//
// @Override
// public Map<String, String> getRegisterCenterList() {
//
// Map<String, String> map=new HashMap<>();
// List<RegisterCenter> registerCenters= registerCenterMapper.findRegisterCenterListByStatus(Constants.REGISTER_CENTER_ENABLE);
// for (RegisterCenter registerCenter:registerCenters) {
// map.put(registerCenter.getCode(),registerCenter.getUrl());
// }
// return map;
// }
//
//
//}

0 comments on commit 22beb61

Please sign in to comment.