Описание тега spring-integration-mqtt

Вопросы с тегом
1 ответ

spring-gration-mqtt с несколькими серверами Mqtt для подписки

Я использую Spring-интеграции-mqtt Spring, и я могу подключиться к одному серверу Mqtt и могу получать сообщения по темам, подписанным, и теперь я хочу сделать приложение, которое может подключаться к нескольким серверам Mqtt и может получать данные…
27 янв '18 в 10:13
1 ответ

Подписка СИ на несколько тем mqtt

Я пытаюсь научиться обрабатывать сообщения MQTT в Spring-Integration. Создал конвертер, который подписывается с помощью одного MqttPahoMessageDrivenChannelAdapter на тему MQTT для использования и преобразования сообщений. Проблема в том, что наш про…
25 янв '19 в 10:18
1 ответ

Может ли подписчик MQTT принимать одновременно несколько сообщений одной и той же темы?

Я пытаюсь создать подписчика в приложении Spring Boot. Моя цель состоит в том, чтобы издатель отправлял несколько сообщений в тему, и я должен получить эти сообщения и обработать их. Я заметил, что "handleMessage" как Paho, так и Apache ActiveMq буд…
04 фев '19 в 07:59
1 ответ

Spring Integration: Основы тестирования интеграции MQTT

Я пытаюсь протестировать простой слушатель MQTT, созданный с помощью Spring Boot и Spring Integration, но у меня не получается. Я перепробовал много подходов. Наиболее перспективным было: @RunWith(SpringRunner.class) @SpringBootTest public class Bas…
12 июл '18 в 14:14
1 ответ

Одновременные потребители в контексте весенней интеграции

В приложении Spring для интеграции я использую одновременных потребителей для одновременного использования и обработки нескольких сообщений. В моем приложении я настроил все bean-компоненты на одноэлементный. Я предполагаю, что если я собираюсь расп…
26 фев '18 в 13:22
1 ответ

Можем ли мы группировать группы из 10 сообщений в комарах, используя весеннюю интеграцию

Это то, как я определил свое соединение mqtt с помощью весенней интеграции. Я не уверен, возможно ли это, но мы можем настроить работу подписчика mqtt после получения 10 сообщений. щас подписчик работает после публикации сообщения как надо. @Autowir…
02 авг '17 в 12:17
0 ответов

Решение mqttlens auto zoom в windows 8.1

Я установил mqttlens от google chorme apps, Он работал довольно хорошо в течение пары недель, но в последнее время он появляется в режиме увеличения при запуске. Как я могу это исправить? ,
07 янв '18 в 08:18
1 ответ

Увеличьте время MQTT между PUBLISH и PUBCOMP

Я настроил подписчика MQTT весной, используя интеграцию Spring mqtt. В методе handleMessage я выполняю определенную бизнес-логику, которая требует времени. Во время тестирования я заметил, что когда я отправляю большое количество сообщений, Брокер п…
11 дек '18 в 08:57
1 ответ

Отправка сообщений на разные темы с помощью шлюза интеграции Spring

Я пытаюсь использовать Spring Integration для отправки сообщений mqtt брокеру, и я пытаюсь использовать интерфейс шлюза. @Bean public MqttPahoClientFactory mqttClientFactory() { DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory…
19 фев '19 в 12:28
0 ответов

MQTT-соединение с собственным сертификатом (PEM)

У меня есть существующий пример Javascript подключения к брокеру MQTT, который выглядит следующим образом (используя эту библиотеку https://github.com/mqttjs/async-mqtt.git): client = MQTT.connect(`mqtts://<url>`, { clientId: config.iotService…
13 ноя '18 в 10:56
0 ответов

Spring MQTT Client

Я пытаюсь настроить MQTT Client . вот моя конфигурация: @Configuration public class MQTTConfig { @Bean public MqttPahoClientFactory mqttClientFactory() { DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory(); factory.setServerURI…
20 мар '18 в 14:11
0 ответов

Spring Integration Адаптер исходящего канала mqtt публикует сообщения, когда сертификат отключен

Вопрос объясняется в вопросе: У меня есть mqtt-outbound-channel-adapter в размещенном в AWS приложении, интегрированном со службой AWS mqtt, как показано ниже: <int-mqtt:outbound-channel-adapter id="outboundMqttChannelAdapter" url="ssl://${mqtt.e…
24 май '18 в 12:40
1 ответ

Клиент AWS IoT MQTT с Apache camel-mqtt

Я изучаю возможность создания Java-клиента AWS IoT с помощью Apache Camel (используя camel-mqtt) + Spring Boot. Это звучит как хороший матч для меня, но не смог найти никаких примеров. Есть ли какой-то недостаток, который я не вижу? Было бы интересн…
03 авг '17 в 22:38
2 ответа

Регистрация основного устройства Google Cloud IoT - несколько устройств могут использовать один и тот же открытый / закрытый ключ

Я работаю над собственным проектом с несколькими сенсорными устройствами. Я не хочу, чтобы пользователь регистрировал каждое устройство отдельно. В том смысле, что я хочу использовать одну и ту же пару открытых / закрытых ключей для всех устройств, …
07 фев '19 в 04:25
1 ответ

Используйте Paho в Spring Integration для получения двоичного сообщения MQTT

У меня есть этот код, который получает сообщения MQTT в Spring Integration 5.0.x / Boot 2.0. Он работает нормально для текстовых сообщений, но когда я пытаюсь обработать двоичные сообщения, это не удается, потому что преобразование в String происход…
29 мар '18 в 18:19
0 ответов

Масштабирующий MQTT-потребитель для многих издателей

Я новичок в Spring-Integration и слежу за решением следующей задачи. Мы пытаемся создать MQTT-Consumer (на основе адаптера входящего канала mqtt), который получает сообщения по 7 темам от 50 издателей. Поскольку адаптер обрабатывает сообщения послед…
29 ноя '18 в 15:43
1 ответ

Приостановка и возобновление входящего адаптера MQTT

У нас есть: конвертер, который принимает сообщения из тем mqtt, анализирует, обрабатывает их и после определенных проверок отправляет их в другую систему обмена сообщениями. Если целевая система недоступна, мы создаем определенное событие и отправля…
06 мар '19 в 10:48
0 ответов

Достижение аварийного переключения через MQTT Kafka Bridge

Я использовал МОСТ MQTT-KAFKA в java, и у меня есть сценарий для преодоления потери данных в MQTT и Kafka в случае сбоя клиента MQTT или моста MQTT-KAFKA в производственной среде, необходимо обеспечить аварийное переключение. Я протестировал сценари…
15 май '20 в 19:17
0 ответов

Совместное использование одного и того же экземпляра клиента MQTT между MqttPahoMessageHandler и MqttPahoMessageDrivenChannelAdapter в интеграции Spring Boot

Предположим, у меня есть одно приложение Spring Boot, которому необходимо создать экземпляры нескольких клиентов MQTT (# ~10^4) для виртуализации физических устройств в брокере (Mosquitto). У каждого из них есть уникальный идентификатор клиента, что…
15 окт '19 в 13:48
1 ответ

Как лучше всего обработать переподключение с MqttPahoMessageHandler, поскольку срок действия токена истек?

Я использовал следующий пример в качестве основы для моего собственного кода для публикации на сервере MQTT: https://github.com/spring-projects/spring-integration-samples/blob/master/basic/mqtt/src/main/java/org/springframework/integration/samples/m…
10 мар '20 в 04:13