Rocketmq 消费者默认是集群的方式消费的,消费者还可以用广播的模式进行消费。广播模式消费就是所有订阅同一个主题的消费者都会收到消息。代码实现上其实很简单,就是在消费端添加 就可以了。我们看实验步骤: 一、启动ConsumerBroadCastMember1 二、启动ConsumerBroadC ...
分类:
其他好文 时间:
2018-01-06 23:28:54
阅读次数:
1855
介绍什么是延迟消息,延迟消息在业界的实现情况,分析延迟消息的难点,分析RocketMQ延迟消息的实现,推导延迟消息的方案。 ...
分类:
其他好文 时间:
2018-01-02 11:37:55
阅读次数:
190
基本概念: Producer:消息生产者,负责生产消息,一般由业务系统负责生产消息。 Consumer:消息消费者,负责消费消息,一般是后台系统负责异步消费。 Push Consumer:Consumer的一种,应用通常向Consumer对象注册一个Listener接口,一旦收到消息,Consume ...
分类:
其他好文 时间:
2018-01-01 23:33:48
阅读次数:
279
1、安装JDK 2、下载RocketMQ 3、解压 4、更改内存配置,根据实际机器内存大小更改 vim rocketmq/bin/runbroker.sh vim rocketmq/bin/runserver.sh vim rocketmq/bin/tools.sh 5、启动Name服务 nohup ...
分类:
其他好文 时间:
2017-12-28 16:08:40
阅读次数:
168
1.问题描述 线上项目A部署两台机器,每台机器两个实例,订阅同一个topic,消费心跳数据。 (两台机器host1,host2) 运维同事 部署时 有一个实例用root账户重启的, 然后该实例出现两个线程同时消费一个消息的情况,并且后台查看该消费group delay很多。 图一 host1机器两个 ...
分类:
编程语言 时间:
2017-12-27 14:05:52
阅读次数:
248
原文链接:http://www.cnblogs.com/xiaodf/p/5075167.html 参考链接:rocketmq与kafka http://blog.csdn.net/chunlongyu/article/category/6638499 在原文的基础上,进行了部分修改,但是感觉博客还 ...
分类:
其他好文 时间:
2017-12-26 15:18:03
阅读次数:
211
一、下载RocketMQ首先,我们去下载RocketMQ,RocketMQ 是一个开源的东西,可以去github上面下载,地址是:https://github.com/alibaba/RocketMQ/releases 进去之后,我们会看到很多版本,目前最新的是v3.2.6,也是阿里天池大数据中间件 ...
分类:
Windows程序 时间:
2017-12-26 14:39:43
阅读次数:
1663
1. https://github.com/didapinchegit/rocket-console 在github上下载rocketmq-consoler的源码, 用mvn clean package -DskipTests 打成war包部署到taomcat的webapp下面 2. 修改rocke ...
分类:
其他好文 时间:
2017-12-26 11:55:07
阅读次数:
301
转载自:http://www.coin163.com/good/blog/mq.html 几种MQ产品说明: ZeroMQ : 扩展性好,开发比较灵活,采用C语言实现,实际上他只是一个socket库的重新封装,如果我们做为消息队列使用,需要开发大量的代码 RabbitMQ :结合erlang语言本身 ...
分类:
其他好文 时间:
2017-12-25 17:03:08
阅读次数:
262
最近一段时间才开始关注云栖社区的公众号,在两周前看到要在深圳科兴科学园办一场RocketMQ的Meetup。因为从来没有参加过这种线下活动,而且对RocketMQ比较感兴趣,所以就立即报名参加。 报完名就把这件事给忘了,直到周五收到短信才又想起来,周六中午才决定要去。 回顾Meetup 我一开始想着 ...
分类:
其他好文 时间:
2017-12-17 13:22:37
阅读次数:
266