C 開發筆記 - 使用 libwebsockets 製作簡易的 WebSocket Client

已經有用過 Golang 開發小工具，以及其他現成工具如 websocat 等，做 WebSocket Server 的測試。這次回過頭來再仔細看看 libwebsockets 這套，寫一點 C 語言。

程式架構不會太難，比較難的反而是一些小東西，像是跟 ws.ptt.cc 連線時，PTT 會做 Request Header（Origin欄位) 檢查，當作簡單的管控，然而 libwebsockets 則是要設定  LWS_SERVER_OPTION_JUST_USE_RAW_ORIGIN 才能不加料 XD

#include <include/libwebsockets/lws-context-vhost.h>

For backwards-compatibility reasons, by default lws prepends "http://" to the origin you give in the client connection info struct. If you give this flag when you create the context, only the string you give in the client connect info for .origin (if any) will be used directly.

大概在這種地方耗掉半小時以上。另外，還有做 wss 連線時，也須設定 LWS_SERVER_OPTION_DO_SSL_GLOBAL_INIT 等等，以及如果想要略過 wss 的 SSL 憑證檢查，有滿多設定項目可以試試：LCCSCF_USE_SSL | LCCSCF_ALLOW_SELFSIGNED | LCCSCF_SKIP_SERVER_CERT_HOSTNAME_CHECK | LCCSCF_ALLOW_INSECURE;

其他則是依照 libwebsockets 的架構，要設計連線時的 callback 處理機制，算是體驗了一下。未來就多一個 C 語言工具可以做 WebSocket Server 連線測試。

完整的程式碼：github.com/changyy/study-libwebsockets-client

常見的錯誤訊息：

• E: SSL_new failed: error:00000063:lib(0)::reason(99)
• W: [wsicli|0|WS/h1/default/ws.ptt.cc]: lws_client_ws_upgrade: got bad HTTP response '403'
• E: lws_ssl_client_bio_create: Unable to get hostname

執行 logs：

% make

gcc -g -Wall main.c `pkg-config libwebsockets --libs --cflags`

% ./a.out   

Usage> ./a.out url

./a.out ws://localhost:8000/

./a.out wss://ws.ptt.cc/bbs app://cmd

./a.out wss://ws.ptt.cc/bbs https://term.ptt.cc

% ./a.out wss://ws.ptt.cc/bbs https://term.ptt.cc

[2022/08/25 20:45:29:8530] N: lws_create_context: LWS: 4.3.2-no_hash, NET CLI SRV H1 H2 WS ConMon IPV6-on

[2022/08/25 20:45:29:8539] N: __lws_lc_tag:  ++ [wsi|0|pipe] (1)

[2022/08/25 20:45:29:8964] N: __lws_lc_tag:  ++ [vh|0|default||-1] (1)

wsCallback - LWS_CALLBACK_OPENSSL_LOAD_EXTRA_CLIENT_VERIFY_CERTS

[INFO] libwebsockets version: 4.3.2

[INFO] lws_parse_uri - Server: ws.ptt.cc:443

[INFO] lws_parse_uri - URLScheme: wss

[INFO] lws_parse_uri - URLPath: bbs

[INFO] clientConnectInfo.addres: ws.ptt.cc

[INFO] clientConnectInfo.port: 443

[INFO] clientConnectInfo.path: /bbs

[INFO] clientConnectInfo.host: ws.ptt.cc

[INFO] clientConnectInfo.origin: https://term.ptt.cc

[INFO] clientConnectInfo.ssl_connection: 109

[2022/08/25 20:45:29:9789] N: __lws_lc_tag:  ++ [wsicli|0|WS/h1/default/ws.ptt.cc] (1)

call lws_client_connect_via_info done, webSocket is NULL(NO)

noop

[2022/08/25 20:45:30:0229] N: lws_gate_accepts: on = 0

[2022/08/25 20:45:30:0575] N: lws_gate_accepts: on = 0

wsCallback - LWS_CALLBACK_CLIENT_ESTABLISHED

wsCallback - LWS_CALLBACK_CLIENT_WRITEABLE

wsCallback - LWS_CALLBACK_CLIENT_RECEIVE

RECEIVER: HTTP/1.1 200 OK

     ??      PTT                ?P   ??        ?P  ??      ???i?i?i?i?i?i??

             140.112.172.11 ?P     ???i???i??            ???i?i?i?i?i

  ?z?w?{     ?????~?{        ???d?i?i???i??   ?P   ???i?i?i?i?i??  ?P

  ?x?V?|?{   ptt.cc            ???i?i?i?i?i???i??    ???i?i?i?i?i

  ?x?V  ?x                   ???i?i?i???i?i?i????  ???i?i?i?i?i??  ??  ?P

?w?}    ?x?z?w?w?{  ?P       ????      ?i?i?i?i?????i?i?i?i    ?P

        ?|?t  ?V?x      ?P           ???i?i?i?i???i?i?i??            ?P

                ?x?z?w?w?w?{         ?i?i?i?i?i?h?h?g?g?f?f?e?e?d?c?b

            ?z?w?r?}?V?V  ?| ???i?i?i?i?i?h?h?g?g?f?f?e?e?d?d?c?c?b

            ?x?V?V           ???i?i

wsCallback - LWS_CALLBACK_CLIENT_RECEIVE

RECEIVER:       ?i?h?h?g?g?f?f?e?e?d?c?b

wsCallback - LWS_CALLBACK_CLIENT_RECEIVE

RECEIVER:            ?f?d?d?e?g?f?e         ?e?d?g??     ???âg?d?e       ????            

               ?g?h  ?h         ?e?d         ?b      ???c?g?d                   

?п?J?N???A?ΥH guest ???[?A?ΥH new ???U:               

^C   ?b?c?e?f?e?g?h?g?f?d    ?n  ??   ??  ???n?l?? ??  ???? ?l?k  ?h            

AWS 筆記 - 透過 Script 半自動化處理 MySQL Replication Error

用了 AWS RDS 一陣子了，之前一直沒搞懂為何 call mysql.rds_skip_repl_error; 一次只能清一條 Error ，直到另一台 MySQL Slave Server 出錯，變成也要手動清除錯誤訊息時，才搞懂原理就是這樣，一次只能清一條。

所以，對於 MySQL Replication Error 不知不覺就生了兩種 script 來應付，一種是 RDS 當 MySQL Replication Slave 用的，另一個則是一般 MySQL Replication Slave Server 用的：

處理 AWS RDS MySQL Replication Slave Servers:

#!/bin/sh
a=0
while [ $a -lt 1000 ]
do
        check=`echo "SHOW SLAVE STATUS \G" | mysql -h YOUR_AWS_RDS_SERVER -u root -ppassword | grep "Last_SQL_Error:" | grep -c "Could not execute"`
        if [ $check -eq 0 ] ; then
                break
        fi
        echo "CALL mysql.rds_skip_repl_error;" | mysql -h YOUR_AWS_RDS_SERVER -u root -ppassword
        a=$(( $a + 1 ))
done

處理 MySQL Replication Slave Servers:

#!/bin/sh

a=0
while [ $a -lt 2000 ]
do
        check=`echo "SHOW SLAVE STATUS \G" | mysql -h YOUR_MYSQL_SLAVE_SERVER -u root -ppassword | grep "Last_SQL_Error:" | grep -c "Error "`
        if [ $check -eq 0 ] ; then
                break
        fi
        check=`echo "STOP SLAVE; SET GLOBAL SQL_SLAVE_SKIP_COUNTER = 1; START SLAVE;" | mysql -h localhost -u root -ppassword`
        a=$(( $a + 1 ))
        sleep 3
done

以上是用在 MySQL Server 彼此算異質系統，只能先透過這招頂替了。