Skip to content

Commit b25c1ad

Browse files
committed
更新作业代码
1 parent 398f59d commit b25c1ad

File tree

1 file changed

+1
-5
lines changed
  • 07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client

1 file changed

+1
-5
lines changed

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,10 @@ public static <T, filters> T createFromRegistry(final Class<T> serviceClass, fin
2929
// curator Provider list from zk
3030
List<String> invokers = new ArrayList<>();
3131
// 1. 简单:从zk拿到服务提供的列表
32-
// 2. 挑战:监听zk的临时节点,根据事件更新这个list(注意,需要做个全局map保持每个服务的提供者List)
33-
32+
// 2. 挑战:监听zk 的临时节点,根据事件更新这个list(注意,需要做个全局map保持每个服务的提供者List)
3433
List<String> urls = router.route(invokers);
35-
3634
String url = loadBalance.select(urls); // router, loadbalance
37-
3835
return (T) create(serviceClass, url, filter);
39-
4036
}
4137

4238
public static <T> T create(final Class<T> serviceClass, final String url, Filter... filters) {

0 commit comments

Comments
 (0)