FMQ服務(wù)部署
復(fù)制部署文件
將 fmq 文件夾復(fù)制到 **opt**文件夾下，然后執(zhí)行命令
chmod u+x permission.sh授權(quán) .sh 文件
執(zhí)行 permission.sh文件 ，授權(quán)其他文件和目錄
./permission.sh修改springBoot配置文件
定位路徑 opt\fmq\application.yml
使用內(nèi)網(wǎng)IP地址，配置集群的本地IP，和集群IP
localAddress: 1x.x.x.x
static-ip-addresses: 1x.x.x.x, 1x.x.x.xx修改kafka服務(wù)地址 bootstrap-servers
kafka:
broker-enabled: true # 是否啟用kafka消息橋接
bootstrap-servers: 127.0.0.1:9092 # kafka地址 127.0.0.1:9092,127.0.0.1:9093
producer:
acks: -1 # acks回令 如果必須等待回令,那么設(shè)置acks為all,否則，設(shè)置為-1,等待回令會(huì)有性能損耗
retries: 3 # 重試次數(shù)
batch-size: 16384 # 批量提交大小
buffer-memory: 33554432 # 緩存大小
key-serializer: org.apache.kafka.common.serialization.StringSerializer #序列化方式
value-serializer: org.apache.kafka.common.serialization.StringSerializer #序列化方式
partitioner:
class: cn.fastbee.iot.store.kafaka.MqttPartitioner
message-bridge: # kafka消息橋接轉(zhuǎn)發(fā)的主題
bridge-topics:
- "property_post"
enable: true修改webHook的認(rèn)證地址
webhook-url: http://127.0.0.1:18083/webhook項(xiàng)目打包
修改 fmq-application 對應(yīng)的 pom文件
放開這里注釋，更新maven
<resources>
<resource>
<directory>src/main/resources</directory>
<excludes>
<exclude>application.yml</exclude>
<exclude>application-dev.yml</exclude>
</excludes>
</resource>
</resources>在IDEA中，執(zhí)行 package
完成后將 fmq-application.jar 復(fù)制至 opt/fmq 目錄下
創(chuàng)建 Systemd 服務(wù)方式（推薦）
執(zhí)行 fmq-system-register.sh
./fmq-system-register.sh使用系統(tǒng)命令啟動(dòng)服務(wù)
systemctl start fmq查看服務(wù)狀態(tài)
systemctl status fmq停止服務(wù)
systemctl stop fmq直接運(yùn)行方式
執(zhí)行 fmq-start.sh
./fmq-start.sh start停止
./fmq-start.sh stop注意??！其他節(jié)點(diǎn)部署，先修改springBoot配置文件
localAddress: 1x.x.x.x
static-ip-addresses: 1x.x.x.x, 1x.x.x.xx集群驗(yàn)證
部署完成后，打開 http://ip:18083 登錄 fmq的可視化頁面 首頁 -> 節(jié)點(diǎn)
可以看到前面兩個(gè)節(jié)點(diǎn)