rust插件支持发送外部请求

[titrxw]

Why do you need it?

Is your feature request related to a problem? Please describe in details
如题

How could it be?

A clear and concise description of what you want to happen. You can explain more about input of the feature, and output of it.

Other related information

Add any other context or screenshots about the feature request here.

[johnlanni]

这块已经有一个初步的实现，不过sdk还在优化中 cc @007gzs

[007gzs]

外部请求是指http_call么？

[titrxw]

@007gzs 是的， 还有就是http_call这个没法同步返回响应结果（body,status）？ 只能走回调？

[jizhuozhi]

受限于envoy的IO模型，wasm是没办法写同步风格的外部调用的（GO也不行）。

之前想过能不能通过JS Promise风格的API来简化外部调用，刚好昨天实现了一个原型， #1377 ，可以看下能不能满足需求http-dispatch-example

[titrxw]

看着可以， 我试试看

[titrxw]

self.http_dispatcher.dispatch(
"httpbin",
vec![
(":method", "GET"),
(":path", "/bytes/1"),
(":authority", "httpbin.org"),
],
None,
vec![],
Duration::from_secs(1)
)

panicked at /Users/rxwyun/Develop/rust/higress/plugins/wasm-rust/src/dispatcher.rs │ │
│ :36:87: │ │
│ called Result::unwrap() on an Err value: BadArgument

BadArgument一般是什么原因?

[jizhuozhi]

这里httpbin是需要envoy有注册过这个cluster，如果没有配置话这里是没办法正确分配的

[007gzs]

参考 https://github.com/alibaba/higress/blob/main/plugins/wasm-rust/src/cluster_wrapper.rs

[titrxw]

经过网关的原始请求的数据包大小超过30K后， 插件里面如果设置cache_response_body为true， 会直接影响原始请求响应的下发。 这个是什么原因？

[007gzs]

经过网关的原始请求的数据包大小超过30K后， 插件里面如果设置cache_response_body为true， 会直接影响原始请求响应的下发。 这个是什么原因？

@johnlanni 网关缓存大小有限制么

[hanxiantao]

经过网关的原始请求的数据包大小超过30K后， 插件里面如果设置cache_response_body为true， 会直接影响原始请求响应的下发。 这个是什么原因？

应该是这个配置 downstream.connectionBufferLimits。可以看下这个文档全局配置说明

[titrxw]

我修改下试试

[titrxw]

可以了，感谢

[jizhuozhi]

可以了，感谢

可以了解下最终形态么，我们也看下怎么优化HTTP调用这块

[cuisongliu]

受限于envoy的IO模型，wasm是没办法写同步风格的外部调用的（GO也不行）。

之前想过能不能通过JS Promise风格的API来简化外部调用，刚好昨天实现了一个原型， #1377 ，可以看下能不能满足需求http-dispatch-example

我记得这个是因为envoy的wasm必须实现ABI协议才行 之前做过尝试应该是不大行的 不知道higress能否脱离这个。 https://github.com/proxy-wasm/spec

[johnlanni]

@cuisongliu 也是遵循这个ABI协议的，你是说基于wasi么，这个在envoy里不太现实。envoy本身有个eventloop，如果用wasi的异步IO，还需要在wasm里再起一个eventloop，两个eventloop之间目前无法联动。

[007gzs]

最新版支持回调模式了，可以看下

higress/plugins/wasm-rust/extensions/demo-wasm/src/lib.rs

Lines 97 to 131 in f8d62a8

	let self_rc = match self.weak.upgrade() {
	Some(rc) => rc.clone(),
	None => {
	self.log.error("self_weak upgrade error");
	return DataAction::Continue;
	}
	};
	let http_call_res = self.http_call(
	&cluster,
	&Method::POST,
	"http://httpbin.org/post",
	MultiMap::new(),
	Some("test_body".as_bytes()),
	Box::new(move |status_code, headers, body| {
	if let Some(this) = self_rc.borrow().downcast_ref::<DemoWasm>() {
	this.log.info(&format!(
	"test_callback status_code:{}, headers: {:?}, body: {}",
	status_code,
	headers,
	format_body(body)
	));
	this.resume_http_request();
	} else {
	self_rc.borrow().resume_http_request();
	}
	}),
	Duration::from_secs(5),
	);
	match http_call_res {
	Ok(_) => DataAction::StopIterationAndBuffer,
	Err(e) => {
	self.log.info(&format!("http_call fail {:?}", e));
	DataAction::Continue
	}
	}