micropython 问题

yc0526vip

@fishc
micro python ssd1306接收mqtt消息，超过16个字符自动换行，不停循环从下到上滚动显示，mqtt接收消息"ting",停止循环。

FishC

首先，我们需要确保你已经成功将MicroPython固件烧录到你的设备上，并且已经正确连接了SSD1306 OLED显示屏和MQTT消息服务器。接下来，我们可以编写一段代码来实现你所描述的功能。

1. import time
   
2. from machine import Pin, I2C
   
3. from ssd1306 import SSD1306_I2C
   
4. from umqtt.simple import MQTTClient
   
5. 
   
6. # 设置SSD1306 OLED的相关参数
   
7. OLED_WIDTH = 128
   
8. OLED_HEIGHT = 64
   
9. OLED_ADDR = 0x3c
   
10. 
    
11. # 设置MQTT连接参数
    
12. MQTT_BROKER = "your_mqtt_broker_ip"
    
13. MQTT_TOPIC = "your_mqtt_topic"
    
14. MQTT_CLIENT_ID = "your_mqtt_client_id"
    
15. 
    
16. 
    
17. def scroll_display(oled, text):
    
18.     # 清空显示屏
    
19.     oled.fill(0)
    
20.    
    
21.     # 将超长文本拆分成多行
    
22.     rows = []
    
23.     while len(text) > OLED_WIDTH:
    
24.         rows.append(text[:OLED_WIDTH])
    
25.         text = text[OLED_WIDTH:]
    
26.     rows.append(text)
    
27.    
    
28.     # 逐行显示并滚动
    
29.     for i in range(OLED_HEIGHT // 8):
    
30.         oled.text(rows[i % len(rows)], 0, i * 8)
    
31.    
    
32.     # 更新显示
    
33.     oled.show()
    
34. 
    
35. 
    
36. def mqtt_callback(topic, msg):
    
37.     global running
    
38.     message = msg.decode()
    
39.     if message == "ting":
    
40.         running = False
    
41.     else:
    
42.         scroll_display(oled, message)
    
43. 
    
44. 
    
45. # 初始化I2C总线和OLED显示屏对象
    
46. i2c = I2C(scl=Pin(5), sda=Pin(4))
    
47. oled = SSD1306_I2C(OLED_WIDTH, OLED_HEIGHT, i2c, addr=OLED_ADDR)
    
48. 
    
49. # 连接MQTT服务器
    
50. client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER)
    
51. client.set_callback(mqtt_callback)
    
52. client.connect()
    
53. client.subscribe(MQTT_TOPIC)
    
54. 
    
55. # 循环接收消息并显示
    
56. running = True
    
57. while running:
    
58.     client.check_msg()
    
59.     # 可以加入其他任务的代码
    
60. 
    
61. # 断开MQTT连接
    
62. client.disconnect()

复制代码

在这段代码中，我们使用`scroll_display`函数来实现文本的分行显示和滚动功能。当接收到MQTT消息时，我们会调用`scroll_display`函数来更新显示屏的内容。如果接收到消息为"ting"，则停止循环，并退出程序。

请注意，在使用此代码前，你需要根据你的具体情况修改MQTT服务器的IP地址、主题、客户端ID以及SSD1306 OLED显示屏的相关参数。

希望这个代码能够帮助到你！祝你编程愉快！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

yc0526vip

FishC 发表于 2024-1-1 00:08
首先，我们需要确保你已经成功将MicroPython固件烧录到你的设备上，并且已经正确连接了SSD1306 OLED显示屏 ...

换个方案

FishC

yc0526vip 发表于 2024-01-01 00:12
换个方案

当然，我们可以尝试使用另一种方案来实现你的需求。在这种方案中，我们将利用Python内置的字符串处理方法和计时器功能来实现文字滚动效果。

1. import time
   
2. from machine import Pin, I2C
   
3. from ssd1306 import SSD1306_I2C
   
4. from umqtt.simple import MQTTClient
   
5. 
   
6. # 设置SSD1306 OLED的相关参数
   
7. OLED_WIDTH = 128
   
8. OLED_HEIGHT = 64
   
9. OLED_ADDR = 0x3c
   
10. 
    
11. # 设置MQTT连接参数
    
12. MQTT_BROKER = "your_mqtt_broker_ip"
    
13. MQTT_TOPIC = "your_mqtt_topic"
    
14. MQTT_CLIENT_ID = "your_mqtt_client_id"
    
15. 
    
16. def scroll_display(oled, text):
    
17.     # 清空显示屏
    
18.     oled.fill(0)
    
19.    
    
20.     # 计算每一行显示的起始位置
    
21.     start_positions = [0] * (OLED_HEIGHT // 8)
    
22.     for i in range(len(start_positions)):
    
23.         start_positions[i] = max(0, len(text) - (OLED_WIDTH // 6)) * (i + 1) // (OLED_HEIGHT // 8)
    
24. 
    
25.     # 逐行显示
    
26.     for i in range(OLED_HEIGHT // 8):
    
27.         start_pos = start_positions[i]
    
28.         end_pos = start_pos + (OLED_WIDTH // 6)
    
29.         row_text = text[start_pos:end_pos]
    
30.         oled.text(row_text, 0, i * 8)
    
31.    
    
32.     # 更新显示
    
33.     oled.show()
    
34. 
    
35. def mqtt_callback(topic, msg):
    
36.     global running
    
37.     message = msg.decode()
    
38.     if message == "ting":
    
39.         running = False
    
40.     else:
    
41.         scroll_display(oled, message)
    
42. 
    
43. # 初始化I2C总线和OLED显示屏对象
    
44. i2c = I2C(scl=Pin(5), sda=Pin(4))
    
45. oled = SSD1306_I2C(OLED_WIDTH, OLED_HEIGHT, i2c, addr=OLED_ADDR)
    
46. 
    
47. # 连接MQTT服务器
    
48. client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER)
    
49. client.set_callback(mqtt_callback)
    
50. client.connect()
    
51. client.subscribe(MQTT_TOPIC)
    
52. 
    
53. # 循环接收消息并显示
    
54. running = True
    
55. while running:
    
56.     client.check_msg()
    
57.     # 可以加入其他任务的代码
    
58.    
    
59.     # 滚动显示效果
    
60.     for _ in range(5):  # 控制滚动速度
    
61.         for _ in range(6):  # 每次滚动一个像素的距离
    
62.             oled.scroll(0, -1)
    
63.             oled.show()
    
64.             time.sleep(0.05)
    
65.         time.sleep(0.1)
    
66. 
    
67. # 断开MQTT连接
    
68. client.disconnect()

复制代码

在这个改进方案中，我们使用`scroll`方法来实现文本的滚动效果，通过控制滚动速度和滚动的像素数来调整滚动效果的流畅度。希望这个新方案能够满足你的需求，祝你编程愉快！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。

yc0526vip

FishC 发表于 2024-1-1 00:12
当然，我们可以尝试使用另一种方案来实现你的需求。在这种方案中，我们将利用Python内置的字符串处理方 ...

micro python 多个线程方法，ssd1306接收mqtt消息，超过16个字符自动换行，上下滚动显示，mqtt消息小于3个字符时，停止循环。

FishC

yc0526vip 发表于 2024-01-01 00:15
micro python 多个线程方法，ssd1306接收mqtt消息，超 ...

在MicroPython中，可以使用`_thread`模块创建多个线程来实现并发执行的功能。下面是一个示例代码，展示如何使用多线程来实现SSD1306 OLED接收MQTT消息并滚动显示的功能：import timeimport _threadfrom machine import Pin, I2Cfrom ssd1306 import SSD1306_I2Cfrom umqtt.simple import MQTTClient# 设置SSD1306 OLED的相关参数OLED_WIDTH = 128OLED_HEIGHT = 64OLED_ADDR = 0x3c# 设置MQTT连接参数MQTT_BROKER = "your_mqtt_broker_ip"MQTT_TOPIC = "your_mqtt_topic"MQTT_CLIENT_ID = "your_mqtt_client_id"# 创建全局变量，用于控制循环运行running = True# 设置互斥锁，用于保证同时只有一个线程能够操作OLED显示屏lock = _thread.allocate_lock()def scroll_display(oled, text):    # 清空显示屏    with lock:        oled.fill(0)        # 将超过16字符的消息进行换行        if len(text) > 16:            rows = []            while len(text) > OLED_WIDTH:                rows.append(text[:OLED_WIDTH])                text = text[OLED_WIDTH:]            rows.append(text)        else:            rows = [text]        # 上下滚动显示        for i in range(len(rows) + OLED_HEIGHT // 8):            with lock:                oled.fill(0)                for j in range(min(len(rows), OLED_HEIGHT // 8)):                    oled.text(rows[j], 0, (i + j) * 8)                oled.show()            time.sleep(0.1)# MQTT回调函数def mqtt_callback(topic, msg):    global running    message = msg.decode()    if len(message) < 3:        running = False    else:        scroll_display(oled, message)# 初始化I2C总线和OLED显示屏对象i2c = I2C(scl=Pin(5), sda=Pin(4))oled = SSD1306_I2C(OLED_WIDTH, OLED_HEIGHT, i2c, addr=OLED_ADDR)# 连接MQTT服务器client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER)client.set_callback(mqtt_callback)client.connect()client.subscribe(MQTT_TOPIC)# 启动OLED显示线程def oled_thread():    while running:        with lock:            oled.scroll(0, -1)            oled.show()        time.sleep(0.05)# 启动MQTT接收线程def mqtt_thread():    while running:        client.check_msg()        time.sleep(0.1)# 创建并启动多个线程_thread.start_new_thread(oled_thread, ())_thread.start_new_thread(mqtt_thread, ())# 主线程等待循环结束while running:    pass# 断开MQTT连接client.disconnect()在这个示例代码中，我们使用了两个线程，一个用于处理SSD1306 OLED屏幕的显示，另一个用于接收MQTT消息。主线程检测到消息长度小于3时会将全局变量`running`设置为False以停止循环。同时，我们使用一个互斥锁`lock`来保护对OLED屏幕的操作，确保在同一时间只有一个线程能够对其进行操作。你可以根据需要进行调整和扩展。希望对你有所帮助，祝你编程愉快！

以上回复来自 FishC AI 小助理，如未能正确解答您的问题，请继续追问。