如何在异步JmsOutboundGateway上实现高效线程重试

数据老陈

2026-7-12

问题：基于JmsOutboundGateway的异步MQ请求重试优化

我使用JmsOutboundGateway进行MQ连接，输入通道为ExecutorChannel，当前ServiceActivator未配置输出通道，网关接口方法返回CompletableFuture对象。

现有实现代码

网关接口

@MessagingGateway
public interface SimpleGateway {

    @Gateway(requestChannel = "mqRequestChannel")
    CompletableFuture sendAndReceiveMqMessage(String message);
}

配置类与调用示例

@Bean
public MessageChannel mqRequestChannel(AsyncTaskExecutor taskExecutor) {
    return new ExecutorChannel(taskExecutor);
}

@ServiceActivator(inputChannel = "mqRequestChannel")
@Bean
public JmsOutboundGateway jmsOutboundGateway(... ) {
    JmsOutboundGateway gateway = new JmsOutboundGateway();
    gateway.setConnectionFactory(mqConnectionFactory);
    gateway.setRequestDestinationName(requestDestination);
    gateway.setReplyDestinationName(responseDestination);
    gateway.setAsync(true);
    // 其他配置省略
    return gateway;
}

@Autowired
private SimpleGateway simpleGateway;

// 调用示例
CompletableFuture<String> mqResponse = simpleGateway.sendAndReceiveMqMessage("sdsadas");

尝试过的递归重试方案（非最优）

我曾用递归实现重试逻辑，但该方案并非最优，相关代码如下：

private void callGateway(int retry, int requestNum){

    String dummyOfs = "dsfsdf";

    CompletableFuture<String> response = simpleGateway.sendAndReceiveMqMessage(dummyOfs);

    response.exceptionally(throwable -> { 
        LOG.info("error occured");
        LOG.info("[Error section CURRENT THREAD in gateway class call ]: {} , requestNum = {}, retry = {}", Thread.currentThread(), requestNum, retry );
        if(MAX_RETRY > retry){
            Set<Thread> threadSet = Thread.getAllStackTraces().keySet();
            callGateway(retry + 1, requestNum);
        }
        return null;
    });

    response.thenAccept((String someString) -> {
        LOG.info("[success ]: {} , returned value: {}", Thread.currentThread(), someString);
    });
}