前言 之前我们一起了解了使用RocketMQ事务消息解决生产者发送消息时消息丢失的问题,但使用了事务消息后消息就一定不会丢失了吗,肯定是不能保证的。 因为虽然我们解决了生产者发送消息时候的消息丢失问题,但也只是保证Broker正确的接收到了消息,实际上接收到的消息会保存在os cache
#broker集群名称,用于划分broker brokerClusterName=MQCluster001 #broker名称,用于主从配对,相同名称的broker才能做主从设置 brokerName=mq_broker_1 #用于标识主从关系,0为主,其他大于0的为从(不能小于0)master设置0,slave设置1。Master角色的Broker支持读和写,Slave角色的Broker仅
Broker差异 主从差异: kafka的master/slave是基于partition维度的,而rocketmq是基于broker维度的;kafka的master/slave是可以切换的,而rocketmq不行,当rocketmq的master宕机时,读能被路由到slave上,但写会被路由到此topic的其他broker上。刷盘: rocketmq支持同步刷盘,也就是每次消息都等刷
Broker差异 主从差异: kafka的master/slave是基于partition维度的,而rocketmq是基于broker维度的;kafka的master/slave是可以切换的,而rocketmq不行,当rocketmq的master宕机时,读能被路由到slave上,但写会被路由到此topic的其他broker上。 刷盘: rocketmq支持同步刷盘,也就是每次消息
1:jdk 环境 3.修改环境变量(如果没有修改全局的权限的话) 当前用户的: vi .bash_profile /opt/java/jdk1.8.0_191 /opt/jdk/jdk1.8.0_171 -- 这个版本会报错 JAVA_HOME="/opt/jdk/jdk1.8.0_171" CLASS_PATH="$JAVA_HOME/lib:$JAVA_HOME/jre/lib" CATALINA_HOME="/usr/local