尝试使用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
我正在使用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
我在我的服务器上构建了一个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
在向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
回答已采纳
我试图在我的测试集群上部署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
回答已采纳
image.png
看控制台是有堆积的，实际是重试的导致的堆积，但是用go写的rocketmq exporter采集不到这个堆积数，只能采集normal的topic,不能采集到retry和死信的
image.png
浏览 367提问于2020-01-06
我们使用ActiveMQ配置网络连接器来实现两个代理之间的消息通道，现在我们想要使用RocketMQ。但我读了很多文章，似乎没有像WebSphere MQ那样的“通道”概念，也没有像RocketMQ中的ActiveMQ那样的“网络连接器”概念。那么如何在RockemtMQ中配置两个代理之间的消息通道呢？或者如何在RocketMQ中实现像WMQ或AMQ这样的“通道”场景？
浏览 0提问于2017-03-13得票数 1
我正在尝试运行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
RocketMQ消费者可以订阅具有多个标签的主题，如下所示
consumer.subscribe("topic", "taga||tagb");
生产者如何同时使用taga和tagb发送消息
我尝试发送带有"taga||tagb“标签的消息，但是消费者没有收到任何消息。根据msg_id查询消息时，标签是[taga||tagb]，不是"taga"，"tagb“
Topic: handy_test
Tags: [taga||tagb]
Keys:
浏览 4提问于2017-04-12得票数 1
找不到依赖项org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0
如图所示，我需要导入rocketmq的依赖项。但是找不到IDE错误消息。
我该如何解决这个问题？
浏览 15提问于2021-07-15得票数 0
我是Apache RocketMQ的新手。我发现我们可以使用RocketMQ控制台获取RocketMQ消息事务的详细信息。
如何将该控制台与本地运行的RockerMQ代理连接(同步)？
我使用运行代理和客户端。
浏览 4提问于2018-03-09得票数 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
我想知道为什么RocketMQ不支持JMS2.0？众所周知，JMS2.0是mq的一个常见标准。如果RocketMQ支持JMS2.0，它可以轻松地与其他mq产品连接。
浏览 4提问于2021-12-08得票数 0
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
1回答
目前，我们的虚拟机配置了18 we内存，8核CPU。
我们在同一台机器上同时运行代理和名称服务器。
到目前为止，我们大约有3563个主题。因此，名称服务器和代理消耗了18 GB中的13 GB。
我在创建一个新主题时遇到了延迟问题。(对于新的主题，创建它需要大约13到15秒)。
我希望在短短几秒内创建一个主题。
我能知道这个延迟问题的原因吗？
快速说明:我们希望在RocketMQ中创建数以百万计的主题。
我们也理解它需要足够的内存/核心来管理这些。
RocketMQ是否足以处理数百万个主题……？
浏览 2提问于2017-12-01得票数 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
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
我在使用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
回答已采纳
我试图让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
我看到了一个类似的问题，但它是为一个较早的版本。不确定冲突的版本对我来说是什么，以及我需要使用什么。
我使用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
回答已采纳
1回答
用于文件传输的消息队列
、、、
我的问题很简单。我正在寻找一种能够可靠地传输EDI文件以及附加一些元数据的MQ解决方案。
我最近尝试过RocketMQ，但遇到了硬编码的消息大小限制。我喜欢RocketMQ是因为它的简单性，但是文档的缺乏和消息大小的限制让我怀疑是否还有其他选择。
您将使用什么进行EDI消息传输？
浏览 22提问于2018-02-08得票数 1
回答已采纳
我在youtube 上看了一个春季教程视频，其中他没有实现public interface TopicRepository extends CrudRepository<Topic, String>，但他仍然能够通过编写来运行应用程序。
@Autowired
private TopicRepository topicRepository;
在服务类中，但当我尝试同样的操作时，会得到一个错误，如下所示：
io.spring.springbootstarter.topic.TopicService中的字段topicRepository需要一个无法找到的'io.spring.s
浏览 0提问于2020-07-25得票数 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
1回答
我正在编写Kafka consumer，我有一个与consumer进程相关的查询。
我有一个使用groupId="testGroupId"的消费者，他使用的groupId与我从多个主题使用的相同，比如"topic1"和"topic2"。
另外，假设已经在broker上创建了"topic1"，而"topic2"尚未创建。
现在，如果启动使用者，我会在zookeeper节点中看到"topic1" (已经创建)的使用者线程，但没有看到"topic2"的任何使用者线程。
我的问题是，只有在创
浏览 2提问于2015-10-14得票数 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
2回答
使用java应用程序，我尝试在jms统一分布式主题上创建一个持久的订阅。
jms服务器运行在WebLogic10.3.5上，该主题分布在两个服务器上。
如果我正在开发一个消息驱动的bean，它是有效的。我在两台服务器上都有一个具有相同订阅名称的持久订阅。
有了一个独立的java应用程序，我就可以用一个普通的主题(而不是分布式的)来完成这项工作。但是不能管理它来处理分布式主题。
InitialContext ic = new InitialContext();
TopicConnectionFactory connectionFactory = (TopicConnectionFactory)
浏览 1提问于2014-11-12得票数 2
我使用strimzi操作符(版本为0.28.0)创建了一个kafka集群，设置如下：
spec:
kafka:
config:
log.retention.hours: 5
auto.create.topics.enable: false
default.replication.factor: 3
min.insync.replicas: 2
假设不会自动创建主题，我添加了两个主题定义：
模式注册表的_schemas
面向消费者群体的__consumer_offsets
但是，在启动集群之后，我还看到了两个自动创建的主
浏览 25提问于2022-02-15得票数 0
回答已采纳
我按照快速入门的指导设置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
我正在创建一个Rails应用程序，并刚刚添加了一个文件(app/spec/models/test_spec.rb )，其中包含5个新的rspec测试：
describe Topic do
describe "scopes" do
before do
@public_topic = Topic.create # default is public
@private_topic = Topic.create(public: false)
end
describe "publicly_viewable
浏览 1提问于2016-02-12得票数 0
回答已采纳
我正在从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
我正在使用pykafka python库api创建一个kafka主题，使用以下代码。
from pykafka import KafkaClient
client = KafkaClient(hosts="127.0.0.1:9092")
topic = client.topics[topic_name]
producer = topic.get_producer(sync=True)
producer.produce('message'))
这里创建的主题只有一个分区，因为default.How可以使用pykafka为主题分配多个分区吗，类似于
topic.n
浏览 10提问于2017-03-10得票数 2
1回答
我有一个有很多Post的Topic，当一个主题被创建时，它会同时创建第一个帖子。
我在表单中包含了post字段：
= form_for @topic do |topic_form|
# ...
= topic_form.fields_for @post do |post_fields|
= post_fields.label :content
%br/
= post_fields.text_area :content
%br/
下面是我的TopicsController的样子：
def new
@topic = Topic.new
@post
浏览 0提问于2011-01-29得票数 4
回答已采纳
Hazelcast会懒惰地创建主题吗？在下面的例子中，我们调用了getTopic('default')。如果默认主题不存在，Hazelcast会自动创建吗？
这是否意味着没有理由初始化宇宙中所有可能的主题？
public static void main(String[] args) {
Sample sample = new Sample();
Topic topic = Hazelcast.getTopic ("default");
topic.addMessageListener(sample);
浏览 4提问于2013-05-16得票数 3
回答已采纳
我正在尝试实现一个自定义处理器，它读取来自RocketMQ的消息。
基本上我需要
创建一次MessageCosumer
然后调用MessageCosumer重复使用消息。
@onScheduled和@onTrigger，我应该使用哪一个?如何实现？
浏览 0提问于2019-07-01得票数 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
我知道在broker上为offsets.topic.replication.factor参数指定了server.properties。
我可以创建一个主题，如下所示：
offsets.topic.replication.factor = 1
另一种是：
offsets.topic.replication.factor = 2
在kafka集群中？
我有3个zookeper、3个代理和我的集群复制factor=2。
浏览 121提问于2019-10-26得票数 1
回答已采纳
我有这个控制器的方法来创建
[HttpPost]
public ActionResult Create(Topic topic)
{
if (ModelState.IsValid)
{
topicRepo.Add(topic);
topicRepo.Save();
return RedirectToAction("Details", new { id = topic.ID });
}
return View(topic);
浏览 1提问于2011-01-21得票数 2
回答已采纳
1回答
我正在尝试创建一个简单的网页，它显示从web服务接收的数据。
@Service
@Transactional
public class TopicService {
@Autowired
private TopicRepository topicRepository;
public int saveTopic(Topic topic){
return topicRepository.save(topic).getId();
}
public Iterable<Topic> findAllTopics(){
浏览 3提问于2012-01-27得票数 0
回答已采纳
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
我的Django项目中有以下模型(models.py)：
class Topic(models.Model):
id = models.AutoField(primary_key=True)
title = models.CharField(max_length=140)
def __unicode__(self):
return self.title
class ArgumentElement(models.Model):
id = models.AutoField(primary_key=True)
contents = mode
浏览 3提问于2013-06-16得票数 0
回答已采纳
实际上 ConsumeFromWhere 的枚举类源码中还有另外三个值，但是已经被弃用了。但是这个配置仅对新的 ConsumerGroup 有效，已经存在的 ConsumerGroup 会继续按照上次消费到的 Offset 继续消费。
其实也很好理解，假设有 1000 条消息，你的服务已经消费到了 500 条了，然后你上线新的东西将服务重新启动，然后又从头开始消费了？这不扯吗？
这里我们传的是 *，代表订阅所有类别的消息。当然我们也可以传入 tagA || tagB || tagC 这种，代表我们只消费打了这三种 Tag 的消息。
RocketMQ 会根据我们传入的这两个参数，构造出 Su
浏览 116提问于2021-11-27
2023-07-14：讲一讲Kafka与RocketMQ中存储设计的异同？
答案见文章，全网同名。
浏览 72提问于2023-07-14
我学会了做rocketMQ的“过滤器示例”，但是在eclipse中，我找不到MessageSelector。有谁能帮帮我呢？
。
浏览 2提问于2018-05-28得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
