本文章介紹Raspberry Pi Pico W 使用lwIP MQTT Client 透過手機設定Pico W 上的WS2812 LED燈條展示方式。
- 顯示時鐘。
- 警示閃光。
- 隨機顏色、燈數與方向。
- 固定顏色、燈數與方向。
一、pico-sdk加入MQTT library:
pico-sdk(1.4)未將lwip MQTT client application llibrary加入，為了使用lwIP MQTT Client library修正下列檔案加入MQTT Client library。
（註：Pico SDK 1.5.0 已經加入了）
pico-sdk/src/rp2-common/pico_lwip/CMakeLists.txt:
#MQTT
add_library(pico_lwip_mqtt INTERFACE)
target_sources(pico_lwip_mqtt INTERFACE
${PICO_LWIP_PATH}/src/apps/mqtt/mqtt.c
)
如下圖所示：
在project CMakeLists.txt加入pico_lwip_mqtt library。
二、WS2812 LED燈條：
根據Datasheet每個bit 0 & 1 timer，使用raspberry Pi Pico PIO的時間如下圖：
WS2812的 Send data at speeds of 800Kbps. PIO clock如下設定。
ws2812_program_init(pio, sm, WS2812_PIN, 800000);
三、lwIP MQTT Clinet Appliction:
Subscribe API:
mqtt_sub_unsub(): subscribe or unsubscribe MQTT topic。
mqtt_set_inpub_callback():設定callback function，接收subscribe的topic＆message。
mqtt_incoming_publish_cb_t: callback function 接收topic 與total length。
mqtt_incoming_data_cb_t: callback funcion 接收subscibe data。
Publish API:
mqtt_publish(): publish a topic message。
Connection API:
mqtt_client_connect(): connect to MQTT server。設定connected callback。
mqtt_connection_cb_t: connect callback function，mqtt_connection_status_t 參數為連線狀態。
四、MQTT Server ＆ Node-RED
請參閱下列連結進一步說明：
- MQTT 簡介：使用Mosquitto Broker
- 使用NODE-RED Dashboard 以MQTT訊息驅動來控制MCU上的感應器或設備(Controlling MCU/Sensor/Device with Node-RED Dashboard via MQTT)
- Node-RED 進階使用筆記
Node-RED Flow:
五、成果影片：
六、程式碼：
- Pi Pico W
#include <stdio.h> #include "pico/stdlib.h" #include "hardware/pio.h" #include "pico/cyw43_arch.h" #include "hardware/rtc.h" #include "lwip/apps/mqtt.h" #include "ws2812.pio.h" #include "hardware/clocks.h" #include "ntp_time.h" #include "cJSON.h" #define WIFI_SSID "your_SSID" #define WIFI_PASSWORD "your_PASSWORD" typedef struct MQTT_CLIENT_DATA_T_ { mqtt_client_t* mqtt_client_inst; struct mqtt_connect_client_info_t mqtt_client_info; uint8_t data[MQTT_OUTPUT_RINGBUF_SIZE]; uint8_t topic[100]; uint32_t len; bool playing; bool newTopic; } MQTT_CLIENT_DATA_T; MQTT_CLIENT_DATA_T *mqtt; struct mqtt_connect_client_info_t mqtt_client_info= { "ws2812", NULL, /* user */ NULL, /* pass */ 0, /* keep alive */ NULL, /* will_topic */ NULL, /* will_msg */ 0, /* will_qos */ 0 /* will_retain */ #if LWIP_ALTCP && LWIP_ALTCP_TLS , NULL #endif }; #define NUM_PIXELS 60 #define WS2812_PIN 16 #define green 0xff0000 #define red 0x00ff00 #define blue 0x0000ff uint32_t color_pixel[NUM_PIXELS]; repeating_timer_t colok_timer; static inline void ws2812_program_init(PIO pio, uint sm, uint pin, float freq) { pio_gpio_init(pio, pin); pio_sm_set_consecutive_pindirs(pio, sm, pin, 1, true); uint offset = pio_add_program(pio, &ws2812_program); pio_sm_config c = ws2812_program_get_default_config(offset); sm_config_set_sideset_pins(&c, pin); sm_config_set_out_shift(&c, false, true, 24); sm_config_set_fifo_join(&c, PIO_FIFO_JOIN_TX); int cycles_per_bit = ws2812_T1 + ws2812_T2 *2; float div = clock_get_hz(clk_sys) / (freq * cycles_per_bit); sm_config_set_clkdiv(&c, div); pio_sm_init(pio, sm, offset, &c); pio_sm_set_enabled(pio, sm, true); } static inline void put_pixel(uint32_t pixel_grb) { pio_sm_put_blocking(pio0, 0, pixel_grb << 8u); } static inline uint32_t urgb_u32(uint8_t r, uint8_t g, uint8_t b) { return ((uint32_t) (r) << 8) | ((uint32_t) (g) << 16) | (uint32_t) (b); } void wait_connecting() { for (int i = 0; i < NUM_PIXELS; i++) put_pixel(red); } void clear_pixel() { for (int i = 0; i < NUM_PIXELS; i++) put_pixel(0x000000); } void connected() { for (int i = 0; i < NUM_PIXELS; i++) put_pixel(green); } void random_pixel(uint8_t color_index, uint len, int dir, uint32_t color, uint8_t speed) { static uint t=0; while(mqtt->playing) { if (len > NUM_PIXELS) len = NUM_PIXELS; for (int i=0; i < NUM_PIXELS; i++) color_pixel[i] = 0x000000; // reset all pixel for (int i = t; i < (t+len);++i) { switch (color_index) { case 1: color_pixel[(i)%NUM_PIXELS]=color; break; case 2: color_pixel[(i)%NUM_PIXELS] = (rand()); break; } } for (int i = 0; i < NUM_PIXELS; i++) put_pixel(color_pixel[i]); t = (t+dir+NUM_PIXELS) % NUM_PIXELS; sleep_ms(10*speed); } clear_pixel(); } bool repeat_timer_cb(repeating_timer_t *rt) { static datetime_t dt; rtc_get_datetime(&dt); for (int i=0; i < NUM_PIXELS; i++) color_pixel[i]=0x000000; color_pixel[(dt.hour%12)*5] |= green; color_pixel[dt.min] |= blue; color_pixel[dt.sec] |= red; for (int i=0; i < NUM_PIXELS; i++) put_pixel(color_pixel[i]); return true; } void sparkle() { while(mqtt->playing) { for (int i = 0; i < NUM_PIXELS; ++i) put_pixel(rand() % 32 ? 0 : 0xffffffff); sleep_ms(10); } } void ws2812_action() { cancel_repeating_timer(&colok_timer); cJSON* json_obj = cJSON_CreateObject(); json_obj = cJSON_Parse(mqtt->data); uint8_t *type = cJSON_GetStringValue(cJSON_GetObjectItem(json_obj, "type")); uint8_t speed = 11-(uint8_t)cJSON_GetNumberValue(cJSON_GetObjectItem(json_obj, "speed")); uint8_t length = (uint8_t)cJSON_GetNumberValue(cJSON_GetObjectItem(json_obj, "length")); int8_t dir = (int8_t)cJSON_GetNumberValue(cJSON_GetObjectItem(json_obj, "dir")); uint8_t *colorstr = (cJSON_GetStringValue(cJSON_GetObjectItem(json_obj, "color"))); uint32_t color=strtoul(colorstr,NULL, 16); color = (color&0xff0000) >> 8 | (color&0x00ff00) << 8 | color &0x0000ff; if (strcmp(type, "clock") == 0) { mqtt->playing=true; add_repeating_timer_ms(-1000, repeat_timer_cb, NULL, &colok_timer); } if (strcmp(type, "sparkle") == 0) { mqtt->playing=true; sparkle(); } if (strcmp(type, "randomcolor") == 0) { mqtt->playing=true; random_pixel(2,length,dir,0x000000,speed);//// } if (strcmp(type, "pixelcolor") == 0) { mqtt->playing=true; random_pixel(1,length,dir,color,speed);//// } cJSON_Delete(json_obj); } void ws2812_stop() { mqtt->playing=false; } static void mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t flags) { MQTT_CLIENT_DATA_T* mqtt_client = (MQTT_CLIENT_DATA_T*)arg; LWIP_UNUSED_ARG(data); strncpy(mqtt_client->data, data, len); mqtt_client->len=len; mqtt_client->data[len]='\0'; mqtt_client->newTopic=true; mqtt->playing=false; } static void mqtt_incoming_publish_cb(void *arg, const char *topic, u32_t tot_len) { MQTT_CLIENT_DATA_T* mqtt_client = (MQTT_CLIENT_DATA_T*)arg; strcpy(mqtt_client->topic, topic); } static void mqtt_request_cb(void *arg, err_t err) { MQTT_CLIENT_DATA_T* mqtt_client = ( MQTT_CLIENT_DATA_T*)arg; LWIP_PLATFORM_DIAG(("MQTT client \"%s\" request cb: err %d\n", mqtt_client->mqtt_client_info.client_id, (int)err)); } static void mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t status) { MQTT_CLIENT_DATA_T* mqtt_client = (MQTT_CLIENT_DATA_T*)arg; LWIP_UNUSED_ARG(client); LWIP_PLATFORM_DIAG(("MQTT client \"%s\" connection cb: status %d\n", mqtt_client->mqtt_client_info.client_id, (int)status)); if (status == MQTT_CONNECT_ACCEPTED) { mqtt_sub_unsub(client, "start", 0, mqtt_request_cb, arg, 1); mqtt_sub_unsub(client, "stop", 0, mqtt_request_cb, arg, 1); } } int main() { stdio_init_all(); PIO pio = pio0; int sm = 0; ws2812_program_init(pio, sm, WS2812_PIN, 800000); mqtt=(MQTT_CLIENT_DATA_T*)calloc(1, sizeof(MQTT_CLIENT_DATA_T)); if (!mqtt) { printf("mqtt client instant ini error\n"); return 0; } mqtt->playing=false; mqtt->newTopic=false; mqtt->mqtt_client_info = mqtt_client_info; if (cyw43_arch_init()) { printf("failed to initialise\n"); return 1; } wait_connecting(); cyw43_arch_enable_sta_mode(); if (cyw43_arch_wifi_connect_timeout_ms(WIFI_SSID, WIFI_PASSWORD, CYW43_AUTH_WPA2_AES_PSK, 30000)) { printf("failed to connect\n"); return 1; } ntp_time_init(); get_ntp_time(); ip_addr_t addr; if (!ip4addr_aton("your_MQTT_SERVER_IP", &addr)) { printf("ip error\n"); return 0; } mqtt->mqtt_client_inst = mqtt_client_new(); mqtt_set_inpub_callback(mqtt->mqtt_client_inst, mqtt_incoming_publish_cb, mqtt_incoming_data_cb, mqtt); err_t err = mqtt_client_connect(mqtt->mqtt_client_inst, &addr, MQTT_PORT, &mqtt_connection_cb, mqtt, &mqtt->mqtt_client_info); if (err != ERR_OK) { printf("connect error\n"); return 0; } connected(); while(1) { if (mqtt->newTopic) { mqtt->newTopic=false; if (strcmp(mqtt->topic, "start")==0) { ws2812_action(); } if (strcmp(mqtt->topic, "stop")==0) { ws2812_stop(); } } } return 0; }
- Node-RED flow
[ { "id": "6e21089b48879905", "type": "tab", "label": "Flow 1", "disabled": false, "info": "", "env": [] }, { "id": "27103af5cfb31338", "type": "function", "z": "6e21089b48879905", "name": "function 1", "func": "var newmsg={};\n\nif (msg.payload == \"clock\" || msg.payload == \"sparkle\") {\n newmsg.payload = {\n \"group\":\n {\n \"hide\": [\"WS2812_SCROOLCOLOR\", \"WS2812_SLIDEPARAM\"]\n }\n };\n} else {\n if (msg.payload==\"pixelcolor\") {\n newmsg.payload = {\n \"group\":\n {\n \"show\": [\"WS2812_SCROOLCOLOR\",\"WS2812_SLIDEPARAM\"]\n }\n };\n } else {\n newmsg.payload = {\n \"group\":\n {\n \"hide\": [\"WS2812_SCROOLCOLOR\"], \"show\":[\"WS2812_SLIDEPARAM\"]\n }\n };\n }\n}\n\n\nreturn newmsg", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 320, "y": 40, "wires": [ [ "700d3dc46fdd7924" ] ] }, { "id": "dbe22a0817d2347d", "type": "ui_dropdown", "z": "6e21089b48879905", "name": "", "label": "Dispaly Type:", "tooltip": "", "place": "Select option", "group": "82089b24e7a5068c", "order": 1, "width": 5, "height": 1, "passthru": false, "multiple": false, "options": [ { "label": "Clock", "value": "clock", "type": "str" }, { "label": "Sparkle", "value": "sparkle", "type": "str" }, { "label": "Pixel Color", "value": "pixelcolor", "type": "str" }, { "label": "Random Color", "value": "randomcolor", "type": "str" } ], "payload": "", "topic": "type", "topicType": "msg", "className": "", "x": 120, "y": 80, "wires": [ [ "27103af5cfb31338", "1272075b2d61d0ce" ] ] }, { "id": "700d3dc46fdd7924", "type": "ui_ui_control", "z": "6e21089b48879905", "name": "", "events": "all", "x": 480, "y": 40, "wires": [ [] ] }, { "id": "5a66ec42f68bd5aa", "type": "ui_slider", "z": "6e21089b48879905", "name": "", "label": "speed", "tooltip": "", "group": "f72a2a2a55f0b438", "order": 4, "width": 0, "height": 0, "passthru": false, "outs": "end", "topic": "topic", "topicType": "msg", "min": "1", "max": 10, "step": 1, "className": "", "x": 90, "y": 220, "wires": [ [ "50b09b338cf91909" ] ] }, { "id": "ca0b6363716ad933", "type": "ui_slider", "z": "6e21089b48879905", "name": "", "label": "Pixels#", "tooltip": "", "group": "f72a2a2a55f0b438", "order": 3, "width": 0, "height": 0, "passthru": false, "outs": "end", "topic": "topic", "topicType": "msg", "min": "1", "max": "59", "step": 1, "className": "", "x": 100, "y": 180, "wires": [ [ "08d9446473a7a2f2" ] ] }, { "id": "ddb42afe82963199", "type": "ui_colour_picker", "z": "6e21089b48879905", "name": "", "label": "", "group": "ff7916db92ed582e", "format": "hex", "outformat": "string", "showSwatch": true, "showPicker": false, "showValue": true, "showHue": false, "showAlpha": false, "showLightness": true, "square": "false", "dynOutput": "false", "order": 2, "width": 0, "height": 0, "passthru": false, "topic": "topic", "topicType": "msg", "className": "", "x": 110, "y": 360, "wires": [ [ "586673b8704f4617" ] ] }, { "id": "d5e936d54e6a819b", "type": "ui_text", "z": "6e21089b48879905", "group": "ff7916db92ed582e", "order": 1, "width": 0, "height": 0, "name": "", "label": "Pick Color", "format": "", "layout": "col-center", "className": "", "x": 110, "y": 320, "wires": [] }, { "id": "3a36f74e374bc0ab", "type": "ui_text", "z": "6e21089b48879905", "group": "f72a2a2a55f0b438", "order": 1, "width": 0, "height": 0, "name": "", "label": "Select the number of Pixels and speed", "format": "{{msg.payload}}", "layout": "col-center", "className": "", "x": 190, "y": 140, "wires": [] }, { "id": "50b09b338cf91909", "type": "change", "z": "6e21089b48879905", "name": "", "rules": [ { "t": "move", "p": "payload", "pt": "msg", "to": "speed", "tot": "flow" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 270, "y": 220, "wires": [ [] ] }, { "id": "08d9446473a7a2f2", "type": "change", "z": "6e21089b48879905", "name": "", "rules": [ { "t": "move", "p": "payload", "pt": "msg", "to": "length", "tot": "flow" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 270, "y": 180, "wires": [ [] ] }, { "id": "586673b8704f4617", "type": "change", "z": "6e21089b48879905", "name": "", "rules": [ { "t": "move", "p": "payload", "pt": "msg", "to": "color", "tot": "flow" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 310, "y": 360, "wires": [ [] ] }, { "id": "08a77a34f56dd819", "type": "ui_button", "z": "6e21089b48879905", "name": "", "group": "e5d38edfd552806e", "order": 1, "width": 2, "height": 1, "passthru": false, "label": "Start", "tooltip": "", "color": "", "bgcolor": "", "className": "", "icon": "", "payload": "", "payloadType": "str", "topic": "topic", "topicType": "msg", "x": 90, "y": 420, "wires": [ [ "32bc237d4be9a18c" ] ] }, { "id": "32bc237d4be9a18c", "type": "function", "z": "6e21089b48879905", "name": "function 2", "func": "msg.payload={};\nmsg.payload.type=flow.get(\"type\") || \"\";\nmsg.payload.speed = flow.get(\"speed\") || 1;\nmsg.payload.length = flow.get(\"length\") || 1;\nmsg.payload.color = flow.get('color') || 0x000000;\nmsg.payload.dir = flow.get(\"dir\") || 1;\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 240, "y": 420, "wires": [ [ "03cebb9c7b1959d8" ] ] }, { "id": "1272075b2d61d0ce", "type": "change", "z": "6e21089b48879905", "name": "", "rules": [ { "t": "move", "p": "payload", "pt": "msg", "to": "type", "tot": "flow" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 330, "y": 100, "wires": [ [] ] }, { "id": "d98476ae54d711de", "type": "ui_button", "z": "6e21089b48879905", "name": "", "group": "e5d38edfd552806e", "order": 2, "width": 2, "height": 1, "passthru": false, "label": "Stop", "tooltip": "", "color": "", "bgcolor": "", "className": "", "icon": "", "payload": "", "payloadType": "str", "topic": "topic", "topicType": "msg", "x": 90, "y": 480, "wires": [ [ "f82aa1487c39a9cb" ] ] }, { "id": "d84ae8a0e6a9e047", "type": "mqtt out", "z": "6e21089b48879905", "name": "", "topic": "", "qos": "", "retain": "", "respTopic": "", "contentType": "", "userProps": "", "correl": "", "expiry": "", "broker": "466c902492653c8c", "x": 590, "y": 480, "wires": [] }, { "id": "03cebb9c7b1959d8", "type": "json", "z": "6e21089b48879905", "name": "", "property": "payload", "action": "", "pretty": false, "x": 370, "y": 420, "wires": [ [ "f31a49d4d4727859" ] ] }, { "id": "f82aa1487c39a9cb", "type": "function", "z": "6e21089b48879905", "name": "function 3", "func": "msg.topic=\"stop\";\nmsg.payload=\"stop\";\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 280, "y": 480, "wires": [ [ "d84ae8a0e6a9e047" ] ] }, { "id": "f31a49d4d4727859", "type": "function", "z": "6e21089b48879905", "name": "function 4", "func": "msg.topic=\"start\";\n\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 520, "y": 420, "wires": [ [ "d84ae8a0e6a9e047" ] ] }, { "id": "9edca29e76cc4a35", "type": "ui_dropdown", "z": "6e21089b48879905", "name": "", "label": "Direction", "tooltip": "", "place": "", "group": "f72a2a2a55f0b438", "order": 2, "width": 0, "height": 0, "passthru": true, "multiple": false, "options": [ { "label": "clockwise", "value": 1, "type": "num" }, { "label": "counterclockwise", "value": "-1", "type": "str" } ], "payload": "", "topic": "topic", "topicType": "msg", "className": "", "x": 100, "y": 260, "wires": [ [ "ed2d4290fb55a4bc" ] ] }, { "id": "ed2d4290fb55a4bc", "type": "change", "z": "6e21089b48879905", "name": "", "rules": [ { "t": "move", "p": "payload", "pt": "msg", "to": "dir", "tot": "flow" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 270, "y": 260, "wires": [ [] ] }, { "id": "104b1503d903372c", "type": "ui_spacer", "z": "6e21089b48879905", "name": "spacer", "group": "82089b24e7a5068c", "order": 2, "width": 1, "height": 1 }, { "id": "7783de4639450be7", "type": "ui_spacer", "z": "6e21089b48879905", "name": "spacer", "group": "e5d38edfd552806e", "order": 3, "width": 2, "height": 1 }, { "id": "82089b24e7a5068c", "type": "ui_group", "name": "Default", "tab": "8caf46a96fa73472", "order": 1, "disp": false, "width": 6, "collapse": false, "className": "" }, { "id": "f72a2a2a55f0b438", "type": "ui_group", "name": "SLIDEPARAM", "tab": "8caf46a96fa73472", "order": 2, "disp": false, "width": "5", "collapse": false, "className": "" }, { "id": "ff7916db92ed582e", "type": "ui_group", "name": "SCROOLCOLOR", "tab": "8caf46a96fa73472", "order": 3, "disp": false, "width": "5", "collapse": false, "className": "" }, { "id": "e5d38edfd552806e", "type": "ui_group", "name": "Buttons", "tab": "8caf46a96fa73472", "order": 5, "disp": false, "width": 6, "collapse": false, "className": "" }, { "id": "466c902492653c8c", "type": "mqtt-broker", "name": "mosquitto", "broker": "localhost", "port": "1883", "clientid": "", "autoConnect": true, "usetls": false, "protocolVersion": "4", "keepalive": "60", "cleansession": true, "birthTopic": "", "birthQos": "0", "birthPayload": "", "birthMsg": {}, "closeTopic": "", "closeQos": "0", "closePayload": "", "closeMsg": {}, "willTopic": "", "willQos": "0", "willPayload": "", "willMsg": {}, "userProps": "", "sessionExpiry": "", "credentials": {} }, { "id": "8caf46a96fa73472", "type": "ui_tab", "name": "WS2812", "icon": "dashboard", "disabled": false, "hidden": true } ]
沒有留言:
張貼留言