多个MQTT客户端订阅了相同的主题

debugcn 发表于 Dev

凯文

我实际上有一个带有MQTT客户端的spring boot应用程序，该应用程序已订阅该主题。

当我放置应用程序的2个实例（2个容器/容器）时遇到问题，因为它创建了到发布者的2个连接！问题是我将每条消息的内容记录在数据库中，因此我收到了2次数据！一个来自吊舱，另一个来自第二个。..因此数据库中有2条记录...

这是我的实际代码：

.
..
...
....
    @Bean
    public MqttConnectOptions getReceiverMqttConnectOptions() {
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setCleanSession(true);
        mqttConnectOptions.setConnectionTimeout(30);
        mqttConnectOptions.setKeepAliveInterval(60);
        mqttConnectOptions.setAutomaticReconnect(true);

        mqttConnectOptions.setUserName(bean.getProperty("username"));
        String password = bean.getProperty("password");
        String hostUrl = bean.getProperty("url");

        mqttConnectOptions.setPassword(password.toCharArray());
        mqttConnectOptions.setServerURIs(new String[] { hostUrl });
        return mqttConnectOptions;
    }

    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        factory.setConnectionOptions(getReceiverMqttConnectOptions());
        return factory;
    }

    @Bean
    public MessageChannel mqttInputChannel() {
        return new DirectChannel();
    }

    @Bean
    public MessageProducer inbound() {
        String clientId = "client-id" + UUID.randomUUID().toString();
        MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(clientId, mqttClientFactory(), "jenkins");
        adapter.setCompletionTimeout(20000);
        adapter.setConverter(new DefaultPahoMessageConverter());
...
..
.

如果您有任何解决方案，可以在不创建2个MQTT连接的情况下使用我的应用程序的2个容器。

哈迪尔布

您需要使用支持共享订阅的代理（此功能已添加到MQTTv5标准中，但是某些代理在v3中不支持任何标准版本）

共享订阅允许一组客户订阅一个主题（或通配符主题），发布到该主题的任何给定消息将仅传递给一组客户。

您可以在此处阅读有关共享订阅的更多信息

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。