使用阿里云rocketmq发送同步消息报错[阿里云消息队列MQ]

问题描述

使用阿里云rocketmq发送同步消息报错,使用示例demo配置好账号信息、组、主题后运行报错:

Caused by: com.aliyun.openservices.ons.shaded.org.apache.rocketmq.client.exception.ClientException: error code: OTHER

    at com.aliyun.openservices.ons.shaded.org.apache.rocketmq.client.impl.producer.ProducerImpl.onExecutionException(ProducerImpl.java:838)

    at com.aliyun.openservices.ons.shaded.org.apache.rocketmq.client.impl.producer.ProducerImpl.send(ProducerImpl.java:351)

    at com.aliyun.openservices.ons.shaded.org.apache.rocketmq.client.impl.producer.ProducerImpl.send(ProducerImpl.java:339)

    at com.aliyun.openservices.ons.shaded.org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:183)

    at com.aliyun.openservices.ons.client.rocketmq.impl.ProducerImpl.send(ProducerImpl.java:152)

    … 94 more

Caused by: com.aliyun.openservices.ons.shaded.io.grpc.StatusRuntimeException: PERMISSION_DENIED: Grpc server auth error, request doesn’t has topic or group. request=apache.rocketmq.v1.SendMessageRequest, requestId=6afec3dd-7a0d-4350-830f-b6ecc791e7bf, error=permission denied: signature validate failed.-2 Signature not match!, validate=false, akDisabled=false, whiteList=true

    at com.aliyun.openservices.ons.shaded.io.grpc.Status.asRuntimeException(Status.java:534)

    at com.aliyun.openservices.ons.shaded.io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533)

    at com.aliyun.openservices.ons.shaded.io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)

    at com.aliyun.openservices.ons.shaded.io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)

    at com.aliyun.openservices.ons.shaded.io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:553)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:68)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:739)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:718)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)

    at com.aliyun.openservices.ons.shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)

    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

    … 1 more

期望结果

已尝试的方法

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====