第二十四個夏天後: websocket

2022年8月25日星期四

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

2022年8月20日星期六

Go 開發筆記 - 簡易 WebSocket Client 練習，WSS 與 Skip SSL Check

公司的 WebSocket Server 使用 node.js Primus 建構服務，最近正在調整架構，弄隻 WebSocket Client 交叉比對，這時就想到 Golang 可以練一下 XD 預設先以 PTT 的 WebSocket 為例 wss://ws.ptt.cc/bbs 練習，而 PTT WebSocket 連線時，有檢查 Request Header 的 Origin 欄位的，完整的用法請直接使用 https://term.ptt.cc 。

實作上，直接用 Gorilla WebSocket 即可，用他建制 WebSocket server 跟 client。

此外，對於 WebSocket over SSL (wss) 連線瑣事上，若要處理 SKIP SSL Check 這件事，可以這樣處理：

// https://pkg.go.dev/crypto/tls
type zeroSource struct{}
func (zeroSource) Read(b []byte) (n int, err error) {
for i := range b {
b[i] = 0
}
return len(b), nil
}

func main() {

// ...

var dialer ws.Dialer
if *skipSSLCheck {
fmt.Println("[IFNO] Skip SSL check")
// https://github.com/gorilla/websocket/blob/master/client.go
// https://github.com/gorilla/websocket/blob/master/tls_handshake.go
dialer = ws.Dialer{
Subprotocols: []string{},
ReadBufferSize: 2048,
WriteBufferSize: 2048,
TLSClientConfig: &tls.Config{
Rand: zeroSource{},
InsecureSkipVerify: true,
},
}
} else {
dialer = ws.Dialer{
Subprotocols: []string{},
ReadBufferSize: 2048,
WriteBufferSize: 2048,
}
}
fmt.Println("[IFNO] try to connect to: ", connectToURL)

// ...

}

至於跟 node.js Primus WebSocket server 溝通時，會有 PING/PONG 的 heartbeat 檢驗，目前偷懶等收到 server 詢問時才回，此外，實際上可以靠 messageType (Control Messages) 來判斷：

go func() {
defer func() {
wg.Done()
}()
for {
_, p, err := conn.ReadMessage()
if err == nil {
cmd := string(p)
fmt.Println("SERVER> ", cmd)

if strings.Index(cmd, "\"primus::ping::") >= 0 {
text := fmt.Sprintf("\"primus::ping::%d\"", time.Now().UnixMilli())
fmt.Println("CLIENT:AUTO> [",text,"]")
conn.WriteMessage(ws.TextMessage, []byte(text))
}

} else {
fmt.Println("SERVER:ERROR> ", err)
break
}
}
fmt.Println("[IFNO] server error")
}()

更多完整的資訊，就直接參考 github.com/changyy/go-ws-client 吧

2022年8月25日 星期四

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

2022年8月20日 星期六

Go 開發筆記 - 簡易 WebSocket Client 練習，WSS 與 Skip SSL Check

Subscribe Now

2022年8月25日星期四

2022年8月20日星期六