иллюстрировать

В этом разделе используется Java для подключения к серверу MQTT, а затем подписывается на эту тему для получения всех данных об устройстве.

Затем запишите данные в базу данных MySQL через пул соединений Druid.

Примечание. Подключение Java к MQTT такое же, как подключение Android к MQTT.

Чтобы использовать пул соединений Druid для подключения к базе данных в Java, обратитесь к предоставленному базовому руководству по MySQL с открытым исходным кодом.

Код Java открывается с помощью программного обеспечения IntelliJ IDEA.

Создание новых баз данных и таблиц

1. Создайте новую базу данных, имя базы данных Historical_data, формат кодировки utf8.

2. В обычных обстоятельствах пользователи могут щелкнуть эту кнопку на сервере, чтобы управлять базой данных (мы не используем это, мы используем следующий navicat)

3. Используйте Navicat на своем компьютере для подключения к базе данных.

4. Создайте новую таблицу.

5. Добавьте несколько полей

Идентификатор поля, тип — int, удалите допустимое нулевое значение, установите для него автоматическое приращение, а затем установите его в качестве первичного ключа;

Поле data_time, тип устанавливается timestamp (время хранения данных);

Поле client_id, тип установлен на varchar (запишите идентификатор устройства)

Температура поля, тип установлен на плавающее значение (данные о температуре хранения);

Влажность в поле, тип плавающий (данные о влажности при хранении);

5. Нажмите «Сохранить». Имя таблицы — humature_table.

Вы можете открыть таблицу и посмотреть. Данных сейчас нет.

тест

1. Используйте IntelliJ IDEA, чтобы открыть проект в этом разделе.

2. Исходный код должен использовать JDK1.8 и выше.

Если версия меньше 1.8, вам необходимо ее установить (нужно только установить, не нужно настраивать переменные среды)

После установки вам не нужно настраивать переменные среды. Вам нужно только установить путь к JDK в программном обеспечении.

2. Измените информацию о своей собственной базе данных и информацию о сервере MQTT.

3. Измените формат анализа в соответствии с данными вашего устройства.

Если формат данных устройства отличается от моего, пользователь может изменить его в соответствии со своим собственным форматом данных.

Формат данных, сообщаемых моим устройством: {"данные":"датчик","тип":"th","температура":45,"влажность":23}

4, начни

5. Вы можете увидеть данные всех контролируемых устройств на консоли.

6. Откройте таблицу базы данных.

Создайте исполняемый jar-пакет, установите его и запустите на сервере.

1. Перестаньте бегать

2. Поскольку программа настроена на создание пакетов jar, пользователи могут напрямую следовать приведенным ниже инструкциям для создания исполняемых пакетов jar.

3. Добавить собственно процесс генерации jar-пакетов (пользователю не нужно управлять)

4. Местоположение созданного jar-пакета.

5. Как правило, виртуальная машина Java установлена ​​на пагоде. Вы можете найти каталог и нажать на терминал выше.

Введите версию Java

6. Советы

Для работы программного обеспечения требуется JDK версии 1.8 и выше. Если другие версии JDK уже установлены,

Вы можете установить версию 1.8 еще раз.,Нет необходимости настраивать переменные среду, а затем иллюстрировать Как указать JDK для запуска. Не забудьте оглянуться назад!

7. Поместите сгенерированный jar-пакет на сервер.

Я помещаю его в каталог opt и смело делаю это по своим привычкам.

8. Нажмите на терминал выше и войдите в каталог opt.

9. Введите команду java -jar MqttDataToMySQL.jar в терминале, чтобы запустить программу.

Если вы хотите указать путь к JDK, запустите /каталог файлов JDK/bin/java -jar MqttDataToMySQL.jar.

10,Распечатать все данные устройства,иллюстрировать уже работает

Пусть программа работает в фоновом режиме

1. Нажмите комбинацию клавиш Ctrl+C на клавиатуре терминала, чтобы выйти из программы.

2. Введите nohup java -jar MqttDataToMySQL.jar &

Если вы хотите указать путь к JDK, запустите nohup /каталог файлов JDK/bin/java -jar MqttDataToMySQL.jar &

3. Программа запущена, 3073 — это значение PID запущенной программы, и создается файл журнала nohup.out;

4. Закройте эту консоль

5. Нажмите «Обновить», чтобы просмотреть файл журнала.

6.Как закрыть программу

Сначала проверьте PID процесса программы, ps aux|grep MqttDataToMySQL.jar.

Введите kill -9 3073, чтобы закрыть программу.

программаиллюстрировать

1. Весь исходный код состоит из двух частей: MQTT и базы данных.

MQTT использует пакет jar paho.client.mattv3-1.2.0.

В дополнение к базовому коннектору jabc, база данных использует пул соединений Alibaba с открытым исходным кодом druid.

2. Инициализируйте пул соединений и подключитесь к MQTT.

3. Конфигурация пула соединений

4. Подключитесь к MQTT и подпишитесь на темы.

5. Получите данные MQTT, получите объект ссылки из пула соединений и запишите данные в базу данных.

Примечание 1

1. В обычных условиях на сервере также размещается программное обеспечение Java, поэтому адрес подключения MQTT должен быть записан как

tcp://localhost:1883

2. Используйте localhost для подключения к серверу MQTT, получения всех данных устройства MQTT и прямой подписки #

3. Тот же адрес подключения к базе данных также меняется на localhost, а имя пользователя и пароль базы данных должны быть изменены на root.

После завершения модификации повторно создайте пакет jar и поместите его на сервер.

Примечание 2

Вообще говоря, после завершения установки необходимо запретить другим компьютерам прямой удаленный доступ к базе данных.

Вы можете настроить тестовую учетную запись на локальный доступ.