Problem encountered during client connection

[mengwuzhi]

When I tried to connect using the official Java client (5.0.6), I failed and the console reported an error:

Exception in thread "main" java.lang.IllegalStateException: Expected the service PushConsumerImpl-0 [FAILED] to be RUNNING, but the service has FAILED
at com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381)
at com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305)
at com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:165)
at org.apache.rocketmq.client.java.impl.consumer.PushConsumerBuilderImpl.build(PushConsumerBuilderImpl.java:128)
at org.apache.rocketmq.client.java.example.PushConsumerExample.main(PushConsumerExample.java:73)
Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:588)
at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:567)
at com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91)
at org.apache.rocketmq.client.java.impl.ClientImpl.startUp(ClientImpl.java:188)
at org.apache.rocketmq.client.java.impl.consumer.PushConsumerImpl.startUp(PushConsumerImpl.java:162)
at com.google.common.util.concurrent.AbstractIdleService$DelegateService$1.run(AbstractIdleService.java:62)
at com.google.common.util.concurrent.Callables.lambda$threadRenaming$3(Callables.java:103)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason
at io.grpc.Status.asRuntimeException(Status.java:539)
at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:544)
at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:471)
at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:435)
at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:468)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:563)
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:744)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:723)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
... 1 more

Process finished with exit code 1

How should I solve it?

[leizhiyuan]

It should be an issue with your server, check the proxy logs.

[mengwuzhi]

I'm not very sure if it is a problem with my server, It happened in both production and development environments simultaneously.

I can test but no touch with the production server.

On my own server, I can view both the broker and namesrv logs. However, I'm not very sure whether the endpoint should be set to the broker's port number or the server's port number.

Actually, no issues can be seen in the broker log, but after I set the endpoint to the namesrv's port, I can see an error in the log. It says

I don't know why I was just registering as a consumer, but the frame length i too long to be discarded.

[leizhiyuan]

it seems you use grpc client to connect the remoting server

you need deploy proxy component ,and connect the proxy

[mengwuzhi]

I downloaded the java codes from this repository(https://github.com/apache/rocketmq-clients/tree/master/java), and use the example class to connect the rocketMQ server. I don't know much about grpc, I just want to test the rocketMQ server.

According to the description on the official website，I can start broker and proxy by excute the command: "nohup sh bin/mqbroker -n localhost:9876 --enable-proxy &". But I am using windows, the command "mqbroker.cmd -n localhost:9876 --enabe-proxy" can't work.

So I don't know how to deploy a proxy component...Can you direct me?

[mengwuzhi]

I solved it after I deploeyed a proxy component. Thank you very much.