gpt4 book ai didi

com.colobu.rpcx.server.ZkServiceRegister类的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 13:18:28 26 4
gpt4 key购买 nike

本文整理了Java中com.colobu.rpcx.server.ZkServiceRegister类的一些代码示例,展示了ZkServiceRegister类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkServiceRegister类的具体详情如下:
包路径:com.colobu.rpcx.server.ZkServiceRegister
类名称:ZkServiceRegister

ZkServiceRegister介绍

暂无

代码示例

代码示例来源:origin: smallnest/rpcx-java

/**
 * 周期性的注册
 */
@Override
public void start() {
  new ScheduledThreadPoolExecutor(1).scheduleWithFixedDelay(() -> {
    register();
  }, 0, 5, TimeUnit.SECONDS);
}

代码示例来源:origin: smallnest/rpcx-java

@PostConstruct
private void init() {
  Reflections reflections = new Reflections(rpcxProviderPackagePath);
  Set<Class<?>> providerSet = reflections.getTypesAnnotatedWith(Provider.class, true);
  providerSet.stream().forEach(it -> {
    logger.info("provider:{}", it);
  });
  NettyServer server = new NettyServer();
  Function<Class, Object> getBeanFunc = (clazz) -> context.getBean(clazz);
  server.setGetBeanFunc(getBeanFunc);
  server.start();
  IServiceRegister reg = new ZkServiceRegister(rpcxBasePath, server.getAddr() + ":" + server.getPort(), rpcxProviderPackagePath, getBeanFunc);
  reg.register();
  reg.start();
}

代码示例来源:origin: smallnest/rpcx-java

public static void main(String... args) {
    NettyServer server = new NettyServer();
    server.start();
    IServiceRegister reg = new ZkServiceRegister("/youpin/services/", server.getAddr() + ":" + server.getPort(), "com.colobu", null);
    reg.register();
    reg.start();
    server.await();
  }
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com