public interface DemoService {
  List<User> findAll();

  User find(String name, int age);
}

public class User implements Serializable {
  private static final long serialVersionUID = -7765669138848554424L;

  private String name;
  private int age;

  public static User of(String name, int age) {
    User inst = new User();
    inst.name = name;
    inst.age = age;
    return inst;
  }

  //setter && getter
  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }

  public int getAge() {
    return age;
  }

  public void setAge(int age) {
    this.age = age;
  }

  @Override
  public String toString() {
    return "User{" +
            "name='" + name + '\'' +
            ", age=" + age +
            '}';
  }
}

public class DemoServiceImpl implements DemoService {
  private static final List<User> USERS = Arrays.asList(
          User.of("A", 1),
          User.of("B", 2),
          User.of("C", 3),
          User.of("C", 30),
          User.of("C", 31),
          User.of("C", 32),
          User.of("D", 4),
          User.of("E", 5)
  );

  @Override
  public List<User> findAll() {
    return USERS;
  }

  @Override
  public User find(String name, int age) {
    return USERS.stream()
            .filter(u -> u.getName()
                    .equals(name) && u.getAge() == age)
            .findAny()
            .orElseThrow(() -> new IllegalArgumentException("can not find any user"));
  }
}

public class DemoServiceApplication {
  public static void main(String[] args) throws Exception {
    try {
      KinRpcBootstrap.instance()
              .app(ApplicationConfig.create("demo-provider"))
              .servers(ServerConfig.kinrpc(13000))
              .service(ServiceConfig.create(DemoService.class, new DemoServiceImpl())
                      .serviceName("demo")
                      .weight(2))
              .start();

      System.out.println("demo service started");
      System.in.read();

      Thread.sleep(2_000);
      System.exit(0);
    } finally {
      KinRpcBootstrap.instance()
              .destroy();
    }
  }
}

public class DemoServiceApplication {
  public static void main(String[] args) throws Exception {
    KinRpcBootstrap.instance()
            .registries(RegistryConfig.direct("kinrpc://127.0.0.1:13000/default:demo:0.1.0.0?serialization=jsonb"))
            .app(ApplicationConfig.create("demo-consumer"))
            .consumer(ConsumerConfig.create()
                    .cluster(ClusterType.FAILOVER))
            .reference(ReferenceConfig.create(DemoService.class)
                    .serviceName("demo"))
            .start();

    DemoService demoService = KinRpcBootstrap.instance().reference(DemoService.class);
    System.in.read();
    System.out.println(demoService.findAll());
    System.out.println(demoService.find("A", 1));

    System.in.read();
    KinRpcBootstrap.instance().destroy();
  }
}

@KinRpcService(interfaceClass = DemoService.class, serviceName = "demo")
public class DemoServiceImpl implements DemoService {
  private static final List<User> USERS = Arrays.asList(
          User.of("A", 1),
          User.of("B", 2),
          User.of("C", 3),
          User.of("C", 30),
          User.of("C", 31),
          User.of("C", 32),
          User.of("D", 4),
          User.of("E", 5)
  );

  @Override
  public List<User> findAll() {
    return USERS;
  }

  @Override
  public User find(String name, int age) {
    return USERS.stream()
            .filter(u -> u.getName()
                    .equals(name) && u.getAge() == age)
            .findAny()
            .orElseThrow(() -> new IllegalArgumentException("can not find any user"));
  }
}

@SpringBootApplication
@EnableKinRpc
public class DemoServiceApplication {
  public static void main(String[] args) {
    SpringApplication.run(DemoServiceApplication.class);
  }
}

@RestController()
@RequestMapping("/users")
public class ConsumerController {
  @Autowired
  private DemoService demoService;

  @GetMapping("/findAll")
  public String findAll() {
    return demoService.findAll().toString();
  }

  @GetMapping("/find")
  public String find(@RequestParam("name") String name,
                     @RequestParam("age") int age) {
    return demoService.find(name, age).toString();
  }
}

@SpringBootApplication
@EnableKinRpc
@EnableWebMvc
public class DemoServiceConsumerApplication {
  public static void main(String[] args) {
    SpringApplication.run(DemoServiceConsumerApplication.class);
  }

  @KinRpcReference(serviceName = "demo")
  @Bean
  public KinRpcReferenceBean<DemoService> demoService() {
    return new KinRpcReferenceBean<>(DemoService.class);
  }
}