<a target="_blank" rel="noopener noreferrer nofollow" href="https://user-images.github

阿里云目前需要在Topic前面带上实例ID并用【%】连接,组成路由Topic[用来路由到实例Topic]。 fix <a class="issue-link js-issu

consumer.Start();出现问题 about newlife.rocketmq HOT 6 CLOSED

newlifex commented on July 18, 2024

consumer.Start();出现问题

from newlife.rocketmq.

Comments (6)

nnhy commented on July 18, 2024

连接超时，连不上

from newlife.rocketmq.

shiayoung commented on July 18, 2024

连接超时，连不上

请问连不上有超时时间可以设置吗？或者可以有一个可能传递 Cancelled 信息的参数，连不上会一直占用线程池的资源。

from newlife.rocketmq.

nnhy commented on July 18, 2024

这个超时，是客户端连接不上名称服务器，一般不需要配置超时时间，如果服务端启动并且地址正确没有防火墙，一般很短时间内返回。如果超时了，哪怕1秒超时，都可能是服务端没对或者网络问题。
所以，查一查能否telnet你的服务端地址

from newlife.rocketmq.

shiayoung commented on July 18, 2024

这个超时，是客户端连接不上名称服务器，一般不需要配置超时时间，如果服务端启动并且地址正确没有防火墙，一般很短时间内返回。如果超时了，哪怕1秒超时，都可能是服务端没对或者网络问题。所以，查一查能否telnet你的服务端地址

地址没问题，是对应的 Topic 没有创建也会导致。没法控制用户 Topic 填啥，所以如果没法快速失败，确实有可能会影响到其它任务。

16:17:46.953 81 N T System.AggregateException: One or more errors occurred. ([Name]集群所有地址连接失败！)
 ---> NewLife.XException: [Name]集群所有地址连接失败！
   at NewLife.RocketMQ.ClusterClient.EnsureCreate()
   at NewLife.RocketMQ.ClusterClient.SendAsync(Command cmd)
   --- End of inner exception stack trace ---
   at System.Threading.Tasks.Task`1.GetResultCore(Boolean waitCompletionNotification)
   at System.Threading.Tasks.Task`1.get_Result()
   at NewLife.RocketMQ.ClusterClient.Invoke(RequestCode request, Object body, Object extFields, Boolean ignoreError)
   at NewLife.RocketMQ.NameClient.GetRouteInfo(String topic)
   at NewLife.RocketMQ.NameClient.DoWork(Object state)
   at NewLife.Threading.TimerScheduler.Execute(Object state)
16:17:46.953 81 N T 任务 [6]NameClient.DoWork (30000ms) 耗时过长 192,511ms，建议使用异步任务Async=true

from newlife.rocketmq.

nnhy commented on July 18, 2024

如果对应的Topic不存在，则需要使用默认Topic连上去，然后创建新的Topic

from newlife.rocketmq.

nnhy commented on July 18, 2024

阿里云目前需要在Topic前面带上实例ID并用【%】连接,组成路由Topic[用来路由到实例Topic]。 fix #24 fix#35 … · 33e58a6
33e58a6

from newlife.rocketmq.

Recommend Projects