D 的个人博客

Java 端作为服务提供者，基于 Dubbo 实现服务并通过 Dubbo Hessian 扩展暴露服务；Node 端作为服务消费者，通过 node-hessian 调用 Java 端的服务。

Java 端

服务接口

package com.yuanxin.paas.ssb;
public interface TestService {
 1/**
 2 * 测试：无参，无返回值。
 3 */
 4void test();
 5
 6/**
 7 * 测试：原生类型参数与返回值。
 8 * 
 9 * @param i
10 * @return 
11 */
12String test0(int i);
13
14/**
15 * 测试：无参，自定义类型返回值。
16 * 
17 * @return 
18 */
19Result test1();
20
21/**
22 * 测试：自定义类型参数，无返回值。
23 * 
24 * @param arg 
25 */
26void test2(Arg arg);
27
28/**
29 * 测试：自定义参数，自定义返回值。
30 * 
31 * @param arg
32 * @return 
33 */
34Result test3(final Arg arg);

}

自定义参数类

package com.yuanxin.paas.ssb;
import java.io.Serializable;
public class Arg implements Serializable {
1private int i;
2
3public int getI() {
4    return i;
5}
6
7public void setI(int i) {
8    this.i = i;
9}

}

自定义返回值类

package com.yuanxin.paas.ssb;
import java.io.Serializable;
public class Result implements Serializable {
 1private int i;
 2
 3private String string;
 4
 5public int getI() {
 6    return i;
 7}
 8
 9public void setI(int i) {
10    this.i = i;
11}
12
13public String getString() {
14    return string;
15}
16
17public void setString(String string) {
18    this.string = string;
19}

}

Dubbo 配置略。

Node 端

node-hessian

安装 node-hessian：

npm install hessian-proxy

调用服务接口

var Proxy = require('hessian-proxy').Proxy;
var proxy = new Proxy('http://127.0.0.1:9098/test-provider/provider/com.yuanxin.paas.ssb.TestService', '', '', proxy);
proxy.invoke('test', null, function (err, reply) {

console.log('test: ' + reply);

});
proxy.invoke('test0', [25], function (err, reply) {

console.log('test0: ' + JSON.stringify(reply));

})
proxy.invoke('test1', null, function (err, reply) {

if (err) {

console.log('test1: ' + err);

}
1console.log('test1: ' + JSON.stringify(reply));

})
var argForTest2 = {

i: 2

};
argForTest2.type = 'com.yuanxin.paas.ssb.Arg';
proxy.invoke('test2', [argForTest2], function (err, reply) {

if (err) {

console.log('test2: ' + err);

}
1console.log('test2: ' + JSON.stringify(reply));

})
var argForTest3 = {

i: 3

};
argForTest3.type = 'com.yuanxin.paas.ssb.Arg';
proxy.invoke('test3', [argForTest3], function (err, reply) {

if (err) {

console.log('test3: ' + err);

}
1console.log('test3: ' + JSON.stringify(reply));

})

运行结果

Java 端

Node 端

总结

Dubbo 非常赞，提供了对 Hessian 原生协议的支持；Node 调用起来也非常简单，不过还是有几个点需要注意一下：

• 接口方法不能重载（接口里的方法必须使用不同的方法名）
• 自定义类型的命名空间服务端与消费端要一致（com.yuanxin.paas.ssb.Arg）
• 服务端自定义类型需要实现序列化接口（java.io.Serializable）
• 尽量使用简单的自定义类型结构（避免嵌套）