MQTT paho客户端发布消息并立即删除，接收者使用它
我一直试图与paho mqtt客户端一起工作，以mosquitto作为代理发布和接收消息，并且工作良好。我的用例虽然涉及到发送者向代理发布消息并断开连接，但此时，接收者无论连接还是断开都应该使用该消息并立即删除它。我已经使用了所有的属性，例如QOS、保留的消息、干净的会话等，但没有一个产生我想要的结果。请帮忙。
共有1个答案
假设在QOS2上发布和订阅，消息只会传递给订阅者一次，因此没有任何东西可以从任何地方删除。
如果您试图确保消息只被一个特定的客户机使用，那么我认为您对MQTT有误解。
MQTT是一个pub/sub协议，因此被设计成将订阅服务器与发布服务器完全分离。发布者不知道有多少订阅者，只知道它已将消息发布到给定的主题。
-
我正在运行一个Autobahn/Twisted python websocket服务器，但我在向客户机发送消息时遇到了问题。它似乎只在客户端向它发送消息时才向客户端发送消息。由于某种原因，如果我想将消息强制输出到已连接的客户端，那么消息就会卡在队列中，直到任何客户端向我发送消息。此时，所有排队的消息都发送到所有客户端。 我能够在python Autobahn/Twisted websocket服务
-
我在远程机器上设置了Kafka和动物园管理员。在那台机器上，我可以看到下面使用官方网站上的测试方法工作。 但是当我使用本地消费者脚本时，它就不起作用了： 我试着把它改成： 然后运行客户端使用者脚本，它会给出错误： [2017-08-11 15:49:01,591]获取相关id为3的元数据时警告错误：{listings-incoming=leader_not_available}(org.apach
-
我是一个使用python进行套接字编程的初学者。我正在做我的课程项目。我的项目的一部分需要用不同的端口发送和接收UDP消息。提供了名为robot的服务器程序，我需要编写名为student的客户端程序，它可以与机器人进行交互。因此，我不能显示服务器程序中的所有源代码。 这是服务器程序中与UDP套接字相关的部分 这是我的客户端程序。s3 是 UDP 套接字。我可以成功地向服务器程序发送消息，但无法从中
-
我目前正在使用亚马逊的SQS，在尝试删除当前“正在运行”的队列消息时遇到问题。 下面是一些示例代码： 现在，在接收到句柄和消息体之后，我将接收句柄字符串存储到云存储中（例如DynamoDB）。随后，我从存储服务中加载该句柄，并使用类似于以下内容的方式调用delete： 但是，当运行该行时，我收到一条“输入收据句柄无效”的错误消息。 注意，我知道这条消息没有被重新接收，所以记录的接收句柄应该是最新的
-
我一直在努力通过Smack和Openfire服务器与XMPP聊天。我的问题如下： 每当一个用户向另一个用户发送消息时，该消息就会在另一个用户处正确接收。但是任何回复都不会出现在第一条消息的发件人处。因此，用户1成功地发送给用户2。然后，用户2无法向用户1发送任何回复。另一方面，如果我重新启动并让用户再次登录，则用户2可以发送给用户1，但反之亦然。 我想说的是，只有聊天的发起者才能发送消息，接收者不
-
概述 为了能够让轻应用订阅号的开发者接收到用户在消息窗口的留言消息，开发者可以在管理后台设置消息服务器并开启接收用户对话消息模式。 设置消息服务器时接需要提供可用的接收消息的回调URL地址，为了让通信更加安全，建议使用https。 设置成功并开启了接收对话消息模式后，用户在轻应用或订阅号窗口里发送的消息会推送给设置的URL，服务器接收到消息后，可以通过异步发送消息接口给用户回复消息。 设置消息服务