application.yaml

server:
  # ip地址/域名（公网环境下部署需要配置成公网ip）
  addr: 127.0.0.1
  # Gin服务运行端口号
  port: 8011

mq:
  # 生产者、控制台访问密钥（放在请求头部）
  secretKey: test

  # 消息推送模式（1：点对点模式，一条消息只能随机被一个消费者客户端消费。2：订阅/发布推送模式：将消息推送给所有消费者客户端）
  pushType: 1

  # 消息通道的缓冲空间大小（消息队列可容纳的未消费消息数量，超过该数值，生产者消息接收协程将被阻塞）
  messageChanBuffer: 10000000

  # 推送消息的速度（{pushMessagesSpeed}秒/一批消息）
  pushMessagesSpeed: 1
  # 单批次推送的消息数量
  pushCount: 1000
  # 消息消费超时阈值（如果在消息插入队列的{delayTime消息延时推送时间 + pushRetryTime消息消费超时阈值}秒后，仍未被消费，就重新推送消息）
  pushRetryTime: 300

  # 持久化文件
  persistentFile: MQDATA
  # 是否进行持久化（0：不开启持久化，1：周期性全量数据持久化（不包含已消费消息），2：在两次周期性全量数据持久化之间增加WAL追加写入日志,影响性能）
  isPersistent: 0
  # 数据恢复策略（0：清空本地数据，不进行数据恢复。1：将本地数据恢复到内存）
  recoveryStrategy: 1
  # 两次全量数据持久化的间隔时间（单位：秒）
  persistentTime: 5

  #是否立即清除已确认消费的消息（1：是。0：否）
  isCleanConsumed: 0

  # 是否开启自动重推未确认消费消息功能（1：是。0：否）
  isRePush: 1
  # 是否开启自动清理过期消息功能（1：是。0：否）
  isClean: 1

  # 检查消息的速度（每隔{checkSpeed}秒检查一批消息，用于消费失败的消息重推、延时消息推送与过期消息清理）
  checkSpeed: 5

  # 消息过期阈值（当消息存在超过{cleanTime}秒后，删除该消息）
  cleanTime: 172800

# Gossip集群配置
cluster:
  # 是否以集群方式部署（1：是。0：否）
  isCluster: 0
  # 该节点的Gossip服务端口号（使用Gossip协议，通过此端口连接注册中心，不能与上面的Gin http服务端口号{server.port}相同）
  gossipPort: 8021
  # 注册中心的ip地址/域名
  registryAddr: 127.0.0.1
  # Serena注册中心的Gossip服务端口号
  registryGossipPort: 8041

# 主从同步配置
sync:
  # 是否开启主从同步功能（1：是。0：否）
  isSync: 0
  # 该节点是否为从节点（1：是。0：否）
  isSlave: 0
  # 主节点网络协议（此配置在{isSlave}为1时生效）
  masterProtocol: ws
  # 主节点的ip地址/域名（此配置在{isSlave}为1时生效）
  masterAddr: 127.0.0.1
  # 主节点的Gin http服务端口号（此配置在{isSlave}为1时生效）
  masterPort: 8011