5

在 IBM WebSphere 上运行的 Web 项目中的 ServletContextListener 中设置了以下工作 Camel 流，传入的 XML 被转换为 JSON 并打印到 System.out 并打印到 report.txt。到目前为止，一切都很好。

@WebListener
public class SetupCamel implements ServletContextListener {

    private CamelContext camelContext;

@Override
    public void contextInitialized(ServletContextEvent sce) {
        System.out.println("SetupCamel:contextInitialized - enter");
        try {
            Context ctx = new InitialContext();
            QueueConnectionFactory qcf = (QueueConnectionFactory) ctx.lookup("jms/TestConnectionFactory");

            camelContext = new DefaultCamelContext();

            JmsConfiguration jmsConfiguration = new JmsConfiguration(qcf);
            JmsComponent jmsComponent = new JmsComponent(jmsConfiguration);
            camelContext.addComponent("jms", jmsComponent);

            final XmlJsonDataFormat xmlJsonFormat = new XmlJsonDataFormat();
            xmlJsonFormat.setEncoding("UTF-8");
            xmlJsonFormat.setForceTopLevelObject(false);
            xmlJsonFormat.setTrimSpaces(true);
            xmlJsonFormat.setRootName("newRoot");
            xmlJsonFormat.setSkipNamespaces(true);
            xmlJsonFormat.setRemoveNamespacePrefixes(true);

            camelContext.addRoutes(new RouteBuilder() {
                public void configure() {
                    onException(Exception.class)
                    .to("log:GeneralError?level=ERROR")
                    .end();

                    from("jms:queue:TestQueue?concurrentConsumers=1")
                    .marshal(xmlJsonFormat)
                    .to("file:/tmp/messages?fileName=report.txt&fileExist=Append")
                    .to("stream:out")
                    ;
                }
            });
            camelContext.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("SetupCamel:contextInitialized - leaving");
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        System.out.println("SetupCamel:contextDestroyed - enter");
        try {
            if (camelContext != null) {
                camelContext.stop();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("SetupCamel:contextDestroyed - leaving");
    }
}

我必须扩展流程以将 JSON 发布到 REST 服务/消费者。（Rest 资源已经过测试并且可以工作..）

搜索（网络）文档并没有给我一个可以使用的好的/完整的 Java DSL 示例。根据我的发现，我认为它应该类似于添加一个端点，例如：

.to("cxfrs://http://localhost:9080/WebContext/TestResource")

但这不起作用，我不明白如何将转换后的 JSON 设置为正文并使其成为 POST 请求。也没有打印异常。

如何在此流程中将 REST 调用添加为带有 JSON 正文的 POST？

在 IBM WebSphere v8.5.5、IBM jdk 1.7x、Camel 2.11.2 中运行

以下 jar 文件位于 WEB-INF/lib 类路径中：

camel-core-2.11.2.jar
camel-cxf-2.11.2.jar
camel-cxf-transport-2.11.2.jar
camel-jms-2.11.2.jar
camel-servletlistener-2.11.2.jar
camel-spring-2.11.2.jar
camel-stream-2.11.2.jar
camel-xmljson-2.11.2.jar
com.ibm.ws.prereq.jackson.jar
commons-beanutils-1.8.0.jar
commons-collections-3.2.1.jar
commons-lang-2.5.jar
commons-logging-1.1.1.jar
cxf-api-2.7.6.jar
cxf-rt-frontend-jaxrs-2.7.6.jar
ezmorph-1.0.6.jar
json-lib-2.4-jdk15.jar
slf4j-api-1.7.5.jar
spring-beans-3.1.4.RELEASE.jar
spring-context-3.1.4.RELEASE.jar
spring-core-3.1.4.RELEASE.jar
spring-jms-3.1.4.RELEASE.jar
spring-tx-3.1.4.RELEASE.jar
xom-1.2.5.jar

谢谢。

4

2 回答 2

1

如果你只是想将 JSON 消息发布到 REST 服务，你不需要使用 camel-cxfrs 组件，因为你已经有了请求消息体，你只需要使用 camel-http 端点发送请求。

所以路线可能是

from("jms:queue:TestQueue?concurrentConsumers=1")
                    .marshal(xmlJsonFormat)
                    .to("http://localhost:9080/WebContext/TestResource");
于 2013-12-09T08:26:48.713 回答
0 
.process(new Processor() {

        @Override
        public void process(Exchange exchange) throws Exception {
            String body = (String) exchange.getIn().getBody();
            logger.info(body);
            exchange.getIn().setHeader(Exchange.HTTP_METHOD, constant(HttpMethod.POST));
            exchange.getIn().setHeader(Exchange.CONTENT_TYPE, MediaType.APPLICATION_JSON);
            exchange.getIn().setHeader("Authorization", "Bearer " + getToken());
            HttpServletRequest request = exchange.getIn().getBody(HttpServletRequest.class);
            exchange.getIn().setHeader(Exchange.HTTP_SERVLET_REQUEST, request); // POST body is set here
        }
    })
    .to(apiToCall);
于 2017-01-10T21:43:10.480 回答