草庐IT

rabbitmq-plugins

全部标签

RabbitMQ的基本用法

1、信息队列概念    1.1信息队列是什么        消息队列(MessageQueueMQ)是实现应用之间数据通信的一种机制,采用先进先出的数据结构和生产者消费者设计模式实现通信。        1.2信息队列有什么作用        1.2.1解耦        实现生产者和消费者的解耦,生产者和消费者不直接调用,也不用关心对方如何处理,代码的维护性提高        例如:使用openfeign实现服务调用,如果被调用服务的接口发生修改,服务调用方也需要进行修改,服务之间的耦合性较高,不利于开发和维护    1.2.2异步                同步调用,服务A调用服务B,

奇技淫巧:如何给项目中的RabbitMQ添加总开关

本文主要分享了如何给项目中的RabbitMQ添加总开关,通过简单配置开/关RabbitMQ。一、需求背景SpringBoot项目里使用了RabbitMQ,但某些场景下,不希望项目启动时自动检查RabbitMQ连接例如:在开发不需要RabbitMQ的功能过程中,若RabbitMQ服务未启动,会导致SpringBoot项目启动失败。二、实现方案1.排除org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration(2种方式)在SpringBootApplication启动类上使用exclude排除@SpringBootAppl

整合MQ-----RabbitMQ

应用场景:异步处理。把消息放入消息中间件中,等到需要的时候再去处理。流量削峰例如秒杀活动,在短时间内访问量急剧增加,使用消息队列,当消息队列满了就拒绝响应,跳转到错误页面,这样就可以使得系统不会因为超负载而崩溃安装rabbitMQ#拉取镜像dockerpullrabbitmq:3.8-management#创建容器启动dockerrun-d--restart=always-p5672:5672-p15672:15672--namerabbitmqrabbitmq:3.8-management管理后台:http://IP:15672搭建rabbit_util模块引入依赖org.springfra

Plugin ‘org.springframework.boot:spring-boot-maven-plugin:‘ not found的解决办法

 pom.xml文件中出现这样的依赖报错解决办法如下:1、找到这个spring-boot-starter-parent依赖2、将其版本复制到spring-boot-maven-plugin下面   

MacBook macOs安装RabbitMQ【超详细图解】

目录一、使用brew安装RabbitMQ 二、安装RabbitMQWeb管理界面  三、启动RabbitMQ 一、使用brew安装RabbitMQ 刚好项目要用到RabbitMQ,安装顺便写下安装步骤记录一下以备用使用brew命令安装,一般Mac会自带这个命令,如没有,那就需要先安装HomeBrew(软件包管理系统)brewinstallrabbitmq 安装成功后,它会告诉你RabbitMQ有两种启动方式 #方式一:brewservicesstartrabbitmq;#方式二:进入默认的安装目录下,手动启动二、安装RabbitMQWeb管理界面  默认情况下,rabbitmq是没有安装Rab

Prometheus实战篇:Prometheus监控rabbitmq

Prometheus实战篇:Prometheus监控rabbitmq准备环境docker-compose安装rabbitmq这里注意rabbitmq需要暴露2个端口docker-compose.yamlversion:'3'services:rabbitmq: image:rabbitmq:3.7.15-management container_name:rabbitmq restart:always volumes: -/data/rabbitmq/data:/var/lib/rabbitmq -/data/rabbitmq/log:/var/log/rabbitmq port: -56

RabbitMQ之Exchange(交换机)属性及备用交换机解读

目录基本介绍主要结论备用交换机 springboot代码实战(备用交换机)实战架构工程概述RabbitConfigDeal 配置类:创建队列及交换机并进行绑定 MessageService业务类:发送消息及接收消息主启动类RabbitMq01Application:实现ApplicationRunner接口基本介绍在RabbitMQ中,交换机主要用来将生产者生产出来的消息,传送到对应的频道中,即交换机是一个消息传送的媒介,其英文被称为exchange。交换机在RabbitMQ中起着承上启下的作用。它主要由以下属性可供选择:Name:交换机名称;就是一个字符串Type:交换机类型,direct,

RabbitMQ

简介RabbitMQRabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(称面向消息的中间件)。RabbitMQ服务器是使用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端。RabbitMQ是一个消息中间件:它接受并转发消息。你可以把它当做一个快递站点,当你要发送一个包裹时,你把你的包裹放到快递站,快递员最终会把你的快递送到收件人那里,按照这种逻辑RabbitMQ是一个快递站,一个快递员帮你传递快件。RabbitMQ与快递站的主要区别在于,它不处理快件而是接收,存储和转发消息数据什么是AMQP协议?AMQP,即

RabbitMQ避免重复消费

在Java中,可以使用消息队列来实现消息的异步处理,其中常用的消息队列有RabbitMQ、ActiveMQ、Kafka等。什么是幂等性?幂等性是指无论操作执行多少次,都是得到相同的结果,而不会产生其他副作用。在rabbitMQ中什么是消息重复消费?同一条消息在MQ中被消费多次出现重复消费的原因:生产者发送一条消息到rabbitMQ,但rabbitMQ尚未收到消费者的确认,会认为消息消费未被消费而重新发送。网络不稳定、消费者故障、网络分区、消息重复传递策略、消费者超时设置不当为什么需要避免重复消费?业务错误:我本来写的业务逻辑就是只要执行一次数据重复:数据插入重复,破坏数据唯一性资源浪费:占用系

Idea的maven依赖一直报错:Cannot resolve plugin org.apache.maven.plugins

        报这个错基本上就是maven依赖出现了问题,要么是写错,要么是下载时网络出现问题导致下载的文件不完整出现失败,一般有以下几种解决方案。1)镜像文件配置错误    Rx:修改本地仓库位置下的settings.xml文件,将正确的镜像文件加载到标签中,如下图所示:2)找不到依赖    Rx:出现这个问题的概率较小,是在找依赖时出现了问题,这个时候可以在项目的根pom.xml下添加如下配置3)网络原因    Rx:因为网络波动问题,依赖下载失败,解决办法就是按照报错信息提示,到本地仓库中,依照路径一步步找下去,删除 .lastUpdated结尾的文件,回到Idea中重新加载4)其他问