我试图在RocketMQ之后从头开始安装，我使用了jdk 1.8.0_121和maven 3.5.0。
但是，在步骤mvn -Prelease-all -DskipTests clean install -U之后，没有生成目录distribution，因此cd distribution/target/apache-rocketmq不会成功。
然后，我尝试通过输入sh bin/mqnamesrv直接启动名称服务器，它给了我以下错误。
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support
浏览 12提问于2017-04-30得票数 1
回答已采纳
我看到了一个类似的问题，但它是为一个较早的版本。不确定冲突的版本对我来说是什么，以及我需要使用什么。
我使用Spring创建我的项目，遵循SCS引用。这为我设置了我的当前版本(2.1.5，Greenwich.SR1)。
我手动添加的唯一依赖项是RocketMQ，因为找不到它。这是我的pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://
浏览 3提问于2019-05-28得票数 0
回答已采纳
我试图在我的测试集群上部署rocketmq。我从github上的apache/rocketmq-docker repo中提供的脚本开始，但它们不起作用。我从前面提到的回购中创建了自己的yaml部署，它适用于mqnamsrv，但不适用于代理。在以下2个部署中：
apiVersion: apps/v1
kind: Deployment
metadata:
name: rocketmq-namesrv
spec:
replicas: 1
selector:
matchLabels:
app: rocketmq-namesrv
template:
metad
浏览 14提问于2022-03-09得票数 0
回答已采纳
我正在尝试运行docker rocketmq
docker run --name rmqbroker -d -p 10911:10911 -p 10909:10909 -v /root/deployment/rocketmq/broker/logs:/home/rocketmq/logs -v /root/deployment/rocketmq/broker/store:/home/rocketmq/store -v /root/deployment/rocketmq/broker/conf/broker.conf:/opt/rocketmq/broker.conf -e "
浏览 181提问于2021-06-03得票数 0
2024-07-10 15:38:38,697 ERROR org.apache.rocketmq.shaded.io.grpc.internal.ManagedChannelImpl$2.uncaughtException 264736 grpc-default-executor-3 [Channel<213>: (rmq-w4mx48ga.rocketmq.gz.qcloud.tencenttdmq.com:8081)] Uncaught exception in the SynchronizationContext. Panic! requ
浏览 53提问于2024-07-10
找不到依赖项org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0
如图所示，我需要导入rocketmq的依赖项。但是找不到IDE错误消息。
我该如何解决这个问题？
浏览 15提问于2021-07-15得票数 0
尝试使用spring-cloud-stream-rocketmq开发微服务项目。我有默认的rocketmq服务器，我的配置是
spring:
cloud:
stream:
default-binder: rocketmq
rocketmq:
binder:
name-server: nameserver1
bindings:
output1:
producer:
transactional: false
bindings
浏览 112提问于2020-02-12得票数 1
我只想知道它为什么会抛出这个: sendDefaultImpl调用超时。我知道可能是防火墙引起的，但是我已经把它关闭了，我找不到原因。 在org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:667)在org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1343)在org.apache.rocketm
浏览 33提问于2021-04-03得票数 0
我是Apache RocketMQ的新手。我发现我们可以使用RocketMQ控制台获取RocketMQ消息事务的详细信息。
如何将该控制台与本地运行的RockerMQ代理连接(同步)？
我使用运行代理和客户端。
浏览 4提问于2018-03-09得票数 1
回答已采纳
我想知道为什么RocketMQ不支持JMS2.0？众所周知，JMS2.0是mq的一个常见标准。如果RocketMQ支持JMS2.0，它可以轻松地与其他mq产品连接。
浏览 4提问于2021-12-08得票数 0
我们使用ActiveMQ配置网络连接器来实现两个代理之间的消息通道，现在我们想要使用RocketMQ。但我读了很多文章，似乎没有像WebSphere MQ那样的“通道”概念，也没有像RocketMQ中的ActiveMQ那样的“网络连接器”概念。那么如何在RockemtMQ中配置两个代理之间的消息通道呢？或者如何在RocketMQ中实现像WMQ或AMQ这样的“通道”场景？
浏览 0提问于2017-03-13得票数 1
我正在使用apache-rocketmq发送消息，但收到一个异常。我尝试了csdn的许多解决方案，但它不work.Now我不知道如何处理它。 这是一台Linux服务器，运行rocketmq 4.2.0、java 8和tomcat 8。 2019-05-06 15:16:01,440 WARN RocketmqClient(256) - doRebalance, eventConsumer, but the topic[alarm_event] not exist.
2019-05-06 15:16:09,230 INFO RocketmqRemoting(454) - createChann
浏览 715提问于2019-05-06得票数 0
docker运行如下：
docker create -p 10911:10911 -p 10909:10909 --name rmqbroker \
-e "JAVA_OPTS=-Duser.home=/opt" \
-e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \
-v /haoke/rmq/rmqbroker/conf/broker.conf:/etc/rocketmq/broker.conf \
-v /haoke/rmq/rmqbroker/logs:/opt/logs \
-v /ha
浏览 416提问于2021-06-03得票数 1
我正在尝试设置一个RocketMQ集群，只有一个名称服务器，一个主服务器和两个从服务器。但是，我遇到了一些问题。
我正在运行的版本是从下载的。
代理是使用mqbroker -c broker.conf运行的，其中主和从的broker.conf是不同的。对于大师，我有：
listenPort=10911
brokerName=mybroker
brokerClusterName=mybrokercluster
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
浏览 2提问于2017-10-03得票数 1
我在使用Rocket MQ(v4.1.0-孵化)客户端时遇到严重问题，如下所示：
2017-10-16 16:18:12:457[ERROR][SimpleProducer$1.onException(SimpleProducer.java:44)] - send message to mq fail:
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: invokeAsyncImpl invoke too fast
at org.apache.rocketmq.remoting.netty.N
浏览 0提问于2017-10-16得票数 1
在这里，我使用spring-cloud-starter-stream-rocketmq和spring-message发送消息dn，例如 Message m = MessageBuilder.withPayload(obj).setHeader(RocketMQHeaders.TAGS, tag).build();
MessageChannel.output().send(m); 但我想在队列中设置消息过期时间，如果它不被使用的话。 我知道rocketmq可以设置ttl，但我不知道它是否可以设置为不同的消息，以及如何在之前的代码中使用？
浏览 588提问于2021-01-07得票数 0
回答已采纳
当我提到时，我遵循了这些提示:下载源代码并构建，运行sh启动一个代理，我从os获得了一些提示。所以我检查了shell脚本，发现堆大小默认设置为8g。对于开发机器来说，这是不是太大了？当我使用maven构建整个项目时，我也感到困惑，因为maven构建项目需要1g的堆大小，所以再次从os中获得了一些技巧。我认为rocket mq的文档应该提到这些，以帮助开发人员真正快速入门。
浏览 12提问于2017-02-18得票数 0
我有一个这样的crontab。python脚本将向我的手机发送一条消息。当我在命令行上执行'/usr/local/bin/python /home/work/alibaba-rocketmq/monitor/monitor.py‘时，我可以得到消息。但是在crontab中。它不起作用。
为什么。谢谢你的帮忙
* * * * * /usr/local/bin/python /home/work/alibaba-rocketmq/monitor/monitor.py
浏览 0提问于2014-09-28得票数 1
我只是发送了一个字符串，我不知道为什么会发生这种情况。客户端-版本: 4.5.2服务器-版本: 4.5.2 希望有人能帮助我！ enter image description here enter image description here private void sendMission(String pushId) {
try {
Message message = new Message();
message.setTopic(missionTpoic);
message.setBody(pushId.getBytes("
浏览 58提问于2021-03-26得票数 0
1回答
用于文件传输的消息队列
、、、
我的问题很简单。我正在寻找一种能够可靠地传输EDI文件以及附加一些元数据的MQ解决方案。
我最近尝试过RocketMQ，但遇到了硬编码的消息大小限制。我喜欢RocketMQ是因为它的简单性，但是文档的缺乏和消息大小的限制让我怀疑是否还有其他选择。
您将使用什么进行EDI消息传输？
浏览 22提问于2018-02-08得票数 1
回答已采纳
我正在从rocketmq-cpp开源github项目生成rocketmq。我使用了下面的Prequisite 1.56.0，--> have build using this jam.exe msvc architecture=x86 address-model=64 link=static runtime-link=static stage(它是64位构建的) Cmake 3.9.3所以，我已经使用cmake -G "Visual Studio15 2017“构建了rocketmq-cpp，它将生成项目，但我正在构建项目，它总是显示错误libboost_thread-vc140
浏览 17提问于2018-08-07得票数 1
我按照快速入门的指导设置RocketMQ，运行
sh bin/mqnamesrv
日志显示：
Java HotSpot(TM)服务器VM警告:忽略选项PermSize=128m；在8.0中删除了支持
Java HotSpot(TM)服务器VM警告:忽略选项MaxPermSize=320m；在8.0中删除了支持
Java (TM) Server警告:不推荐将DefNew young收集器与HotSpot收集器一起使用，在将来的版本中可能会将其删除
Java HotSpot(TM) Server VM警告: UseCMSCompactAtFullCollection已被弃用，可能会在将来的版本中删
浏览 43提问于2017-05-12得票数 1
有一些RocketMQ主题，但只有一个主题有4个队列，只能消费一个队列。
RocketMQ 4.2.0 Java 1.8
消费组配置：
depthConsumerGroup.setNamesrvAddr(rocketMQConfig.getNameServers());
depthConsumerGroup.setConsumeThreadMin(64);
depthConsumerGroup.setConsumeThreadMax(128);
depthConsumerGroup.setAdjustThreadPoolNumsThreshold(500);
浏览 5提问于2019-09-04得票数 1
2回答
了解下腾讯云服务中提供的nacos、zk、redis、rocketmq、Kafka中间件，是否提供了对应完善的sdk，已实现go的TKE部署?
浏览 162提问于2023-11-29
我在我的服务器上构建了一个rocketmq服务，它是2m-noslave集群，它可以向rocketmq发送消息，但我的消费者无法接收消息，有人告诉我哪里错了，thinks...this是我的消费者CLass代码：
public class Consumer{
public static final String CONSUMER_GROUP_NAME = "broker-b";
public static final String CLUSTER_ADDR = "120.27.128.207:9876;120.27.146.42:9876";
浏览 5提问于2017-11-22得票数 0
2023-07-14：讲一讲Kafka与RocketMQ中存储设计的异同？
答案见文章，全网同名。
浏览 71提问于2023-07-14
我学会了做rocketMQ的“过滤器示例”，但是在eclipse中，我找不到MessageSelector。有谁能帮帮我呢？
。
浏览 2提问于2018-05-28得票数 0
我试图让rockerMQ代理明星化，但我得到了错误消息：
Java运行时环境没有足够的内存继续运行。
本机内存分配(mmap)未能映射用于提交保留内存的8589934592字节。
包含更多信息的错误报告文件保存为：
/usr/local/soft/rocketMQ/incubator-rocketmq/distribution/target/apache-rocketmq/hs_err_pid6034.log
HotSpot(TM) 64位服务器VM警告: INFO: os：：commit_memory(0x00000005c00000,8589934592，0)失败；错误=‘无法分配内存’
浏览 4提问于2017-09-10得票数 2
RocketMQ消费消息频繁 MySQL存储跟新也频繁 效率不高且影响MySQL性能
浏览 12提问于2024-09-19
1回答
经营环境：
CentOS Linux版本7.8.2003 (核心)- openjdk版本"11.0.8“2020-07-14 LTS -
序言：
为了快速启动和运行，我将下载一个二进制版本。不需要构建二进制工件。
对问题的描述：
由于RocketMQ启动脚本不支持java11，因此我对启动文件进行了基于web搜索的更改，使用runserver.sh、runbroker.sh和tools.sh修改文件，大致相同。配置文件如下所示。
runserver.sh
# JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:Metas
浏览 3提问于2020-10-13得票数 0
我得到了名为A和B的rocketmq集群，它们分别位于网络网络-A和net中。如何同步他们的主题和消息.
浏览 18提问于2022-05-10得票数 0
在向RocketMQ 4.8发送消息之后，我发现使用者只消耗了部分队列。这是RocketMQ消费者代码，如下所示：
public void appConsumer(Long appId, List<String> topics) throws MQClientException {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(appId.toString());
RocketMQConfigDTO rocketMQConfigDTO = MqConfigHandler.MQConfig();
浏览 14提问于2022-06-27得票数 -1
回答已采纳
1回答
目前，我们的虚拟机配置了18 we内存，8核CPU。
我们在同一台机器上同时运行代理和名称服务器。
到目前为止，我们大约有3563个主题。因此，名称服务器和代理消耗了18 GB中的13 GB。
我在创建一个新主题时遇到了延迟问题。(对于新的主题，创建它需要大约13到15秒)。
我希望在短短几秒内创建一个主题。
我能知道这个延迟问题的原因吗？
快速说明:我们希望在RocketMQ中创建数以百万计的主题。
我们也理解它需要足够的内存/核心来管理这些。
RocketMQ是否足以处理数百万个主题……？
浏览 2提问于2017-12-01得票数 1
我正在构建一个共享库，它与boost是静态链接的，如下所示：
/usr/bin/c++ -fPIC -Wall -Wshadow -g -Wl,-Bstatic -lboost_date_time -lboost_thread -lboost_filesystem -lboost_system -Wl,-Bdynamic -ldl -shared -Wl,-soname,liboms_rocketmq.so -o ../lib/liboms_rocketmq.so
问题是，当在Ubuntu16.04上dlopen这个库时，本应静态链接的符号是未定义的(参见以下命令输出: U)，而符号可以
浏览 0提问于2018-03-14得票数 0
我正在使用RocketMQ，并希望按顺序生产和使用数据。我已经完成了订单示例：
但在消费者的倾听者中，信息并不是有序的。有谁能告诉我这个订单消息是如何工作的吗？
浏览 2提问于2017-10-19得票数 1
image.png
看控制台是有堆积的，实际是重试的导致的堆积，但是用go写的rocketmq exporter采集不到这个堆积数，只能采集normal的topic,不能采集到retry和死信的
image.png
浏览 367提问于2020-01-06
我正在尝试实现一个自定义处理器，它读取来自RocketMQ的消息。
基本上我需要
创建一次MessageCosumer
然后调用MessageCosumer重复使用消息。
@onScheduled和@onTrigger，我应该使用哪一个?如何实现？
浏览 0提问于2019-07-01得票数 1
回答已采纳
根据上的文档，没有Artemis / ActiveMQ绑定器/实现？
有没有这样做的计划？
RabbitMQ
阿帕奇·卡夫卡
Kafka流
Amazon Kinesis
谷歌PubSub (合作伙伴维护)
Solace PubSub+ (合作伙伴维护)
Azure事件中心(合作伙伴维护)
Apache RocketMQ (合作伙伴维护)
谢谢
浏览 21提问于2020-03-12得票数 2
在腾讯云上部署rocketmq，两台机器，部署2m-2s-sync，主从交叉部署，namesrv可以正常启动，
机器A ： 主： broker-a，也可正常启动，从：broker-b-s 不能正常启动
机器B ： 主： broker-b，也可正常启动，从：broker-a-s 不能正常启动
搜狗截图20191202220014.png
浏览 1480提问于2019-12-02
我正在运行为.NET SDK RocketMQ提供的演示示例。
但是它抛出了下面的异常。
An unhandled exception of type 'System.TypeInitializationException'
Additional information: The type initializer for 'ons.ONSClient4CPPPINVOKE' threw an exception.
我没有得到任何解决方案的issue.Can，任何人请给出一个解决方案的异常。
浏览 12提问于2017-07-20得票数 1
1回答
雅虎( )似乎是下一代Apache。
阿里巴巴( )似乎是阿帕奇的下一代ActiveMQ。
这两个平台都是开源的分布式消息传递和流式数据平台。
但它们的比较如何呢？就功能和性能而言，我什么时候应该更喜欢彼此？
普尔萨尔(像卡夫卡一样)严格来说是更擅长流媒体，而RocketMQ (比如ActiveMQ)是严格来说更擅长消息传递吗？
浏览 5提问于2018-06-12得票数 10
回答已采纳
我知道rocketmq的名称服务器端口是9876 (默认)，这里我可以将端口更改为9877 (示例)，如下所示
echo "listenPort=9877“> port.properties
nohup sh mqnamesrv -c port.properties &
然后是netstat -tunlp |grep 9877
# » netstat -tunlp |grep 9877
tcp 0 0 0.0.0.0:9877 0.0.0.0:* LISTEN 17808/
浏览 6提问于2018-05-18得票数 0
据我所知，在RocketMq中，“队列”类似于Kafka中的“分区”。一个主题有多个队列，也有多个代理(主和从)。
但是队列是如何映射到主队列的呢？
例如，如果我有一个具有3个队列和3个主控器的主题。3个队列分布在3个主服务器中吗？或者每个主服务器有3个队列？
浏览 2提问于2017-01-05得票数 1
1回答
我正在使用RocketMQ，并且希望在每次新请求时从队列中获取消息
@Service
public class GetMessageFromQueue extends BaseObject {
@Resource
private RocketMQTemplate rocketMQTemplate;
@Value("${demo.rocketmq.topic}")
private String springTopic;
private String ms;
public void getMessage(InternalRequest internalRequest) thr
浏览 7提问于2019-12-03得票数 0
我需要将消息发布到在不允许发起连接的环境中运行的客户端，但接受连接是可以的。
使用rocketmq或pulsar时，我遇到的问题是它们都需要客户端(或代理或代理)启动连接来注册自己。
想知道在这种情况下部署它们的正确方式是什么？或适用于此场景的任何其他类似软件？
浏览 4提问于2021-04-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
