Paho MQTT“无法在套接字上接收：[Errno 32]断开管道”
Paho MQTT是一个开源的MQTT客户端库，用于在互联网上进行轻量级的消息传输。它提供了一种可靠的、基于发布/订阅模式的通信方式，适用于各种物联网和机器到机器（M2M）应用场景。
MQTT（Message Queuing Telemetry Transport）是一种基于发布/订阅模式的消息传输协议，它被设计用于低带宽和不稳定网络环境下的物联网设备通信。MQTT协议具有轻量级、开销小、易于实现和扩展等特点，因此在物联网领域得到广泛应用。
对于"Paho MQTT“无法在套接字上接收：[Errno 32]断开管道"这个错误，它通常表示在使用Paho MQTT库时，连接的套接字（socket）意外断开导致无法接收消息。这可能是由于网络连接不稳定、服务器故障或其他原因引起的。
解决这个问题的方法可以包括以下几个方面：
- 检查网络连接：确保网络连接稳定，并且没有防火墙或其他网络设备阻止了MQTT通信。
- 检查服务器状态：确认MQTT服务器正常运行，并且没有出现故障或重启。
- 错误处理：在代码中添加适当的错误处理机制，以便在出现错误时能够及时捕获并处理异常情况。
- 重新连接机制：在Paho MQTT库中，可以设置自动重新连接的机制，以便在连接断开后能够自动重新连接服务器。
腾讯云提供了一系列与MQTT相关的产品和服务，例如：
- 物联网通信（IoT Hub）：提供高可靠、安全的物联网设备接入和通信服务，支持MQTT协议。
- 消息队列 MQTT 版（CMQ MQTT）：提供高可靠、低延迟的消息队列服务，支持MQTT协议。
- 物联网套件（IoT Suite）：提供一站式的物联网解决方案，包括设备管理、数据采集、数据存储和可视化等功能。
以上是关于Paho MQTT和相关错误的简要介绍和解决方法，希望能对您有所帮助。
相关·内容
1回答
Python异常处理
、、、
目前，我正在努力确保我的Python脚本仍然活着，不管它是在什么情况下，因此，我试图捕获所有的异常，并找到一个apropiate脚本响应。
在我的脚本中，我试图捕捉在连接到MQTT代理时可能发生的错误，即：(1)通过没有插入的eth0连接，或者(2)路由器无法访问internet。
1的错误消息是：
socket.gaierror: [Errno -5] No address associated with hostname
2的错误消息是：
socket.gaierror: [Errno -2] Name or service not known
遗憾的是，我还没有捕捉到这些例外。这些是我试
浏览 4提问于2016-04-10得票数 0
回答已采纳
我正在尝试连接到我的MQTT代理，它位于一个Raspberry Pi上。我正在尝试使用我笔记本电脑上的Wifi远程发布到RPi。我已经验证过，我可以通过SSH -端口22连接到Raspberry Pi。但是，当我试图运行我的代码时，我会得到这个错误，显然我无法连接到代理。有办法解决这个问题吗？
Traceback (most recent call last):
File "F:/multi_mqtt.py", line 55, in <module>
client.connect('10.xxx.xxx.xxx', 1883, 60
浏览 4提问于2016-04-16得票数 1
回答已采纳
1回答
我正在尝试在我自己的C++项目(VisualStudio2017)中使用Paho C++库。我已经构建并安装了Paho C库和Paho C++库，解释了。到目前一切尚好。之后，我在Visual 2017中创建了一个新的(空白) C++项目，并在项目属性中应用了以下更改：
In Tab C/C++ / General:在“附加包含目录”中，我添加了两个包含路径(来自泛美卫生组织c和泛美卫生组织c++安装路径)：
In Tab Linker / General:在“附加库目录”中，我将路径添加到库文件夹(来自paho c和paho c++安装路径)：
In Tab Linker
浏览 7提问于2020-02-24得票数 0
回答已采纳
在我当前的.NET项目中，我想通过MQTT向代理发布一条消息，但我尝试了几种实现方法，但没有一种方法有效。我想使用 ()，但我也尝试了，但没有成功。
我目前解决这个问题的方法是让最简单的实现工作，但即使是这个也不起作用。我只是创建一个MqttClient实例，连接到代理(调试通过‘IsConnected’向我展示了它的工作原理)，然后我发布了一条消息(简单的字符串‘Local0:0:user:dev’)。尽管如此，我的代理从来没有收到过这条消息，我从VisualStudio得到的唯一反应是以下4行：
在线程0x13a8帽麻省理工学院代码259 (0x103)根特。在线程0x16d4帽麻省理工
浏览 4提问于2015-09-26得票数 1
回答已采纳
javascript mqtt websocket连接在localhost中工作正常，在https服务器中不工作 代码 <html>
<head>
<meta charset="utf-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title>Hello MQTT World</title>
<meta name="
浏览 72提问于2021-05-01得票数 0
? 我使用的是Paho MQTT C代码，在MQTTClient_publish.c中，我在代码层启用了所有与TLS/SSL相关的东西，并且通信完成得很好。但是我找不到哪个API在加密包。 ?
浏览 36提问于2019-09-06得票数 1
我的客户端无法从MQTT服务器接收消息有效负载。我已经在我的电脑上设置了蚊虫作为服务器和发行者，并执行以下命令：
mosquitto_pub -h 192.168.1.2 -t topic/test -m "testing" -i simulator -d
订阅我自己的作品，并收到有效载荷。
但是，使用paho mqtt的客户端只接收到成功的连接，而没有有效负载消息。因此，这里有以下代码：
def on_connect(client, userdata, flags, rc):
print("connection ok")
client.subs
浏览 8提问于2022-03-28得票数 0
回答已采纳
我使用"org.eclipse.paho.client.mqttv3“来连接我的java代码到azure IOT，但同时却引发了连接MQTT异常。 步骤： 1)创建MQTT客户端。 2)创建SSL工厂。 3)最终连接到Azure IOT。 但是，当connect异常被抛出时： Inside AzureCommunicator::connect, Could not connect due to an MqttException!
MqttException (0) - java.lang.ClassCastException: class java.net.Socket canno
浏览 428提问于2019-05-10得票数 0
回答已采纳
1回答
我正在构建一个AngularJS应用程序，并使用Paho JavaScript客户端通过web套接字连接到MQTT (test.mosquitto.org)。这个很好用。我想通过直接的MQTT连接到MQTT代理(为了完整地支持没有启用websockets的代理)。
由于Paho客户端不支持直接MQTT，所以我尝试了mqtt.js (browserMqtt.js)的浏览器序列化版本。
下面是我代码中的主要行：
//var options = { host: "test.mosquitto.org", port: 8080 }; //works!
var options = { h
浏览 7提问于2017-03-12得票数 5
回答已采纳
1回答
我正在使用Paho MQTT客户端连接到MQTT服务器。在接收完消息后，我运行以下代码：
function dummy() {
console.log("dummy");
}
if (window.MQTTClient!==null){
console.log("Disconnecting from MQTT server...");
window.MQTTClient.disconnect;
window.MQTTClient.onMessageArrived=dummy;
let element = documen
浏览 17提问于2022-07-13得票数 0
我已经成功地使用了一个1.1.0版本的Paho MQTT JS客户端连接到我的Mosquitto。但是，客户端在完成连接后立即断开连接。在使用这个版本之前，我使用的是1.0.1，它起作用了。这是我的主要功能代码：
function onConnectionLost(){
console.log("connection lost");
document.getElementById("status").innerHTML = "Connection Lost";
connected_flag=0;
浏览 2提问于2020-05-01得票数 0
1回答
我已经试着让这个例子运行了好几个小时。我正在建立一个例子，这样我的朋友就可以学到一些巨蟒，但我最终还是很沮丧。
我的蟒蛇知识非常有限。无论我如何尝试用time.sleep延迟执行，都会导致程序线程完成(我已经删除了这部分代码)。
预期结果:发送方容器应在接收方启动后启动。因此，接收方被订阅到代理并等待消息。
给定的结果:接收容器启动，然后死亡。
提前谢谢。
我有一个码头组合如下：
services:
mqtt_broker:
image: eclipse-mosquitto
volumes:
- "./mosquitto.conf:/mosquitto/
浏览 8提问于2022-11-20得票数 0
当我启动Phusion 独立web服务器(version 5.0.2)时，我在日志中看到以下错误(尽管否则一切正常)：
ServerKit/Server.h:892 ]: [Client 1-1] Disconnecting client with error: client socket write error: Broken pipe (errno=32)
知道是什么引起的吗？
注意:我用foreman start启动服务器，用control-c停止服务器。
浏览 2提问于2015-03-10得票数 6
回答已采纳
我正在使用paho-mqtt在Python中创建一个MQTT测试，并且我需要能够向我的代理发送一个字节数组。订阅服务器查找不同数据类型的多个主题。基于字符串的有效负载运行良好，但数值必须以字节数组的形式接收，数值类型的正确长度(即32位整数必须是4字节的数组)
例如，要发送32位整数(INT32)，有效负载应为00 00 00
如果我想发送一个十进制的53，我需要发送00 00 00 35 (0x35 = 53)
由于此测试是作为套件的一部分运行的，因此它需要使用Python和paho-mqtt作为我们的mqtt包。
如果有人能告诉我如何使用paho-mqtt来传输字节数组，我将不胜感激。
浏览 48提问于2017-07-19得票数 0
回答已采纳
我有一个小型服务器端程序，它接受来自客户端的连接并写入套接字。当客户端断开连接时，我希望从服务器端检测到。我看到客户端在断开连接时发送了一个TCP Fin，而服务器只有在有一些数据要发送给客户端时才会检测到它，而我看到的是管道故障。相反，我希望服务器能够检测到客户端已经发送完并立即关闭会话。有人能帮我提供一些投入吗。
>>> Error sending data: [Errno 32] Broken pipe
[DEBUG] (Keepalive-Thread) Exiting
接受连接的服务器程序：
def enable_pce(ip):
#Step 1: Create
浏览 4提问于2015-01-19得票数 2
我正在使用paho-mqtt Python库来实现对亚马逊网络服务AppSync的订阅。 以下是订阅的代码： postHeaders = {
'Content-Type': 'application/json',
**self._headers
}
payload = {
"operationName": "onCommand",
"query": ""
浏览 37提问于2020-05-03得票数 0
回答已采纳
我有一个mqtt java代码(paho)写的，当它试图连接到Mosquitto时工作良好。它能够建立、发布所有消息到一个主题。但是使用MQXR (包含在MQ中的代理)，我得到
严重:无法连接到MQTT broker，请求可能丢失。连接丢失(32109) -由以下原因引起的org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:138) at java.io.DataInputStream.readByte(DataInputStream.java:250) at java.io.EOFExcep
浏览 3提问于2016-06-16得票数 0
1回答
如何处理服务器关闭TCP
、、、
现在，我有一个简单的TCP服务器/客户端。我对它进行了设置，以便每当客户端连接时，它都会被forked()，并且连接本身被放入无限循环中，从而使连接保持打开状态。服务器正在接收来自客户端的信息时，我进行了检查以确保接收到的字节数> 0。到目前为止，它在确定客户端是否已断开连接方面运行良好。但是，如果服务器断开连接，客户端也会关闭，但不会设置errno。如何检查以确保服务器仍处于连接状态？
浏览 0提问于2009-09-10得票数 0
回答已采纳
我编写了一个lambda，它使用AWS客户端发布到AWS IoT Broker。
AWS MQTT客户端在其下划线中使用PAHO MQTT客户端。
每当我的Lambda被调用时，它都会将消息发布到AWS IoT Broker，该代理目前触发了一个IoT规则。
但是，当调用lambda的两个连续消息之间的持续时间超过30秒时，客户端连接就会丢失。尽管重试逻辑重新建立了连接，但损失了几毫秒。
我最初的想法是，可能是IoT代理由于不活动而断开了客户端的连接。因此，我编写了一个从本地运行的连接IoT代理的简单程序。
我打开了org.eclipse.paho.client.mqttv3.in
浏览 0提问于2018-05-17得票数 3
当MQTT或客户端出现问题时，我有许多QoS2级别的消息会在场景中造成问题。这些问题可以包括
客户端开始看到服务器超时。
客户端已失去与代理的连接(因特网连接中断，与代理发出问题，.)再重新连接一段时间。
通常，当MQTT客户端开始从代理接收超时或其他错误时，消息将存储在持久性存储中(在运行中的消息)，并最终将被重新发布。
但是，在泛美卫生组织客户端失去与代理的连接的情况下，消息将不再在运行中被考虑，也不会被泛美卫生组织存储。这时，这个应用程序似乎开始负责维护这些消息(在泛美卫生组织之外)并重新发布它们。
我说的对吗?当MQTT代理不可用时，Paho MQTT客户端不能帮助我保
浏览 20提问于2015-01-24得票数 7
1回答
我目前正在开发一个Android应用程序，它通过TCP连接到服务器。服务器是用Qt编写的，并在计算机上运行。
在服务器端，我使用QTcpServer和信号QTcpServer::newConnection()来获得与QTcpServer::nextPendingConnection()新连接的QTcpSocket。我实现了一个名为SocketManager的类，它管理这个套接字接收的数据。
在Android端，我使用java套接字连接到服务器。
一切都很好。当Android端与服务器断开连接时，我的SocketManager对象会被很好地通知并破坏自己。但是，当Android设备离线或关机时，
浏览 0提问于2011-07-28得票数 3
回答已采纳
我正在用javascript编写一个web应用程序，我希望一个Paho.MQTT.Client能够断开与MQTT代理的连接，并使用不同的IP地址将其连接到另一个MQTT代理。
这个是可能的吗？
或者，为了在不同的Paho.MQTT.Client之间切换，我是否必须删除现有的MQTT并使用不同的IP地址创建一个新的MQTT？
我尝试过myClient._setHost("a.b.c.d")；，即使在调用myClient.disconnect()之后也会返回“Unsupported”。
浏览 0提问于2018-06-15得票数 0
我已经创建了一个android应用程序，在MQTT上发布消息。我正在创建一个python程序来接收命令。但是，当我运行它时，我总是会遇到一个错误。
Traceback (most recent call last):
File "mqttapptest.py", line 13, in <module>
client.connect(MQTTHOST)
File "E:\Anaconda\lib\site-packages\paho\mqtt\client.py", line 686, in connect
return self.reconnect
浏览 2提问于2016-11-17得票数 1
回答已采纳
1回答
我在我的笔记本电脑上运行MQTT Mosquitto。然后我尝试连接2个Paho MQTT客户端: 1)从Android手机使用Java Paho和2)从树莓派使用Python Paho。
从Android连接是完美的。没问题。
但是，由于某些原因，Raspberry无法连接。相反，client.connect方法会阻塞，一段时间后，我会收到以下内容：
Traceback (most recent call last):
File "sensorsClient.py", line 28, in <module>
client.connect(mqttSe
浏览 0提问于2017-04-14得票数 3
我正在使用蚊子经纪人与mqtt vcpkg C++客户端。
我可以使用v5属性发布带有回复主题的消息。
当我尝试使用Paho Python客户端时，在C++端接收的消息中没有应答主题。
我遵循了一些关于python端的指导方针：
from paho.mqtt.properties import Properties
from paho.mqtt.packettypes import PacketTypes
from paho.mqtt.client import Client
properties=Properties(PacketTypes.PUBLISH)
properties.Resp
浏览 12提问于2022-11-15得票数 0
回答已采纳
3回答
使用paho-mqtt并尝试让它接收排队的消息。我使用的代理是emqx 4.2.2，这是我的脚本： from paho.mqtt.client import Client, MQTTv5
def on_connect(mqttc, obj, flags, rc, other):
print(" Session present: " + str(flags['session present']))
print(" Connection result: " + str(rc))
mqttc.subscribe
浏览 77提问于2020-12-18得票数 0
回答已采纳
我正在使用穆斯基托Mqtt和泛美卫生组织API在android设备上接收推送消息。但是，一旦网络连接改变，它就停止接收消息。下面是用简单测试用例再现问题的步骤：
1)创建一个简单的活动。
( 2)在活动上，StartUp通过paho连接到蚊虫检测服务器(test.mosquitto.org:1883)。
3)订阅某一主题。
4)向主题发布消息。
结果： Mqtt客户端接收发布到主题的所有消息。现在
5)禁用移动互联网连接(移动数据)
6)向主题发布一些信息。
( 7)重新连接互联网。
结果：客户端未收到任何在禁用internet连接后发布的消息。
由于KeepAliveInterval的价值很
浏览 0提问于2014-08-07得票数 5
尝试简单地订阅，而不断开与Mosquitto的连接，从发布特定主题中的数据的设备中获取所有消息，将它们保存在BD中，并将它们发布到一个执行"staff“操作的php中。
这是我的subscribe.py
import paho.mqtt.client as mqtt
from mqtt_myapp import *
topic="topic/#" # MQTT broker topic
myclient="my-paho-client" # MQTT broker My Client
user=
浏览 7提问于2016-10-05得票数 2
回答已采纳
我是paho-mqtt的新手。我试图使用我的localhost发布一个主题，但遇到了以下错误：
Traceback (most recent call last):
File "server.py", line 10, in <module>
client1.connect(host,port,keepalive)
File "/usr/local/lib/python2.7/dist-packages/paho_mqtt-1.3.1-py2.7.egg/paho/mqtt/client.py", line 768, in conne
浏览 0提问于2018-07-15得票数 2
1回答
import sys
import paho.mqtt.publish as publish
publish.single("paho/test/single", "boo", hostname="iot.eclipse.org")
我正在使用上面的Python代码发布到一个主题。我得到的错误是：
Traceback (most recent call last):
File "/home/pi/bgvf.py", line 8, in <module>
publish.single("paho/
浏览 1提问于2017-04-04得票数 0
3回答
最近，我开始使用paho mqtt for java和mqtt，我一直使用mqtt broker和paho客户端it self提供的持久性机制。也许我误解了(可能是这样) mqtt上下文中持久性的概念。
我们必须支持的用例如下：我们的mqtt客户端已经断开了7天(我非常怀疑这将发生，但很好)，甚至应用程序在这7天没有恢复连接的情况下关闭，并且一旦启动并运行，在断开连接时发送所有7天的所有消息。
Paho客户端支持缓冲消息在其或代理故障时的持久性，一旦网络恢复或代理运行，就会发送缓冲消息，但如果应用程序在客户端断开连接或代理不可用时关闭，则无法发送缓冲消息。
基本上，我的问题是-断开连接的缓冲消
浏览 0提问于2017-03-09得票数 2
2回答
我试图在MQTT服务器上读取消息。在某些情况下，连接是不稳定的，需要重新连接。但是在重新连接之后，我无法收到来自我以前订阅的主题的任何消息。我正在使用paho的python包来处理MQTT连接。下面是我正在使用的一些代码
TopicName='some/topic/name'
class Counter:
def __init__(self, mqttClient):
self.messages_recieved = 0
self.mqttClient = mqttClient
self.mqttClient.subsc
浏览 4提问于2020-12-02得票数 1
回答已采纳
import paho.mqtt.publish as publish
import paho.mqtt.client as mqtt
USERNAME = "admin-user"
PASSWORD = "admin-user@12345"
AUTH = {"username":USERNAME, "password":PASSWORD}
HOSTNAME = "ssl://b-c7d1ea8g-f777-4c71-23a3-2d73088fdb64-1.mq.us-west-2.amazonaws.com"
浏览 2提问于2020-09-03得票数 1
我正在尝试将MQTT集成到我的应用程序中。我正在阅读，但由于使用过时的React Native MQTT库或我的代码错误，我无法连接到代理。如何成功连接到代理？
import init from 'react_native_mqtt';
import { AsyncStorage } from 'react-native';
init({
size: 10000,
storageBackend: AsyncStorage,
defaultExpires: 1000 * 3600 * 24,
enableCache: true,
reconn
浏览 4提问于2020-03-02得票数 0
我从pimoroni买了一个触摸phat，我正在使用我的树莓Pi Zero W (stretch OS)。Touch phat基本上是一个电容式按钮，为覆盆子设备添加屏蔽。()。我决定在我的touch phat python脚本中实现Paho MQTT函数，该脚本取自pimoroni示例脚本()。例如，当我按下'A‘按钮时，脚本将向另一个同时运行的脚本(MQTT客户端)发布一条MQTT消息，通知该按钮已被按下，而MQTT客户端脚本将执行最后的操作(例如，播放音频文件)。当我的脚本处于非活动状态大约5分钟时，问题就出现了。当我再次触摸按钮时，终端打印一个错误，指出带有MQTT发布函数的t
浏览 48提问于2018-01-12得票数 0
我已经实现了mqtt使用服务器连接tcp套接字在我的机器上与蚊虫经纪人。我完全理解mqtt协议及其帧格式。我想在支持mqtt的webserver上发布我的数据。
我怎么能从这件事开始？
我不清楚websocket的概念。
我是否可以使用tcp实现websocket，或者是否有其他方法。我是否必须使用http在web套接字上实现mqtt作为通过web服务器发送数据？
由于http和mqtt使用不同的方法发送或接收数据。
我不想使用像paho这样的现成库。我是全新的这个套接字programming.any帮助或指南将非常感谢！
浏览 1提问于2018-05-23得票数 0
回答已采纳
我刚开始使用MQTT，我想同时运行两个Python程序:一个将消息发布到某个主题，另一个在将消息发布到主题时打印出来。但是，打印消息的回调函数对我不起作用。
以下是我的两个项目：
发布信息：
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected! Result code: " + str(rc))
client = mqtt.Client(client_id="clientID")
client.on_connect
浏览 5提问于2021-08-11得票数 0
回答已采纳
3回答
蚊子和遗嘱的问题(遗嘱)
、、、
我正在使用Mosquitto和Paho的Python实现来尝试与几个程序通信。当我使用最后一个will函数时，我遇到了一些麻烦。我的代码是：
Suscriber：
import paho.mqtt.client as mqtt
def on_message(client, userdata, msg):
print 'Received: ' + msg.payload
client = mqtt.Client()
client.on_message = on_message
client.connect('localhost', 1883)
clie
浏览 0提问于2015-02-20得票数 4
回答已采纳
1回答
注:我使用EMQX作为代理，python-paho作为客户端库。我不知道是谁对这个问题负责。
如果发布服务器在一段时间内不发送任何消息，则订阅服务器将断开连接，但也会再次重新连接(因为loop_forever会自动处理重新连接)。但是在重新连接之后，如果生产者再次开始发送数据，自动重新连接的服务器将不会收到任何消息。在这种情况下，订阅服务器需要重新启动(手动重新连接)。
我的订户
import paho.mqtt.client as mqttClient
import json
import datetime
def on_connect(client, userdata, flags, r
浏览 5提问于2021-05-20得票数 0
回答已采纳
1回答
我正在用C/C++编写一个用tcp/ip套接字在两台机器之间传输数据的程序。程序检查每次读取和写入的大小，以确保传输的数据大小正确。我还实现了校验和验证，以确保传输正确的数据。大多数时候是没有问题的。有时，比如，每50,000次，我注意到接收到的数据与发送端的长度相同，但其中一些内容被更改了。更改的部分始终为64字节长。下面是我的send和read代码。请帮我弄清楚这是如何发生的，以及如何防止它发生。谢谢!
bool WriteSocket(int pSocket, unsigned char* pData, uint32_t pNumBytes, uint32_t &pNumByte
浏览 0提问于2019-10-01得票数 0
对于MQTT在WebSocket上提供的额外功能与传统的MQTT与传统的MQTT在响应本机中提供的功能，我有点困惑。MQTT是否是浏览器的解决方案，以便实时接收事件，还是添加了一些我无法捕捉到的内容？
浏览 2提问于2020-03-21得票数 1
回答已采纳
我正在为一个项目测试MQTT。我还能够收到关于客户端连接时我的客户已经订阅的主题的消息。我已经将QoS设置为1，cleanSession设置为false。但是，当我的客户端再次连接时，我无法接收发送到订阅主题的消息。在我的应用程序中，几乎所有的工作都是由助手服务完成的。
这是我的密码
AndroidManifest.xml
<?xml version="1.0" encoding="utf-8"?>
<uses-permission android:name="android.permission.WAKE_LOCK" /&
浏览 13提问于2015-06-25得票数 2
回答已采纳
1回答
我有一个mqtt beoker，我正在尝试连接和订阅python。代码
client = mqtt.Client("P1",clean_session=True) #create new instance
client.on_connect = on_connect
client.on_message = on_message #attach function to callback
client.on_disconnect = on_disconnect
print("connecting to broker")
client.connect(broker_a
浏览 54提问于2019-08-07得票数 2
回答已采纳
我在使用Apache Mina和flash (客户端/服务器游戏)时遇到了问题。
当用户通过任务管理器(或集成开发环境中的Flash player )关闭浏览器进程时，服务器会抛出无限异常"Java.io.BrokenPipe“。
更改操作系统TCP/IP设置(keep-alive)不起作用。
浏览 0提问于2011-03-02得票数 0
我写了一个Android套接字演示，它只是将用户的输入发送到服务器。我从android客户端通过wifi连接建立了一个socket，一切顺利，服务器可以接收android客户端发送的消息。问题是，然后我关闭了手机的WIFI，但插座可以无一例外地写入。
Android客户端代码：
public class MyActivity extends Activity {
private SocketHandlerThread thread;
/**
* Called when the activity is first created.
*/
@Overr
浏览 1提问于2013-01-07得票数 2
我已经使用以下脚本在本地网络中的MQTT代理上测试了我的脚本：
import paho.mqtt.publish as publish
publish.single('some_topic, 'some message', hostname="192.168.1.123")
一切都能正常工作。现在，我想要发布到一个实际的服务器，我被赋予了凭据。遗憾的是，paho MQTT脚本的所有示例都发布到本地服务器，因此我无法对我的脚本进行真正的建模。我提供的凭据包括用户名、密码和主题。我以"hostname“的身份进入了公司服务器的网站。
脚本现在说
i
浏览 2提问于2019-10-04得票数 0
我正在尝试使用Python2.7和Paho MQTT 1.3.1将JSON数据推送到IBM Watson IoT平台。
它确实可以与IBM的IBM客户端一起工作，但是我的设备环境不允许这个扩展。
在测试时，我在IBM Watson IoT中禁用了TLS加密。
这是我的代码：
import json
import paho.mqtt.client as mqtt
client = mqtt.Client('d:ORG-ID:DEVICE-TYPE:DEVICE-ID')
client.username_pw_set('use-token-auth', '
浏览 3提问于2017-10-10得票数 0
我在运行一个简单的wsgi服务器，
from run import app
if __name__ == "__main__":
app.run(threaded=True, debug=True)
我用get请求访问服务器，服务器返回一条200条消息，但不返回任何数据。我收到以下错误消息
Error on request:
Traceback (most recent call last):
File "/Library/Python/2.7/site-packages/werkzeug/serving.py", line 209, in run
浏览 4提问于2017-11-20得票数 0
回答已采纳
2回答
我正在使用paho-mqtt从emqx代理接收数据，但我正在丢失数据，因为有时我的paho-mqtt订阅者会宕机。当我再次运行subscriber时，任何获取数据的方法都会给出所有已发布的数据。
浏览 88提问于2020-02-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
