个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
24
4
我使用 AWS MQTT 客户端编写了一个 lambda 以发布到 AWS IoT Broker。
其下划线中的 AWS MQTT 客户端使用 PAHO MQTT 客户端。< br/>每当我的 Lambda 被调用时，它都会将消息发布到 AWS IoT Broker，这会触发一个 IoT 规则。
但是，当调用 lambda 的两个连续消息之间的持续时间恰好超过 30 秒时，客户端连接丢失。尽管重试逻辑会重新建立连接，但会丢失几毫秒。 
我最初的想法是，IoT Broker 可能因不活动而断开客户端连接。因此，我编写了一个从本地运行的连接 IoT Broker 的简单程序。 
我打开类 org.eclipse.paho.client.mqttv3.internal.ClientState 的日志级别以使用 logback.xml 跟踪级别。可以看出底层PAHO客户端不断发送PINGREQ包。客户端满足保持事件间隔条件，因此永远不会断开连接。
我的问题:
为什么应用程序在 lambda 中的行为不同？
我的方法:
因此，为了了解根本原因，我想在 CloudWatch 中打开同一底层 PAHO MQTT 客户端的日志。
我尝试了以下操作 log4j2.xml但无法在 cloudwatch 中打开同一个类的日志。因此，我想知道如何在 Java 的 lambda 应用程序中打开其他一些库类的日志？
最佳答案
对于每个 lambda 执行，应该期望连接/发布或订阅/断开连接？
这里有更多日志:https://docs.aws.amazon.com/iot/latest/developerguide/viewing-logs.html
关于amazon-web-services - 在 AWS Cloudwatch 上为 Lambda 启用 Paho MQTT 客户端日志，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50387363/
24
4
0
当我使用 paho 和 spring 框架修复应用程序中客户端的一些问题时，我发现了 spring MQTT 集成。我不确定这是否能解决我的问题，我什至不确定这是什么。 有人可以解释一下两者一起使用有
我正在尝试设置一个 mqtt 客户端，但我收到一个 ImportError: 我安装了 paho: pip install paho-mqtt 它说:成功安装 dnspython-1.15.0 pah
我的 raspberrypi 上的以下 python 代码没有连接到我的 mqtt 代理，它只是在打印 Connecting... 后挂起: import paho.mqtt.client as mq
当我通过 MQTTLens 测试发布时，它有效。然而，当我按下按钮时，它确实会触发“on_publish”，但另一端的 on_message 没有收到任何内容；它没有被触发。有两个 Raspberry
我正在使用 Java Paho MQTT 客户端库通过 MQTT 连接到服务器。 库支持使用签名证书进行身份验证和加密的 TLS/SSL。 但是，如果我只是使用用户名和密码进行身份验证(如下所示)，而
我的 python paho-mqtt client无法连接到用 java 编写的代理。代理已使用 jks 类型证书启用 SSL 连接。经纪人不在我的管理范围内。 我将 jks 证书转换为 pem 证
如果连接丢失，我的 paho-mqtt 服务无法重新连接到代理。 在连接丢失时，我使用 adb shell 从 Android 客户端 ping 两个代理，并从托管 mosquito 代理的服务器 (
我在笔记本电脑上运行 MQTT Mosquitto 代理。然后我尝试将 2 个 Paho MQTT 客户端连接到它:1)使用 Java Paho 从 Android 手机和 2)使用 Python
有没有一种优雅的方法可以从代理中提取一条消息而不必: 订阅 创建一个 on_message() 接收消息 退订 我问是因为我们使用了一个包含多个字段的 json 消息。当新数据进入时，我只想更新 js
我正在使用适用于 Android 的 Paho MQTT 库，我的应用程序正在交换实时编辑数据。我想在应用程序与代理断开连接时禁用编辑文本，并在重新建立连接时启用它。 第一部分很简单，MqttCall
我正在使用 Eclipse MQTT 库 Paho，但我找不到方法来决定客户端与代理的连接何时建立。 有人知道目前是否有办法做到这一点吗？ 我似乎在文档中的 MqttCallback 类中找不到任
我对 paho mqtt 库有一个小问题。我注册了回调函数 MQTTClient_messageArrived 和 MQTTClient_connectionLost。 我在此回调函数中调用 MQTT
我使用 Apache Artemis 作为我的 mqtt 代理。我有一个以主从方式配置的 Artemis 集群。当主服务器发生故障时，备份服务器接管，客户端必须连接到从服务器。主站和从站有不同的IP。
我目前正在开发一个应该在医疗机构中运行的小型“紧急按钮”应用程序。由于该项目的假设之一是独立于 Internet，因此我决定使用在本地 WLAN 中设置服务器的 MQTT。 我已经实现了 Paho A
我正在尝试使用基本的 Eclipse Paho MQTT 客户端版本 1.1.0，用于连接到 CloudAMQP RabbitMQ 实例、订阅主题并接收消息(我从 Web 管理控制台发送的消息)。 如
我已经创建了 mqtt 连接suscribeData()，如下所示，以 24/7 从多个设备接收数据 @RequestMapping("/suscribe") @ResponseBody public
我最近开始使用 paho mqtt for java 和 mqtt，但我坚持使用 mqtt 代理和 paho 客户端本身提供的持久性机制。也许我误解了(可能就是这样)mqtt 上下文中的持久性概念。
我是 MQTT 和树莓派的新手!我正在运行一个客户端脚本，我只是使用另一个脚本发布一条消息。我正在使用自己的 Mosquitto 代理。 客户: import paho.mqtt.client as
我设法在我的 RPi 中的 Paho-MQTT 客户端和我的 VPS 中的 MQTT 代理之间建立了连接。 现在我正在尝试保护 MQTT 连接，并且我已将用户和密码添加到代理。我更改了 mosquit
为了演示 Paho MQTT，我下载了一个 Java 示例。 public class Thermometer { public static final String BROKER_URL
我是一名优秀的程序员,十分优秀！