腾讯云

开发者社区

文档建议反馈控制台

首页

文章/答案/技术大牛

发布

社区首页 >问答首页 >从Broker收到消息后，MQTT Broker中的回滚功能

问从Broker收到消息后，MQTT Broker中的回滚功能
EN

Stack Overflow用户

提问于 2020-08-11 13:46:25

回答 1查看 89关注 0票数 0

我有一种情况，一旦从MQTT Broker收到消息，在处理数据的过程中，假设DB停机并且没有完成任务。在这种特定情况下，接收到的数据必须发送回代理，我的任务尚未完成，我指的是回滚。

如何实现这一点，以及如何告诉broker在处理数据的过程中出现了一些异常，您需要再次发送数据。

有人能帮上忙吗？

emq

mqtt

校园云服务器 2H2G30元起

云+校园是针对学生用户推出的扶持计划，2核2G云服务器30元起，1核1G云数据库4元起，并享受免费体验6个月云开发

回答 1

Stack Overflow用户

发布于 2020-08-11 15:18:24

可以做到这一点，但只能使用某些MQTT客户端库，这些库允许您完全控制QOS握手过程。

假设客户端已经在QOS1或QOS2订阅了一个主题，然后它可以选择将PUBACK或PUBREC数据包发送回代理。它可以推迟完成QOS握手，直到消息完全处理完毕。如果处理失败并且完全握手没有完成，那么代理将再次尝试将消息重新传递给客户端，因此客户端应该在失败的情况下离线，这样代理将对消息进行排队。

当后端(数据存储)恢复在线时，客户端可以重新连接到代理，排队的消息将被重新传递。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/63359542

复制

broker 保存消息

存储 kafka

物理上把topic分成一个或多个patition（对应 server.properties 中的num.partitions=3配置），每个patition物理上对应一个文件夹（该文件夹存储该patition的所有消息和索引文件）

编程那点事

2023/02/25

1540

EMQX vs Mosquitto | 2023 MQTT Broker 对比

物联网开源 mqtt mosquitto 数据集成

物联网开发者需要为自己的物联网项目选择合适的 MQTT 消息产品或服务，从而构建可靠高效的基础数据层，保障上层物联网业务。目前市面上有很多开源的 MQTT 产品，在性能功能等方面各有优点。本文将选取目前最为流行的两个开源 MQTT Broker：EMQX 和 Mosquitto，从技术架构、性能、功能、社区情况等多维度进行 1v1 对比，帮助读者更加深入了解这两个产品。

EMQ映云科技

2023/04/21

2.8K0

Mosquitto vs NanoMQ | 2023 MQTT Broker 对比

物联网 iot mqtt mosquitto

Mosquitto 和 NanoMQ 都是用 C/C++ 开发的快速轻量的开源 MQTT Broker，完全支持 MQTT 3.1.1 和 5.0。

EMQ映云科技

2023/04/23

1.2K0

EMQX vs VerneMQ | 2023 MQTT Broker 对比

物联网 iot mqtt 数据集成开源

EMQX 和 VerneMQ 都是用 Erlang/OTP 开发的高性能、分布式开源 MQTT Broker，以其稳定性、容错性和扩展性著称。

EMQ映云科技

2023/04/21

6860

EMQX vs NanoMQ | 2023 MQTT Broker 对比

物联网开源 mqtt iot

EMQX 和 NanoMQ 都是由全球领先的开源物联网数据基础设施软件供应商 EMQ 开发的开源 MQTT Broker。

EMQ映云科技

2023/04/19

1.3K0

Broker消息设计--Kafka从入门到精通（十三）

zookeeper java kafka 数据结构

上篇文章说了，触发rebalance是当消费者组订阅的topic数量发生改变，或者topic分区数量发生改变，或者consumer数量发生变化，比如新的consumer加入组，则会重平衡。还介绍了分区策略range，round-robin，sticky。Kafka监听。以及kafkaConsumer是线程安全的吗？

用户9919783

2022/12/14

4920

MQTT 开放基准测试规范：全面评估你的 MQTT Broker 性能

物联网 iot mqtt

该测试规范包含了实用的典型使用场景、一套衡量 Broker 性能的主要指标，以及一个模拟负载和收集测试结果的工具，可以帮助开发者评估 MQTT Broker 的可扩展性和性能，从而选择最需要和合适的产品。

EMQ映云科技

2023/04/23

4890

MQTT Broker 集群解析：基础概念与高级实现

集群物联网 mqtt

EMQ映云科技

2023/07/05

8920

如何在 Python 中使用 MQTT

mqtt 编程算法 https 网络安全物联网

MQTT (https://www.emqx.io/cn/mqtt) 是一种基于发布/订阅模式的轻量级物联网消息传输协议，可以用极少的代码和带宽为联网设备提供实时可靠的消息服务，它广泛应用于物联网、移动互联网、智能硬件、车联网、电力能源等行业。

用户8949263

2023/01/09

3.4K0

Kafka Broker配置

node.js zookeeper https SSL 证书 .net

kafka大于等于v0.10 名称描述类型默认有效值重要程度 zookeeper.connect 以hostname:port的形式指定ZooKeeper连接字符串，其中host和port是ZooKeeper服务器的主机和端口。为了使得单个ZooKeeper机器宕机时通过其他ZooKeeper节点进行连接，你也可以以hostname1:port1,hostname2:port2,hostname3:port3的形式指定多个，提高可用性。也可以将ZooKeeper chroot路径作为其ZooKee

友儿

2022/09/13

5860

Doris：部署Broker

ip 集群配置

如果机器有多个IP，需要配置priority_networks 1、启动Broker [root@node1 ~]# cd /app/doris-0.14.13/apache_hdfs_broker/ [root@node1 apache_hdfs_broker]# sh bin/start_broker.sh --daemon [root@node1 apache_hdfs_broker]# jps 10400 PaloFe 12744 Worker 14153 BrokerBootstrap 12249

程裕强

2021/09/07

1.1K0

Oracle broker 详解

数据库 sql oracle

　　Data Guard broker是建立在Data Guard基础上的一个对Data Guard配置，集中管理操作的一个平台.我们再上次DG主备切换的时候会发现特别麻烦,为此broker出来了。

星哥玩云

2022/08/17

3320

RocketMQ-Broker

负载均衡 rocketmq 队列配置数据

作用：消息中转角色。负责存储消息，转发消息。一般也称为Server。在JMS规范中称为: Provider。

潇洒

2023/10/20

1580

Broker模块划分

其他

Broker需要和NameServer及Client通信，包括Broker之间也需要通信（主从结构），所以Broker会有一个模块（Net&PacketHandler）用于所有网络包的处理。

林一

2018/07/24

5270

支持插件的消息中间件【msg broker with plugin】

rabbitmq lua python

支持插件的消息中间件 msg broker with plugin Msg Broker概念： msg broker是实现application 之间互通讯的组件。通常为实现application之间的解耦，消息都是通过msg broker完成转发。application只需知道其他applicatipn的逻辑名称，而不需要知道对方的具体位置。Broker中维护一个查找表，记录着哪个application注册在此逻辑名称之下，所以消息总是会被正确的投递到目的地。 msg broker不限于1-1的转发，也支

知然

2018/03/09

1.6K0

2023 年 MQTT Broker 选型时需要考虑的 7 个因素

物联网 iot mqtt 开源云原生

MQTT Broker 是用于连接物联网设备，完成消息传递的重要组件。MQTT Broker 的选型，是物联网应用构建过程中最为基础也是最为关键的一步。本文将从物联网应用普遍场景和项目需求出发，提供一些通用的选型思路和关注点，帮助读者了解如何选择一款最适合自己的 MQTT Broker。

EMQ映云科技

2023/04/14

1.1K0

消息中间件基础知识-从RabbitMQ、RocketMQ、Kafka到Pulsar

pulsar kafka rocketmq rabbitmq mq

本文梳理笔者的MQ知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。

知码行者

2023/04/03

9390

RocketMQ消息发送Broker端流程处理【源码笔记】

存储

processRequest方法主要三件事情： 1.处理consumer发回broker的消息重试 2.处理批量发送 3.处理单条消息发送

瓜农老梁

2019/08/30

1K0

深入解析Apache Pulsar系列（二） —— Broker消息确认的管理

zookeeper 存储 apache 消息队列 TDMQ 消息队列 CMQ 版

导语我们在之前的《深入解析Apache Pulsar系列之一 —— 客户端消息确认》中介绍过Apache Pulsar客户端的多种消息确认模式。这篇文章中，我们将介绍Broker侧对于消息确认的管理。作者简介林琳腾讯云中间件专家工程师 Apache Pulsar PMC，《深入解析Apache Pulsar》作者。目前专注于中间件领域，在消息队列和微服务方向具有丰富的经验。负责TDMQ的设计与开发工作，目前致力于打造稳定、高效和可扩展的基础组件与服务。客户端通过消息确认机制通知Bro

腾讯云中间件团队

2021/12/21

2K0

MQTT 服务器介绍

开源 mqtt 负载均衡 hive 负载均衡缓存

MQTT 是基于发布（Publish）/订阅（Subscribe）模式来进行通信及数据交换的，与 HTTP 的请求（Request）/应答（Response）的模式有本质的不同。

全栈程序员站长

2022/08/25

6.9K0

相似问题

MQTT Broker不接收任何消息

129

MQTT RaspberryPi Broker

219

MQTT Broker - Mosquitto消息日志记录

Mosca Mqtt Broker读取已发布消息

activemq : broker在重新连接后未收到消息

活动推荐

提供大模型在企业的应用构建、高效便捷

添加站长进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例