什么是MQ本质是一个队列，只不过队列中存放的信息是message罢了，还是一种跨进程的通信机制，用于上下游传递信息。在互联网架构中，MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了MQ之后，信息发送上有只需要依赖MQ，不用依赖其他服务。为什么要使用MQ流量消峰应用解耦异步处理MQ的分类ActiveMQ优点：单机吞吐量万级，时效性ms级，可用性高，基于主从架构高可用性，消息可靠性较低的概率丢失数据缺点：维护较少，高吞吐量场景较少使用Kafka大数据中使用率高，百万级TPS的吞吐量优点：吞吐量高、分布式、时效性高、不会丢失数据、使用广泛缺点：消息失败不支持重试RocketMQ
平时用控制台或者网页进行管理不免有点不方便，尤其在读取消息的时候不支持过滤和批量发送消息，在此推荐一个漂亮的GUI客户端工具。下载地址：http://www.redisant.cn/rta主要特点.png生成拓扑图为指定的vhost一键生成拓扑图，支持导出png、svg、pdf、tk等多种格式，让您的消息流动一目了然。2.png数据格式化RabbitMQAssistant会自动识别并格式化不同的消息格式，包括Text、JSON、XML、HEX、MessagePack，以及各种整数、浮点类型。3.png测试生产者和消费者您可以测试解决方案的各个部分，模拟进出的第三方消息。您可以创建和编辑测试消息
文章目录一、创建VirtualHost类二、初始化三、API1.创建交换机2.删除交换机3.创建队列4.删除队列5.创建绑定6.删除绑定7.发送消息转发规则8.订阅消息1.消费者管理2.推送消息给消费者3.添加一个消费者管理ConsumerManager9.确认消息创建VirtualHost类。1.串起内存和硬盘的数据。2.通过在队列名、交换机名前面加上虚拟主机的名字来隔离不同组的业务。3.实现API4.实现转发规则一、创建VirtualHost类二、初始化初始化硬盘加载硬盘数据到内存三、API1.创建交换机创建过了returntrue没有创建过，创建先写硬盘、后写内存2.删除交换机检查交换机
🎈1参考文档RabbitMQ消费消息坑：failedtoconvertserializedMessagecontent|jiuchengi-cnblogs🔍2问题描述org.springframework.amqp.rabbit.support.ListenerExecutionFailedException:Failedtoconvertmessage atorg.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdap
问题描述 最近在黑马学习rabbitMQ的过程中，在使用docker部署好rabbitMQ后，使用账号为：itcast，密码为：123321登录的时候浏览器显示了这个问题，如图所示：当时以为自己需要输入自己的浏览器登录的账号进行验证，但是密码和账号输入后却显示 这就纳闷了，到底是什么原因导致的？去百度上面搜说需要去浏览器设置->隐私里面去关闭安全设置。等等乱七八糟的设置，结果发现问题还是存在。于是在其他的搜索下知道了错误的原因所在。解决办法 导致这个问题的原因是我在docker上面部署rabbitMQ的时候没有设置管理员账号。导致rabbitMQ中只有自己的默认账号。没有我
RabbitmqqueueNaNstatuscode如下图：参考文章##https://groups.google.com/g/rabbitmq-users/c/4MlYbOXvy4E##https://groups.google.com/g/rabbitmq-users/c/SsXtN165_30###https://www.cnblogs.com/weschen/p/13321817.html###https://community.pivotal.io/s/article/Investigating-Ghost-queues-on-RabbitMQ?language=en_US原因分析：
对比架构对比从架构可以看出三者有些类似，但是在细节上有很多不同。下面我们就从它们的各个组件，介绍它们：RabbitMQ，是一种开源的消息队列中间件。下面是RabbitMQ中与其相关的几个概念：1.生产者（Producer）：生产者是消息的发送者，将消息发送到RabbitMQ的消息队列中。2.消费者（Consumer）：消费者是消息的接收者，从RabbitMQ的消息队列中获取消息并进行处理。3.消息队列（MessageQueue）：消息队列是RabbitMQ的核心组件，用于存储待处理的消息。生产者将消息发送到队列中，消费者从队列中获取消息进行处理。4.交换机（Exchange）：交换机负责接收生
一、RabbitMQ的优点1、应用解耦提高系统容错性和可维护性在订单系统中，可以通过远程调用直接调用库存系统，支付系统，物流系统。但是这三个系统耦合度太高了，因为订单系统下完订单首先去库存系统将库存-1，然后将返回值返回给订单系统，然后通过订单系统的返回结果来在支付系统进行支付，当支付完成后将返回结果返回给订单系统，最后物流系统拿着支付系统的返回结果进行物流发货。第一种情况是当库存系统因为网络波动无法收到订单系统的消息或者受到时间过长会导致整个链路的崩溃第二种情况是新增一个与订单系统相关联的X系统，就需要在订单系统的源码种进行改写，这样会造成高内聚对后续应用的维护成本较高对于以上的情况可以使用
1.如何在Windows中的Rabbitmq如何启动1、进入rabbitmq的sbin目录，输入CMD，然后按下enter(回车键) 2、在命令窗口中输入： rabbitmq-pluginsenablerabbitmq_management 启用管理服务。3、在命令窗口中输入： rabbitmqctlstart_app 启动服务。查看是否启动成功1、浏览器访问http://localhost:15672/输入账号：guest（你的账号），密码：guest（你的密码） 点击登录停止服务的命令: Rabbitmq-service stop 这样就成功了！ 2.如何在java中使用
第一种：（生产者）生产者弄丢了数据。生产者将数据发送到RabbitMQ的时候，可能数据就在半路给搞丢了，因为网络问题啥的，都有可能。第二种：（服务端）RabbitMQ弄丢了数据。MQ还没有持久化自己挂了第三种：（消费者）消费端弄丢了数据。刚消费到，还没处理，结果进程挂了，比如重启了。 1.针对生产者方案1：开启RabbitMQ事务可以选择用RabbitMQ提供的事务功能，就是生产者发送数据之前开启RabbitMQ事务channel.txSelect，然后发送消息，如果消息没有成功被RabbitMQ接收到，那么生产者会收到异常报错，此时就可以回滚事务channel.txRollback，然后重试
