骆驼：如何检查响应http响应

Surasin Tancharoen 发表于 Dev

Surasin Tancharoen

我对骆驼很陌生。我一直在尝试将数据（文件中的Json）提交到Web服务。这是我的代码：

    public static void main(String args[]) throws Exception {
        // create CamelContext
        CamelContext context = new DefaultCamelContext();

        // add our route to the CamelContext
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() {
                from("file:data/inbox?noop=true")
                    .marshal()
                    .string()
                    .setHeader(Exchange.CONTENT_TYPE,constant("application/json"))
                    .to("http://www.a-service.com");
            }
        });

        // start the route and let it do its work
        context.start();
        Thread.sleep(10000);

        // stop the CamelContext
        context.stop();
    }

然后，Web服务将使用Json响应，该响应可以为{result：OK}或{result：FAIL}

现在，如果响应的responseCode为200，则Camel将视为成功。

我的问题是，如何对响应的JSon进行验证，以便如果失败，则Camel不应该认为成功？

解决方案信用@Namphibian：

通过添加处理器和末尾。此代码已经过测试：

    from("file:data/inbox?noop=true")
        .marshal()
        .string("UTF-8")
        .setHeader(Exchange.CONTENT_TYPE,constant("application/json"))
    .to("http://monrif-test.userspike.com/monrif/rss/monrif_-all-global")
        .process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                Message in = exchange.getIn();
                String msg = in.getBody(String.class);
                System.out.println("Response: " + msg);
                if(msg.contains("OK")){
                    // go to party
                }else{
                    throw new Exception("test exception");
                }
            }
        });

南皮比

您可以使用两种广泛的策略来实现这一目标。

基于处理器：

在路由末尾添加一个处理器。在此处理器中，检查Web服务是否以true或false值进行响应。

处理器看起来像这样：

    package com.example;

    import java.util.Map;

    import org.apache.camel.Body;
    import org.apache.camel.Exchange;
    import org.apache.camel.Handler;
    import org.apache.camel.Headers;
    import org.apache.camel.Message;

    public class GeneralProcessor {
        @Handler

        public void PrepapreErrorImportReport
        (

                @Headers Map hdr
                , Exchange exch
        )
        {

            //todo: Get the message as a string;

            Message in = exch.getIn();
            String msg = (String)in.getBody();
            // Now check if body contains failed or ok.
            if(msg.contains("OK")){
                //todo: go party the message was OK
            }
            else{
               //todo: Oh Oh! Houston we have a problem
            }


        }

    }

然后，您可以修改路由以使用此处理器。

简单表达语言

这是一种方法，另一种方法是使用简单表达语言。请参阅以下示例，了解如何使用它。

 from("file:data/inbox?noop=true")
                .marshal()
                .string()
                .setHeader(Exchange.CONTENT_TYPE,constant("application/json"))
                .to("http://www.a-service.com")
                .choice()
                .when(simple("${body} contains 'OK'")).to("activemq:okqueue")
                .otherwise().to("activemq:queue:other");

注意simple("${body} contains 'OK'")这段代码。那就是简单的力量。

两种方法都有用。

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。