SpringBoot是企业级开发的整体整合解决方案，特别用于快速构建微服务应用，旨在用简单的方式让开发人员适应各种开发场景。与此同时，随着SpringBoot的日益成熟，使用SpringBoot的公司也越来越多，想要深入了解，学习SpringBoot的同学也日益增多，所以博主决定对SpringBoot动手了。
消息队列作为高并发系统的核心组件之一，能够帮助业务系统解构提升开发效率和系统稳定性。主要用于三种典型场景：应用解耦、流量消峰、消息分发。
代码地址：https://gitcode.net/java_wxid/springboot-rocketmq
文代码：https://gitee.com/hong99/spring/issues/I1N1DF
Apache Kafka是一个分布式发布 - 订阅消息系统和一个强大的队列，可以处理大量的数据，并使您能够将消息从一个端点传递到另一个端点。 Kafka适合离线和在线消息消费。 Kafka消息保留在磁盘上，并在集群内复制以防止数据丢失。 Kafka构建在ZooKeeper同步服务之上。 它与Apache Storm和Spark非常好地集成，用于实时流式数据分析。
在之前的《浅入浅出消息队列》一文中，我们了解了消息队列的作用、优缺点和使用场景，相信你对消息队列已经有了一个大致的概念，文末给自己埋的坑说日后会写一篇实战教程，正好现在实习结束了，也许久没有写实战教程了，于是这就来填坑了。
引入fastjson及rocketmq-client依赖，这两个都是必须的。版本号根据自己实际需求可更改
整体而言，今年技术层面稍微有点拓宽，跨入了外表看上去高大上的流式计算领域，打开了另外一扇窗；而基于java的分布式/微服务领域，今年变化比较大，spring cloud netflix的部分组件宣布将要进入维护阶段，而国内spring cloud alibaba组件逐渐活跃起来，目前看来处于PublicEvolving阶段；而java自身也处在不断进化中，今年发布了java10及java11，明年java12也要来了，版本变化非常快。稍不留神就跟不上技术更迭了。
随着使用越来越多的队列和虚拟主题，ActiveMQ IO模块遇到了瓶颈。我们尽力通过节流，断路器或降级来解决此问题，但效果不佳。因此，我们那时开始关注流行的消息传递解决方案Kafka。不幸的是，Kafka不能满足我们的要求，特别是在低延迟和高可靠性方面。
点击上方“芋道源码”，选择“设为星标” 管她前浪，还是后浪？ 能浪的浪，才是好浪！ 每天 10:33 更新文章，每天掉亿点点头发... 源码精品专栏 原创 | Java 2021 超神之路，很肝~ 中文详细注释的开源项目 RPC 框架 Dubbo 源码解析 网络应用框架 Netty 源码解析 消息中间件 RocketMQ 源码解析 数据库中间件 Sharding-JDBC 和 MyCAT 源码解析 作业调度中间件 Elastic-Job 源码解析 分布式事务中间件 TCC-Transaction
我们平时的程序多数都是同步的，常见的RestApi，都是同步的调用。在处理异步的请求时，适合采用消息中间件。特别是涉及到一些跨系统的调用，而且在处理一些高并发问题的时候，也可以采用mq队列的串行特征，使得开发简单。此外，mq的订阅模式，适用于在消费生产者发出信息时不知道有多少消费者时，这种模式完美适用。
RocketMQ有一个对其扩展的开源项目 ocketmq-console ，如今也提交给了 Apache ，
最近几年，Java 的技术栈发展的非常快，成百上千的技术工具正不断地涌出来，这也造成了一个问题：
RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。
项目启动时会在{user.home}/logs目录下创建一个rocketmq_client.log日志文件，文件全路径是：{user.home}/logs/rocketmqlogs/rocketmq_client.log。如果一个系统部署多个微服务话，会导致所有的微服务的RocketMQ的日志都会打印到该文件里，不容易定位到底是哪个微服务的RocketMQ Client出现了错误。所以需要配置rocketmq_client.log日志目录到各自微服务的日志目录加以区分。
上文:spring整合中间件(RocketMQ、kafka、RabbitMQ)-RabbitMQ
RocketMQ是目前主流的消息中间件之一，并且自身就支持分布式功能。最初由阿里巴巴团队开发，并且经历过双十一等海量消息场景的考验，后捐赠给Apache开源基金会，这也是为什么我们经常听说RocketMQ是阿里巴巴的消息中间件，项目却在Apache的顶级项目中。
男怕入错行，女怕嫁错郎，学java最怕看错书！也是很久之前就想写这篇了，以前也零零星星的推荐过几本书，但是始终没有这样认真的整理一篇出来，这篇文章就是和大家探讨一下哪个阶段，应该看什么书，需要掌握到什么程度。
如果胖友还没了解过分布式消息队列 Apache RocketMQ ，建议先阅读下艿艿写的 《芋道 RocketMQ 极简入门》 文章。虽然这篇文章标题是安装部署，实际可以理解成《一文带你快速入门 RocketMQ》，哈哈哈。
本节演示使用SpringBoot整合RocketMQ的入门程序，包括消息的生产端和消费端两个工程。
不积跬步无以至千里，本人从事Java开发多年，通过记录分享的形式，记录自己从事编程的一些心路历程和技术总结，希望能结交更多志同道合的朋友，个人见识有限，难免会有疏忽和错误之处，还望各位大佬能够指点迷津，感激不尽。 本文整理的Java知识汇总主要包括Java基础、Java进阶、数据库、JVM、消息队列、缓存、微服务与分布式、Java面试系列、高并发、数据结构与算法、计算机网络、开发工具、搜索引擎、大数据、团队管理、运维等。包含一个Java开发工程师所需的绝大多数知识。相信只要勤奋学习，每天进步一点点，各位大佬总有一天会成为飞过沧海横过大洋的海鸥。总结记录的同时，希望大家一起共同进步。
MQ，是一种跨进程的通信机制，用于上下游传递消息。在传统的互联网架构中通常使用MQ来对上下游来做解耦合。
上周花了一点时间从头到尾、从无到有地搭建了一套RocketMQ的环境，觉得还挺easy的，所以就写篇文章分享给大家。
最近学习使用 rocketmq，需要搭建 rocketmq 服务端，本文主要记录 rocketmq 搭建过程以及这个过程踩到的一些坑。至于有多简单呢，在本机已有Docker环境的情况下只需要三步即可。
上文:spring整合中间件(kafka、RabbitMQ、ActiveMQ、ZeroMQ、TubeMQ、NSQ)-kafka
消息队列已然成为当下非常火热的中间件，而rocketmq作为阿里开源的中间件产品，历经数次超大并发的考验，已然成为中间件产品的首选。而有时候我们在使用消息队列的时候，往往需要能够保证消息的顺序消费，而rocketmq是可以支持消息的顺序消费的。rocketmq在发送消息的时候，是将消息发送到不同的队列（queue,也有人称之为分区）中，然后消费端从多个队列中读取消息进行消费，很明显，在这种全局模式下，是无法实现顺序消费的。为了实现顺序消费，我们需要把有顺序的消息按照他的顺序，将他们发送到同一个queue中，这样消费端在消费的时候，就保证了其顺序。但是顺序消费的性能肯定也相对差一些，因为只能使用一个队列。
Spring Cloud Alibaba致力于提供微服务开发的一站式解决方案，它是Spring Cloud组件被植入Alibaba元素之后的产物。利用Spring Cloud Alibaba，可以快速搭建微服务架构并完成技术升级。中小企业如果需要快速落地业务中台和技术中台，并向数字化业务转型，那Spring Cloud Alibaba绝对是一个“神器”。
RocketMQ 主要由 Producer、Broker、Consumer 三部分组成，其中 Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个 Topic 的消息，每个Topic 的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个 Topic 中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个 Consumer 实例构成。
上文：spring整合各种中间件(RocketMQ、kafka、RabbitMQ、TubeMQ、NSQ)-腾讯开源【TubeMQ】
20170712182011089.gif 题外话 什么情况下的异步操作需要使用消息队列而不是多线程消息队列和多线程两者并不冲突，多线程可以作为队列的生产者和消费者。 使用外部的消息队列时，第一是可以提高应用的稳定性，当程序fail后，已经写入外部消息队列的数据依旧是保存的，如果使用两步commit的队列的话，可以更加提高这个项目。 用线程的话，会占用主服务器资源， 消息队列的话， 可以放到其他机器上运行， 让主服务器尽量多的服务其他请求。我个人认为， 如果用户不急着知道结果的操作， 用消息队列， 否则再考
配置中的127.0.0.1:9876根据具体情况修改成实际的RocketMQ的NameServer地址与端口
RabbitMQ 是消息中间件的一种, 消息中间件即分布式系统中完成消息的发送和接收的基础软件. 这些软件有很多, 包括 ActiveMQ ( apache 公司的), RocketMQ (阿里巴巴公司的, 现已经转让给 apache), 还有性能极高的 Kafka。
进入bin目录，建议修改runbroker.sh和runserver.sh默认JVM的大小，防止内存不足启动失败。参考设置如下
Spring Boot 是一种简化创建基于 Spring 框架的 Java 应用程序的工具。它提供了一种快速入门的方式，并减少了繁琐的配置工作。消息队列是一种用于在分布式系统中解耦和异步通信的常用技术。RabbitMQ、RocketMQ 和 Kafka 是三种常见的消息队列实现。以下是它们的基本概念和在 Spring Boot 中的实战示例。
修改/etc/profile文件，添加环境变量，代码段如下面所示，其中/opt/jdk1.8.0_144的值为上图中解压的路径。
一、安装与配置 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
前面一篇文章分析了broker的启动过程，浏览了broker的基本功能。接下来的几篇文章，准备按照十分钟入门RocketMQ一文中提到的一系列特性，依次进行学习。这篇文章准备分析RocketMQ作为MQ的最基本的功能：消息的发布（publish）和订阅（subscribe）。首先，我参考Spring Boot系列文章（六）：SpringBoot RocketMQ 整合使用和监控这篇文章完成了一个简单的例子。
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无法创建成功。
小简从 0 开始学 Java 知识之 Java-学习路线 中的《SpringBoot-整合篇》，不定期更新所学笔记，期待一年后的蜕变吧！<有同样想法的小伙伴，可以联系我一起交流学习哦！>
Apache RocketMQ™是一个开源的分布式消息传递和流数据平台。下面记录在CentOS 7 安装 RocketMQ 4.4 及相关的注意事项。
Linux系统常用诊断工具（uptime、dmesg、vmstat、mpstat、free、sar、top）
最近学习使用 rocketmq，需要搭建 rocketmq 服务端，本文主要记录 rocketmq 搭建过程以及这个过程踩到的一些坑。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
