java如何在apache camel路由中将数据发送到netty4socket

Question

我有一条路线

'服务器已接收：'+exchange。getIn（）。getBody（String.class）

我想使用一些java客户端向这个socket发送数据。我该怎么做

Answer 1

'服务器已接收：'+exchange。getIn（）。getBody（String.class）不是一个驼峰路由，它更像是一个打印正文内容的处理器。您需要定义一个上下文，添加一个带有自定义处理器的路由

CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
    public void configure() {

        from("direct:start")
        .process(new Processor() {
                      public void process(Exchange exchange) throws Exception {
                         String body = exchange.getIn().getBody(String.class);
                         System.out.println("Server received: " + body);
                    }
                  })
    }
});

ProducerTemplate template = context.createProducerTemplate();
context.start();
template.sendBody("direct:start", "Hello World");

RouteBuilder Camel doc