No accessKey is configured 本来这个错误是很简单个错误，本意是mq上边开启了acl验证机制，而客户端没有配置accessKey。但是笔者这次遇到的这个问题比较有意思，废了我半天时间去研究。在这里记录一下。
引子
当时笔者是先行自己封装好了一个rocket的工具库，考虑到安全问题，决定引入acl机制，然后主要是参照了网上的两个文章。配置mq的broker和plain_acl两个配置文件，客户端加入acl相关代码，主要是加入了AclRPCHook，在发送消息之前插入accessKey和签名供mq进行校验。之后用测试工程引用本地maven库上安装的rocket工具库进行测试，结果之前能用的代码在用了acl之后一直报错：No accessKey is configured。
这个时候发现直接弄个带main方法的类运行例子里的代码是可以的，一样的代码copy到测试工程里就不行了：分析一下这应该是客户端问题，mq服务端的acl配置应该是对的。
客户端哪里的问题呢？
接下来1天各种实验无果，开始回到起点，潜心来看源码，搞清楚客户端的mq发送消息以及acl的源码是怎么写的。
当调用DefaultMQProducer的send方法，同步的向mq投递消息的时候，实际上是defaultMQProducerImpl.send(msg)，也即DefaultMQProducerImpl的sendKernelImpl方法，关键代码：
sendResult = this.mQClientFactory.getMQClientAPIImpl().sendMessage
里边其实是MQClientAPIImpl的如下方法：
private SendResult sendMessageSync(
final String addr,
final String brokerName,
final Message msg,
final long timeoutMillis,
final RemotingCommand request
) throws RemotingException, MQBrokerException, InterruptedException {
RemotingCommand response = this.remotingClient.invokeSync(addr, request, timeoutMillis);
assert response != null;
return this.processSendResponse(brokerName, msg, response,addr);
}
其中remotingClient是接口，其实现是netty NettyRemotingClient invokeSync()，后者会doBeforeRpcHooks(addr, request);
if (rpcHooks.size() > 0) {
for (RPCHook rpcHook: rpcHooks) {
rpcHook.doBeforeRequest(addr, request);
}
}
rpcHooks这里相当于是NettyRemotingClient的成员变量。
对于acl的DefaultMQProducer
DefaultMQProducer实例化的时候，是把rpcHook都给到了自己的defaultMQProducerImpl。
factory是在defaultMQProducerImpl.start()也就是DefaultMQProducer.start()的时候实例化的。
MQClientInstance是factory的实现，实例化的时候内部：
this.mQClientAPIImpl = new MQClientAPIImpl(this.nettyClientConfig, this.clientRemotingProcessor, rpcHook, clientConfig);
然后factory提供这个mQClientAPIImpl实例。
defaultMQProducerImpl的start方法中实例化factory时，会判断如果生成过，就不再生成了。也就是说整个进程只会有一个factory实例。
关键代码：
this.mQClientFactory = MQClientManager.getInstance().getOrCreateMQClientInstance(this.defaultMQProducer, rpcHook);
到这里原因搞清楚了：测试工程里刚好有另外一个transactionProducer的代码，是笔者用来测试事务消息的，没加acl相关的代码和配置，所以一旦先transactionProducer.start()创建了factory，那之后会一直用这个无acl的factory，所以发送消息到mq的时候一直提示没有accessKey就是这个原因。
网友评论