FolkMQ v1.7.8

客户端访问账号

因为很重要,所以单列再讲下。访问账号是成对出现的,服务端加了,客户端要跟上!

1、服务端添加访问账号

系统属性或环境变量示例值说明
folkmq.access.akdemo访问账号
folkmq.access.skpLtqej89访问密钥

加到哪里?

  • 单机部署时,加到 broker
  • 集群部署时,加到 proxy

配置示例:

#加到 broker (jar) 
java -Dfolkmq.access.ak=demo -Dfolkmq.access.sk=pLtqej89 -jar folkmq-broker.jar

#加到 broker (docker)
docker run -p 18602:18602 -p 8602:8602 -e folkmq.access.ak=demo -e folkmq.access.sk=pLtqej89  noearorg/folkmq-broker:1.7.8

或者,使用配置文件(./data/app.yml)

folkmq.access.ak: demo
folkmq.access.sk: pLtqej89

# 以 jar 启动为例
# java -jar folkmq-broker.jar

2、客户端连接地址添加访问账号

上面的配置,对应客户端连接时示例:(ak=demo,sk=pLtqej89)

folkmq://127.0.0.1:18602?ak=demo&sk=pLtqej89

或者,用通过元信息传递:

MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                .config(c->c.metaPut("ak", "demo").metaPut("sk", "pLtqej89"))
                .nameAs("demoapp")
                .connect();