Actix-Web 2.0 JsonConfig error_handler无法正常工作

如何解决Actix-Web 2.0 JsonConfig error_handler无法正常工作

我有以下代码,一切正常,期望error_handler。我不知道怎么了。如果我以正确的格式发出过帐请求,则会得到200份响应数据。但是在错误的请求下,我希望400的Json数据无法接收。它只是说400,但不返回任何错误json数据。

预期行为

BAD REQ-> curl -X POST -H“ Content-Type:application / json” -d'{“ bad”:“有人在这里”}}'localhost:8080 / send

status 400
{
    error: String,server_id: usize,request_count: usize,}

当前行为

BAD REQ-> curl -X POST -H“ Content-Type:application / json” -d'{“ bad”:“有人在这里”}'localhost:8080 / send 状态400

可能的解决方案

我用.data取代了.app_data,但是它找不到AppState

代码

    pub struct MessageApp {
        pub port: u16,}

    impl MessageApp {
        pub fn new(port: u16) -> Self {
            Self{port}
        }

        pub async fn run(&self) -> std::io::Result<()> {
            let messages = Arc::new(Mutex::new(vec![]));
            println!("Starting http server: 127.0.0.1:{}",self.port);

            HttpServer::new(move || {
                App::new()
                    .data(AppState {
                        server_id: SERVER_COUNTER.fetch_add(1,Ordering::SeqCst),request_count: Cell::new(0),messages: messages.clone(),})
                    .wrap(middleware::Logger::new(LOG_FORMAT))
                    .service(index)
                    .service(
                        web::resource("/send")
                        .data(
                            web::JsonConfig::default()
                                .limit(4096)
                                .error_handler(post_error)
                        )
                        .route(web::post().to(post))
                    )
                    .service(clear)
            })
            .bind(("127.0.0.1",self.port))?
            .workers(8)
            .run()
            .await
        }
    }

错误处理程序

    fn post_error(err: JsonPayloadError,req: &HttpRequest) -> Error {
        let extns = req.extensions();
        let state = extns.get::<web::Data<AppState>>().unwrap();
        let request_count = state.request_count.get() + 1;
        state.request_count.set(request_count);

      let post_error = PostError {
          server_id: state.server_id,request_count,error: format!("{}",err),};

      InternalError::from_response(err,HttpResponse::BadRequest().json(post_error)).into()
    }

上下文

我只是想学习Actix

您的环境

  • Pop OS 20.04 LTS
  • Rust版本:rustc 1.45.2(d3fb005a3 2020-07-31)
  • Actix Web版本:2.0.0

解决方法

正如我之前在可能的解决方案中所述。

在github上获得作者的帮助后。他提到我需要移出.app_data才能解决此问题,或移至解决此问题的新版本3.0。

但是使用下面的2.0.0版本是解决方案:

HttpServer::new(move || {
            App::new()
                .data(AppState {
                    server_id: SERVER_COUNTER.fetch_add(1,Ordering::SeqCst),request_count: Cell::new(0),messages: messages.clone(),})
                .wrap(middleware::Logger::new(LOG_FORMAT))
                .service(index)
                .service(
                    web::resource("/send")
                    .app_data(
                        web::JsonConfig::default().limit(4096).error_handler(post_error)
                    )
                    .route(web::post().to(post))
                )
                .service(clear)
        })
        .bind(("127.0.0.1",self.port))?
        .workers(8)
        .run()
        .await

我提取AppState的方法也做错了。该问题已在 post_error 函数内部固定在下面。

fn post_error(err: JsonPayloadError,req: &HttpRequest) -> Error {
    // let extns = req.extensions();
    // let state = extns.get::<web::Data<AppState>>().unwrap();
    let state = req.app_data::<web::Data<AppState>>().unwrap();
    let request_count = state.request_count.get() + 1;
    state.request_count.set(request_count);

    let post_error = PostError {
        server_id: state.server_id,request_count,error: format!("{}",err),};

    InternalError::from_response(err,HttpResponse::BadRequest().json(post_error)).into()
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


依赖报错 idea导入项目后依赖报错,解决方案:https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错:更换其他版本 无法下载依赖可参考:https://blog.csdn.net/weixin_42628809/a
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
错误1:gradle项目控制台输出为乱码 # 解决方案:https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
错误还原:在查询的过程中,传入的workType为0时,该条件不起作用 &lt;select id=&quot;xxx&quot;&gt; SELECT di.id, di.name, di.work_type, di.updated... &lt;where&gt; &lt;if test=&qu
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
解决方案1 1、改项目中.idea/workspace.xml配置文件,增加dynamic.classpath参数 2、搜索PropertiesComponent,添加如下 &lt;property name=&quot;dynamic.classpath&quot; value=&quot;tru
删除根组件app.vue中的默认代码后报错:Module Error (from ./node_modules/eslint-loader/index.js): 解决方案:关闭ESlint代码检测,在项目根目录创建vue.config.js,在文件中添加 module.exports = { lin
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-