如何将 Apollo Client 与 AppSync 结合使用?
AppSync 使用 MQTT over WebSockets 进行订阅，而 Apollo 使用 WebSockets.在将 apollo 与 AppSync 一起使用时，Query 组件中的 Subscription 组件或 subscribeForMore 都不适合我. 引起广泛关注的 AppSync 功能之一是它强调实时数据.在幕后，AppSync 的实时功能是强大的通过 GraphQ
..
mqtt相关内容
最大 MQTT 连接数
我需要创建一个可以处理 5+ 百万个连接、5+ 百万个主题(每个客户端一个)、处理 30 万条消息/秒的服务器群. 我试图了解各种消息代理的功能，因此我目前使用两个 RHEL EC2 实例 (r3.4xlarge) 来制作大量可用资源.所以你不需要查找它，它有 16vCPU，122GB RAM.我远未达到使用限制. 我无法通过 600k 连接限制.由于客户端和服务器上似乎没有任何 O/
..
无法找到任何实现连接器且名称与 io.confluent.connect.mqtt.MqttSourceConnector 匹配的类
curl -s -X POST -H 'Content-Type: application/json' http://localhost:8083/connectors -d '{>"name" : "mqtt-源",>“配置":{>"connector.class" : "io.confluent.connect.mqtt.MqttSourceConnector",>"tasks.max" :
..
mqtt 代理和 kafka 独立连接
我想将数据从 mqtt 代理(mosquitto)摄取到 kafka 代理(apache kafka)，所以我执行这些步骤 1/我从 evokly github 创建了我的 mqtt 连接器:所以我下载了代码并使用 gradlew 来构建项目并生成 .jar 依赖项(kafka-connect-mqtt-1.1-SNAPSHOT.jar)2/我将 .jar 文件放入 C:\kafka_2.1
..
无法找到任何实现连接器且名称与 io.confluent.connect.mqtt.MqttSourceConnector 匹配的类
curl -s -X POST -H 'Content-Type: application/json' http://localhost:8083/connectors -d '{>"name" : "mqtt-源",>“配置":{>"connector.class" : "io.confluent.connect.mqtt.MqttSourceConnector",>"tasks.max" :
..
无法找到任何实现连接器且名称与 io.confluent.connect.mqtt.MqttSourceConnector 匹配的类
curl -s -X POST -H 'Content-Type: application/json' http://localhost:8083/connectors -d '{>"name" : "mqtt-源",>“配置":{>"connector.class" : "io.confluent.connect.mqtt.MqttSourceConnector",>"tasks.max" :
..
使用 mqtt 协议和 kafka 作为消息代理
我们如何使用 mqtt 协议和 kafka 作为消息代理? 客户端(android/ios/desktop java 应用程序等)将使用 mqtt phao 客户端库来生成和消费消息，这些客户端库使用 kafka 作为消息代理提供不同的语言版本. 有什么建议吗? 解决方案 您可以使用 Kafka 源连接器，它将数据从 Mosquitto 等 MQTT 代理流式传输到 Kafka
..
Camel PAHO 路由在连接回时未收到离线消息
我正在使用基于 apache camel xml 的 paho 路由进行订阅、发布过程.在线时，一切正常.但是我无法接收离线消息. 我已经设置了以下内容， 固定客户 ID 清除会话为假， 两者都订阅了使用 QoS 2 发布 使用独立程序，它可以获取所有离线消息.骆驼路线不会发生这种情况. 解决方案 最后，我能够手动解决这个问题. Camel PAHO 客户端在执
..
无法通过 angular8 中的 ngx-mqtt 连接到 MQTT 代理
无论我做什么，我都无法在我的 Angular 应用程序中通过 websocket 连接到 mqtt 代理(在 chrome 和 firefox 中尝试).为简单起见，我使用 HiveMQ 代理，我已经发布了关于该主题的/gat/38/openReservationRequests 一些数据 我已经关注了这个中篇文章关于如何使用 ngx-mqtt 以角度连接到 mqtt 但对我来说它不起作用.
..
由于 MQTT 错误，AWS App Sync 订阅不起作用
我正在我的 React 应用上调用这个 graphql 订阅: export const OnCreateMessage = `订阅 OnCreateMessage($conversationId: ID!) {onCreateMessage(messageConversationId: $conversationId) {ID内容作者 ID消息会话 ID创建于}}` 这就是我在类组件中调用它
..
我正在使用 react_native_mqtt 并且需要在客户端和服务器之间实现安全的 mqtt 通信
在连接到 mqtt 服务器时，我将 useSSL 设置为 true.正在使用 443 端口. 我需要在此调用中使用 SSL 固定，设置 useSSL 标志是否足够? 如果没有，那么建议我使用 SSL 固定来安全连接服务器的方式. 我没有发现 react_native_mqtt 库中与证书固定相关的任何问题. 此外，其中一个库建议使用节点的 tls.connect() 进行连
..
如何将 Apollo Client 与 AppSync 结合使用?
AppSync 使用 MQTT over WebSockets 进行订阅，而 Apollo 使用 WebSockets.在将 apollo 与 AppSync 一起使用时，Query 组件中的 Subscription 组件或 subscribeForMore 都不适合我. 引起大量关注的 AppSync 功能之一是它强调实时数据.在幕后，AppSync 的实时功能是强大的通过 GraphQ
..
客户端上的 MQTT 套接字错误 <unknown>
我已在 Raspberry Pi 上设置了 MQTT 并为代理配置了 Arduino Uno，但我在/var/log/mosquitto/mosquitto.log 文件中看到以下条目: 来自 192.168.10.114 端口 1883 的新连接.客户端 上的套接字错误，正在断开连接. Pi 设置了 ETH0 连接到我的本地 LAN，IP 地址为 192.168.1.50 Pi 上还
..
是否可以在没有 websocket 的情况下制作 mqtt 网页?
我正在尝试构建一个连接到 mqtt 代理并更新一些信息的简单网页.是否可以使用纯 mqtt 而不是 websocket 来实现，如果可以，它更安全还是更好? 解决方案 如果您希望直接页面到代理通信，那么 MQTT over WebSockets 是唯一的选择. 浏览器中的沙箱将只允许 HTTP 或 WebSocket 连接.
..
使用 Paho MQTT 订阅消息时如何读取标头键:值对
我在使用 pika like 向我的 rabbitmq 代理发布消息时添加了一个标头键:值对 channel.basic_publish(exchange=self.exchange,routing_key=self.routing_key,属性=鼠兔.BasicProperties(headers={'key': 'value'}),正文=消息) 在我的客户端，我使用 websockets
..
python Mqtt订阅如何删除第一个会话/消息
我使用具有 HA 作为代理的 python 创建了一个 Mqtt 订阅......当我建立第一个连接时，我开始一系列我连接的所有 mqtt 按钮的消息，即使我没有激活它们，因为我的订阅是“房子"/点击/# ".列表完成后……如果你按下一个按钮，我就会开始收到我需要的消息……有没有办法删除它给我的第一个列表. 这是我使用的代码: 导入 paho.mqtt.client 作为 paho将熊猫导
..
将订阅主题中的 MQTT 数据保存在文本文件中
我正在设置从订阅的主题接收 MQTT 数据，我想将数据保存在文本文件中. 我添加了将变量保存到文本文件的代码.然而，这不起作用，因为它只给我变量而不是它的值，即不给我“on_message"的值.有人可以帮帮我吗? 谢谢 我的代码如下: 导入 paho.mqtt.client 作为 mqttClient导入时间def on_connect(client, userdata, f
..
MQTT.js 未从 websockets 连接
我正在尝试连接到 MQTT.js 的 websocket 客户端，但无法连接与服务器握手. 我的代码: test Ws mqtt.js变量选项 = {clientId: 'service-3Kx03pKnM2',连
..
在不使用堆栈的情况下创建瘦 MQTT 发布者(操作方法)
我之前对 Google 的研究使我进入了这个页面:https://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html在这里我找到了一些信息……我开始尝试.测试设置是针对当地蚊子的.这到目前为止有效(它运行没有错误)，但是如果我发送 PUBLISH 消息，我会与蚊子断开连接. [edit] 所以最大的问题是，消息有什么问题.
..
将 MQTTNet 服务器与 MQTT.js 客户端一起使用
我已经启动了一个 MQTT 服务器，就像 这个 示例一样.此代码托管在 ASP.Net Core 2.0 应用程序中，但我尝试过控制台应用程序但没有成功. 我还使用与上面相同的演示设置了一个客户端，它连接完美.此外，Android 客户端连接正常.但是我已经放置了一个 MQTT.js 客户端网页，但它无法与 chrome 连接，显示 net::ERR_CONNECTION_REFUSED 错
..