分布式消息服务ROCKETMQ版-使用ACL权限访问:生产者增加用户认证信息

时间：2024-08-29 16:36:38

生产者增加用户认证信息

生产者初始化时需要增加“rpcHook”参数。

普通消息、顺序消息和定时消息，增加如下代码。

RPCHook rpcHook = new AclClientRPCHook(new SessionCredentials("ACL_AC CES S_KEY", "ACL_SECRET_KEY"));
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", rpcHook);

事务消息，增加如下代码。

RPCHook rpcHook = new AclClientRPCHook(new SessionCredentials("ACL_ACCESS_KEY", "ACL_SECRET_KEY"));
TransactionMQProducer producer = new TransactionMQProducer("ProducerGroupName", rpcHook);

ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。创建用户的步骤，请参见创建用户。为了确保用户名和密钥的安全性，建议对用户名和密钥进行加密处理。

上一篇：分布式消息服务ROCKETMQ版-使用ACL权限访问:消费者增加用户认证信息

下一篇：分布式消息服务ROCKETMQ版-使用ACL权限访问:消费者增加用户认证信息