public interface HelloService {
String sayHello(String name);
}
public class HelloServiceImpl implements HelloService {
@Override
public String sayHello(String name) {
return "Hello, " + name + "!";
}
}
public class Server {
public static void main(String[] args) {
final ServerConfig serverConfig = new ServerConfig();
serverConfig.setProtocol(RpcProtocol.PROTOCOL_BAIDU_STD);
serverConfig.setPort(8000);
final ServiceRegistry serviceRegistry = new DefaultServiceRegistry();
serviceRegistry.addService(HelloService.class, new HelloServiceImpl());
final Server server = new Server(serviceConfig, serviceRegistry);
server.start();
server.awaitTermination();
}
}
public class Client {
public static void main(String[] args) {
final ClientConfig clientConfig = new ClientConfig();
clientConfig.setProtocol(RpcProtocol.PROTOCOL_BAIDU_STD);
final ServiceDiscoverer serviceDiscoverer = new DefaultServiceDiscoverer();
serviceDiscoverer.setAddress("127.0.0.1:8000");
final Client client = new Client(clientConfig, serviceDiscoverer);
final HelloService helloService = client.createProxy(HelloService.class);
String result = helloService.sayHello("BRPC");
System.out.println(result);
}
}
