TIANAI-RPC

public class RpcServerImplTest2 {

    CountDownLatch countDownLatch = new CountDownLatch(1);

    public static void main(String[] args) throws InterruptedException {
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.codec("protostuff")
                .timeout(5000)
                // Устанавливаем сервисную регистрацию как zookeeper, поддерживая zookeeper и nacos два сервиса регистрации
                .registry(new URL("zookeeper", "127.0.0.1", 2181))
                .server("netty")
                .port(20881)
                .start();
        // Регистрация
        serverBootstrap.register(Demo.class, new DemoImpl());
        System.out.println("Запуск успешен");
    }
}

public class RpcClientTest {

    public static void main(String[] args) {
        RpcClientConfiguration prop = new RpcClientConfiguration();
        // Сериализация, по умолчанию protostuff
        prop.setCodec("protostuff");
        // Тайм-аут, по умолчанию 5000
        prop.setTimeout(5000);
        // Запрос тайм-аута, по умолчанию 3000
        prop.setRequestTimeout(3000);
        // Устанавливаем клиент как netty, по умолчанию netty
        prop.setProtocol("netty");

        // Сервисная регистрация, в настоящее время поддерживает zookeeper и nacos две, по умолчанию zookeeper
        // Устанавливаем службу регистрации как nacos
        // URL nacosConf = new URL("nacos", "127.0.0.1", 8848);
        // nacosConf = nacosConf.addParameter("namespace", "1ca3c65a-92a7-4a09-8de1-4bfe1c89d240");

        // Устанавливаем регистрацию службы как zookeeper
        prop.setRegistryUrl(new URL("zookeeper", "127.0.0.1", 2181));
        // Регистратор

        // Удаленный клиент
        Demo proxy = RpcProxyFactory.create(Demo.class, prop, RpcProxyType.JDK_PROXY);
        for (int i = 0; i < 20; i++) {
            // Выполнение RPC запроса
            String res = proxy.sayHello();
            System.out.println("rpc вызов возвращает данные:" + res);
        }
    }
}