diff --git a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/RegisterServiceImpl.java b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/RegisterServiceImpl.java index 7ca802889d1f019a556b563f21f3dcdb52f6e636..23cb8cab3df7317dbaa6201a9a4b2af2e97266ee 100644 --- a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/RegisterServiceImpl.java +++ b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/service/impl/RegisterServiceImpl.java @@ -67,6 +67,8 @@ public class RegisterServiceImpl implements RegisterService, InitializingBean { @Override public void doRegister(List registers) { // 查询,如果有,则更新时间,没有则插入 + // TODO 查询是否有此域,如果没有,则不能注册 + // 返回注册失败的域给SDK for (RegisterVO register : registers) { RegisterDO dbRegister = registerDAO.queryUnionOne(register.getDomain(), register.getClientAddress(), register.getClientPort()); if (dbRegister == null) { diff --git a/rec-admin/rec-admin-web/src/main/java/cn/icanci/rec/admin/web/controller/register/RegisterController.java b/rec-admin/rec-admin-web/src/main/java/cn/icanci/rec/admin/web/controller/register/RegisterController.java index 828b9d1fdc53a4ece1f7b527a07f249332178812..1cba0e759744dfee79102cd57fbad289fd51c0b9 100644 --- a/rec-admin/rec-admin-web/src/main/java/cn/icanci/rec/admin/web/controller/register/RegisterController.java +++ b/rec-admin/rec-admin-web/src/main/java/cn/icanci/rec/admin/web/controller/register/RegisterController.java @@ -46,6 +46,13 @@ public class RegisterController { return R.builderOk().build(); } + /** + * TODO SDK注册的时候需要返回注册的结果 + * 要识别注册的结果,然后SDK做响应的操作 + * 也就是当全部域都发生注册的时候,就不再自动注册 + * @param register register + * @return 返回注册的结果 + */ @PostMapping("doRegister") public R register(@RequestBody RegisterDTO register) { doRegister(register); diff --git a/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/server/RegisterServer.java b/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/server/RegisterServer.java index 075006518b688ef1d4229d38dabdd8e2e6bca239..635b18525697ea7e8eec85a120bb7f590f082b68 100644 --- a/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/server/RegisterServer.java +++ b/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/server/RegisterServer.java @@ -73,6 +73,7 @@ public class RegisterServer implements InitializingBean { } String[] addresses = serverAddress.split(","); + // TODO 注册地址打散,防止压力放在同一个机器上 for (String address : addresses) { try { FutureTask task = new FutureTask<>(new RegisterCallable(address, clientPort, appName, domain, serverPort));