diff --git a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/discovery/DbDiscoveryImpl.java b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/discovery/DbDiscoveryImpl.java index 4b2cd6af910b7e2abea351ecbb8d1295817c9b02..8bfcea009f455cf97ac59d1cf1d0e033e2d2aea1 100644 --- a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/discovery/DbDiscoveryImpl.java +++ b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/discovery/DbDiscoveryImpl.java @@ -16,6 +16,7 @@ package io.iec.edp.caf.msu.client.discovery; +import io.iec.edp.caf.commons.runtime.CafEnvironment; import io.iec.edp.caf.commons.utils.SpringBeanUtils; import io.iec.edp.caf.datasource.CAFDataSourceSelector; import io.iec.edp.caf.msu.api.client.ServiceDiscovery; @@ -91,6 +92,9 @@ public class DbDiscoveryImpl implements ServiceDiscovery { */ @Override public List getEnabledServiceUnitInfo() { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } List infos = null; try { @@ -125,6 +129,9 @@ public class DbDiscoveryImpl implements ServiceDiscovery { * @return 所有实例 */ private List findAppsBySu(String su) { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } List apps = new ArrayList<>(); try { diff --git a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/health/DbHealthCheck.java b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/health/DbHealthCheck.java index f4a26c586ccadd756bf03c99a89fd4081cb8acca..7a4fbd96842aed0257bc5783fffd359f027a7e90 100644 --- a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/health/DbHealthCheck.java +++ b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/health/DbHealthCheck.java @@ -16,6 +16,7 @@ package io.iec.edp.caf.msu.client.health; +import io.iec.edp.caf.commons.runtime.CafEnvironment; import io.iec.edp.caf.commons.transaction.JpaTransaction; import io.iec.edp.caf.commons.transaction.TransactionPropagation; import io.iec.edp.caf.commons.utils.SpringBeanUtils; @@ -109,6 +110,9 @@ public class DbHealthCheck { // 健康检测 private void doCheck() { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } try { //设置主库 CAFDataSourceSelector.selectMaster(); diff --git a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/register/DbRegisterImpl.java b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/register/DbRegisterImpl.java index 86a843bf12b0f384122ae28bc8e62d634dffdb55..238c789fd797c6c47f6fb6b717d276d6905106e7 100644 --- a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/register/DbRegisterImpl.java +++ b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/client/register/DbRegisterImpl.java @@ -99,6 +99,9 @@ public class DbRegisterImpl implements ServiceRegistry { @Override public Boolean register(ServiceUnitRegisterInfo registerInfo, String ip, Integer port) { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } try { //设置主库 CAFDataSourceSelector.selectMaster(); diff --git a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/common/DBMsuServiceImpl.java b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/common/DBMsuServiceImpl.java index 940c5e4a5cd9662270f0446964cb6f37ff8b8924..59dd3c29fb6b274db3b04365f546017f0f0759b3 100644 --- a/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/common/DBMsuServiceImpl.java +++ b/caf-msu/caf-msu-database/src/main/java/io/iec/edp/caf/msu/common/DBMsuServiceImpl.java @@ -1,5 +1,6 @@ package io.iec.edp.caf.msu.common; +import io.iec.edp.caf.commons.runtime.CafEnvironment; import io.iec.edp.caf.datasource.CAFDataSourceSelector; import io.iec.edp.caf.msu.api.ServiceUnitAwareService; import io.iec.edp.caf.msu.api.client.ServiceDiscovery; @@ -34,6 +35,9 @@ public class DBMsuServiceImpl extends MsuServiceImpl { //根据Su名称获取appServer信息 public List getGspAppServerInfoBySu(String suName) { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } try { CAFDataSourceSelector.selectMaster(); @@ -57,6 +61,9 @@ public class DBMsuServiceImpl extends MsuServiceImpl { //获取一个Su的信息 public GspSuInstance getGspSuInfo(String suName) { + if (CafEnvironment.enablePrimaryDataService()) { + throw new RuntimeException("The Primary-Data-Service mode does not support using the database as a service registry. Please switch to Nacos or other alternatives."); + } try { CAFDataSourceSelector.selectMaster();