实测 Tengine 开源的 Dubbo 功能

捉虫大师

关注

发布于: 2021 年 05 月 27 日

本文已收录 https://github.com/lkxiaolou/lkxiaolou 欢迎 star。

背景

Tengine是阿里巴巴基于 Nginx 开发并开源的 Web 服务器，它继承了 Nginx 所有的功能和特性，并在其基础上做了大量的扩展和增强，其中像动态模块加载，四层负载均衡，reuseport 支持等能力，都逐渐被 Nginx 官方吸收引用。Tengine 在开源以后大受欢迎，成为了 Nginx 最好的替代品之一，官方网站（http://tengine.taobao.org/）。
Dubbo是阿里巴巴开源的一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

2019 年 9 月，Tengine 2.3.2 版本发布了dubbo_pass模块，支持 HTTP 协议到 Dubbo 协议的转换。Release 页面如下：

https://github.com/alibaba/tengine/releases/tag/2.3.2

意义

《Gateway技术革命 - Tengine开源Dubbo功能》对 Tengine 支持 Dubbo 协议的意义讲的比较清楚，总结有如下几点：

架构优化：减少一层转发，降低系统复杂度；
性能优势：文中给出数据，“Tengine 直接支持 Dubbo 的架构在 CPU 消耗和 RT 上的表现在不同场景下，有 28%-73%不等的性能优势”

实测

Tengine 环境搭建

这里我用 centos 的基础镜像搭了一套 Tengine 环境，简单说明一下步骤：

mkdir -p /home/roshi && cd /home/roshi/

复制代码

下载相关源码并解压

wget https://github.com/alibaba/tengine/archive/2.3.2.zipunzip 2.3.2.zip && cd tengine-2.3.2/
wget https://ftp.pcre.org/pub/pcre/pcre-8.43.tar.gztar xvf pcre-8.43.tar.gz
wget https://www.openssl.org/source/openssl-1.0.2s.tar.gztar xvf openssl-1.0.2s.tar.gz
wget http://www.zlib.net/zlib-1.2.11.tar.gztar xvf zlib-1.2.11.tar.gz

复制代码

安装相关依赖

yum install gccyum install gcc-c++yum -y install gcc automake autoconf libtool make

复制代码

编译

./configure --add-module=./modules/mod_dubbo --add-module=./modules/ngx_multi_upstream_module --add-module=./modules/mod_config --with-pcre=./pcre-8.43/ --with-openssl=./openssl-1.0.2s/ --with-zlib=./zlib-1.2.11make && make install

复制代码

启动

/usr/local/nginx/sbin/nginx

复制代码

Dubbo 例子

这里要提一下之前在《dubbo应用级服务发现初体验》中提到的快速搭建 Dubbo 调试环境的方法：

git clone https://github.com/apache/dubbo.git
使用/dubbo-demo 目录下的例子，本文使用/dubbo-demo/dubbo-demo-api-provider 下的例子

由于 Tengine 有限制，接口的出参和入参必须是Map<String, Object>，所以需要对例子进行修改：

DemoService

public interface DemoService {
    String sayHello(String name);
    default Map<String, Object> testTengine(Map<String, Object> args) {        return null;    }
    default CompletableFuture<String> sayHelloAsync(String name) {        return CompletableFuture.completedFuture(sayHello(name));    }}

复制代码

DemoServiceImpl.java

public class DemoServiceImpl implements DemoService {    private static final Logger logger = LoggerFactory.getLogger(DemoServiceImpl.class);
    @Override    public String sayHello(String name) {        logger.info("Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());        return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();    }
    @Override    public Map<String, Object> testTengine(Map<String, Object> args) {        Map<String, Object> res = new HashMap<>();        res.put("body", "hello tengine dubbo\n");        res.put("status", "200");        System.out.println("testTengine");        return res;    }
    @Override    public CompletableFuture<String> sayHelloAsync(String name) {        return null;    }
}

复制代码

为了更好的测试多个 provider 的情况，可以用同一份代码，在不同的端口起多个服务。

修改 Tengine 配置

vi /usr/local/nginx/conf/nginx.conf

worker_processes  1;
events {    worker_connections  1024;}
http {    include       mime.types;    default_type  application/octet-stream;
    sendfile        on;
    server {        listen       8080;        server_name  localhost;
        #pass the Dubbo to Dubbo Provider server listening on 127.0.0.1:20880        location / {            dubbo_pass_all_headers on;            # dubbo_pass_set args $args;            dubbo_pass_set args hello;            dubbo_pass_set uri $uri;            dubbo_pass_set method $request_method;
            dubbo_pass org.apache.dubbo.demo.DemoService 0.0.0 testTengine dubbo_backend;        }    }

    #pass the Dubbo to Dubbo Provider server listening on 127.0.0.1:20880    upstream dubbo_backend {        multi 1;        server host.docker.internal:20880;        server host.docker.internal:20881;    }}

复制代码

修改配置后 reload 配置，使其生效

/usr/local/nginx/sbin/nginx -s reload

复制代码

测试

使用如下命令测试

curl -X POST http://127.0.0.1:8080/dubbo -i -d "hello=roshi"

复制代码

看一下传参情况

总结

经过测试，总结以下几点：

接口的出参入参固定为 Map<String, Object>，否则会报错
使用 body 传参，到 Dubbo 侧是 byte[]，还需要解析
可以控制返回的 body 和 http 状态码，其中返回的 body 可以是 String，也可以是 byte[]类型，状态码是 String 类型
具备 Tengine 原生的负载均衡算法
具备故障摘除，Tegine 与 Dubbo Provider 会建立长连接，断开则摘除
未实现 version、group 分组功能，文档中的 version 实测没有任何效果

最后

正如《Gateway技术革命 - Tengine开源Dubbo功能》文中所说，Tengine 只是完成了作为 Dubbo Consumer 的协议支持，像服务发现、自定义接口、服务分组、容错降级等其他功能暂未实现，暂时还离生产有些距离。

最后吐槽一下 Tengine 官网的文档

参考

官方文档 http://tengine.taobao.org/document_cn/ngx_http_dubbo_module_cn.html
官方例子 https://github.com/apache/dubbo-samples/tree/master/dubbo-samples-tengine

搜索关注微信公众号"捉虫大师"，后端技术分享，架构设计、性能优化、源码阅读、问题排查、踩坑实践。

发布于: 2021 年 05 月 27 日阅读数: 873

原文链接:【http://xie.infoq.cn/article/35da7c471e070dafdfb0e760a】。文章转载请联系作者。

捉虫大师

关注

还未添加个人签名 2018.09.19 加入

欢迎关注我的公众号“捉虫大师”

发布

暂无评论

创作场景

实测 Tengine 开源的 Dubbo 功能

背景

意义

实测

Tengine 环境搭建

Dubbo 例子

修改 Tengine 配置

测试

总结

最后

参考

捉虫大师

评论