物联网技术与应用：智能家居与智慧城市

    import paho.mqtt.client as mqtt
    
    # MQTT服务器地址
    broker = "mqtt.eclipse.org"
    # 智能灯泡的主题
    topic = "home/livingroom/light"
    
    # 当与MQTT服务器的连接建立后，该函数被调用
    def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅智能灯泡的主题
    client.subscribe(topic)
    
    # 当接收到MQTT消息时，该函数被调用
    def on_message(client, userdata, msg):
    print(f"Received message: {msg.payload.decode()} on topic {msg.topic}")
    # 根据接收到的消息控制智能灯泡
    if msg.payload.decode() == "on":
        print("Turning on the light")
        # 这里可以添加实际控制智能灯泡的代码
    elif msg.payload.decode() == "off":
        print("Turning off the light")
        # 这里可以添加实际控制智能灯泡的代码
    
    # 创建MQTT客户端实例
    client = mqtt.Client()
    
    # 绑定连接和消息回调函数
    client.on_connect = on_connect
    client.on_message = on_message
    
    # 连接到MQTT服务器
    client.connect(broker, 1883, 60)
    
    # 开启循环，等待消息
    client.loop_forever()
    
    
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
    

    import random
    import time
    
    # 模拟交通流量数据
    def generate_traffic_data():
    return random.randint(0, 100)  # 随机生成0到100之间的交通流量数据
    
    # 交通流量监测主函数
    def traffic_monitoring():
    while True:
        traffic_data = generate_traffic_data()
        print(f"Current traffic flow: {traffic_data}")
        # 这里可以添加将交通流量数据发送到云平台或进行进一步处理的代码
        time.sleep(5)  # 每5秒更新一次数据
    
    # 运行交通流量监测
    traffic_monitoring()