fmq集群部署

FMQ服务部署

复制部署文件

将 fmq 文件夹复制到 **opt**文件夹下，然后执行命令

chmod u+x permission.sh

授权 .sh 文件

执行 permission.sh文件 ，授权其他文件和目录

./permission.sh

修改springBoot配置文件

定位路径 opt\fmq\application.yml

使用内网IP地址，配置集群的本地IP，和集群IP

localAddress: 1x.x.x.x
static-ip-addresses: 1x.x.x.x, 1x.x.x.xx

修改kafka服务地址 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回令 如果必须等待回令,那么设置acks为all,否则，设置为-1,等待回令会有性能损耗
      retries: 3    # 重试次数
      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消息桥接转发的主题
      bridge-topics:
        - "property_post"
      enable: true

修改webHook的认证地址

 webhook-url: http://127.0.0.1:18083/webhook

项目打包

修改 fmq-application 对应的 pom文件

放开这里注释，更新maven

        <resources>
            <resource>
                <directory>src/main/resources</directory>
                <excludes>
                    <exclude>application.yml</exclude>
                    <exclude>application-dev.yml</exclude>
                </excludes>
            </resource>
        </resources>

在IDEA中，执行 package

完成后将 fmq-application.jar 复制至 opt/fmq 目录下

创建 Systemd 服务方式（推荐）

执行 fmq-system-register.sh

./fmq-system-register.sh

使用系统命令启动服务

systemctl start fmq

查看服务状态

systemctl status fmq

停止服务

systemctl stop fmq

直接运行方式

执行 fmq-start.sh

./fmq-start.sh start

停止

./fmq-start.sh stop

注意！！其他节点部署，先修改springBoot配置文件

localAddress: 1x.x.x.x
static-ip-addresses: 1x.x.x.x, 1x.x.x.xx

集群验证

部署完成后，打开 http://ip:18083 登录 fmq的可视化页面 首页 -> 节点

可以看到前面两个节点