From d822c5ef19e010322e781478ffecd89e3c6b282c Mon Sep 17 00:00:00 2001 From: bigshcool <990194923@qq.com> Date: Fri, 28 Apr 2023 09:32:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=95=E5=85=A5=E6=8F=92=E4=BB=B6=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E7=B1=BB=E4=BB=A5=E5=8F=8A=E7=BC=96=E5=86=99Redis?= =?UTF-8?q?=E9=85=8D=E7=BD=AEDemo?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mqtt/broker/config/PluginConfig.java | 33 +++++++++++++++++++ .../src/main/resources/smart-mqtt.yaml | 7 ++-- 2 files changed, 38 insertions(+), 2 deletions(-) create mode 100644 smart-mqtt-broker/src/main/java/org/smartboot/mqtt/broker/config/PluginConfig.java diff --git a/smart-mqtt-broker/src/main/java/org/smartboot/mqtt/broker/config/PluginConfig.java b/smart-mqtt-broker/src/main/java/org/smartboot/mqtt/broker/config/PluginConfig.java new file mode 100644 index 00000000..9833b3b0 --- /dev/null +++ b/smart-mqtt-broker/src/main/java/org/smartboot/mqtt/broker/config/PluginConfig.java @@ -0,0 +1,33 @@ +package org.smartboot.mqtt.broker.config; + + +public class PluginConfig { + /** + * 端口号 + */ + private int port; + + /** + * 主机地址 + */ + private String host; + + + public int getPort() { + return port; + } + + public void setPort(int port) { + this.port = port; + } + + public String getHost() { + return host; + } + + public void setHost(String host) { + this.host = host; + } + + +} diff --git a/smart-mqtt-broker/src/main/resources/smart-mqtt.yaml b/smart-mqtt-broker/src/main/resources/smart-mqtt.yaml index 7e8ba1b9..580776b0 100644 --- a/smart-mqtt-broker/src/main/resources/smart-mqtt.yaml +++ b/smart-mqtt-broker/src/main/resources/smart-mqtt.yaml @@ -10,5 +10,8 @@ plugins: port: 1884 - kafka-bridge: - mqtt-bridge: - - - redis-bridge: \ No newline at end of file + - redis-bridge: + port: 6379 + host: 8.130.53.106 + password: 990194923 + base64: true \ No newline at end of file -- Gitee