NaiveRpc

NaiveRpc is a project base on java language development. It is an Rpc(Remote Procedure Call) framework based on Netty, Zookeeper and Spring. Because of the poor level of myself, I call it naiverpc.

Read more

Author	Flying Cat
Email	cat@shiwenhao.gq

Features

Transport in netty
Serialization in kryo
Service register center is ZooKeeper
Support BIO and NO-BIO(similar Class Future<T> in Java) call
Spring integration

Design:

Quick Start

Maven dependency

<dependency>
    <groupId>gq.shiwenhao</groupId>
    <artifactId>naive-rpc</artifactId>
    <version>1.0.0</version>
</dependency>

Demo

NaiveRpc supports can use in api and spring.

Assume there is an interface

package demo.rpc;
public interface SayHello{
    String sayHelloToOne(String one);
}

And next is an implement class.

public class SayHelloImpl implements SayHello{
    @Override
    public String sayHelloToOne(String one){
        return "Hello!" + one;
    }
}

We can use it like this.

API

/*
 * Start Server
 */
ProviderPublisher provider = new ProviderPublisher.Builder("127.0.0.1:2181", 9000,
                SayHello.class, new SayHelloImpl()).build();

/*
 * Start Client
 */
ConsumerProxy consumser = new ConsumerProxy.Builder("127.0.0.1:2181",
                "demo.rpc.SayHello").build();

/*
 * Sync
 */
SayHello sayHello = consumer.callSync();
System.out.println(sayHello.sayHelloToOne("Li Hua"));

/*
 * Async
 */
ProxyFactory proxyFactory = consumerProxy.callAsync();
RpcFuture rpcFuture = proxyFactory.call("sayHelloToOne", new Object[]{"world"});
//Somethind need to do
System.out.println(rpcFuture.get());

Spring

/*
 * Server
 */
 <bean id="springProviderPublisher" class="gq.shiwenhao.naiverpc.endpoint.SpringProviderPublisher">
    <property name="zookeeperHost" value="127.0.0.1:2181"/>
    <property name="interfaceClassName" value="demo.rpc.SayHello"/>
    <property name="interfaceImpl">
       <bean class="SayHelloImpl"/>
    </property>
    <property name="port" value="9000"/>
</bean>

/*
 * Client
 */
 <bean id = "springConsumerProxy" class="gq.shiwenhao.naiverpc.endpoint.SpringConsumerProxy">
     <property name="zookeeperHost" value="127.0.0.1:2181"/>
     <property name="interfaceClassName" value="demo.rpc.SayHello"/>
     <!--property name="async" value="true"-->
 </bean>

 
 /*
  * Sync call (if async is false, default)
  */
SayHello sayHello = (SayHello) beanFactory.getBean("springConsumerProxy");
System.out.println(sayHello.sayHelloToOne("Li Hua"));

/*
 * Async call (if async is true)
 */
ProxyFactory proxyFactory = (ProxyFactory) beanFactory.getBean("springConsumerProxy");
RpcFuture rpcFuture =  proxyFactory.call("sayHelloToOne", new Object[]{"World"});
System.out.print(rpcFuture.get());

It is easy. If you want to know more, please git clone the repositry and observery the test code. It has a demo of using naive-rpc includes api and spring.

Parameter

Client

Property	Parameter	comment
must	ZookeeperHost(String)	Zookeeper server address
must	InterfaceClass(String/Class)	Interface class
optional	LoadBalanceEnum	LoadBalanceEnum.Random,WeightRandom,Polling,WeightPolling，Random Deafult
optional	RetryRequest(Boolean)
optional	RetryTimes(int)
optional	Timeout(int /ms)

Server

Property	Parameter	comment
must	ZookeeperHost(String)	Zookeeper server address
must	port(int)	Listen port
must	InterfaceClass(String/Class)	Interface class
must	InterfaceImpl(Object)	Impl Object
optional	weight(int)	Server load balance weight, Default 1
optional	MaxRequestMessageLength(int)	Default 65535, default is ok

TODO

Optimize parameters set method of Spring
Mock test
Add hash load balance stargegy
Others

License

Apache License, Version 2.0

nzooherd/NaiveRpc