- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我想修改 Actix-Web 中的响应主体。我已经实现了 v1.0.0 中间件,但到目前为止我还没有成功更改响应主体。
我已经尝试了两种基本方法:返回一个新的 ServiceResponse
并使用 ServiceResponse
上的方法链来尝试设置一个新的主体。这两种方法都导致了我无法解决的各种编译器错误和移动违规。虽然我是 Rust 的新手,但我团队中的其他成员更有经验,也无法应对这些挑战。我没能找到任何相关的示例。
这是我对 call()
的实现。
fn call(&mut self, req: ServiceRequest) -> Self::Future {
let content_type = req.get_header_value("content-type");
println!(
"Request Started: {}; content type: {};",
req.path(),
content_type
);
Box::new(self.service.call(req).and_then(move |mut res| {
match res.response().error() {
Some(e) => {
println!(
"Response: Error Code: {}; content type: {};",
res.status(),
content_type
);
dbg!(e);
// I'd really like to modify the response body here.
return Ok(res);
}
None => {
println!("Middleware detected the response is not an error. ");
return Ok(res);
}
}
}))
}
我想将响应正文修改为文本“fredbob”。如果我能做到这一点,我就能完成剩下的想做的事情。
use actix_service::{Service, Transform};
use actix_web::http::StatusCode;
use actix_web::{dev::ServiceRequest, dev::ServiceResponse, Error, HttpResponse};
use futures::future::{ok, FutureResult};
use futures::{Future, Poll};
use serde::Serialize;
use serde_json;
pub trait Headers {
fn get_header_value(&self, name: &str) -> String;
}
impl Headers for ServiceRequest {
fn get_header_value(&self, name: &str) -> String {
self.headers()
.get(name)
.unwrap()
.to_str()
.unwrap()
.to_string()
}
}
// There are two step in middleware processing.
// 1. Middleware initialization, middleware factory get called with
// next service in chain as parameter.
// 2. Middleware's call method get called with normal request.
pub struct SayHi;
// Middleware factory is `Transform` trait from actix-service crate
// `S` - type of the next service
// `B` - type of response's body
impl<S, B> Transform<S> for SayHi
where
S: Service<Request = ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
S::Future: 'static,
B: 'static,
{
type Request = ServiceRequest;
type Response = ServiceResponse<B>;
type Error = Error;
type InitError = ();
type Transform = SayHiMiddleware<S>;
type Future = FutureResult<Self::Transform, Self::InitError>;
fn new_transform(&self, service: S) -> Self::Future {
ok(SayHiMiddleware { service })
}
}
pub struct SayHiMiddleware<S> {
service: S,
}
fn is_error(status: StatusCode) -> bool {
status.as_u16() >= 400
}
impl<S, B> Service for SayHiMiddleware<S>
where
S: Service<Request = ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
S::Future: 'static,
B: 'static,
{
type Request = ServiceRequest;
type Response = ServiceResponse<B>;
type Error = Error;
type Future = Box<Future<Item = Self::Response, Error = Self::Error>>;
fn poll_ready(&mut self) -> Poll<(), Self::Error> {
self.service.poll_ready()
}
fn call(&mut self, req: ServiceRequest) -> Self::Future {
let content_type = req.get_header_value("content-type");
println!(
"Request Started: {}; content type: {};",
req.path(),
content_type
);
Box::new(self.service.call(req).and_then(move |mut res| {
match res.response().error() {
Some(e) => {
println!(
"Response: Error Code: {}; content type: {};",
res.status(),
content_type
);
dbg!(e);
// I'd really like to modify the response body here.
return Ok(res);
}
None => {
println!("Middleware detected the response is not an error. ");
return Ok(res);
}
}
}))
}
}
最佳答案
上面发布的解决方案不再适用于更高版本的 Actix。在 4.0.0-beta.14 中,您可以在中间件中通过以下方式捕获请求:
let mut request_body = BytesMut::new();
while let Some(chunk) = req.take_payload().next().await {
request_body.extend_from_slice(&chunk?);
}
let mut orig_payload = Payload::empty();
orig_payload.unread_data(request_body.freeze());
req.set_payload(actix_http::Payload::from(orig_payload));
您可以通过以下方式捕获响应:
let _body_data =
match str::from_utf8(&body::to_bytes(res.into_body()).await?){
Ok(str) => {
str
}
Err(_) => {
"Unknown"
}
};
注意:拉取请求/响应将意味着您使用请求/响应,因此您需要更改它并创建一个新的请求/响应。
然后您可以返回一个新的响应:
let new_request = res.request().clone();
let new_response = HttpResponseBuilder::new(StatusCode::BAD_REQUEST)
.insert_header((header::CONTENT_TYPE, "application/json"))
.body("New body data");
Ok(ServiceResponse::new(
new_request,
new_response
))
我在这里发布了一个完整的例子:
关于rust - 如何修改 actix-web 1.0 中间件中的响应主体?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56449508/
我试图将护照逻辑放入 Controller 文件中,但问题是当我将逻辑放入 Controller 中时,它告诉我“无法读取未定义的属性“主体””,但是当我将代码移至索引时,所有内容都会路由向右走 in
我正在学习 Javascript,我正在尝试创建一个简单的下拉菜单。我想要的功能的一个例子可以在谷歌主页的顶部菜单中看到,带有“更多”和“设置”下拉菜单。具体来说,当您单击关闭菜单时,菜单会消失。 我
我正在努力让 Swagger 正确呈现我的 ServiceStack 服务。 我希望看到一个 UserId 字符串作为表单参数,一个 PrivateCustomer 对象作为主体参数,但是尽管 Use
注意:由于随后的研究,这个问题已经完全重组。 我正在尝试从 Shiro 的主题 PrincipalCollection 中检索值.我在集合中添加了两个主体。 Username和 UUID .当我试图记
我们正在开发一个将 OAuth 2 用于两个用例的应用程序: 访问后端微服务(使用 client_credentials) 验证应用程序的用户(使用 authorization_code ,因此将用户
我有这段代码生成一个将 myNumber 乘以 5 的委托(delegate) ParameterExpression numParam = Expression.Parameter(typeof(i
我有一些jquery, $( document ).ready(function() { body=$(body).html; $("html").html(body); }); 这应
我创建了一个通用异常 DTO,它也扩展了 RuntimeException。通过这种方式,可以在应用程序中使用它,也可以将其用作 DTO。问题是当我将 DTO 应用于 ResponseEntity 构
在 Angular 5 HttpClient 中,我可以通过这种方式设置 HttpParams()。 const body = new HttpParams() .set('email', '
我正在从 RabbitMQ 读取数据,如下所示: connection = factory.newConnection(); ch = connection.createChannel() ; Str
如何使用不同类型的调用和响应主体来改造 PUT?我有一个错误限制。类型必须相同 and 。响应bodie可以包含int值,但call不应该,因为当我用int值初始化CallBody对象时,它已经包
原则上我想做这样的事情: #grab some value from outer source (i.e. file or list defined by another programer) set
我知道如何使用TextureRegions 创建动画并将其应用于非box2d 游戏中的对象。 但是在 libgdx 的 box2d 中,我不知道该怎么做。在CocosD2中,Sprite对象中有run
我有这段代码生成一个将 myNumber 乘以 5 的委托(delegate) ParameterExpression numParam = Expression.Parameter(typeof(i
我已经计算了花括号的数量,但无法弄清楚为什么类主体不完整。每次我试图修复类(class)时,都会把整个类(class)弄乱。问题出在代码中的最后一个类。最后一个花括号给我带来了类里面的麻烦。我正在使用
有人知道吗?我只能看到 ApplyTorque 和 SetAngularVelocity,我只想在将对象添加到模拟之前旋转对象,例如:所以我有一个 crate 倾斜靠在墙上,另一个 crate 是平的
我可以获得如何让图像出现在 box2d 主体上的简单答案吗?我尝试为图像和主体创建 x 和 y int,但是一旦主体移动,图像就会保持静态。如果您确实回答,请尽可能解释一下代码。如果您对我的完整源代码
我知道我可以通过使用 PolygonRegion 来做到这一点,但问题是我使用 scene2d.Stage 和几个 Actor 。您可能知道阶段使用 SpriteBatch 而我无法渲染 Polygo
您好,我有以下代码: function redirect(){ window.location.href='logged_out_chat.php'; } ...在我的标题和以下正文标记中:
我在 didBegin(contact:) 中触发了 SpriteKit 物理接触。我为要移出屏幕的 Dot 对象的实例抓取物理体,但是当我尝试像这样更改其位置时,没有任何反应: 第一种方法 /* I
我是一名优秀的程序员,十分优秀!