代码地址：https://gitcode.net/java_wxid/springboot-rocketmq
RocketMQ是目前主流的消息中间件之一，并且自身就支持分布式功能。最初由阿里巴巴团队开发，并且经历过双十一等海量消息场景的考验，后捐赠给Apache开源基金会，这也是为什么我们经常听说RocketMQ是阿里巴巴的消息中间件，项目却在Apache的顶级项目中。
项目启动时会在{user.home}/logs目录下创建一个rocketmq_client.log日志文件，文件全路径是：{user.home}/logs/rocketmqlogs/rocketmq_client.log。如果一个系统部署多个微服务话，会导致所有的微服务的RocketMQ的日志都会打印到该文件里，不容易定位到底是哪个微服务的RocketMQ Client出现了错误。所以需要配置rocketmq_client.log日志目录到各自微服务的日志目录加以区分。
上周花了一点时间从头到尾、从无到有地搭建了一套RocketMQ的环境，觉得还挺easy的，所以就写篇文章分享给大家。
Spring Boot 是一种简化创建基于 Spring 框架的 Java 应用程序的工具。它提供了一种快速入门的方式，并减少了繁琐的配置工作。消息队列是一种用于在分布式系统中解耦和异步通信的常用技术。RabbitMQ、RocketMQ 和 Kafka 是三种常见的消息队列实现。以下是它们的基本概念和在 Spring Boot 中的实战示例。
文代码：https://gitee.com/hong99/spring/issues/I1N1DF
整体而言，今年技术层面稍微有点拓宽，跨入了外表看上去高大上的流式计算领域，打开了另外一扇窗；而基于java的分布式/微服务领域，今年变化比较大，spring cloud netflix的部分组件宣布将要进入维护阶段，而国内spring cloud alibaba组件逐渐活跃起来，目前看来处于PublicEvolving阶段；而java自身也处在不断进化中，今年发布了java10及java11，明年java12也要来了，版本变化非常快。稍不留神就跟不上技术更迭了。
随着使用越来越多的队列和虚拟主题，ActiveMQ IO模块遇到了瓶颈。我们尽力通过节流，断路器或降级来解决此问题，但效果不佳。因此，我们那时开始关注流行的消息传递解决方案Kafka。不幸的是，Kafka不能满足我们的要求，特别是在低延迟和高可靠性方面。
如果胖友还没了解过分布式消息队列 Apache RocketMQ ，建议先阅读下艿艿写的 《芋道 RocketMQ 极简入门》 文章。虽然这篇文章标题是安装部署，实际可以理解成《一文带你快速入门 RocketMQ》，哈哈哈。
RocketMQ前身是阿里研发的一个队列模型的消息中间件，后开源给apache基金会成为了apache的顶级开源项目，具有高性能、高可靠、高实时、分布式特点。
针对以上问题，有两个场景：使用阿里云的云服务器的RocketMQ和使用自己搭建的RocketMQ。但无论采用这两种的任何一种，都是可以在同一个topic下，通过tag来进行业务区分的。
随着互联网的蓬勃发展，软件开发技术更新速度越来越快，程序员只有不断学习，充实自己，才能不被淘汰。那么我们如何了解国内最新的技术理念、服务框架、技术架构呢？为了节省时间，高效学习，小编已经为大家整理好了
在之前的《浅入浅出消息队列》一文中，我们了解了消息队列的作用、优缺点和使用场景，相信你对消息队列已经有了一个大致的概念，文末给自己埋的坑说日后会写一篇实战教程，正好现在实习结束了，也许久没有写实战教程了，于是这就来填坑了。
1 导读 在之前的文章中我们介绍了如何基于RocketMQ搭建生产级消息集群，以及2PC、3PC和TCC等与分布式事务相关的基本概念（没有读过的读者详见?推荐阅读）。在这篇文章中我们将介绍Rocke
消息队列作为高并发系统的核心组件之一，能够帮助业务系统解构提升开发效率和系统稳定性。主要用于三种典型场景：应用解耦、流量消峰、消息分发。
一、单体架构 单体架构在中等偏小的业务中比较常见，场景模式就是单个应用、单个数据库。一个程序包（例如war格式或者Jar格式）包含所有业务需求功能，这是一种比较传统的架构风格。 单体架构的缺陷 复杂性高,整个项目包含的模块多，依赖模糊，修改程序容易触发不可知问题。 扩展能力受限,单体应用只能整体进行扩展，无法针对业务模块的特性进行伸缩。 稳定性差,任何微小的问题，都可能导致整个应用服务直接挂掉。 二、微服务架构 微服务架构是一种架构概念，核心思想在于通过将业务功能和需求分解到各个不同的服务中进行管理，实现对
点击上方“芋道源码”，选择“设为星标” 管她前浪，还是后浪？ 能浪的浪，才是好浪！ 每天 10:33 更新文章，每天掉亿点点头发... 源码精品专栏 原创 | Java 2021 超神之路，很肝~ 中文详细注释的开源项目 RPC 框架 Dubbo 源码解析 网络应用框架 Netty 源码解析 消息中间件 RocketMQ 源码解析 数据库中间件 Sharding-JDBC 和 MyCAT 源码解析 作业调度中间件 Elastic-Job 源码解析 分布式事务中间件 TCC-Transaction
https://github.com/zhangdaiscott/JimuReport Star 1388
MQ，是一种跨进程的通信机制，用于上下游传递消息。在传统的互联网架构中通常使用MQ来对上下游来做解耦合。
我们在分布式环境下一个业务可能会涉及到多个模块之间的调用，为了保证操作的原子性，分布式事务是最好的解决方案。
单体架构在中等偏小的业务中比较常见，场景模式就是单个应用、单个数据库。一个程序包（例如war格式或者Jar格式）包含所有业务需求功能，这是一种比较传统的架构风格，小编将从理论-实战，为大家剖析微服务架构。
最近学习使用 rocketmq，需要搭建 rocketmq 服务端，本文主要记录 rocketmq 搭建过程以及这个过程踩到的一些坑。至于有多简单呢，在本机已有Docker环境的情况下只需要三步即可。
tm快了，不知不觉中春招已经结束了很久，不少同学现在已经拿到offer了吧~现在的面试可是越来越难了，动不动就是“互联网三高”。
消息队列已然成为当下非常火热的中间件，而rocketmq作为阿里开源的中间件产品，历经数次超大并发的考验，已然成为中间件产品的首选。而有时候我们在使用消息队列的时候，往往需要能够保证消息的顺序消费，而rocketmq是可以支持消息的顺序消费的。rocketmq在发送消息的时候，是将消息发送到不同的队列（queue,也有人称之为分区）中，然后消费端从多个队列中读取消息进行消费，很明显，在这种全局模式下，是无法实现顺序消费的。为了实现顺序消费，我们需要把有顺序的消息按照他的顺序，将他们发送到同一个queue中，这样消费端在消费的时候，就保证了其顺序。但是顺序消费的性能肯定也相对差一些，因为只能使用一个队列。
RocketMQ 主要由 Producer、Broker、Consumer 三部分组成，其中 Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个 Topic 的消息，每个Topic 的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个 Topic 中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个 Consumer 实例构成。
注意个人使用了4.9.4的Rocketmq版本进行学习部署使用。因为windows上使用docker部署不同版本的RockerMq可能会有不同的情况，这里仅保证4.9.4的版本可以正确运行。
SpringBoot是企业级开发的整体整合解决方案，特别用于快速构建微服务应用，旨在用简单的方式让开发人员适应各种开发场景。与此同时，随着SpringBoot的日益成熟，使用SpringBoot的公司也越来越多，想要深入了解，学习SpringBoot的同学也日益增多，所以博主决定对SpringBoot动手了。
SpringCloud是现阶段最火的微服务治理框架，那么SpringCloud如何实现服务治理的CAP，这里我只想谈谈我对SpringCloud架构思想的理解。
Apache Kafka是一个分布式发布 - 订阅消息系统和一个强大的队列，可以处理大量的数据，并使您能够将消息从一个端点传递到另一个端点。 Kafka适合离线和在线消息消费。 Kafka消息保留在磁盘上，并在集群内复制以防止数据丢失。 Kafka构建在ZooKeeper同步服务之上。 它与Apache Storm和Spark非常好地集成，用于实时流式数据分析。
引入fastjson及rocketmq-client依赖，这两个都是必须的。版本号根据自己实际需求可更改
假如 没有 Spring Boot Starter，我们有两种方式来创建 Spring Bean。
20170712182011089.gif 题外话 什么情况下的异步操作需要使用消息队列而不是多线程消息队列和多线程两者并不冲突，多线程可以作为队列的生产者和消费者。 使用外部的消息队列时，第一是可以提高应用的稳定性，当程序fail后，已经写入外部消息队列的数据依旧是保存的，如果使用两步commit的队列的话，可以更加提高这个项目。 用线程的话，会占用主服务器资源， 消息队列的话， 可以放到其他机器上运行， 让主服务器尽量多的服务其他请求。我个人认为， 如果用户不急着知道结果的操作， 用消息队列， 否则再考
配置中的127.0.0.1:9876根据具体情况修改成实际的RocketMQ的NameServer地址与端口
进入bin目录，建议修改runbroker.sh和runserver.sh默认JVM的大小，防止内存不足启动失败。参考设置如下
一、安装与配置 1、下载 官网：http://rocketmq.apache.org/ 如：rocketmq-all-4.0.0-incubating-bin-release.zip 需要 64bit OS, Linux/Unix/Mac is recommended; 64bit JDK 1.7+; 2、复制到对应目录，linux中解压 复制rocketmq-all-4.0.0-incubating-bin-release.zip到 /opt/rocketmq mkdir /opt/rocketm
修改/etc/profile文件，添加环境变量，代码段如下面所示，其中/opt/jdk1.8.0_144的值为上图中解压的路径。
RocketMQ有一个对其扩展的开源项目 ocketmq-console ，如今也提交给了 Apache ，
1、创建springboot2项目，省略； 2、pom.xml引用 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.0.4</version> </dependency> 3、yml配置文件 rocketmq: nam
今天将一个SpringBoot项目的配置参数从原有的.yml文件迁移到Apollo后，启动报错“Bean method 'rocketMQTemplate' in 'RocketMQAutoConfiguration' not loaded because @ConditionalOnBean (types: org.apache.rocketmq.client.producer.DefaultMQProducer; SearchStrategy: all) did not find any beans of type org.apache.rocketmq.client.producer.DefaultMQProducer”。花了两个小时才最终搞清楚，原因是缺少了配置项 spring.rocketmq.producer.group 从而导致无法成功创建RocketMQAutoConfiguration这个Bean，从而导致一连串对此有依赖的Bean无法创建成功。
不积跬步无以至千里，本人从事Java开发多年，通过记录分享的形式，记录自己从事编程的一些心路历程和技术总结，希望能结交更多志同道合的朋友，个人见识有限，难免会有疏忽和错误之处，还望各位大佬能够指点迷津，感激不尽。 本文整理的Java知识汇总主要包括Java基础、Java进阶、数据库、JVM、消息队列、缓存、微服务与分布式、Java面试系列、高并发、数据结构与算法、计算机网络、开发工具、搜索引擎、大数据、团队管理、运维等。包含一个Java开发工程师所需的绝大多数知识。相信只要勤奋学习，每天进步一点点，各位大佬总有一天会成为飞过沧海横过大洋的海鸥。总结记录的同时，希望大家一起共同进步。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
