云消息队列 MQ消息队列的相关内容

文章 2022-05-11 来自：开发者社区

消息队列之事务消息，RocketMQ 和 Kafka 是如何做的？（上）

每个时代，都不会亏待会学习的人。大家好，我是 yes。今天我们来谈一谈消息队列的事务消息，一说起事务相信大家都不陌生，脑海里蹦出来的就是 ACID。通常我们理解的事务就是为了一些更新操作要么都成功，要么都失败，不会有中间状态的产生，而 ACID 是一个严格的事务实现的定义，不过在单体系统时候一般都不会严格的遵循 ACID 的约束来实现事务，更别说分布式系统了。分布式系统往往只能妥协到最终一致性，....

文章 2022-05-11 来自：开发者社区

消息队列之推还是拉，RocketMQ 和 Kafka 是如何做的？（下）

Kafka 中的长轮询像 Kafka 在拉请求中有参数，可以使得消费者请求在 “长轮询” 中阻塞等待。简单的说就是消费者去 Broker 拉消息，定义了一个超时时间，也就是说消费者去请求消息，如果有的话马上返回消息，如果没有的话消费者等着直到超时，然后再次发起拉消息请求。并且 Broker 也得配合，如果消费者请求过来，有消息肯定马上返回，没有消息那就建立一个延迟操作，等条件满足了再返回。我们来....

文章 2022-05-11 来自：开发者社区

消息队列之推还是拉，RocketMQ 和 Kafka 是如何做的？（上）

每个时代，都不会亏待会学习的人大家好，我是 yes。今天我们就来谈一谈消息队列的推拉模式，这也是一个面试热点，例如你在简历里面写了 RocketMQ ，基本上会问你 RocketMQ 采用的是推模式还是拉模式啊？是拉模式？不是有 PushConsumer 吗？今天我们就来谈谈推拉模式，并且再来看看 RocketMQ 和 Kafka 是如何做的。推拉模式首先明确一下推拉模式到底是在讨论消息队列的哪....

文章 2022-05-07 来自：开发者社区

小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发，聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(下)

AbstractApplicationEventMulticaster 时间发布器的抽象实现它是对事件发布器的抽象实现，如果你自己想自定义一个时间发布器，可以继承它// @since 1.2.3 // 提供基本的侦听器注册功能比如处理代理对象类型~~~ public abstract class AbstractApplicationEventMulticaster impleme...

文章 2022-05-07 来自：开发者社区

小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发，聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(中)

知道了原因，从来都不缺解决方案：强制使用CGLIB动态代理机制监听器（@EventListener）单独写在一个@Compnent里。当然你可以使用内部类没关系，如下也是ok的，若需要高内聚小姑的话可以这么写：@Slf4j @Service public class HelloServiceImpl implements HelloService { ... // 这里用private是...

文章 2022-05-07 来自：开发者社区

小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发，聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(上)

前言说到事件驱动，我心里一直就有一个不解的疑问：它和我们老生长谈的一些概念比如：【观察者模式】【发布订阅模式】【消息队列MQ】【消息驱动】【EventSourcing】等等是一回事吗？可能很多小伙伴会回答：差不多。确实，很有深意的三字回答。那么本文将以Spring的事件驱动机制为引子，好好的聊聊这里面的关系和差异~JDK中的事件驱动机制在了解其它之前，有必要先了解下JDK为我们提供的事件驱动(E....

文章 2022-04-28 来自：开发者社区

使用 simps/mqtt 调用阿里云的微消息队列 MQTT 版

在阿里云的文档中 PHP 推荐的 SDK 是 Mosquitto-PHP ，这是一个基于回调和异步操作的 PHP MQTT 扩展，同时还依赖 libmosquitto。而 simps/mqtt 是纯 PHP 代码实现的协议解析，客户端实现基于 Swoole 的同步阻塞客户端和协程客户端，可以用于 PHP-FPM 和 CLI 两种模式。并且 simps/mqtt 支持 MQTT 5.0 协议，是 ....

文章 2022-04-21 来自：开发者社区

多维度对比5款主流分布式MQ消息队列

MQ选型从17个维度综合对比Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ这5款当前最主流的MQ消息中间件产品，希望能为您的下一次产品的架构设计和MQ消息中间件选型提供参考依据。KafkaRabbitMQZeroMQRocketMQActiveMQ资料文档中等多少少多开发语言ScalaErlangC语言JavaJava支持的协议自定义（基于TCP）AMQPTCP、....

问答 2022-02-15 来自：开发者社区