最新最热精华悬赏待回答 筛选
  • 1

    回答

系统异步调用模块设计

有dl有在系统中设计落地：“调用外部系统异步接口的能力”这样的经验过吗，能否帮忙看看这个设计思路，有什么实际应用上会多余的吗？ 设计目标：创建一个异步调用模块。 一是可以调起任一外部系统异步接口。把外

回答 xwz2244
采纳率0%
  • 2

    回答

rocketmq 双主配置问题

rocketmq 中我使用的双主模式，我返现只有一个boker-b绑定上了，但集群里有boker-a，这样会导致b服务挂了整个服务就用不了，主题中就一个b的路由,请问下这个是哪里配置不对吗？还是说我只

回答 科比的
采纳率0%
  • 3

    回答

Rocketmq配置

有没有rocketmq的大lao，帮忙看一看这个问题，在测试环境启动的rocketmq的集群模式，并且启动的时候指定了一个配置文件broker.properties,起初在配置文件中配置的东西并不多(

回答 杵意
采纳率0%
  • 2

    回答

rocketmq5.2使用controller下whichBrokerWhenConsumeSlowly是如何选择

rocketmq5.2当消息消费者向从服务器拉取消息后，会一直从从服务器拉取？答：不是的。分如下情况：1）如果从服务器的slaveReadEnable设置为false，则下次拉取，从主服务器拉取。2）

回答 wpy0032
采纳率0%
  • 2

    回答

RocketMQ5.0开源版本无法动态调整线程池线程大小

如题，最近在看rocketmq的消费者在面对消息积压时，怎么去动态调整线程池大小的，结果发现实现类ConsumeMessageConcurrentlyService的incCorePoolSize和d

回答 晚风吹行舟_
采纳率0%
  • 6

    回答

mac电脑搭建的rocketmq环境，然后mac本地调试时，发消息耗时很久，怎么解决

mac电脑搭建的rocketmq环境，然后mac本地调试时，发消息耗时很久，谁知道咋回事

回答 JCAL123
采纳率0%
  • 17

    回答

我想要获取控件id的功能

找了几个软件，但是都遇到了问题 或者教会我其他简单好用的软件也可以，能获取控件id就行，谁能帮我解决一下这个问题？远程教会我，谢谢dong ge86729不能远程就不用回复了，谢谢

安琳程
采纳率25%
  • 2

    回答

rocketmq队列

rocketmq 一个group下两个topic，每个topic设置四个读写队列，那这个group下有多少队列

回答 ba__jie
采纳率16.7%
  • 2

    回答

rocketmq没有消费所有队列

rocketmq负载均衡模式下 一个group存在topic-a跟topic-b各4个读写队列，现在有1服务订阅消费topic-a，2服务订阅消费topic-b，目前存在topic-a的队列只被1服务

回答 ba__jie
采纳率16.7%
  • 2

    回答

rocketmq 消息队列没有实现负载均衡

rocketmq单机模式下启动，一个订阅组下有两个topic，两个topic分别为AppTopic跟LogTopic的读写队列都是8个，在启动AppTopic的消费者跟LogTopic的消费者后出现如

回答 ba__jie
采纳率16.7%
  • 6

    回答

rocketMQ的生产者是从nameserver寻找broker信息，kafka也是类似从zookeeper寻找broker信息吗？

rocketMQ的生产者是从nameserver寻找broker信息，kafka也是类似从zookeeper寻找broker信息吗？

回答 GjenFly
采纳率67.9%
  • 2

rocketmq可视化编译报错

问题描述：rocketmq可视化编译报错 你的文章：https://blog.csdn.net/qq_43631716/article/details/119747200 [ERROR] Failed

珈蓝冰雨
采纳率40%
  • 3

    回答

RocketMQ启动dashboard遇到问题

RocketMQ启动，dashboard双击之后报异常怎么办？mqnamesrv.cmd和mqbroker.cmd -n localhost:9876都是正常启动的，唯独dashboard双击后就开始

回答 Txia0718
采纳率0%
  • 3

    回答

RocketMQ mq消息出现NOT_CONSUME_YET

rocketmq消息被投递到了0队列之外，但消费者只能消费0队列 能否让消费者消费其他队列，或者生产者只往一个队列投递

回答 ba__jie
采纳率16.7%
  • 3

    回答

RocketMQ 广播模式 消息堆积

背景：项目使用RocketMQ的广播模式进行消费；问题：每个结点消费完毕后，rocketmq消息监控上依旧显示消息没被消费掉，随着消息的增多，消息开始堆积；每个节点消费完毕后，怎么清除这些消息？

回答 风起了，嗯
采纳率0%
  • 3

    回答

RocketMQ使用广播模式，每个结点消费完毕后，消息堆积

RocketMQ使用广播模式，每个结点消费完毕后，rocketmq-console控制台依旧显示消息没被消费掉（消息堆积）；更换为集群模式后，rocektmq-console正常，没有消息堆积。有什么

回答 风起了，嗯
采纳率0%
  • 3

    回答

单机下rocketmq在集群模式下，没有做到每个实例都在消费

在实例切换到集群模式后，单实例可以做到正常消费，但在启动新的实例后，两个实例或者三个实例都没有继续消费，每个实例的接口仍然正常；（单消费实例下）； （两个消费实例下）

回答 ba__jie
采纳率16.7%
  • 3

单机下rocketmq只能被最新的实例消费

微服务在本地开发的时候，不可避免会启动新的实例去注册到开发环境中，开发环境本身实例是在消费mq消息的，在启动新的实例后，就只会在新的实例中消费了，在新的实例关闭后，开发环境中的实例就没有在消费了

ba__jie
采纳率16.7%
  • 4

    回答

RocketMQ消费者注册失败

RocketMQ消息已发布成功，但消费者订阅并消费失败，未在消费者组列表找到消费者组

回答 纸萌不檬
采纳率0%
  • 2

    回答

RocketMQ dashboard 找不到Broker

命令行可以看到Broker注册到了NameServer，RocketMQ dashboard 可以找到Nameserver，但是找不到Broker。 RocketMQ 5.1.4jdk 17Rocke

回答 纸萌不檬
采纳率0%
  • 3

Failed to stop bean 'org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_1

springboot 项目中重运行时出现： Failed to stop bean 'org.apache.rocketmq.spring.support.DefaultRocketMQListene

-274°C
采纳率100%
  • 1

    回答

求告知 rocketMq nameServer 如何设置

windows10系统 使用docker-compose 安装了rocketMq集群 两个nameServer 两个主节点 两个从节点 配置如下 docker-compose.yml配置如下 vers

回答 weixin_38711205
采纳率0%
  • 12

事务消息，报错，请求修改调试成功后再粘贴出正确答案

package com.example.rocketmq.coml; import org.apache.rocketmq.client.consumer.DefaultMQPushConsume

weixin_46095148
采纳率91.2%
  • 15

过滤信息,报错，请求修改调试成功后粘贴出正确答案

package com.example.rocketmq.comk; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer

weixin_46095148
采纳率91.2%
  • 18

批量发送，报错，请求修改调试成功后再粘贴正确答案

package com.example.rocketmq.comj; import org.apache.rocketmq.client.exception.MQBrokerException;

weixin_46095148
采纳率91.2%
  • 2

延迟消息，报错，请求修改调试成功后再粘贴答案

package com.example.rocketmq.comi; import org.apache.rocketmq.client.consumer.DefaultMQPushConsume

weixin_46095148
采纳率91.2%
  • 3

广播消息，报错，请求修改调试成功后粘贴正确代码

package com.example.rocketmq.comh; import org.apache.rocketmq.client.consumer.DefaultMQPushConsume

weixin_46095148
采纳率91.2%
  • 3

顺序消息，报错，请求修改调试成功后粘贴出正确答案

package com.example.rocketmq.comg; import org.apache.rocketmq.client.consumer.DefaultMQPushConsume

weixin_46095148
采纳率91.2%
  • 2

拉模式之指定获取一个队列信息，报错，请求修改调试成功后再粘贴出正确答案

package com.example.rocketmq.comf; import org.apache.rocketmq.client.exception.MQBrokerException; i

weixin_46095148
采纳率91.2%
  • 2

拉模式2，报错，请求修改调试成功后再粘贴出正确代码

package com.example.rocketmq.come; import org.apache.rocketmq.client.exception.MQBrokerException;

weixin_46095148
采纳率91.2%