1

我们通过 apache camel 在我们的系统中使用 quickfixj：

        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-quickfix</artifactId>
            <version>${camel.version}</version>
        </dependency>

我们现在正在尝试解决 FIX 通道的问题，并希望了解消息通信的延迟在哪里——在我们的网络中发送消息时或在银行端。

quickfixj 有一个传出消息日志记录，但问题是日志记录完成before发送消息，然后消息本身异步发送

private boolean send(String messageString) {
        getLog().onOutgoing(messageString); // message is logged here
        ...
        return responder.send(messageString); // async sent inside 
    }

那么有没有什么方法可以在消息发送后才创建一些日志？通过这种方式，我们将了解在第一个日志和实际发送消息之间是否真的存在一些延迟，以及发送需要多长时间。

谢谢。

UPD：根据 Christoph 的回答，尝试以下方法：

val engine = (camelContext.getEndpoint(fixConfiguration.fixEndpoint) as QuickfixjEndpoint).engine
engine::class.java.getDeclaredField("acceptor").let {
   it.isAccessible = true
   val acceptor = it.get(engine) as SessionConnector

   val loggingFilter = LoggingFilter()
   loggingFilter.sessionOpenedLogLevel = LogLevel.NONE // don't log this event
   loggingFilter.sessionCreatedLogLevel = LogLevel.NONE // don't log this event
   acceptor.setIoFilterChainBuilder { chain -> chain.addLast("LoggingFilter", loggingFilter) }
}
4

1 回答 1

1

我进行了一些测试，并认为要采用的方法是使用org.apache.mina.filter.logging.LoggingFilter.

我假设您使用的是 anInitiator但它当然也适用于Acceptor.

LoggingFilter loggingFilter = new LoggingFilter();
loggingFilter.setSessionOpenedLogLevel(LogLevel.NONE);   // don't log this event
loggingFilter.setSessionCreatedLogLevel(LogLevel.NONE);  // don't log this event
initiator.setIoFilterChainBuilder(chain -> chain.addLast("LoggingFilter", loggingFilter));

这将在您的日志中创建如下事件：

Feb 13, 2021 1:05:11 AM org.apache.mina.filter.logging.LoggingFilter log
INFO: SENT: 8=FIX.4.29=6735=A34=149=TW52=20210213-00:05:11.18456=ISLD98=0108=30141=Y10=244
...
Feb 13, 2021 1:05:11 AM org.apache.mina.filter.logging.LoggingFilter log
INFO: RECEIVED: 8=FIX.4.29=6735=A34=149=ISLD52=20210213-00:05:11.22456=TW98=0108=30141=Y10=239
于 2021-02-13T00:12:04.390 回答