2

我有一个 CXFRS 端点，其中诸如“GET /files/x”之类的请求应从特定目录返回文件“x”，然后将其删除。这些文件是从另一个进程输出的，然后通过此路由快速使用。因此，如果需要，可以对它们进行轮询并临时保存在内存中。

下面是我的网络服务。

@Component
@Path("/")
public class WebService {
 @GET
 @Path("files/{id}")
 public String getFile(@PathParam("id") String id) {
  return null;
 }
}

下面是不完整的路线。

<route>
 <from uri="cxfrs://bean:webService"/>
 <choice>
  <when>
   <simple>${in.headers.operationName} == 'getFile'</simple>
   <setHeader headerName="correlationId">
    <simple>mandatoryBodyAs(java.lang.String)</simple>
   </setHeader>
   ???
  </when>
 <choice>
</route>

我已经调查了内容丰富器模式，但这无济于事，因为消费者无法在丰富器中访问原始交换。因此，文件名不能从输入消息中动态确定。换句话说，下面的示例不会读取文件“x”，因为文件端点永远不会看到文件头。

...setHeader(Exchange.FILE_NAME, "x").pollEnrich("file://dir")...

我还尝试在 Web 服务路由和单独的文件路由之间使用聚合器模式，聚合策略如下所示。

@Component
public class Aggregator implements AggregationStrategy {
 public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
  if (oldExchange == null) {
   return newExchange;
  } else {
   oldExchange.getOut().setBody(newExchange.getIn().getBody());
   return oldExchange;
  }
 } 
}

这不起作用，因为聚合器模式似乎是“仅限于”交换；使用“in out”交换，消息到达聚合器后立即将回复返回给客户端，而不是在聚合完成后。随后，我开始编写下面的过程。

@Component
public class FileEnricher implements Processor {

 @Value("${folder}")
 private String folder;

 public void process(Exchange exchange) throws Exception {

  Endpoint endpoint = exchange.getContext().getEndpoint(String.format(
   "file://%s?fileName=%s",
   folder,
   exchange.getIn().getHeader("correlationId")
  ));
  PollingConsumer consumer = endpoint.createPollingConsumer();
  PollEnricher enricher = new PollEnricher(consumer);
  enricher.setTimeout(10000);

  consumer.start();
  enricher.process(exchange);
  enricher.shutdown();
  consumer.stop();
 }
}

这个过程只允许我动态配置内容丰富器。我很难相信没有更好的方法来做到这一点。特别是，我关心线程和在上下文中不断添加/删除组件/端点。

任何人都可以提出更好的解决方案来解决这个问题吗？

4

1 回答 1

1

只需使用 java.io.File 设置消息正文以丰富文件，例如来自 java bean。然后将消息路由到 bean：

public File whichFileToPick(@Header("id") String id) {
   return new File("somedir/" + id");
}

将来 pollEnrich 将得到增强，因此直接在骆驼路线中进行会更容易。Christian 想出了一个好主意，允许将 Camel 表达式指定为 pollEnrich 的 uri。

于 2012-02-08T04:50:38.603 回答