客户端访问账号
因为很重要,所以单列再讲下。访问账号是成对出现的,服务端加了,客户端要跟上!
1、服务端添加访问账号
系统属性或环境变量 | 示例值 | 说明 |
---|---|---|
folkmq.access.ak | demo | 访问账号 |
folkmq.access.sk | pLtqej89 | 访问密钥 |
加到哪里?
- 单机部署时,加到 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();