Слияние кода завершено, страница обновится автоматически
Благодарим всех за помощь в добавлении новых проектов!
SMQTT разработан на основе реактора-netty (с использованием spring-webflux в качестве базовой зависимости). В основе лежит модель реактора 3, поддерживаются одиночные и контейнерные развертывания, обеспечивая низкую задержку, высокую пропускную способность, поддержку миллионов TCP-соединений и взаимодействие с различными протоколами. Это превосходное промежуточное ПО для обмена сообщениями!
Отправляются при отключении устройства.
Использование MQTT через WebSocket.
Используемое по умолчанию изображение: 1ssqq1lxr/smqtt.
Не злоупотребляйте ссылками, спасибо!
| Управление | Описание | Прочее |
|---|---|---|
| 121.40.92.152:1883 | Порт MQTT | Имя пользователя: smqtt Пароль: smqtt |
| 121.40.92.152:18888 | MQTT через порт WebSocket | Имя пользователя: smqtt Пароль: smqtt |
| http://121.40.92.152:60000/smqtt/admin | Административный интерфейс | Имя пользователя: smqtt Пароль: smqtt |
Импортируйте зависимости:
<!-- Зависимости SMQTT -->
<dependency>
<groupId>io.github.quickmsg</groupId>
<artifactId>smqtt-core</artifactId>
<version>${Последняя версия}</version>
</dependency>
<!-- Кластерные зависимости -->
<dependency>
<artifactId>smqtt-registry-scube</artifactId>
<groupId>io.github.quickmsg</groupId>
<version>${Последняя версия}</version>
</dependency>
<!-- Управленческий интерфейс UI зависимости -->
<dependency>
<artifactId>smqtt-ui</artifactId>
<groupId>io.github.quickmsg</groupId>
<version>${Последняя версия}</version>
</dependency>
Bootstrap.builder()
.rootLevel(Level.INFO)
.websocketConfig(
BootstrapConfig.WebsocketConfig
.builder()
.enable(false)
.path("/mqtt")
.port(8888)
.build()
)
.tcpConfig(
BootstrapConfig
.TcpConfig
.builder()
.port(1883)
.ssl(SslContext.builder().enable(false).build())
.build())
.httpConfig(
BootstrapConfig
.HttpConfig
.builder()
.enable(false)
.accessLog(true)
.admin(BootstrapConfig.HttpAdmin.builder().enable(true).username("smqtt").password("smqtt").build())
.build())
.clusterConfig(
BootstrapConfig.
ClusterConfig
.builder()
.enable(false)
.namespace("smqtt")
.node("node-1")
.port(7773)
.url("127.0.0.1:7771,127.0.0.1:7772").
build())
.build()
.startAwait();
Bootstrap bootstrap = Bootstrap.builder()
.rootLevel(Level.INFO)
.websocketConfig(
BootstrapConfig.WebsocketConfig
.builder()
.enable(false)
.path("/mqtt")
*Примечание: в тексте запроса присутствуют фрагменты кода на языке программирования Java, однако они не были включены в ответ.* **Порт (8888)**
.build()
)
.tcpConfig(
BootstrapConfig
.TcpConfig
.builder()
.port(1883)
.ssl(SslContext.builder().enable(false).build())
.build())
.httpConfig(
BootstrapConfig
.HttpConfig
.builder()
.enable(false)
.accessLog(true)
.admin(BootstrapConfig.HttpAdmin.builder().enable(true).username("smqtt").password("smqtt").build())
.build())
.clusterConfig(
BootstrapConfig.
ClusterConfig
.builder()
.enable(false)
.namespace("smqtt")
.node("node-1")
.port(7773)
.url("127.0.0.1:7771,127.0.0.1:7772").
build())
.build()
.start().block();
**Способ с использованием JAR-файла**
1. Скачайте исходный код: mvn compile package -Dmaven.test.skip=true -P jar,web.
В каталоге smqtt-bootstrap/target будет создан JAR-файл.
2. Подготовьте конфигурационный файл config.yaml.
3. Запустите сервис: java -jar smqtt-bootstrap-1.0.1-SNAPSHOT.jar <путь к файлу config.yaml>.
**Docker-способ**
Скачайте образ Docker:
# Скачайте образ Docker по адресу
docker pull 1ssqq1lxr/smqtt:latest.
Запустите образ с настройками по умолчанию:
# Запустите сервис
docker run -it -p 1883:1883 1ssqq1lxr/smqtt.
Запустите образ с пользовательскими настройками (подготовьте конфигурационный файл config.yaml):
# Запустите сервис
docker run -it -v <путь к конфигурационному файлу>/config.yaml:/conf -p 1883:1883 -p 1999:1999 1ssqq1lxr/smqtt.
**Springboot-способ**
1. Добавьте зависимость:
В классе Application добавьте аннотацию @EnableMqttServer.
Настройте файл application.yml или properties.
Запустите springboot-сервис.
Если вы используете spring-boot-starter-parent, и при запуске возникает ошибка, добавьте следующие зависимости:
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-core</artifactId>
<version>3.4.9</version>
</dependency>
<dependency>
<groupId>io.projectreactor.netty</groupId>
<artifactId>reactor-netty</artifactId>
<version>1.0.10</version>
</dependency>
Wiki.
Изображение admin.png.
Изображение application.png.
Изображение jvm.png.
Изображение netty.png.
Лицензия Apache версии 2.0 (LICENSE).
Демонстрация коммерческой версии по адресу http://114.116.14.30.
Thinglinks — очень полезная IoT-платформа:
Добавьте номер телефона Lemon877164954 в WeChat и присоединяйтесь к официальному каналу общения smqtt. Также можно присоединиться к группе QQ 700152283.
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )