0

使用Apache Camel时，我想在路由的每个处理器/组件之前自动保留交换信息，而不在路由中使用窃听处理器，其中 errorHandlers 也应用于路由。我尝试使用interceptStrategy，但是在路由中应用errorHandlers时不会触发拦截器。我还了解到，使用自定义 InterceptStrategy 并不适合最终用户。有人知道这个的替代方案吗？

我们目前正在研究EventNotifierSupport@RomanVottner 提到的实施。通过下面的实现，我们注意到ExchangeSentEvent某些处理器/端点的发送是重复的。 为什么 ExchangeSentEvent 会针对同一个处理器操作多次发送？

context.getManagementStrategy().addEventNotifier(new RouteHistoryEventNotifier());

public class RouteHistoryEventNotifier extends EventNotifierSupport {

  private int retryCounter = 0;
  private String lastID = "";

  @Override
  public void notify(EventObject eventObject) throws Exception {
      long startTime = System.currentTimeMillis();
    log.info("notify eventname:  " + eventObject.getClass().getName() );

      if (eventObject instanceof ExchangeRedeliveryEvent) {
         ExchangeRedeliveryEvent event = (ExchangeRedeliveryEvent) eventObject;
         Exchange exchange = event.getExchange();
         String id = getProcessorName(exchange);
         retryCounter =  event.getAttempt(); 
         log.info("notify eventname:  " + event.getClass().getName()  + " - retry: " + retryCounter );
      }
      if (eventObject instanceof ExchangeSentEvent) {
          ExchangeSentEvent event = (ExchangeSentEvent) eventObject;
          Exchange exchange = event.getExchange();
          String id = getProcessorName(exchange);

          if(retryCounter > 0) {
             id = String.format("%s (%s)", id, retryCounter ); 
          }

        // write Exhange with timeTaken and processorId to Database
         myRepo.saveStep(id , exchange,startTime,  event.getTimeTaken());
      }
  }

  private String getProcessorName(Exchange exchange) {
      List<MessageHistory> list = exchange.getProperty(Exchange.MESSAGE_HISTORY, List.class);
      MessageHistory msgHistory = list.get(list.size() - 1);
      String id = msgHistory.getNode().getId();
      if (!lastID.equalsIgnoreCase(id) ) {
          lastID  = id;
          retryCounter = 0;
      }
      return id; 
  }

  @Override
  public boolean isEnabled(EventObject event) {
      return true;
  }
}

控制台输出：

Line 4762: 2018-06-26 14:58:44.503 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.CamelContextStartingEvent
Line 4950: 2018-06-26 14:58:44.607 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteAddedEvent
Line 4978: 2018-06-26 14:58:44.617 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteAddedEvent
Line 4996: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteStartedEvent
Line 5002: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteStartedEvent
Line 5005: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.CamelContextStartedEvent
Line 5010: 2018-06-26 14:58:44.620 [d763f7b:1624c6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5011: 2018-06-26 14:58:44.620 [d763f7b:1624c6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeCreatedEvent
Line 5014: 2018-06-26 14:58:44.620 [d763f7b:513548] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5018: 2018-06-26 14:58:44.621 [d763f7b:61dde6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5020: 2018-06-26 14:58:44.622 [d763f7b:783f41] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5024: 2018-06-26 14:58:44.625 [d763f7b:61dde6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5026: 2018-06-26 14:58:44.626 [d763f7b:9d0511] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5030: 2018-06-26 14:58:44.626 [d763f7b:4be680] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5118: 2018-06-26 14:58:45.353 [d763f7b:acf181] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5123: 2018-06-26 14:58:45.353 [d763f7b:61dde6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5126: 2018-06-26 14:58:45.354 [d763f7b:ac8552] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSendingEvent
Line 5130: 2018-06-26 14:58:45.360 [d763f7b:61dde6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5133: 2018-06-26 14:58:45.360 [d763f7b:1624c6] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeCompletedEvent
Line 5136: 2018-06-26 14:58:45.360 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.ExchangeSentEvent
Line 5138: 2018-06-26 14:58:45.360 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.CamelContextStoppingEvent
Line 5183: 2018-06-26 14:58:45.364 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteStoppedEvent
Line 5185: 2018-06-26 14:58:45.364 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteRemovedEvent
Line 5262: 2018-06-26 14:58:45.365 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteStoppedEvent
Line 5286: 2018-06-26 14:58:45.366 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.RouteRemovedEvent
Line 5301: 2018-06-26 14:58:45.367 [d763f7b:d7637b] [ntExecutorGroup] INFO   fiers.RouteHistoryEventNotifier - notify eventname:  org.apache.camel.management.event.CamelContextStoppedEvent

您还可以查看OpenTracingEventNotifier或ZipkinEventNotifier作为示例

4

0 回答 0