Java/Kotlin Spring应用使用NATS request方法时响应为空的问题

你的问题根源在于接收端没有将响应发送到NATS Request模式自动生成的ReplyTo主题，而是错误地发回了原请求主题。当使用request()方法时，NATS客户端会自动生成一个以_INBOX开头的临时ReplyTo主题，接收端必须将响应发送到这个主题，发送端才能收到回复，否则请求会超时返回null。

1. 修复Kotlin接收端的响应发送逻辑 #

修改handleMessage方法，获取消息的replyTo字段，将响应发送到该主题，同时增加replyTo的空判断，避免非请求消息的处理异常：

private fun handleMessage(msg: Message) {
    val receivedMessage = String(msg.data, StandardCharsets.UTF_8)
    val jsonNode = objectMapper.readTree(receivedMessage)
    // 仅处理带replyTo的请求消息
    msg.replyTo?.let { replyTo ->
        if (!jsonNode.has("response") || !jsonNode.has("err")) {
            logger.info("Received order.create message: $receivedMessage")
            val responseEvent = getOrderCreateResponse(receivedMessage)
            // 发送响应到自动生成的replyTo主题，而非原请求主题
            natsConnection.publish(
                replyTo,
                objectMapper.writeValueAsBytes(responseEvent)
            )
            logger.info("Sending order.create response to $replyTo: $responseEvent")
        }
    }
}

2. 优化Java发送端的空指针防护 #

在处理响应前先判断response是否为null，避免直接调用response.getData()触发空指针异常：

public CreateRenewRsEvent getOrderCreationResponse(CreateRenewRqEvent createRenewRqEvent) {
    try {
        String requestJson = objectMapper.writeValueAsString(createRenewRqEvent);
        log.info("Sending order.create event: {}", requestJson);
        final Message response = natsConnection.request(
                    natsProperties.getSendTopic(),
                    objectMapper.writeValueAsBytes(createRenewRqEvent),
                    natsProperties.getTimeout()
            );
        
        if (response == null) {
            log.warn("No response received for order.create request within timeout");
            return null;
        }
        
        String responseJson = new String(response.getData(), StandardCharsets.UTF_8);
        log.info("Received order.create response: {}", responseJson);
        response.ack();
        return objectMapper.readValue(response.getData(), CreateRenewRsEvent.class);
    } catch (Exception e) {
        log.warn("Error sending order.create message", e);
    }
    return null;
}

额外注意事项 #

• 确认natsProperties.getTimeout()设置的超时时间足够覆盖接收端的处理耗时，避免因超时提前返回null。
• NATS服务器默认启用临时_INBOX主题支持，无需额外配置，确保服务器正常运行即可。

内容的提问来源于stack exchange，提问作者Maksym Rybalkin