java - 是否有类似 DefaultMqttPahoClientFactory 的东西用于创建异步客户端？

Question

我想在 Spring Integration 中使用异步 Paho 客户端:

@Bean
public DefaultMqttPahoClientFactory clientFactory() {
    return new DefaultMqttPahoClientFactory();
}

<int-mqtt:message-driven-channel-adapter id="mqttInbound"
client-id="${mqtt.default.client.id}.src"
url="${mqtt.url}"
topics="sometopic"
client-factory="clientFactory"
channel="output"/>

我必须自己写一个吗？我只能找到同步客户端工厂的示例。

Answer 1

正确；目前仅支持同步客户端。

欢迎打开improvement JIRA issue here当然还有contributions are always welcome - guidelines here 。

也就是说，我不清楚在入站适配器中使用异步客户端的好处(如您的示例所示)；它是消息驱动的，到达的消息在客户端线程上异步传递。显然，出站适配器可以从异步操作中获得一些好处。

outbound adapter非常简单，编写一个使用异步客户端的应用程序应该不会太难 - 它可能需要将传递 token 发送到某个 channel - 但我们应该从 IMqttDeliveryToken 对象中抽象出来，这样我们不要将 Paho 泄漏到上层。