🙈作者简介：练习时长两年半的Javaup主🙉个人主页：程序员老茶🙊ps:点赞👍是免费的，却可以让写博客的作者开心好久好久😎📚系列专栏：Java全栈，计算机系列（火速更新中）💭格言：种一棵树最好的时间是十年前，其次是现在🏡动动小手，点个关注不迷路，感谢宝子们一键三连目录课程名：Java内容/作用：知识点/设计/实验/作业/练习学习：SpringBoot整合RabbitMQSpringBoot整合RabbitMQ安装整合(direct模型)整合(topic模型)课程名：Java内容/作用：知识点/设计/实验/作业/练习学习：SpringBoot整合RabbitMQSpringBoot整合Rabbi
目录一、环境准备0. 前提准备1. 更改hostname2. 修改hosts文件3. 安装配置NTP
1.交换机类型Publisher：生产者，发送消息到交换机Exchange：交换机，一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！Queue：消息队列，接收消息、缓存消息。不过队列一定要与交换机绑定Consumer：消费者，订阅队列交换机的类型有四种：Fanout：广播，将消息交给所有绑定到交换机的队列。Direct：订阅，基于Rou
MQ同步通信异步通信事件驱动优势：服务解耦性能提升，吞吐量提高服务没有强依赖，不担心级联失败问题流量消峰小结:大多情况对时效性要求较高，所有大多数时间用同步。而如果不需要对方的结果，且吞吐量，并发量较高则需要使用异步通信MQ常见框架MQ(MessageQueue)，消息队列，字面来看就是存放消息的队列，也就是事件驱动架构中的Broker消息：就是事件，比如支付成功了这个事件，在MQ中就是一个消息RabbitMQ,RocketMQ适合处理业务（若需要优化定制则选Rocket，因为用Java写的）Kafka适合处理日志（海量数据且对数据安全性要求不高的场景），ActiveMQ用的较少Rabbit
工作队列工作队列（又称为任务队列）的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。相反我们安排任务在之后执行。我们把任务封装为消息并将其发送到队列。在后台运行的工作进程将弹出任务并最终执行作业。当有多个工作线程时，这些工作线程将一起处理这些任务轮训分发消息我们启动两个工作线程，一个消息发送线程，一个用来接受线程，我们来看看它们两个工作线程是如何工作的抽取工具类我们将获取信道这个重复的代码封装为一个类，当时用的时候直接调用/***连接工厂创建信道工具类*/publicclassRabbitMqUtils{publicstaticChannelgetChannel(){Connecti
微服务之间实现关联的策略（但并不破坏微服务之间的解耦性）:OpenFeign调用和消息队列（ActiveMQ、RabbitMQ、Kafka、RocketMQ等）内部API调用（OpenFeign）消息队列（ActiveMQ、RabbitMQ、Kafka、RocketMQ）服务组合“内部API调用”和“消息队列”这两种方式的优缺点及对应的适用场景内部API调用优点缺点适用场景消息队列优点缺点适用场景可考虑“内部API调用”和“消息队列”结合使用在实际业务中，不同的微服务之间可能存在一定的关联性，比如在微服务OrderService中需要获取微服务UserService中的用户信息。这种情况下，可
一MQ的基本概念1MQ概述MQ全称MessageQueue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。消息队列就是所谓的存放消息的队列。消息队列解决的不是存放消息的队列的⽬的，解决的是通信问题。传统方式，系统之间直接调用（http协议httpclient/openFeign）中间件2MQ的优势异步、解耦、削峰1应用解耦系统的耦合性越高，容错性就越低，可维护性就越低。以购物为例子使用MQ使得应用间解耦，提升容错性和可维护性。2异步提速一个下单操作耗时：20+300+300+300=920ms，用户点击完下单按钮后，需要等待920ms才能得到下单响应，太慢！用户
这篇文章来源于稀土掘金，来源：https://juejin.cn/post/7132268340541653005，主要用来收藏学习。常见的消息队列很多，主要包括RabbitMQ、Kafka、RocketMQ和ActiveMQ，相关的选型可以看我之前的系列，这篇文章只讲RabbitMQ，先讲原理，后搞实战。1.消息队列1.1消息队列模式消息队列目前主要2种模式，分别为“点对点模式”和“发布/订阅模式”。1.1.1点对点模式一个具体的消息只能由一个消费者消费，多个生产者可以向同一个消息队列发送消息，但是一个消息在被一个消息者处理的时候，这个消息在队列上会被锁住或者被移除并且其他消费者无法处理该消
1RabbitMQ简介1.1基本介绍 RabbitMQ是一个由Erlang语言开发的AMQP的开源实现。AMQP（AdvancedMessageQueue：高级消息队列协议）它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。RabbitMQ最初起源于消息系统，用于在分布式系统中存储转发消息，具体有如下一些特点：可靠性：RabbitMQ使用一些机制来保证可靠性，比如持久化、传输确认机制（ack）和发布确认等。灵活的路由策略：在消息进入队列之前，通过Exchange来路由消息，对于典型的路由功能，Rabb
前言最近在做一个BI项目，用到了RabbitMQ异步化生成图表，同时还添加了死信队列处理无法被消费者正常消费的消息。于是便有了这篇文章，下面由我带大家介绍RabbitMQ的死信队列和其在项目中的应用吧。死信和死信队列的概念什么是死信？简单来说就是无法被消费和处理的消息。一般生产者将消息投递到broker或者queue，消费者直接从中取出消息进行消费。但有时因为某些原因导致消息不能被消费，导致消息积压在队列中，这样的消息如果没有后续的处理就会变成死信，那么专门存放死信的队列就是死信队列。注意：如果一个消息队列设置了过期时间，在队列过期后其中的消息并不会自动转发到死信队列中，而是会被系统丢弃或执行
