http - Camel Jetty 组件写入输出流

Question

我在 Camel 中有一个长时间运行的进程，它是由 HTTP 请求触发的。我想将状态更新写入输出流，但我没有在客户端收到响应。

我尝试使用以下方法:

Camel 路线:

<from uri="jetty:http://localhost:12345/myservice"/>
<process ref="test" />

处理器测试:

public void process(Exchange arg0) throws Exception {
    System.out.println("TestProcessor");
    HttpServletResponse response = (HttpServletResponse) arg0.getIn().getHeader(Exchange.HTTP_SERVLET_RESPONSE);

    OutputStreamWriter wr = new OutputStreamWriter(response.getOutputStream());
    BufferedWriter w = new BufferedWriter(wr);
    for(int x = 0; x < 10; x++){
        w.write("Zeile: " + x + "\n");
        w.newLine();
    }
//      arg0.getIn().setBody("This might also be a response");
}

调用代码:

final HttpURLConnection conn = (HttpURLConnection) url.openConnection();           
            conn.setDoOutput( true );
            conn.setInstanceFollowRedirects( false );
            conn.setRequestMethod( "GET" );
            conn.setRequestProperty( "Content-Type", "application/x-www-form-urlencoded"); 
            conn.setRequestProperty( "charset", "utf-8");
            conn.setRequestProperty( "Content-Length", Integer.toString( postDataLength ));
            conn.setUseCaches( false );
            new Thread(new Runnable(){

                @Override
                public void run() {
                    try {
                        if(!urlParameters.isEmpty()){
                            try( DataOutputStream wr = new DataOutputStream( conn.getOutputStream())) {
                               wr.write( postData );
                               wr.close();
                            }
                        }
                        InputStream s = conn.getInputStream();
                        System.out.println("got InputStream");
                        InputStreamReader is = new InputStreamReader(s);
                        BufferedReader br = new BufferedReader(is);
                        String line;
                        while((line = br.readLine()) != null){
                            System.out.println("ReadLine: " + line);
                        }

                        conn.disconnect();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }

            }).start();

但是当我在处理器中设置主体时(注释行)，我只会得到响应。有什么方法可以保持 Camel 的连接并继续写入它吗？

Answer 1

您应该使用 out使用 HTTP 组件发送应答的消息:

arg0.getOut().setBody("This might also be a response");

HTTP 组件使用 HttpBinding转换 HttpServletRequest到Exchange ，反之，填一个HttpServletResponse来自 Exchange .可以看到默认实现here或提供您自己的。