rocketmq-client5.2手动给生产者和消费者设置access-key和secret-key值
生产者
import org.apache.rocketmq.acl.common.AclClientRPCHook;
import org.apache.rocketmq.acl.common.SessionCredentials;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
public class AclProducer {
public static void main(String[] args) throws Exception {
DefaultMQProducer producer = new DefaultMQProducer("rexel_notice_p1", getAclRPCHook());
producer.setNamesrvAddr("192.168.29.100:9876;192.168.29.101:9876");
producer.start();
Message msg = new Message("rexel_notice", "*", "Hello RocketMQ".getBytes());
SendResult sendResult = producer.send(msg);
System.out.printf("%s%n", sendResult);
producer.shutdown();
}
static AclClientRPCHook getAclRPCHook() {
return new AclClientRPCHook(new SessionCredentials("rexel_developer", "19@ljWo2iUow"));
}
}
消费者代码DefaultMQPushConsumer也需要设置RPCHook，步骤与生产者类似