Python中文
首页
教程
问答
标签
搜索
登录
注册
使用MQTT Python双向发布和订阅
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我目前有一个Python程序写在Raspberry pi3上,读取湿度和温度传感器的数据,并将这些数据发布到一个主题中。然后我可以用我的笔记本电脑接收这些数据。这是我的<strong>读取传感器数据并将其发布到Raspberry Pi中的主题的代码</strong>:</p> <pre><code>import RPi.GPIO as GPIO import time import json import Adafruit_DHT as dht import math import paho.mqtt.publish as publish import paho.mqtt.client as mqtt # Creating the JSON Objects dht22 = {} arduino = {} dht22Temp = [] dht22Hum = [] arduinoLED = [] dht22['temperature'] = dht22Temp dht22['humidity'] = dht22Hum dht22['sensor'] = 'DHT22' arduino['blink'] = arduinoLED arduino['actuator'] = 'arduinoLED' # Timing constants E_PULSE = 0.0005 E_DELAY = 0.0005 def main(): # Main program block while True: h, t = dht.read_retry(dht.DHT22, 17) //Reading humidity and temp data from GPIO17 t = round(t,2) h = round(h,2) if t > 25: if len(arduinoLED) == 3: arduinoLED.pop(0) arduinoLED.<a href="https://www.cnpython.com/list/append" class="inner-link">append</a>("true") else: arduinoLED.append("true") else: if len(arduinoLED) == 3: arduinoLED.pop(0) arduinoLED.append("false") else: arduinoLED.append("false") if len(dht22Temp) == 3: dht22Temp.pop(0) dht22Temp.append(t) else: dht22Temp.append(t) if len(dht22Hum) == 3: dht22Hum.pop(0) dht22Hum.append(h) else: dht22Hum.append(h) # lm35dzTemp.append(tempc) # Publishing sensor information by JSON converting object to a string publish.single("topic/sensorTemperature", json.dumps(dht22), hostname = "test.mosquitto.org") publish.single("topic/sensorTemperature", json.dumps(arduino), hostname = "test.mosquitto.org") # Printing JSON objects print(dht22) print(arduino) time.sleep(2) if __name__ == '__main__': try: main() except <a href="https://www.cnpython.com/pypi/keyboard" class="inner-link">keyboard</a>Interrupt: pass finally: GPIO.cleanup() </code></pre> <p>以下是我从笔记本电脑订阅和接收数据的代码:</strong></p> ^{pr2}$ <p>我现在想做的是从我的笔记本电脑上发布一些东西(也许是在与订阅服务器相同的代码中,或者是在一个单独的文件中,该文件只会将一条消息发布到同一个主题-<code>"topic/sensorTemperature"</code>)。但我的<strong>问题是:如何在我的Raspberry Pi(在我发布的第一个代码中)上发布和订阅消息?因为我是以无限循环的方式将消息发布到我的笔记本电脑上,所以我还需要一个无限循环来订阅相同(或不同的主题)来接收消息。如何同时运行其中两个循环?我需要两条不同的线吗?在</p> <p>谢谢。在</p>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>只需将来自<code>subscribing script</code>的代码放入<code>while True:</code>之前的<code>publishing script</code>,并将<code>loop_forever()</code>替换为{<cd5>}。当脚本在<code>GPIO.cleanup()</code>之前退出时,请使用<code>loop_stop()</code>。在</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
为什么在使用strptime时会出现未进行转换的数据错误?
6 回答
为什么在使用strptim时会出现这个datetime日期错误
2 回答
为什么在使用StyleFrame时索引列的标题不显示sf.至excel()?
3 回答
为什么在使用sum()函数时会发生“int”对象不可调用的错误?
8 回答
为什么在使用sympy.dsolve时会得到“'list'对象没有属性'func'”?
2 回答
为什么在使用tabla时会得到一个空的数据帧?
9 回答
为什么在使用tensorboard时需要add_graph()的第二个参数?
4 回答
为什么在使用TensorFlow Lite转换YOLOv4时,推断时间/大小没有改进?有什么可能的改进吗?
1 回答
为什么在使用Tensorflow加载训练批时会出现内存泄漏?
10 回答
为什么在使用tensorflow时会收到警告/错误(使用函数API,但未实现错误)
2 回答
为什么在使用tetpyclient发出POST请求时出现403错误?
2 回答
为什么在使用TextBlob时会出现HTTP错误?
1 回答
为什么在使用TFIDF时出现错误“IndexError:list index out of range”pyspark.ml.feature?
5 回答
为什么在使用timedelta格式化之后,我在python中的日期是错误的?
8 回答
为什么在使用timeit或exec函数时,函数中的变量不会在提供的全局命名空间中搜索?
2 回答
为什么在使用tkinter时不能使用复选框?
2 回答
为什么在使用todoistpythonapi时会返回这个奇怪的ID?
7 回答
为什么在使用TQM时,在调整图像大小时,处理时间会有很大的差异?
4 回答
为什么在使用Tweepy下载用户时间线时收到错误消息
5 回答
为什么在使用twitter帐户登录Django应用程序时重定向127.0.0.1:8000?
4 回答