RabbitMQ的工作模式及原理

Channel是在Connection的基础上建立的虚拟连接,RabbitMQ中大部分的操作都是使用Channel完成的,比如:声明Queue、声明Exchange、发布消息、消费消息等。看到此处,你是否有这样一个疑问:既然已经有了Connection,我们完全可以使用Connection完成Channel的工作,为什么还要引入Channel这样一个虚拟连接的概念呢?因为现在的程序都是支持...

RabbitMQ简介

RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在不同的应用之间共享数据(跨平台跨语言)。RabbitMQ是使用Erlang语言编写，并且基于AMQP协议实现。RabbitMQ的优势：可靠性(Reliablity)：使用了一些机制来保证可靠性，比如持久化、传输确认、发布确认。灵活的路由(FlexibleRouting)：在消息进入队列之前，通过Ex...

提升RabbitMQ消费速度的一些实践

RabbitMQ是一个开源的消息中间件,自带管理界面友好、开发语言支持广泛、没有对其它中间件的依赖,而且社区非常活跃,特别适合中小型企业拿来就用。这篇文章主要探讨提升RabbitMQ消费速度的一些方法和实践,比如增加消费者、提高Prefetchcount、多线程处理、批量Ack等。增加消费者这个道理比较容易理解,多个人搬砖的速度肯定...

最适合入门的RabbitMQ+PHP教程交换机类型解析!

这个应该是我们用的最多的一种类型了。扇型交换机(funoutexchange)将消息路由给绑定到它身上的所有消息队列,其中它的路由键是不起作用的,所以路由键是可以直接设置为空的。那么既然可以直接将消息发布到绑定在交换机上的匹配的消息队列,那么它就是相当于一个广播站,直接将订阅这个交换机的信息分布到所有匹配的队列...

JMeter RabbitMQ采样器AMQP详解与实战

1、采样器的名称和备注。这是JMeter所有采样器的属性,用来进行线程组的采样管理。建议取有意义的名字。2、交换机信息。如果需要发送的MQ消息是以交换机的方式进行消息传递,需要配置。如果不需要则配置“Exchange”属性为空即可。具体的属性含义如下。Exchange:交换机名称,默认为jmeterExchange。Rabbit...

订单超时怎么处理?我们用这种方案

二RabbitMQ的延时消息RabbitMQ的延时消息主要有两个解决方案:RabbitMQDelayedMessagePlugin消息的TTL+死信ExchangeRabbitMQDelayedMessagePlugin是官方提供的延时消息插件,虽然使用起来比较方便,但是不是高可用的,如果节点挂了会导致消息丢失(www.e993.com)2024年11月5日。引用官网原文:...

分布式事务,EventBus 解决方案:CAP【中文文档】

事务在CAP具有重要作用,它是保证消息可靠性的一个基石。在发送一条消息到消息队列的过程中,如果不使用事务,我们是没有办法保证我们的业务代码在执行成功后消息已经成功的发送到了消息队列,或者是消息成功的发送到了消息队列,但是业务代码确执行失败。

浅谈RocketMQ、Kafka、Pulsar 的事务消息

一、消息队列演化(MessageQueue,简称MQ),是指在消息的传输中保存消息的容器或服务,是一种异步的服务间通信方式,适用于无服务器和微服务架构,是分布式系统实现高性能、高可用、可伸缩等高级特效的重要组件。常见的主流消息队列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ、Pulsar等。而在公司内有Tu...