NettyRpc
An RPC framework based on Netty, ZooKeeper and Spring
中文详情：Chinese Details
Features:
- Simple code and framework
- Non-blocking asynchronous call and Synchronous call support
- Long lived persistent connection
- High availability, load balance and failover
- Service Discovery support by ZooKeeper
Design:
How to use
-
Define an interface:
public interface HelloService { String hello(String name); String hello(Person person); } -
Implement the interface with annotation @RpcService:
@RpcService(HelloService.class) public class HelloServiceImpl implements HelloService { public HelloServiceImpl(){} @Override public String hello(String name) { return "Hello! " + name; } @Override public String hello(Person person) { return "Hello! " + person.getFirstName() + " " + person.getLastName(); } } -
Run zookeeper
For example: zookeeper is running on 127.0.0.1:2181
-
Start server:
Start server with spring: RpcBootstrap
Start server without spring: RpcBootstrapWithoutSpring
-
Use the client:
ServiceDiscovery serviceDiscovery = new ServiceDiscovery("127.0.0.1:2181"); final RpcClient rpcClient = new RpcClient(serviceDiscovery); // Sync call HelloService helloService = rpcClient.create(HelloService.class); String result = helloService.hello("World"); // Async call IAsyncObjectProxy client = rpcClient.createAsync(HelloService.class); RPCFuture helloFuture = client.call("hello", "World"); String result = (String) helloFuture.get(3000, TimeUnit.MILLISECONDS);