视频1 视频21 视频41 视频61 视频文章1 视频文章21 视频文章41 视频文章61 推荐1 推荐3 推荐5 推荐7 推荐9 推荐11 推荐13 推荐15 推荐17 推荐19 推荐21 推荐23 推荐25 推荐27 推荐29 推荐31 推荐33 推荐35 推荐37 推荐39 推荐41 推荐43 推荐45 推荐47 推荐49 关键词1 关键词101 关键词201 关键词301 关键词401 关键词501 关键词601 关键词701 关键词801 关键词901 关键词1001 关键词1101 关键词1201 关键词1301 关键词1401 关键词1501 关键词1601 关键词1701 关键词1801 关键词1901 视频扩展1 视频扩展6 视频扩展11 视频扩展16 文章1 文章201 文章401 文章601 文章801 文章1001 资讯1 资讯501 资讯1001 资讯1501 标签1 标签501 标签1001 关键词1 关键词501 关键词1001 关键词1501 专题2001
Node调用Java的示例代码
2020-11-27 22:29:10 责编:小采
文档


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

Java 端

服务接口

package com.yuanxin.paas.ssb;
 
public interface TestService {
 
 /**
 * 测试:无参,无返回值。
 */
 void test();
 
 /**
 * 测试:原生类型参数与返回值。
 * 
 * @param i
 * @return 
 */
 String test0(int i);
 
 /**
 * 测试:无参,自定义类型返回值。
 * 
 * @return 
 */
 Result test1();
 
 /**
 * 测试:自定义类型参数,无返回值。
 * 
 * @param arg 
 */
 void test2(Arg arg);
 
 /**
 * 测试:自定义参数,自定义返回值。
 * 
 * @param arg
 * @return 
 */
 Result test3(final Arg arg);
}

自定义参数类

package com.yuanxin.paas.ssb;
 
import java.io.Serializable;
 
public class Arg implements Serializable {
 
 private int i;
 
 public int getI() {
 return i;
 }
 
 public void setI(int i) {
 this.i = i;
 }
 
}

自定义返回值类

package com.yuanxin.paas.ssb;
 
import java.io.Serializable;
 
public class Result implements Serializable {
 
 private int i;
 
 private String string;
 
 public int getI() {
 return i;
 }
 
 public void setI(int i) {
 this.i = i;
 }
 
 public String getString() {
 return string;
 }
 
 public void setString(String string) {
 this.string = string;
 }
 
}

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);
 }
 
 console.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);
 }
 
 console.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);
 }
 
 console.log('test3: ' + JSON.stringify(reply));
})

运行结果

Java 端

Node 端

总结

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

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