问题标签 [quickfixj]

试图解决似乎与套接字刷新行为有关的传出消息存在大量延迟的问题。我一直在对从 quickfixj 发起方到接收方的传出 FIX 消息进行数据包捕获。

总结一下环境，java intiator 与另一台服务器上的服务器套接字建立套接字连接。两台服务器都运行 Redhat Enterprise Linux 5.10。来自接口上的 netstat 的 MSS 为 0。网卡的 MTU 都是 1500（我相信对于环回接口是无限的）。在应用程序端，消息由 quickfixj 编码为字节数组并写入套接字。套接字配置为启用 TCP_NODELAY。

我几乎可以肯定我可以消除应用程序作为延迟的原因，因为当接受器（ServerSocket）与使用环回接口的发起者在同一台服务器上运行时，没有发送者延迟。这是使用环回接口的一些数据包捕获条目的示例：

感兴趣的主要事情是 1/ 尽管数据包长度（这里最大的是 2851），但每个数据包上都设置了 PUSH 标志。2/我在这里测量的延迟度量是消息在编码之前设置的“发送时间”，以及数据包捕获时间“时间”。数据包捕获是在与发送数据的发起者相同的服务器上完成的。对于 10,000 个数据包的数据包捕获，使用 loopback 时，“SendingTime”和“Time”之间没有太大区别。出于这个原因，我认为我可以消除应用程序作为发送延迟的原因。

当接收器移动到 LAN 上的另一台服务器时，对于大于 MTU 大小的数据包，发送延迟开始变得更糟。这是 a 捕获的片段：

这里重要的是，当数据包小于 MSS（源自 MTU）时，设置 PUSH 标志并且没有发送者延迟。这是意料之中的，因为禁用 Nagle 算法将导致在这些较小的数据包上设置 PUSH。当数据包大小大于 MSS（在这种情况下为 1514 的数据包大小）时，捕获数据包的时间与 SendingTime 之间的差异已跃升至 35 毫秒。

这 35 毫秒的延迟似乎不太可能是由应用程序对消息进行编码引起的，因为大数据包大小的消息在环回接口上的发送时间小于 1 毫秒。捕获也发生在发送方，因此 MTU 分段似乎也不是原因。在我看来，最可能的原因是因为没有设置 PUSH 标志——因为数据包大于 MSS——所以操作系统级别的套接字和/或 TCP 堆栈直到 35 毫秒后才决定刷新它。另一台服务器上的测试接受者不是一个慢消费者，并且在同一个 LAN 上，所以 ACK 是及时的。

任何人都可以就可能导致该套接字发送 > MSS 数据包延迟的原因给出任何指示吗？对于美国的真实交易对手，此发送方延迟高达 300 毫秒。我认为如果数据包大小大于 MSS，那么无论以前的 ACKS（只要不超过套接字缓冲区大小），它都会立即发送。Netstat 通常显示 0 套接字 q 和风大小，并且该问题似乎发生在所有 > MSS 数据包上，即使从启动时也是如此。这看起来像套接字出于某种原因决定不立即刷新，但不确定是什么因素导致了这种情况。

编辑：正如 EJP 所指出的，linux 中没有刷新。据我了解，套接字发送将数据放入 linux 内核的网络缓冲区中。对于这些非推送数据包，内核似乎正在等待前一个数据包的确认，然后再传递它。这不是我所期望的，在 TCP 中，我希望数据包在套接字缓冲区填满之前仍会被传递。

quickfixj 是否尝试在已发送显式注销的会话上重新连接。

我已经问过了，并被告知没有，但我想确认一下。

在这种情况下应该怎么做才能重新连接？欢迎所有可能的解决方案。

当我们尝试在未连接的会话上发送消息时会发生什么？

我发现发送消息的QuickFIXJ方法会抛出一个检查异常，但我想知道在什么情况下会抛出这个异常。

session.logout有人能帮我理解和之间的区别吗session.generateLogout？

也可以显式地创建和发送注销消息。这和其他两个有什么区别？

我对 FIX 比较陌生，这是我第一次尝试连接。我正在尝试使用 QuickFixJ 库连接到我提供的 UAT 环境。具体来说，我正在使用 quickfixj-all-1.6.0.jar

我已经从这里实现了示例代码，它一直工作到socketAcceptor.start().

这是完整的代码示例：

我得到的错误是

提供了“SenderCompID->TargetCompID”变量，但已从此处的示例中删除。

quickfix.mina.message.FIXProtocolCodecFactory.addMessageDecoder(Ljava/lang/Class;)V 在 socketAcceptor.start 方法中抛出。我看不出有任何原因，因为我只更改了配置示例以指向 FIX UAT 环境

我不明白为什么 jar 中包含的方法会抛出这个错误，我不是在这个阶段试图发送消息，只是试图打开一个连接。这个例子似乎对其他人有用。

我也使用此处找到的 FIX 客户端示例得到了完全相同的错误

您如何从出现在消息日志中但未被 fromAdmin 捕获的 quickfix 捕获较低级别的异常

我需要更改字符集或添加

所以我在 main 函数中添加了上面的内容，但这不会使 quickfixj 日志中出现换行符。有任何想法吗？

有没有办法在不重建 quickFIXJ 的情况下处理这个错误？

我正在使用 FIXT1.1 和 FIX 应用程序版本 5.0SP2。

我向 QuotSetAckGrp 添加了一些自定义字段，这是 MassQuoteAcknowledgement 消息的一部分。但是，当 quickfix 读取重复组时，它不会将自定义字段作为重复组的一部分读取。相反，它将自定义字段视为常规父级字段并抛出“标签出现多次”会话级拒绝。

感谢任何有助于解决问题的输入。

我正在尝试与 quickfix/j 建立连接，但我在公司防火墙后面。所以我需要通过代理连接到接受者。我在互联网上看到新版本 1.6.0 添加了代理支持，但我找不到任何关于如何做到这一点的解释。有人可以解释一下我如何使用发起者的代理来建立与服务器（接受者）的连接吗？

谢谢