RocketMQ懒人包使用问题

Question

MQ后台日志：
INFO closeChannel: close the connection to remote address[] result: true
[2021-12-09 11:18:32.260] ERROR Unexpected error occurred in scheduled task.
java.lang.RuntimeException: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to failed
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at org.apache.rocketmq.console.task.DashboardCollectTask.collectTopic(DashboardCollectTask.java:156)
at org.apache.rocketmq.console.task.DashboardCollectTask$$FastClassBySpringCGLIB$$c818b8cd.invoke()
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)atorg.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)atorg.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)atorg.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)atsun.reflect.GeneratedMethodAccessor102.invoke(UnknownSource)atsun.reflect.DelegatingMethodAccessorImpl.invoke(UnknownSource)atjava.lang.reflect.Method.invoke(UnknownSource)atorg.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)atorg.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)atorg.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)atorg.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)atorg.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)atorg.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)atorg.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:656)
at org.apache.rocketmq.console.task.DashboardCollectTask$$EnhancerBySpringCGLIB$$2854651.collectTopic()
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:65)
at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
at java.util.concurrent.Executors$RunnableAdapter.call(UnknownSource)atjava.util.concurrent.FutureTask.run(UnknownSource)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(UnknownSource)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)

服务后台日志一直打印关闭通道：
2021-12-09 11:18:33.714 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:18:33.868 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:19:03.714 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:19:03.874 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:19:33.706 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:19:33.867 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:20:03.705 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:20:03.881 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:20:33.724 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:20:33.866 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:21:03.700 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:21:03.875 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:21:33.702 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true
2021-12-09 11:21:33.875 INFO 10884 — [lientSelector_1] RocketmqRemoting : closeChannel: close the connection to remote address[] result: true

依赖：

    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-spring-boot-starter</artifactId>
        <version>2.0.3</version>
    </dependency>

配置：
rocketmq:
name-server: 127.0.0.1:9876
producer:
group: test-group

Answer 1

大目 2021-12-13 16:39:31

本地rocketmq可以正常工作吗？