RocketMQ本身支持顺序消息，在使用上发送顺序消息和非顺序消息有所区别 发送顺序消息 SendResult sendResult = producer.send(msg, new MessageQueueSelector() { @Override public MessageQueue sel ...
分类：
其他好文 时间：
2020-05-30 20:10:53
阅读次数：
66
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 private SendResult sendDefaultImpl( Message msg ...
分类：
其他好文 时间：
2020-05-30 19:45:44
阅读次数：
61
主机断电重启后，docker中的应用也就停止了服务。这里我们需要启动这些应用（这里以在docker中启动rocketmq为例）； 1.linux中输入【systemctl status docker.service】命令查看docker是否正在运行,如果没有，输入【systemctl start d ...
分类：
其他好文 时间：
2020-05-29 12:18:26
阅读次数：
126
概念说明 通常一个消息队列需要掌握的知识点有Topic（主体）、Producer（生产者）、Consumer（消费者）、Queue（队列）、Delivery Semantics（消息传递范式） 蛋疼的是不同的消息队列关于这些名词叫法不一样，含义也不是很精确。所以阿里起了一个项目OpenMessagi ...
分类：
其他好文 时间：
2020-05-29 10:38:16
阅读次数：
55
概述 在日常开发中，为了提高主线程的效率，往往需要采用异步调用处理，例如系统日志等。在实际业务场景中，可以使用消息中间件如RabbitMQ、RocketMQ、Kafka等来解决。假如对高可用没有太高的要求，也可以使用线程池或者队列来解决。 创建工程 创建Maven工程 修改配置文件 <project ...
分类：
编程语言 时间：
2020-05-28 18:17:10
阅读次数：
72
本文主要研究一下rocketmq-mysql的ColumnParser ColumnParser rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/ColumnParser. ...
分类：
数据库 时间：
2020-05-28 13:09:26
阅读次数：
58
rocketMQ控制台搭建 （1）下载rocketmq-console代码:https://github.com/875279177/incubator-rocketmq-externals （2）修改配置application配置文件，主要修改端口号及rocketmq.config.dataPat ...
分类：
其他好文 时间：
2020-05-24 14:09:36
阅读次数：
96
序 本文主要研究一下rocketmq-mysql的BinlogPositionManager BinlogPositionManager rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/positio ...
分类：
数据库 时间：
2020-05-23 13:07:01
阅读次数：
61
简介 RocketMQ 特点 RocketMQ 是阿里巴巴在2012年开源的分布式消息中间件，目前已经捐赠给 Apache 软件基金会，并于2017年9月25日成为 Apache 的顶级项目。作为经历过多次阿里巴巴双十一这种“超级工程”的洗礼并有稳定出色表现的国产中间件，以其高性能、低延时和高可靠等 ...
分类：
其他好文 时间：
2020-05-23 00:32:43
阅读次数：
74
首先，在虚拟机上安装rocketmq和rocketMq可视化控制，安装不做描述。 1、pom.xml文件添加依赖 mq的版本与连接的rocketmq版本保持一致 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocke ...
分类：
编程语言 时间：
2020-05-23 00:19:28
阅读次数：
68
