public interface HelloService {
String sayHello(String name);
}
public class HelloServiceImpl implements HelloService {
@Override
public String sayHello(String name) {
return "Hello, " + name + "!";
}
}
Eventloop eventloop = Eventloop.create();
RpcServer rpcServer = RpcServer.create(eventloop)
.withMessageTypes(Protocol.HANDLERS)
.withHandler(HelloService.class, new HelloServiceImpl())
.withListenPort(8080);
rpcServer.listen();
eventloop.run();
Eventloop eventloop = Eventloop.create();
RpcClient rpcClient = RpcClient.create(eventloop)
.withMessageTypes(Protocol.HANDLERS)
.withRemoteAddress("localhost", 8080);
RpcProxy helloService = rpcClient.createProxy(HelloService.class);
String result = helloService.sayHello("Alice");
System.out.println(result);
eventloop.run();
