San*_*jok 5 java spring jpos multiplexing iso8583
我更新了我的旧 spring/java 应用程序,它将事务推送到远程 ISO 服务器(银行)。使用经典方法(channel.seng(isoMsg))通过同步方法,因为通过同一通道发送多个 ISO 请求很难映射请求和响应。过去有太多事务留在队列中,因为每个事务需要 5 秒才能从远程服务器接收响应。因此,所有即将进行的事务都会超时。为了解决这个问题,我开始实施 QMUX。该系统现已上线。
现在我的问题是,如果已经有 50 笔交易的响应未到达或超时,银行告诉我不要发送交易。
所以,现在我需要配置 MUX 框架,以便一旦系统等待 50 个响应,框架应该停止发送并应该在我的末尾排队,当它收到 1 个响应时,它可以再次发送一个事务以保持等待总数响应小于或等于 50。如何使用 jpos QMUX 实现此目的?
小智 2
您可以org.jpos.iso.filter.ThroughtputControlFilter在 ChannelLevel 使用 [1],但不能在 MUX 级别使用。您可以在调用 MUX 之前从其实现中选取一些想法来在代码中处理它们。
您也可以使用信号量。
[1] http://jpos.org/doc/javadoc/org/jpos/iso/filter/ThroughputControlFilter.html
| 归档时间: |
|
| 查看次数: |
348 次 |
| 最近记录: |