java jsonrpc4j_jsonrpc4j在Java项目间通讯实例讲解【轰隆隆原创】
技术介绍
json-rpc是基于json的跨语言远程调用协议，比xml-rpc、webservice等基于文本的协议传输数据格小；相对hessian、java-rpc等二进制协议便于调试、实现、扩展，是非常优秀的一种远程调用协议。目前主流语言都已有json-rpc的实现框架，java语言中较好的json-rpc实现框架有jsonrpc4j、jpoxy、json-rpc。三者之中jsonrpc4j既可独立使用，又可与spring无缝集合，比较适合于基于spring的项目开发。本文将介绍jsonrpc4j的具体使用。jsonrpc4j为开源项目，源代码和JAR包在网上都可以下载到，为了避免广告嫌疑故略去。
Java服务端配置
web.xml 中添加
JsonRpcServerServlet
com.service.jsonrequest.ServiceJsonRpcServlet
10
JsonRpcServerServlet
/json-Rpc
此处配置的/json-Rpc为客户端请求访问地址。
ServiceJsonRpcServlet的servlet
private JsonRpcServer rpcService = null;
public void init(ServletConfig config) throws ServletException {
super.init(config);
rpcService = new JsonRpcServer(new ReceiveChannel(), ReceiveChannel.class);
}
此处的ReceiveChannel类就是将向客户端展现的类。在service方法中可以对客户端的请求头进行预验证
protected void service(HttpServletRequest req, HttpServletResponse resp){
String UserKey = req.getHeader("UserKey");
//在此可以验证客户端的请求，前提是客户端需要在请求头中加入相应的值，我在后面在讲。
}
接下来我们看ReceiveChannel的实现，ReceiveChannel里面的方法是可以被客户端所能调用的，方法的返回对象是可以被客户端所接收到的，返回的类型可以在客户端进行定义，可以是String,List,int,甚至可以是Java bean对象或者json格式。对于方法的传参，在客户端调用的时候需要设置，以下我以例子为大家讲解
public List> publicQuery(String key1,String key2,String sql) throws Exception{
//在进行业务逻辑处理前，可以对传递过来的参数进行合法性验证。
//有必要的情况下可以对参数进行加密，并在这里解密。
List> list = new ArrayList>();
HashMap hm = new LinkedHashMap();
hm.put("网站名称","轰隆隆小站");
hm.put("网站地址","http://www.honglonglong.com");
list.add(hm);
return list;
}
Java客户端调用
public List> getQueryMap(String sql){
List> list = new ArrayList>();
JsonRpcHttpClient client;
try {
//实例化请求地址，注意服务端web.xml中地址的配置
client = new JsonRpcHttpClient(new URL("http://127.0.0.1:8080/json-Rpc"));
} catch (MalformedURLException e) {
e.printStackTrace();
return list;
}
//请求头中添加的信息
Map headers = new HashMap();
headers.put("UserKey", "www.honglonglong.com");
//添加到请求头中去
client.setHeaders(headers);
try {
//将请求参数封装为数组(注：服务端publicQuery方法的参数个数)
String [] send =new String[3];
send[0]="我是轰隆隆";
send[1]="轰隆隆是我";
send[2]=sql;
long x1=System.currentTimeMillis();
//此处就是向服务端获取数据。publicQuery就是ReceiveChannel对外公开的方法。
list = client.invokes("publicQuery",send);
System.out.println("请求时间："+ (System.currentTimeMillis()-x1)+"毫秒，返回记录数："+list.size()+"条，SQL："+sql);
return list;
} catch (Throwable e) {
e.printStackTrace();
return null;
}
}
接下来我们看一下JsonRpcHttpClient的invokes方法写法
@SuppressWarnings("unchecked")
public T invokes(String methodName, Object argument)throws Throwable {
return (T)invoke(methodName, argument,Type.class.cast(List.class));
}
其中的invoke方法是JsonRpcHttpClient类的原始方法，可以不作处理。
至此，整个请求流程结束，各位可以试着运行，有问题可以随时觅我，本人轰隆隆-小站欢迎大家光临。
因为时间仓促，文章难免有纰漏和不足之处，敬请各位大侠斧正。