Wasm C++ Filter 拓展 Envoy

2024-03-15 12:58
文章标签 c++ 拓展 filter wasm envoy

本文主要是介绍Wasm C++ Filter 拓展 Envoy,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Wasm C++ Filter

这篇博客演示了一个用 C++ 编写的入门 Envoy Wasm Filter,它将返回值注入到 HTTP 响应的 body 中,并且更新与添加 header。

通过该文章完成构建我们的 C++ Wasm Filter 所需的步骤,并使用 Envoy 运行它。

启动所有的应用进程

首先让我们启动容器应用

一个使用 Wasm 过滤器的 Envoy 代理服务,以及一个响应我们请求的后端服务。

克隆下载 envoy

切换到 Envoy 仓库中的 examples/wasm-cc 目录下,运行如下命令:

pwd
envoy/examples/wasm-cc
docker-compose build --pull
docker-compose up -d
docker-compose psName                     Command                State             Ports
-----------------------------------------------------------------------------------------------
wasm_proxy_1         /docker-entrypoint.sh /usr ... Up      10000/tcp, 0.0.0.0:8000->8000/tcp
wasm_web_service_1   node ./index.js                Up

检查 web 响应

向 envoy 代理发出请求时,Wasm 过滤器应该在响应正文的末尾注入“Hello, world”。

过滤器还将内容类型 header 设置为 text/plain,并添加自定义 x-wasm-custom header。

编译一个新的 wasm 可执行二进制文件

Wasm 过滤器提供了两个源代码文件。

envoy_filter_http_wasm_example.cc 提供了包含的预构建二进制文件的源代码。

envoy_filter_http_wasm_updated_example.cc 对原始文件进行了一些更改。

以下差异显示了所做的更改:

--- /tmp/tmp1lcx0q03/generated/rst/start/sandboxes/_include/wasm-cc/envoy_filter_http_wasm_example.cc
+++ /tmp/tmp1lcx0q03/generated/rst/start/sandboxes/_include/wasm-cc/envoy_filter_http_wasm_updated_example.cc
@@ -65,8 +65,8 @@for (auto& p : pairs) {LOG_INFO(std::string(p.first) + std::string(" -> ") + std::string(p.second));}
-  addResponseHeader("X-Wasm-custom", "FOO");
-  replaceResponseHeader("content-type", "text/plain; charset=utf-8");
+  addResponseHeader("X-Wasm-custom", "BAR");
+  replaceResponseHeader("content-type", "text/html; charset=utf-8");removeResponseHeader("content-length");return FilterHeadersStatus::Continue;}
@@ -78,9 +78,9 @@return FilterDataStatus::Continue;}-FilterDataStatus ExampleContext::onResponseBody(size_t body_buffer_length,
+FilterDataStatus ExampleContext::onResponseBody(size_t /* body_buffer_length */,bool /* end_of_stream */) {
-  setBuffer(WasmBufferType::HttpResponseBody, 0, body_buffer_length, "Hello, world\n");
+  setBuffer(WasmBufferType::HttpResponseBody, 0, 17, "Hello, Wasm world");return FilterDataSta

使用 envoyproxy/envoy-build-ubuntu 镜像编译更新的 Wasm 二进制文件。将需要 4-5GB 的磁盘空间来存储该镜像。

停止 envoy 代理服务并使用更新后的代码编译 Wasm 二进制可执行文件: 

docker-compose stop proxy
docker-compose -f docker-compose-wasm.yaml up --remove-orphans wasm_compile_update

 编译后的二进制文件现在应该在 lib 文件夹中。

ls -l lib
total 120
-r-xr-xr-x 1 envoy_filter_http_wasm_example.wasm
-r-xr-xr-x 1 envoy_filter_http_wasm_updated_example.wasm

 编辑 Dockerfile 并重启 Envoy 代理

编辑示例中提供的 Dockerfile-proxy 文件,使用在步骤 3 中创建的更新的二进制文件。

将 Wasm 二进制文件添加到 Dockerfile 中

FROM envoyproxy/envoy-dev:latest
COPY ./envoy.yaml /etc/envoy.yaml
COPY ./lib/envoy_filter_http_wasm_example.wasm /lib/envoy_filter_http_wasm_example.wasm
RUN chmod go+r /etc/envoy.yaml /lib/envoy_filter_http_wasm_example.wasm
CMD ["/usr/local/bin/envoy", "-c", "/etc/envoy.yaml", "--service-cluster", "proxy"]替换 COPY ./lib/envoy_filter_http_wasm_example.wasm /lib/envoy_filter_http_wasm_example.wasm 行COPY ./lib/envoy_filter_http_wasm_updated_example.wasm /lib/envoy_filter_http_wasm_example.wasm

现在重启 Envoy 服务代理

docker-compose up --build -d proxy

检验服务代理是否已被更新

Wasm 过滤器应该在响应主体的末尾注入“Hello, Wasm world”。curl -s http://localhost:8000 | grep "Hello, Wasm world"
}Hello, Wasm worldcontent-type 和 x-wasm-custom header 也应该改变了。curl -v http://localhost:8000 | grep "content-type: "
content-type: text/html; charset=utf-8curl -v http://localhost:8000 | grep "x-wasm-custom: "
x-wasm-custom: BAR

 

 

参考

Envoy Wasm filter

Envoy Wasm API(V3)

Proxy Wasm C++ SDK

这篇关于Wasm C++ Filter 拓展 Envoy的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/812050

相关文章

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen

C++如何通过Qt反射机制实现数据类序列化

《C++如何通过Qt反射机制实现数据类序列化》在C++工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作,所以本文就来聊聊C++如何通过Qt反射机制实现数据类序列化吧... 目录设计预期设计思路代码实现使用方法在 C++ 工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作。由于数据类

Linux下如何使用C++获取硬件信息

《Linux下如何使用C++获取硬件信息》这篇文章主要为大家详细介绍了如何使用C++实现获取CPU,主板,磁盘,BIOS信息等硬件信息,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下... 目录方法获取CPU信息:读取"/proc/cpuinfo"文件获取磁盘信息:读取"/proc/diskstats"文

C++使用printf语句实现进制转换的示例代码

《C++使用printf语句实现进制转换的示例代码》在C语言中,printf函数可以直接实现部分进制转换功能,通过格式说明符(formatspecifier)快速输出不同进制的数值,下面给大家分享C+... 目录一、printf 原生支持的进制转换1. 十进制、八进制、十六进制转换2. 显示进制前缀3. 指

C++中初始化二维数组的几种常见方法

《C++中初始化二维数组的几种常见方法》本文详细介绍了在C++中初始化二维数组的不同方式,包括静态初始化、循环、全部为零、部分初始化、std::array和std::vector,以及std::vec... 目录1. 静态初始化2. 使用循环初始化3. 全部初始化为零4. 部分初始化5. 使用 std::a

C++ vector的常见用法超详细讲解

《C++vector的常见用法超详细讲解》:本文主要介绍C++vector的常见用法,包括C++中vector容器的定义、初始化方法、访问元素、常用函数及其时间复杂度,通过代码介绍的非常详细,... 目录1、vector的定义2、vector常用初始化方法1、使编程用花括号直接赋值2、使用圆括号赋值3、ve

如何高效移除C++关联容器中的元素

《如何高效移除C++关联容器中的元素》关联容器和顺序容器有着很大不同,关联容器中的元素是按照关键字来保存和访问的,而顺序容器中的元素是按它们在容器中的位置来顺序保存和访问的,本文介绍了如何高效移除C+... 目录一、简介二、移除给定位置的元素三、移除与特定键值等价的元素四、移除满足特android定条件的元

Python获取C++中返回的char*字段的两种思路

《Python获取C++中返回的char*字段的两种思路》有时候需要获取C++函数中返回来的不定长的char*字符串,本文小编为大家找到了两种解决问题的思路,感兴趣的小伙伴可以跟随小编一起学习一下... 有时候需要获取C++函数中返回来的不定长的char*字符串,目前我找到两种解决问题的思路,具体实现如下:

C++ Sort函数使用场景分析

《C++Sort函数使用场景分析》sort函数是algorithm库下的一个函数,sort函数是不稳定的,即大小相同的元素在排序后相对顺序可能发生改变,如果某些场景需要保持相同元素间的相对顺序,可使... 目录C++ Sort函数详解一、sort函数调用的两种方式二、sort函数使用场景三、sort函数排序

springboot filter实现请求响应全链路拦截

《springbootfilter实现请求响应全链路拦截》这篇文章主要为大家详细介绍了SpringBoot如何结合Filter同时拦截请求和响应,从而实现​​日志采集自动化,感兴趣的小伙伴可以跟随小... 目录一、为什么你需要这个过滤器?​​​二、核心实现:一个Filter搞定双向数据流​​​​三、完整代码