前言：本文介绍使用docker部署-RocketMq；1RocketMq介绍：ApacheRocketMQ是一款开源的分布式消息中间件，具有高吞吐量、高可用性、高伸缩性和灵活的可靠消息传输机制等特点。RocketMQ支持多种消息模式，包括异步传输、同步传输和单向传输，并支持多种订阅模式，包括广播模式和集群模式。RocketMQ还提供了丰富的API和管理工具，可以轻松地进行消息的发送、订阅和管理。RocketMQ的主要特点包括：高吞吐量：RocketMQ具有高吞吐量的特点，每秒可以处理百万级别的消息。高可用性：RocketMQ支持主从模式，确保在某个节点故障的情况下仍然能够保证消息的传输。高可靠
环境：（1）Centos7（2）JDK1.8（3）docker（4）rocketmq4.8两台服务器ipA：192.168.5.49B：192.168.5.50集群模式1、单节点:优点：本地开发测试，配置简单，同步刷盘消息一条都不会丢缺点：不可靠，如果宕机，会导致服务不可用2、主从(异步、同步双写):优点：同步双写消息不丢失,异步复制存在少量丢失，主节点宕机，从节点可以对外提供消息的消费，但是不支持写入缺点：主备有短暂消息延迟，毫秒级，目前不支持自动切换，需要脚本或者其他程序进行检测然后进行停止broker,重启让从节点成为主节点3、双主：优点：配置简单,可以靠配置RAID磁盘阵列保证消息可靠
环境：（1）Centos7（2）JDK1.8（3）docker（4）rocketmq4.8两台服务器ipA：192.168.5.49B：192.168.5.50集群模式1、单节点:优点：本地开发测试，配置简单，同步刷盘消息一条都不会丢缺点：不可靠，如果宕机，会导致服务不可用2、主从(异步、同步双写):优点：同步双写消息不丢失,异步复制存在少量丢失，主节点宕机，从节点可以对外提供消息的消费，但是不支持写入缺点：主备有短暂消息延迟，毫秒级，目前不支持自动切换，需要脚本或者其他程序进行检测然后进行停止broker,重启让从节点成为主节点3、双主：优点：配置简单,可以靠配置RAID磁盘阵列保证消息可靠
概述 rocketmq消息组件在springboot框架中的应用，使用rocketmq的整合包进行编码实现。编码参考引入rocketmq依赖jar,最新版本参考GitHub-apache/rocketmq-spring:ApacheRocketMQSpringIntegrationorg.apache.rocketmqrocketmq-spring-boot-starter2.2.3基本配置rocketmq:name-server:192.168.15.175:9876;192.168.15.77:9876producer:group:ta-cipher-encoderocketmq.
一个消费者组中的所有消费者订阅关系，可以多个topic，多个tag，但是必须一致，否则就倒沫子了，如下图： 下面贴了如下结构的代码 一个消费组（消费者）订阅多个topic的代码（只写了一个消费组的，其他类似）：@Component@RocketMQMessageListener(topic="",consumerGroup="group1")publicclassMessageListener1implementsRocketMQListener,RocketMQPushConsumerLifecycleListener{@OverridepublicvoidonMessage
写在开始:本文合计2万多字,500多行,阅读可能需要花费一点时间;主要包括消息队列和常用MQ(比如RabbitMQ,RocketMQ和Kafka)的部分高频面题,可供复习参考使用导读一.RabbitMQ如何保证消息不丢失日常应用场景:异步发送(验证码、短信、邮件==)，MySQL和Redis、ES之间的数据同步、分布式事务、削峰填谷等等生产者确认机制消息持久化消费者确认小结开启生产者确认机制，确保生产者的消息能到达队列开启持久化功能，确保消息被消费前在队列不会丢失开启消费者确认机制为auto,由spring确认消息处理成功后完成ack开启消费者失败重试机制，多次重试失败后将消息投递到异常交换机
dockerpullfoxiswho/rocketmq报错latestnotfound:manifestunknown:manifestunknown解决方案问题背景解决方案总结Lyric：我知道是自己错过问题背景在拉取rocketmq的docker镜像的时候，报错Errorresponsefromdaemon:manifestforfoxiswho/rocketmq:latestnotfound:manifestunknown:manifestunknown[root@localhost~]#dockerpullfoxiswho/rocketmqUsingdefaulttag:latestE
文章目录概述几种MQ的对比综合以上对比后，有如下建议：概述MQ(MessageQueue)，即消息队列。早已成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的MQ，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。几种MQ的对比下面我们先看下主流的几种MQ的对比，如下表格：比较项ActiveMQRabbitMQRocketMQKafka所属社区/公司ApacheMozillaPublicLicense阿里巴巴Apache成熟度及授权成熟/开源
NameServer是专为RocketMQ设计的轻量级名字服务，它的源码非常精简，八个类，少于1000行代码。图片这篇文章，笔者会从基础概念、Broker发送心跳包、NameServer维护路由、ZookeepervsNameServer 四个模块揭秘名字服务的设计精髓。1基础概念图片NameServer是一个非常简单的Topic路由注册中心，其角色类似Dubbo中的zookeeper，支持Broker的动态注册与发现。RocketMQ集群工作流程：1、NameServer启动服务，监听TCP端口，集群多节点之间无任何信息交互，然后等待Broker、Producer、Consumer连上来；2
