不同的开发语言适合不同的领域,例如 Python 适合做数据分析,C++ 适合做系统的底层开发,假如它们需要用到相同功能的基础组件,组件使用多种语言分别开发的话,不仅增加了开发和维护成本,而且不能确保多种语言间在处理效果上是一致的。本文讲述在 Linux 系统下跨语言调用的实践总结,即开发一次 C++ 语言的组件,其他语言通过跨语言调用技术调用 C++ 组件。
1 背景介绍
查询理解(QU, Query Understanding)是美团搜索的核心模块,主要职责是理解用户查询,生成查询意图、成分、改写等基础信号,应用于搜索的召回、排序、展示等多个环节,对搜索基础体验至关重要。该服务的线上主体程序基于 C++ 语言开发,服务中会加载大量的词表数据、预估模型等,这些数据与模型的离线生产过程有很多文本解析能力需要与线上服务保持一致,从而保证效果层面的一致性,如文本归一化、分词等。
而这些离线生产过程通常用 Python 与 Java 实现。如果在线、离线用不同语言各自开发一份,则很难维持策略与效果上的统一。同时这些能力会有不断的迭代,在这种动态场景下,不断维护多语言版本的效果打平,给我们的日常迭代带来了极大的成本。因此,我们尝试通过跨语言调用动态链接库的技术解决这个问题,即开发一次基于 C++ 的 so,通过不同语言的链接层封装成不同语言的组件库,并投入到对应的生成过程。这种方案的优势非常明显,主体的业务逻辑只需要开发一次,封装层只需要极少量的代码,主体业务迭代升级,其它语言几乎不需要改动,只需要包含最新的动态链接库,发布最新版本即可。同时 C++ 作为更底层的语言,在很多场景下,它的计算效率更高,硬件资源利用率更高,也为我们带来了一些性能上的优势。
本文对我们在实际生产中尝试这一技术方案时,遇到的问题与一些实践经验做了完整的梳理,希望能为大家提供一些参考或帮助。
2 方案概述
为了达到业务方开箱即用的目的,综合考虑 C++、Python、Java 用户的使用习惯,我们设计了如下的协作结构:
3 实现详情
Python、Java 支持调用 C 接口,但不支持调用 C++ 接口,因此对于 C++ 语言实现的接口,必须转换为 C 语言实现。为了不修改原始 C++ 代码,在 C++ 接口上层用 C 语言进行一次封装,这部分代码通常被称为 “胶水代码”(Glue Code)。具体方案如下图所示:
本章节各部分内容如下:
- 【功能代码】部分,通过打印字符串的例子来讲述各语言部分的编码工作。
- 【打包发布】部分,介绍如何将生成的动态库作为资源文件与 Python、Java 代码打包在一起发布到仓库,以降低使用方的接入成本。
- 【业务使用】部分,介绍开箱即用的使用示例。
- 【易用性优化】部分,结合实际使用中遇到的问题,讲述了对于 Python 版本兼容,以及动态库依赖问题的处理方式。
3.1 功能代码
3.1.1 C++ 代码
作为示例,实现一个打印字符串的功能。为了模拟实际的工业场景,对以下代码进行编译,分别生成动态库 libstr_print_cpp.so、静态库 libstr_print_cpp.a。
str_print.h#pragma once #include <string> class StrPrint { public: void print(const std::string& text); }; str_print.cpp #include <iostream> #include "str_print.h" void StrPrint::print(const std::string& text) { std::cout << text << std::endl; }
复制代码3.1.2 c_wrapper 代码
如上文所述,需要对 C++ 库进行封装,改造成对外提供 C 语言格式的接口。
c_wrapper.cpp#include "str_print.h" extern "C" { void str_print(const char* text) { StrPrint cpp_ins; std::string str = text; cpp_ins.print(str); } }
复制代码为了支持 Python 与 Java 的跨语言调用,我们需要对封装好的接口生成动态库,生成动态库的方式有以下三种
- 方式一:源码依赖方式,将 c_wrapper 和 C++ 代码一起编译生成 libstr_print.so。这种方式业务方只需要依赖一个 so,使用成本较小,但是需要获取到源码。对于一些现成的动态库,可能不适用。
g++ -o libstr_print.so str_print.cpp c_wrapper.cpp -fPIC -shared
复制代码- 方式二:动态链接方式,这种方式生成的 libstr_print.so,发布时需要携带上其依赖库 libstr_print_cpp.so。 这种方式,业务方需要同时依赖两个 so,使用的成本相对要高,但是不必提供原动态库的源码。
g++ -o libstr_print.so c_wrapper.cpp -fPIC -shared -L. -lstr_print_cpp
复制代码- 方式三:静态链接方式,这种方式生成的 libstr_print.so,发布时无需携带上 libstr_print_cpp.so。 这种方式,业务方只需依赖一个 so,不必依赖源码,但是需要提供静态库。
g++ c_wrapper.cpp libstr_print_cpp.a -fPIC -shared -o libstr_print.so
复制代码3.1.4 Python 接入代码
Python 标准库自带的 ctypes 可以实现加载 C 的动态库的功能,使用方法如下:
str_print.py
# -*- coding: utf-8 -*-import ctypes # 加载 C lib lib = ctypes.cdll.LoadLibrary("./libstr_print.so") # 接口参数类型映射 lib.str_print.argtypes = [ctypes.c_char_p] lib.str_print.restype = None # 调用接口 lib.str_print('Hello World')
复制代码3.1.5 Java 接入代码
Java 调用 C lib 有 JNI 与 JNA 两种方式,从使用便捷性来看,更推荐 JNA 方式。
3.1.5.1 JNI 接入
Java 从 1.1 版本开始支持 JNI 接口协议,用于实现 Java 语言调用 C/C++ 动态库。JNI 方式下,前文提到的 c_wrapper 模块不再适用,JNI 协议本身提供了适配层的接口定义,需要按照这个定义进行实现。JNI 方式的具体接入步骤为:
Java 代码里,在需要跨语言调用的方法上,增加 native 关键字,用以声明这是一个本地方法。
import java.lang.String;public class JniDemo { public native void print(String text); }
复制代码javah JniDemo
复制代码#include <jni.h>#ifdef __cplusplus extern "C" { #endif JNIEXPORT void JNICALL Java_JniDemo_print (JNIEnv *, jobject, jstring); #ifdef __cplusplus } #endif
复制代码JNIEXPORT 和 JNICALL 是 JNI 中定义的两个宏,JNIEXPORT 标识了支持在外部程序代码中调用该动态库中的方法,JNICALL 定义了函数调用时参数的入栈出栈约定。
Java_JniDemo_print 是一个自动生成的函数名,它的格式是固定的由 Java_{className}_{methodName} 构成,JNI 会按照这个约定去注册 Java 方法与 C 函数的映射。
三个参数里,前两个是固定的。JNIEnv 中封装了 jni.h 里的一些工具方法,jobject 指向 Java 中的调用类,即 JniDemo,通过它可以找到 Java 里 class 中的成员变量在 C 的堆栈中的拷贝。 jstring 指向传入参数 text,这是对于 Java 中 String 类型的一个映射。有关类型映射的具体内容,会在后文详细展开。
编写实现 Java_JniDemo_print 方法。
JniDemo.cpp
#include <string>#include "JniDemo.h" #include "str_print.h" JNIEXPORT void JNICALL Java_JniDemo_print (JNIEnv *env, jobject obj, jstring text) { char* str=(char*)env->GetStringUTFChars(text,JNI_FALSE); std::string tmp = str; StrPrint ins; ins.print(tmp); }
复制代码g++ -o libJniDemo.so JniDemo.cpp str_print.cpp -fPIC -shared -I<$JAVA_HOME>/include/ -I<$JAVA_HOME>/include/linux
java -Djava.library.path=<path_to_libJniDemo.so> JniDemo
复制代码3.1.5.2 JNA 接入
JNA 是在 JNI 基础上实现的编程框架,它提供了 C 语言动态转发器,实现了 Java 类型到 C 类型的自动转换。因此,Java 开发人员只要在一个 Java 接口中描述目标 native library 的函数与结构,不再需要编写任何 Native/JNI 代码,极大的降低了 Java 调用本地共享库的开发难度。
JNA 的使用方法如下:
在 Java 项目中引入 JNA 库。
<dependency> <groupId>com.sun.jna</groupId> <artifactId>jna</artifactId> <version>5.4.0</version> </dependency>
复制代码public interface CLibrary extends Library { void str_print(String text); // 方法名和动态库接口一致,参数类型需要用Java里的类型表示,执行时会做类型映射,原理介绍章节会有详细解释 }
复制代码JnaDemo.java
package com.jna.demo;import com.sun.jna.Library; import com.sun.jna.Native; public class JnaDemo { private CLibrary cLibrary; public interface CLibrary extends Library { void str_print(String text); } public JnaDemo() { cLibrary = Native.load("str_print", CLibrary.class); } public void str_print(String text) { cLibrary.str_print(text); } }
复制代码3.2 打包发布
为了做到开箱即用,我们将动态库与对应语言代码打包在一起,并自动准备好对应依赖环境。这样使用方只需要安装对应的库,并引入到工程中,就可以直接开始调用。这里需要解释的是,我们没有将 so 发布到运行机器上,而是将其和接口代码一并发布至代码仓库,原因是我们所开发的工具代码可能被不同业务、不同背景(非 C++)团队使用,不能保证各个业务方团队都使用统一的、标准化的运行环境,无法做到 so 的统一发布、更新。
3.2.1 Python 包发布
Python 可以通过 setuptools 将工具库打包,发布至 pypi 公共仓库中。具体操作方法如下:
创建目录。
. ├── MANIFEST.in #指定静态依赖 ├── setup.py # 发布配置的代码 └── strprint # 工具库的源码目录 ├── __init__.py # 工具包的入口 └── libstr_print.so # 依赖的c_wrapper 动态库 编写__init__.py, 将上文代码封装成方法。
# -*- coding: utf-8 -*- import ctypes import os import sys dirname, _ = os.path.split(os.path.abspath(__file__)) lib = ctypes.cdll.LoadLibrary(dirname + "/libstr_print.so") lib.str_print.argtypes = [ctypes.c_char_p] lib.str_print.restype = None def str_print(text): lib.str_print(text)
复制代码 from setuptools import setup, find_packages setup( name="strprint", version="1.0.0", packages=find_packages(), include_package_data=True, description='str print', author='xxx', package_data={ 'strprint': ['*.so'] }, )
复制代码include strprint/libstr_print.so
复制代码python setup.py sdist upload
复制代码对于 Java 接口,将其打包成 JAR 包,并发布至 Maven 仓库中。
编写封装接口代码 JnaDemo.java。
package com.jna.demo; import com.sun.jna.Library; import com.sun.jna.Native; import com.sun.jna.Pointer; public class JnaDemo { private CLibrary cLibrary; public interface CLibrary extends Library { Pointer create(); void str_print(String text); } public static JnaDemo create() { JnaDemo jnademo = new JnaDemo(); jnademo.cLibrary = Native.load("str_print", CLibrary.class); //System.out.println("test"); return jnademo; } public void print(String text) { cLibrary.str_print(text); } }
复制代码通过打包插件,将依赖的库一并打包到 JAR 包中。
<plugin> <artifactId>maven-assembly-plugin</artifactId> <configuration> <appendAssemblyId>false</appendAssemblyId> <descriptorRefs> <descriptorRef>jar-with-dependencies</descriptorRef> </descriptorRefs> </configuration> <executions> <execution> <id>make-assembly</id> <phase>package</phase> <goals> <goal>assembly</goal> </goals> </execution> </executions> </plugin>
复制代码3.3.1 Python 使用
安装 strprint 包。
pip install strprint==1.0.0
复制代码 # -*- coding: utf-8 -*- import sys from strprint import * str_print('Hello py')
复制代码 <dependency> <groupId>com.jna.demo</groupId> <artifactId>jnademo</artifactId> <version>1.0</version> </dependency>
复制代码 JnaDemo jnademo = new JnaDemo(); jnademo.str_print("hello jna");
复制代码3.4.1 Python 版本兼容
Python2 与 Python3 版本的问题,是 Python 开发用户一直诟病的槽点。因为工具面向不同的业务团队,我们没有办法强制要求使用统一的 Python 版本,但是我们可以通过对工具库做一下简单处理,实现两个版本的兼容。Python 版本兼容里,需要注意两方面的问题:
- 语法兼容
- 数据编码
# -*- coding: utf-8 -*-import ctypes import os import sys dirname, _ = os.path.split(os.path.abspath(__file__)) lib = ctypes.cdll.LoadLibrary(dirname + "/libstr_print.so") lib.str_print.argtypes = [ctypes.c_char_p] lib.str_print.restype = None def is_python3(): return sys.version_info[0] == 3 def encode_str(input): if is_python3() and type(input) is str: return bytes(input, encoding='utf8') return input def decode_str(input): if is_python3() and type(input) is bytes: return input.decode('utf8') return input def str_print(text): lib.str_print(encode_str(text))
复制代码在很多情况下,我们调用的动态库,会依赖其它动态库,比如当我们依赖的 gcc/g++ 版本与运行环境上的不一致时,时常会遇到 glibc_X.XX not found 的问题,这时需要我们提供指定版本的 libstdc.so 与 libstdc++.so.6。
为了实现开箱即用的目标,在依赖并不复杂的情况下,我们会将这些依赖也一并打包到发布包里,随工具包一起提供。对于这些间接依赖,在封装的代码里,并不需要显式的 load,因为 Python 与 Java 的实现里,加载动态库,最终调用的都是系统函数 dlopen。这个函数在加载目标动态库时,会自动的加载它的间接依赖。所以我们所需要做的,就只是将这些依赖放置到 dlopen 能够查找到路径下。
dlopen 查找依赖的顺序如下:
- 从 dlopen 调用方 ELF (Executable and Linkable Format) 的 DT_RPATH 所指定的目录下寻找,ELF 是 so 的文件格式,这里的 DT_RPATH 是写在动态库文件的,常规手段下,我们无法修改这个部分。
- 从环境变量 LD_LIBRARY_PATH 所指定的目录下寻找,这是最常用的指定动态库路径的方式。
- 从 dlopen 调用方 ELF 的 DT_RUNPATH 所指定的目录下寻找,同样是在 so 文件中指定的路径。
- 从 /etc/ld.so.cache 寻找,需要修改 /etc/ld.so.conf 文件构建的目标缓存,因为需要 root 权限,所以在实际生产中,一般很少修改。
- 从 /lib 寻找, 系统目录,一般存放系统依赖的动态库。
- 从 /usr/lib 寻找,通过 root 安装的动态库,同样因为需要 root 权限,生产中,很少使用。
最后,在 Java 中还有一个细节需要注意,我们发布的工具包是以 JAR 包形式提供,JAR 包本质上是一个压缩包,在 Java 程序中,我们能够直接通过 Native.load() 方法,直接加载位于项目 resources 目录里的 so,这些资源文件打包后,会被放到 JAR 包中的根目录。
但是 dlopen 无法加载这个目录。对于这一问题,最好的方案可以参考【2.1.3 生成动态库】一节中的打包方法,将依赖的动态库合成一个 so,这样无须做任何环境配置,开箱即用。但是对于诸如 libstdc++.so.6 等无法打包在一个 so 的中系统库,更为通用的做法是,在服务初始化时将 so 文件从 JAR 包中拷贝至本地某个目录,并指定 LD_LIBRARY_PATH 包含该目录。
4. 原理介绍
4.1 为什么需要一个 c_wrapper
实现方案一节中提到 Python/Java 不能直接调用 C++ 接口,要先对 C++ 中对外提供的接口用 C 语言的形式进行封装。这里根本原因在于使用动态库中的接口前,需要根据函数名查找接口在内存中的地址,动态库中函数的寻址通过系统函数 dlsym 实现,dlsym 是严格按照传入的函数名寻址。
在 C 语言中,函数签名即为代码函数的名称,而在 C++ 语言中,因为需要支持函数重载,可能会有多个同名函数。为了保证签名唯一,C++ 通过 name mangling 机制为相同名字不同实现的函数生成不同的签名,生成的签名会是一个像__Z4funcPN4printE 这样的字符串,无法被 dlsym 识别(注:Linux 系统下可执行程序或者动态库多是以 ELF 格式组织二进制数据,其中所有的非静态函数 (non-static) 以 “符号 (symbol)” 作为唯一标识,用于在链接过程和执行过程中区分不同的函数,并在执行时映射到具体的指令地址,这个 “符号” 我们通常称之为函数签名)。
为了解决这个问题,我们需要通过 extern "C" 指定函数使用 C 的签名方式进行编译。因此当依赖的动态库是 C++ 库时,需要通过一个 c_wrapper 模块作为桥接。而对于依赖库是 C 语言编译的动态库时,则不需要这个模块,可以直接调用。
4.2 跨语言调用如何实现参数传递
C/C++ 函数调用的标准过程如下:
- 在内存的栈空间中为被调函数分配一个栈帧,用来存放被调函数的形参、局部变量和返回地址。
- 将实参的值复制给相应的形参变量(可以是指针、引用、值拷贝)。
- 控制流转移到被调函数的起始位置,并执行。
- 控制流返回到函数调用点,并将返回值给到调用方,同时栈帧释放。
由于 Python/Java 的调用过程基本一致,我们以 Java 的调用过程为例来进行解释,对于 Python 的调用过程不再赘述。
4.2.1 内存管理
在 Java 的世界里,内存由 JVM 统一进行管理,JVM 的内存由栈区、堆区、方法区构成,在较为详细的资料中,还会提到 native heap 与 native stack,其实这个问题,我们不从 JVM 的角度去看,而是从操作系统层面出发来理解会更为简单直观。以 Linux 系统下为例,首先 JVM 名义上是一个虚拟机,但是其本质就是跑在操作系统上的一个进程,因此这个进程的内存会存在如下左图所示划分。而 JVM 的内存管理实质上是在进程的堆上进行重新划分,自己又 “虚拟” 出 Java 世界里的堆栈。如右图所示,native 的栈区就是 JVM 进程的栈区,进程的堆区一部分用于 JVM 进行管理,剩余的则可以给 native 方法进行分配使用。
4.2.2 调用过程
前文提到,native 方法调用前,需要将其所在的动态库加载到内存中,这个过程是利用 Linux 的 dlopen 实现的,JVM 会把动态库中的代码片段放到 Native Code 区域,同时会在 JVM Bytecode 区域保存一份 native 方法名与其所在 Native Code 里的内存地址映射。
一次 native 方法的调用步骤,大致分为四步:
- 从 JVM Bytecode 获取 native 方法的地址。
- 准备方法所需的参数。
- 切换到 native 栈中,执行 native 方法。
- native 方法出栈后,切换回 JVM 方法,JVM 将结果拷贝至 JVM 的栈或堆中。
由上述步骤可以看出,native 方法的调用同样涉及参数的拷贝,并且其拷贝是建立在 JVM 堆栈和原生堆栈之间。
对于原生数据类型,参数是通过值拷贝方式与 native 方法地址一起入栈。而对于复杂数据类型,则需要一套协议,将 Java 中的 object 映射到 C/C++ 中能识别的数据字节。原因是 JVM 与 C 语言中的内存排布差异较大,不能直接内存拷贝,这些差异主要包括:
- 类型长度不同,比如 char 在 Java 里为 16 字节,在 C 里面却是 8 个字节。
- JVM 与操作系统的字节顺序(Big Endian 还是 Little Endian)可能不一致。
- JVM 的对象中,会包含一些 meta 信息,而 C 里的 struct 则只是基础类型的并列排布,同样 Java 中没有指针,也需要进行封装和映射。
上图展示了 native 方法调用过程中参数传递的过程,其中映射拷贝在 JNI 中是由 C/C++ 链接部分的胶水代码实现,类型的映射定义在 jni.h 中。
Java 基本类型与 C 基本类型的映射(通过值传递。将 Java 对象在 JVM 内存里的值拷贝至栈帧的形参位置):
typedef unsigned char jboolean;typedef unsigned short jchar; typedef short jshort; typedef float jfloat; typedef double jdouble; typedef jint jsize;
复制代码typedef _jobject *jobject;typedef _jclass *jclass; typedef _jthrowable *jthrowable; typedef _jstring *jstring; typedef _jarray *jarray;
复制代码class _jobject {};class _jclass : public _jobject {}; class _jthrowable : public _jobject {}; class _jarray : public _jobject {}; class _jcharArray : public _jarray {}; class _jobjectArray : public _jarray {};
复制代码整个调用过程,产生的内存拷贝,Java 中的对象由 JVM 的 GC 进行清理,Native Heap 中的对象如果是由 JNI 框架分配生成的,如上文 JNI 示例中的参数,均由框架进行统一释放。而在 C/C++ 中新分配的对象,则需要用户代码在 C/C++ 中手动释放。简而言之,Native Heap 中与普通的 C/C++ 进程一致,没有 GC 机制的存在,并且遵循着谁分配谁释放的内存治理原则。
4.3 扩展阅读(JNA 直接映射)
相比于 JNI,JNA 使用了其函数调用的基础框架,其中的内存映射部分,由 JNA 工具库中的工具类自动化的完成类型映射和内存拷贝的大部分工作,从而避免大量胶水代码的编写,使用上更为友好,但相应的这部分工作则产生了一些性能上的损耗。
JNA 还额外提供了一种 “直接映射”(DirectMapping) 的调用方式来弥补这一不足。但是直接映射对于参数有着较为严格的限制,只能传递原生类型、对应数组以及 Native 引用类型,并且不支持不定参数,方法返回类型只能是原生类型。
直接映射的 Java 代码中需要增加 native 关键字,这与 JNI 的写法一致。
DirectMapping 示例
import com.sun.jna.*;public class JnaDemo { public static native double cos(DoubleByReference x); static { Native.register(Platform.C_LIBRARY_NAME); } public static void main(String[] args) { System.out.println(cos(new DoubleByReference(1.0))); } } DoubleByReference 即是双精度浮点数的 Native 引用类型的实现,它的 JNA 源码定义如下(仅截取相关代码): //DoubleByReference public class DoubleByReference extends ByReference { public DoubleByReference(double value) { super(8); setValue(value); } } // ByReference public abstract class ByReference extends PointerType { protected ByReference(int dataSize) { setPointer(new Memory(dataSize)); } }
复制代码在 ByReference 的对象释放时,调用 free,释放该内存。JNA 的源码中 ByReference 基类的 finalize 方法会在 GC 时调用,此时会去释放对应申请的内存。因此在 JNA 的实现中,动态库中的分配的内存由动态库的代码管理,JNA 框架分配的内存由 JNA 中的代码显示释放,但是其触发时机,则是靠 JVM 中的 GC 机制释放 JNA 对象时来触发运行。这与前文提到的 Native Heap 中不存在 GC 机制,遵循谁分配谁释放的原则是一致的。
@Overrideprotected void finalize() { dispose(); } /** Free the native memory and set peer to zero */ protected synchronized void dispose() { if (peer == 0) { // someone called dispose before, the finalizer will call dispose again return; } try { free(peer); } finally { peer = 0; // no null check here, tracking is only null for SharedMemory // SharedMemory is overriding the dispose method reference.unlink(); } }
复制代码提高运算效率是 Native 调用中的一个重要目的,但是经过上述分析也不难发现,在一次跨语言本地化的调用过程中,仍然有大量的跨语言工作需要完成,这些过程也需要支出对应的算力。因此并不是所有 Native 调用,都能提高运算效率。为此我们需要理解语言间的性能差异在哪儿,以及跨语言调用需要耗费多大的算力支出。
语言间的性能差异主要体现在三个方面:
- Python 与 Java 语言都是解释执行类语言,在运行时期,需要先把脚本或字节码翻译成二进制机器指令,再交给 CPU 进行执行。而 C/C++ 编译执行类语言,则是直接编译为机器指令执行。尽管有 JIT 等运行时优化机制,但也只能一定程度上缩小这一差距。
- 上层语言有较多操作,本身就是通过跨语言调用的方式由操作系统底层实现,这一部分显然不如直接调用的效率高。
- Python 与 Java 语言的内存管理机制引入了垃圾回收机制,用于简化内存管理,GC 工作在运行时,会占用一定的系统开销。这一部分效率差异,通常以运行时毛刺的形态出现,即对平均运行时长影响不明显,但是对个别时刻的运行效率造成较大影响。
- 对于 JNA 这种由动态代理实现的跨语言调用,在调用过程中存在堆栈切换、代理路由等工作。
- 寻址与构造本地方法栈,即将 Java 中 native 方法对应到动态库中的函数地址,并构造调用现场的工作。
- 内存映射,尤其存在大量数据从 JVM Heap 向 Native Heap 进行拷贝时,这部分的开销是跨语言调用的主要耗时所在。
由实验数据可知,运行效率依次是 C > Java > JNI > JNA DirectMapping > JNA。 C 语言高于 Java 的效率,但两者非常接近。JNI 与 JNA DirectMapping 的方式性能基本一致,但是会比原生语言的实现要慢很多。普通模式下的 JNA 的速度最慢,会比 JNI 慢 5 到 6 倍。
综上所述,跨语言本地化调用,并不总是能够提升计算性能,需要综合计算任务的复杂度和跨语言调用的耗时进行综合权衡。我们目前总结到的适合跨语言调用的场景有:
- 离线数据分析:离线任务可能会涉及到多种语言开发,且对耗时不敏感,核心点在于多语言下的效果打平,跨语言调用可以节省多语言版本的开发成本。
- 跨语言 RPC 调用转换为跨语言本地化调用:对于计算耗时是微秒级以及更小的量级的计算请求,如果通过 RPC 调用来获得结果,用于网络传输的时间至少是毫秒级,远大于计算开销。在依赖简单的情况下,转化为本地化调用,将大幅缩减单请求的处理时间。
- 对于一些复杂的模型计算,Python/Java 跨语言调用 C++ 可以提升计算效率。
5 应用案例
如上文所述,通过本地化调用的方案能够在性能和开发成本上带来一些收益。我们将这些技术在离线任务计算与实时服务调用做了一些尝试,并取得了比较理想的结果。
5.1 离线任务中的应用
搜索业务中会有大量的词表挖掘、数据处理、索引构建等离线计算任务。这个过程会用到较多查询理解里的文本处理和识别能力,如分词、名命体识别等。因为开发语言的差异,将这些能力在本地重新开发一遍,成本上无法接受。因此之前的任务中,在离线计算过程中会通过 RPC 方式调用线上服务。这个方案带来如下问题:
- 离线计算任务的量级通常较大,执行过程中请求比较密集,会占用占用线上资源,影响线上用户请求,安全性较低。
- 单次 RPC 的耗时至少是毫秒级,而实际的计算时间往往非常短,因此大部分时间实际上浪费在了网络通信上,严重影响任务的执行效率。
- RPC 服务因为网络抖动等因为,调用成功率不能达到 100%,影响任务执行效果。
- 离线任务需引入 RPC 调用相关代码,在 Python 脚本等轻量级计算任务里,这部分的代码往往因为一些基础组件的不完善,导致接入成本较高。
将 RPC 调用改造为跨语言本地化调用后,上述问题得以解决,收益明显。
- 不再调用线上服务,流量隔离,对线上安全不产生影响。
- 对于 1000 万条以上的离线任务,累计节省至少 10 小时以上的网络开销时间。
- 消除网络抖动导致的请求失败问题。
- 通过上述章节的工作,提供了开箱即用的本地化工具,极大的简化了使用成本。
5.2 在线服务中的应用
查询理解作为美团内部的基础服务平台,提供分词词性、查询纠错、查询改写、地标识别、异地识别、意图识别、实体识别、实体链接等文本分析,是一个较大的 CPU 密集型服务,承接了公司内非常多的本文分析业务场景,其中有部分场景只是需要个别信号,甚至只需要查询理解服务中的基础函数组件,对于大部分是通过 Java 开发的业务服务,无法直接引用查询理解的 C++ 动态库,此前一般是通过 RPC 调用获取结果。通过上述工作,在非 C++ 语言的调用方服务中,可以将 RPC 调用转化为跨语言本地化调用,能够明显的提升调用端的性能以及成功率,同时也能有效减少服务端的资源开销。
6 总结
微服务等技术的发展使得服务创建、发布和接入变得越来越简单,但是在实际工业生产中,并非所有场景都适合通过 RPC 服务完成计算。尤其在计算密集型和耗时敏感型的业务场景下,当性能成为瓶颈时,远程调用带来的网络开销就成了业务不可承受之痛。本文对语言本地化调用的技术进行了总结,并给出一些实践经验,希望能为大家解决类似的问题提供一些帮助。
当然,本次工作中还有许多不足,例如因为实际生产环境的要求,我们的工作基本都集中在 Linux 系统下,如果是以开放库形式,让使用方可以自由使用的话,可能还需要考虑兼容 Windows 下的 DLL,Mac OS 下的 dylib 等等。本文可能还存在其他不足之处,欢迎大家指留言指正、探讨。
本文例子的源代码请访问:GitHub。 https://github.com/linyang02/python_java_on_cpp
7 参考文献
- JNI 内存相关文档 https://www.zhihu.com/question/438698030/answer/1670533755
- JNI 类型映射 https://docs.oracle.com/javase/7/docs/technotes/guides/jni/spec/types.html#wp914
- JNA 开源地址 https://github.com/java-native-access/jna
- Linux dlopen https://man7.org/linux/man-pages/man3/dlopen.3.html
- Linux dlclose https://man7.org/linux/man-pages/man3/dlclose.3p.html
- Linux dlsym https://man7.org/linux/man-pages/man3/dlsym.3.html
- CPython 源码 https://github.com/python/cpython
- CPython 中 ctypes 的介绍 https://docs.python.org/zh-cn/3/library/ctypes.html#
- CTypes Struct 实现 https://blog.csdn.net/mergerly/article/details/76858589
- Python 项目分发打包 https://zhuanlan.zhihu.com/p/276461821
- C 与 C++ 函数签名 https://blog.csdn.net/lwj1396/article/details/5204484
- JNI,JNA 与 JNR 性能对比 https://blog.csdn.net/weixin_34288121/article/details/88722310
8 本文作者
林阳、朱超、识瀚,均来自美团平台 / 搜索与 NLP 部 / 搜索技术部。