如何根据客户端日志判断当前状态? -问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

如何根据客户端日志判断当前状态?

保持可爱mmm 2020-03-28 21:33:15 122

如何根据客户端日志判断当前状态?

分享到
取消 提交回答
全部回答(1)
  • 保持可爱mmm
    2020-03-28 21:35:08

    消息队列 RocketMQ 版客户端日志文件是 ons.log,包括 INFO、WARN、ERROR 级别的日志。 本文提供常见的客户端日志打印信息,旨在帮助您更好地从打印的日志中获取信息,并判断当前状态,从而排查故障。 下表列举了 ons.log 日志信息说明(持续更新)。

    日志级别 打印信息 说明 解决方案 INFO [persistAll] Group: CID_XXXX ClientId: 10.31.40.100@171374#14159XXX#-2036649XXX#20931314294957XXX updateConsumeOffsetToBroker MessageQueue [topic=XXXX, brokerName=qdinternetorder-XX, queueId=X] 1013XXX 这种现象说明消息已经消费成功,并且在消息队列 RocketMQ 版服务端已持久化消费进度;MessageQueue 里包括了消息主题、对应的 brokerName、消费队列的 ID 不涉及 INFO [PULL_TPS] [CID_XXXX@CID_XXXX] Stats In One Minute, SUM: 0 TPS: 0.00 AVGPT: 0.00
    [PULL_RT] [%RETRY%CID_XXXX@CID_XXXX] Stats In One Minute, SUM: 0 TPS: 0.00 AVGPT: 0.00 该类信息打印的是从 consumeQueue 中拉取消息时的 TPS(每秒 Request 的数量) 不涉及 WARN [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 905ms, size of queue: 1164 消息队列 RocketMQ 版服务端压力过大,处理不了过多的请求;由于服务端在存储数据时是先写入 pageCache,然后去刷盘,因此每隔 10s 会去清理过期的请求(此过程会判断缓存页是否繁忙) 扩容,增加 Broker,分担压力 osPageCacheBusyTimeOutMills 属性值调大 WARN execute the pull request exceptioncom.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 25 DESC: the consumer's subscription not latest Broker 每隔一段时间就会向 NameServer 上报自己的路由信息,如果此过程网络抖动,拉不到最新的订阅信息,导致消费者消费的时候,会出现该警告 不涉及 WARN [WRONG]mq is consuming, so can not unlock it, MessageQueue [topic=XX, brokerName=szorder2-02, queueId=1]. maybe hanged for a while, 2 进行负载均衡时,对消息处理队列尝试加锁,如果 1s 内还未加锁成功,说明当前消息处理队列已经有消费者在访问,不能进行解锁 不涉及 WARN doRebalance, XXX-CID, add a new mq failed, MessageQueue [topic=XXXX, brokerName=szorder2-XX, queueId=X], because lock failed 当前使用的是顺序 Topic,为了保证单个分区中消息的顺序消费,会有个 Lock 的机制。客户端有这个日志说明其中某个分区已经有客户端在消费了。 不涉及 WARN get Topic [XXXXXX] RouteInfoFromNameServer is not exist valuecom.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException: CODE: 17 DESC: No topic route info in name server for the topic: TOPIC_XXXXX
    See http://rocketmq.apache.org/docs/faq/ for further details. AccessKey(包含 AccessKeyId 和 AccessKeySecret)配置错误 没有控制台于当前实例下创建的 Group ID(GID) 实例化的代码中,NameServerAddr 没有配置正确 配置正确的 AccessKey 在当前实例下创建 GID Java SDK 1.8.0 及以上版本,推荐配置 NameServerAddr,此参数可从消息队列 RocketMQ 版控制台获取,与之前版本配置的 ONSAddr 是不一致的 WARN com.aliyun.openservices.ons.api.impl.authority.exception.AuthenticationException: signature validate by dauth failed AccessKey(包含 AccessKeyId 和 AccessKeySecret)配置错误 AccessKey 要配置创建该 GID 使用的 AccessKey WARN NettyClientPublicExecutor_3 - execute the pull request exceptioncom.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 26 DESC: subscription group [CID_XXX] does not exist,See http://rocketmq.apache.org/docs/faq/ for further details. 订阅关系没有推送到消息队列 RocketMQ 版 broker 上 subscription.json 文件里直接添加 GID 对应的信息即可 WARN execute the pull request exceptioncom.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 24 DESC: the consumer's subscription not exist 缺少订阅关系 不涉及

    0 0
云计算
使用钉钉扫一扫加入圈子
+ 订阅

时时分享云计算技术内容,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

推荐文章