Skip to content

liuzhaozhao/rpc-service

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

39 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

描述

rpc-service是一个基于netty的远程方法调用框架,也可单独提供HTTP服务,HTTP服务是通过JSR-311规范配置

使用方式

假定接口代码为:

public interface IService {
	public String test(int arg);
}

接口实现类代码为:

public class Service implements IService {
	public String test(int arg){
		return "arg="+arg;
	}
}

1. 开启RPC服务

// 在端口8809上开启服务
RpcServer.get().start(8809, Service.class);

2. RPC客户端调用

// 初始化
ServiceFactory.get().init(new String[]{"127.0.0.1:8809"});
// 获取类实例
IService iService = ServiceFactory.get(IService.class);
// 调用方法
iService.test(123);

3. 开启HTTP服务

RPC服务方式用于服务提供方和服务使用方都为java语言时使用,如果服务调用方不为java语言,则服务端往往提供的是HTTP调用方式,以下为开启http服务的方式
对Service类添加http配置注解,添加后的代码为(HTTP服务不需要实现接口):

public class Service {
	@GET @Path("/path")
	public String test(@QueryParam("param") int arg){
		return "arg="+arg;
	}
}

开启服务:

// 在端口8080上开启服务
HttpServer.get().start(8080, Service.class);

客户端通过url:http://localhost:8080/path?param=123 即可获取返回值,默认返回值为json格式

测试

开启服务测试类:rpc.TestServer.java
开启客户端测试类:rpc.TestClient.java、rpc.TestClient2.java

已测试点

  • 泛型对象传输(Serializable、json)
  • 异常客户端抛出,包含服务器端异常、客户端异常
  • 响应超时异常抛出
  • 多线程数据正确性检测
  • 中文编码
  • 通过测试发现,客户端针对一个服务地址建立多个连接跟一个连接在请求并发上没有区别,所以一个服务地址只需要一个连接
  • zookeeper服务管理支持
  • 正在使用中的客户端连接断线重连,重连时获取不同的连接

待完成功能

  • 添加其他序列化支持,目前支持:FST序列化、fastJson
  • 添加安全校验,可标识客户端调用
  • 添加spring支持

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages