| 共 140 篇文章 |
|
MQTT 与 Kafka｜物联网消息与流数据集成实践MQTT 如何与 Kafka 一起使用？EMQX 是一款流行的 MQTT Broker，通过其内置的 Kafka 数据集成功能，能够实现与 Kafka 的无缝集成。它提供了一个 MQTT 协议代理模块，用于连接 MQTT 客户端和 Kafka Broker，使客户端能够发布和订阅 Kafka 主题。这个桥接服务通过 MQTT 客户端从 MQTT Broker 订阅数据，... 阅4 转0 评0 公众公开 23-07-23 18:29 |
消息队列三剑客：RabbitMQ、RocketMQ、Kafka全面对决。RabbitMQ：RabbitMQ是一个基于AMQP（高级消息队列协议）的开源消息中间件，强调易用性和灵活性，支持多种消息模式和可靠的消息传递。RabbitMQ：RabbitMQ采用队列（Queue）模型，消息被发送到队列中，消费者从队列中接收消息并进行处理。队列模式：RocketMQ还支持队列模式，其中生产者将消... 阅30 转1 评0 公众公开 23-07-10 11:52 |
消息队列性能对比——ActiveMQ、RabbitMQ与ZeroMQDissecting Message Queues.我们在两个不同的端点之间发送消息，所以我们观察到的是一个“发送方”吞吐量和一个“接收方”吞吐量，即每秒可以发送的消息数和每秒可以接收的消息数.。有一半的Brokered 消息队列吞吐量少于25000条消息每秒。对于Redis的吞吐量或许有一定的误导，尽管Redis 提供 发... 阅1 转自yespon 公众公开 23-06-05 21:11 |
4 款消息队列软件产品大比拼。我完全理解，这对那些初始配置十分保守的消息队列产品将会是个惩罚。ZeroMQ.ZeroMQ具有一个独特的非中间件的模式，也就是说，跟其它几个接受测试的产品不同，你不需要安装和运行一个消息服务器，或 中间件。就目前我知道的，ZeroMQ仅提供非持久性的队列。公平的说，ZeroMQ跟其它几个比起来像头巨兽，尽管这样，结... 阅1 转自jeckyzile... 公众公开 23-06-05 21:10 |
Pulsar—新一代云原生消息平台。Pulsar采用了计算存储分离的多层架构。RoP、AoP、KoP 分别是将RocketMQ、AMAP消息系统、Kafka协议处理插件引入到Pulsar broker的代理，这样Pulsar 就能支持原生各种消息队列的协议了。RocketMQ 由于使用的消息处理协议和Pulsar不同，如果Pulsar想要兼容RocketMQ协议，为了将RocketMQ 的协议适配到Pulsar的消息协... 阅1 转自刘振东 公众公开 23-06-05 20:58 |
云原生对于消息中间件而言，还有另一层含义就是消息队列自身架构的云原生化演进，如何充分发挥云的弹性计算、存储、网络，让自己获得更强的技术指标和 Serverless 弹性能力。微服务、大数据、实时计算、IoT、事件驱动等技术潮流，不断的扩展消息的业务边界，业界有不同的消息队列满足不同的业务场景，比如RabbitMQ侧重满足微服务场景，Kafka则... 阅173 转2 评0 公众公开 23-06-05 14:21 |
AMQP是什么消息代理和他们所扮演的角色AMQP 0-9-1 模型简介AMQP是一个可编程的协议交换机和交换机类型。队列名称队列持久化绑定消费者。消息确认拒绝消息Negative Acknowledgements预取消息消息属性和有效载荷（消息主体）消息确认AMQP 0-9-1 方法连接通道虚拟主机AMQP是可扩展的AMQP 0-9-1 客户端生态系统AMQP 0-9-1 简介。AMQP中的队列（queu... 阅33 转0 评0 公众公开 23-06-05 05:46 |
20-RabbitMQ应用问题-消息幂等性保障RabbitMQ应用问题消息可靠性保障。消息补偿机制消息幂等性保障。消息发送还是之前的消息补偿流程图，而这里消息幂等性保障主要是依赖 DB 的乐观锁机制。-- 第二次执行：version=2，由于where条件查询不到 version=1 的结果了，所以第二次执行将失败update account set money = money - 500 , version = vers... 阅3 转0 评0 公众公开 23-06-01 08:07 |
19-RabbitMQ应用问题-消息补偿RabbitMQ应用问题消息可靠性保障。需求：100%确保消息发送成功消息可靠性保障--消息补偿。6.监听 Consumer 发送过来的确认消息7.当确认消息已消费，则写入第二个数据库实例 MDB8.监听延迟队列消息 Q3，对比 MDB 数据库的记录，判断是否已经确认消费 Q2 的消息，如果对比结果为 Q2 没有确认消息确认记录，那么则 调... 阅3 转0 评0 公众公开 23-06-01 08:07 |
# 停用插件root@d52d13792d25:/# rabbitmq-plugins disable rabbitmq_tracingDisabling plugins on node rabbit@d52d13792d25:rabbitmq_tracingThe following plugins have been configured: rabbitmq_management rabbitmq_management_agent rabbitmq_web_dispatchApplying plugin configuration to rabbit@d52d13792d25...The following pl... 阅18 转0 评0 公众公开 23-06-01 08:07 |
