public static void startServer() throws Exception {
    RPCServer server = new RPCServer();

    // Устанавливаем порт, на котором будет слушать сервер
    server.getConfiguration().setListeningPort(8900);

    // Добавляем bean-компоненты, которые можно выполнить на сервере, и соответствующие классы
    server.getConfiguration().addBean("addBean", SampleDoServerClass.class);

    // По умолчанию сервер работает в однопоточном режиме, что обеспечивает атомарность выполнения
    // Если вы хотите запустить его с использованием многопоточного режима ввода-вывода (многопоточность, высокая эффективность), выполните следующую строку
    server.getConfiguration().setThreadType(ThreadType.MULTI);

    // Запускаем сервер
    server.start();
}

public static RPCClient getClient() throws Exception {
    // Создаём экземпляр клиента и указываем адрес и порт сервера (можно указать несколько, будет автоматически балансировать нагрузку)
    RPCClient client = new RPCClient("localhost", 8900);

    // Регистрируем методы, которые клиент может выполнять, через интерфейс
    client.getConfiguration().addBean(SampleDoClientInterface.class, "addBean");

    return client;
}

SampleDoClientInterface bean = client.getBean(SampleDoClientInterface.class);
System.out.println("1 + 2 = " + bean.add(1, 2));

package com.codelifeliwan.rpc.samples;

import com.codelifeliwan.rpc.client.RPCClient;
import com.codelifeliwan.rpc.samples.models.cient.*;
import com.codelifeliwan.rpc.server.RPCServer;

import java.io.InputStream;

public class Start {

    public static void main(String[] args) throws Exception {
        startServer();

        RPCClient client = getClient();

        // Вызов удаленного метода
        SampleDoClientInterface bean = client.getBean(SampleDoClientInterface.class);

        System.out.println("10 + 20 = " + bean.add(10, 20));
    }


    /**
     * Получение клиента
     *
     * @throws Exception
     */
    public static RPCClient getClient() throws Exception {
        InputStream inputStream = Start.class.getClassLoader().getResourceAsStream("easyrpc.yml");
        return RPCClient.fromYaml(inputStream);
    }

    /**
     * Запуск сервера
     *
     * @throws Exception
     */
    public static void startServer() throws Exception {
        InputStream inputStream = Start.class.getClassLoader().getResourceAsStream("easyrpc.yml");
        RPCServer server = RPCServer.fromYaml(inputStream);
        server.start();
    }
}

# Конфигурация сервера easyrpc
server:
  # Порт прослушивания
  port: 8912
  # Режим потока прослушивания, есть single (однопоточная обработка, выполнение бизнес-логики является атомарным), multi (модель NIO главный-подчиненный, многопоточность, эффективность выше, но пока не реализована)
  thread: multi
  # Класс сериализации сообщений
  serializer: com.codelifeliwan.rpc.core.serializer.DefaultMessageSerializer
  # Зарегистрированный класс, формат: bean-name:bean-class, model (singleton/prototype, по умолчанию singleton)
  beans:
    testBean: com.codelifeliwan.rpc.samples.models.server.SampleDoServerClass
    sortBean: com.codelifeliwan.rpc.samples.models.server.SampleDoSort

# Конфигурация клиента easyrpc
client:
  # Сервер связи, несколько серверов разделяются запятыми, при наличии нескольких серверов будет автоматически распределять нагрузку (случайное значение hash)
  server: localhost:8912
  # Класс сериализации сообщений
  serializer: com.codelifeliwan.rpc.core.serializer.DefaultMessageSerializer
  # Интерфейс, который необходимо создать
  beans:
    testBean: com.codelifeliwan.rpc.samples.models.client.SampleDoClientInterface
    sortBean: com.codelifeliwan.rpc.samples.models.client.SampleSort