5 许志武

钱粒科技 - JAVA开发工程师

把生活过成段子,把代码写成诗

添加认证
等级
TA的排名 1w+

rocketmq 之namesrv(四十)mqclient admin请求处理查询消费队列

查询消费队列 AdminBrokerProcessor#queryConsumeQueueAdminBrokerProcessor#processRequest#this.queryConsumeQueue(ctx, request)private RemotingCommand queryConsumeQueue(ChannelHandlerContext ctx, Remo...

2020-03-31 14:30:27

rocketmq 之namesrv(三十九)mqclient admin请求处理拉取broker消费者组状态

拉取broker消费者组状态 AdminBrokerProcessor#fetchAllConsumeStatsInBrokerAdminBrokerProcessor#processRequest#this.fetchAllConsumeStatsInBroker(ctx, request)private RemotingCommand fetchAllConsumeStatsInBroke...

2020-03-31 14:30:08

rocketmq 之namesrv(三十八)mqclient admin请求处理查看broker的状态数据

查看broker的状态数据 AdminBrokerProcessor#ViewBrokerStatsData这里ViewBrokerStatsData方法命名不符合规范,没看出来为啥必须要用这个方法名AdminBrokerProcessor#processRequest#this.ViewBrokerStatsData(ctx, request) private RemotingComman...

2020-03-31 14:29:51

rocketmq 之namesrv(三十七)mqclient admin请求处理clone组的offset

clone组的offset AdminBrokerProcessor#cloneGroupOffsetAdminBrokerProcessor#processRequest#this.cloneGroupOffset(ctx, request) private RemotingCommand cloneGroupOffset(ChannelHandlerContext ctx, ...

2020-03-31 14:29:34

rocketmq 之namesrv(三十六)mqclient admin请求处理直接消费消息

直接消费消息AdminBrokerProcessor#consumeMessageDirectlyAdminBrokerProcessor#processRequest#this.consumeMessageDirectly(ctx, request) private RemotingCommand consumeMessageDirectly(ChannelHandlerContext ct...

2020-03-31 14:29:22

一文读懂authorized_keys和known_hosts

authorized_keys我们需要本地机器ssh访问远程服务器时为了减少输入密码的步骤,基本上都会在本地机器生成ssh公钥,然后将本地ssh公钥复制到远程服务器的.ssh/authorized_keys中,这样就可以免密登录了。( 服务器之间访问同理)。流程如下本机生成 ssh公钥;复制本机公钥到远程服务器.ssh/authorized_keys中,authorized_keys文件...

2020-03-27 17:44:52

rocketmq 之namesrv(三十五)mqclient admin请求处理查询修改后的offset

查询修改后的offset AdminBrokerProcessor#queryCorrectionOffsetAdminBrokerProcessor#processRequest#this.queryCorrectionOffset(ctx, request) private RemotingCommand queryCorrectionOffset(ChannelHandlerContex...

2020-03-27 15:37:44

rocketmq 之namesrv(三十四)mqclient admin请求处理获取消费者运行信息

获取消费者运行信息 AdminBrokerProcessor#getConsumerRunningInfoAdminBrokerProcessor#processRequest#this.getConsumerRunningInfo(ctx, request) RemotingCommand request) throws RemotingCommandException { ...

2020-03-27 15:12:51

rocketmq 之namesrv(三十三)mqclient admin请求处理清除不再使用的topic

清除不再使用的topic AdminBrokerProcessor#cleanUnusedTopicAdminBrokerProcessor#processRequest#this.cleanUnusedTopic(ctx, request)public RemotingCommand cleanUnusedTopic() { log.warn("invoke cleanUnu...

2020-03-27 15:11:26

rocketmq 之namesrv(三十二)mqclient admin请求处理清除过期的消费队列

清除过期的消费队列AdminBrokerProcessor#cleanExpiredConsumeQueueAdminBrokerProcessor#processRequest#this.cleanExpiredConsumeQueue(ctx, request)public RemotingCommand cleanExpiredConsumeQueue() { log.w...

2020-03-26 11:42:27

rocketmq 之namesrv(三十一)mqclient admin请求处理从broker中获取系统topic列表

从broker中获取系统topic列表AdminBrokerProcessor#getSystemTopicListFromBrokerAdminBrokerProcessor#processRequest#this.getSystemTopicListFromBroker(ctx, request)private RemotingCommand getSystemTopicListFromB...

2020-03-26 10:40:54

rocketmq 之namesrv(三十)mqclient admin请求处理查询消费者时间跨度

查询消费者时间跨度AdminBrokerProcessor#queryConsumeTimeSpanAdminBrokerProcessor#processRequest#this.queryConsumeTimeSpan(ctx, request)private RemotingCommand queryConsumeTimeSpan(ChannelHandlerContext ctx, ...

2020-03-26 10:21:55

rocketmq 之namesrv(二十九)mqclient admin请求处理注册过滤服务器

注册过滤服务器AdminBrokerProcessor#registerFilterServerAdminBrokerProcessor#processRequest#this.registerFilterServer(ctx, request)private RemotingCommand registerFilterServer(ChannelHandlerContext ctx, ...

2020-03-23 14:53:35

rocketmq 之namesrv(二十八)mqclient admin请求处理查询topic被哪些消费者消费

查询topic被哪些消费者消费 AdminBrokerProcessor#getConsumerStatusAdminBrokerProcessor#processRequest#this.queryTopicConsumeByWho(ctx, request)private RemotingCommand queryTopicConsumeByWho(ChannelHandlerContex...

2020-03-23 14:38:58

rocketmq 之namesrv(二十七)mqclient admin请求处理调用broker获取消费者状态

获取所有消费者的offsetAdminBrokerProcessor#getConsumerStatusAdminBrokerProcessor#processRequest#this.getConsumerStatus(ctx, request)public RemotingCommand getConsumerStatus(ChannelHandlerContext ctx, ...

2020-03-23 11:53:54

rocketmq 之namesrv(二十六)mqclient admin请求处理调用broker重置offset

获取所有消费者的offsetAdminBrokerProcessor#resetOffsetAdminBrokerProcessor#processRequest#this.resetOffset(ctx, request)public RemotingCommand resetOffset(ChannelHandlerContext ctx, RemotingCommand ...

2020-03-23 10:57:12

rocketmq 之namesrv(二十五)mqclient admin请求处理获取所有delay的offset

获取所有消费者的offsetAdminBrokerProcessor#getAllDelayOffsetAdminBrokerProcessor#processRequest#this.getAllDelayOffset(ctx, request)private RemotingCommand getAllDelayOffset(ChannelHandlerContext ctx, Remot...

2020-03-23 10:43:19

异步线程threadLocal中对象获取失败

问题描述在一个比较复杂的业务中,同步执行了主任务,将与当前任务无关的任务丢进了异步线程,然后发现异步线程没有获取到用户。所有的异步任务都没有执行下去。排查1.直接debug,发现任务在异步方法开始执行就失败了,没有进入异步方法;2.打log,异步方法前的log打印了,之后的没有。3.仔细看代码,发现了开启异步线程后入参直接来自threadLocal,找到问题了,明显的子线程获取父线程对象...

2020-03-19 12:02:06

rocketmq 之namesrv(二十四)mqclient admin请求处理获取所有消费者的offset

获取所有消费者的offsetAdminBrokerProcessor#getAllConsumerOffsetAdminBrokerProcessor#processRequest#this.getAllConsumerOffset(ctx, request)private RemotingCommand getAllConsumerOffset(ChannelHandlerContext c...

2020-03-05 18:49:35

rocketmq 之namesrv(二十三)mqclient admin请求处理获取消费者的状态

获取消费者的状态AdminBrokerProcessor#getConsumeStatsAdminBrokerProcessor#processRequest#this.getConsumeStats(ctx, request)private RemotingCommand getConsumeStats(ChannelHandlerContext ctx, RemotingC...

2020-03-05 17:50:41

查看更多

勋章 我的勋章
  • GitHub
    GitHub
    绑定GitHub第三方账户获取
  • 脉脉勋章
    脉脉勋章
    绑定脉脉第三方账户获得
  • 签到新秀
    签到新秀
    累计签到获取,不积跬步,无以至千里,继续坚持!
  • 技术圈认证
    技术圈认证
    用户完成年度认证,即可获得
  • 专栏达人
    专栏达人
    授予成功创建个人博客专栏的用户。专栏中添加五篇以上博文即可点亮!撰写博客专栏浓缩技术精华,专栏达人就是你!
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 勤写标兵Lv4
    勤写标兵Lv4
    授予每个自然周发布9篇以上(包括9篇)原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。
  • 分享达人
    分享达人
    成功上传6个资源即可获取