3 WebSocket
| (require net/websocket) |
The net/websocket library provides utilities to run and communicate with WebSocket servers, as specified in the WebSocket protocol IETF draft as of August 16th, 2010.
This module provides the exports from net/websocket/client and net/websocket/server.
3.1 Client API
| (require net/websocket/client) |
| (ws-connect u [#:headers headers]) → open-ws-conn? |
| u : ws-url? |
| headers : (listof header?) = empty |
Connects to the WebSocket server specified by u, providing headers as additional headers.
Returns the connection handle.
This module also provides the exports from net/websocket/conn.
3.2 Server API
| (require net/websocket/server) |
| ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| conn-handle : (open-ws-conn? any/c . -> . void) | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| tcp@ : (unit/c (import) (export tcp^)) = raw:tcp@ | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| port : tcp-listen-port? = 80 | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| listen-ip : (or/c string? false/c) = #f | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| max-waiting : integer? = 4 | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| timeout : integer? = (* 60 60) | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| confirm-ch : (or/c false/c async-channel?) = #f |
Starts a WebSocket server where each new connection uses conn-headers to compute
what headers the client receives based on the client’s request line and headers. conn-headers
also returns a piece of state that will be passed to conn-handle as its second argument.
After the connection handshake is finished, conn-handle receives the connection and is in
sole control until the WebSocket connection completes.
All other arguments are used as in a Dispatching Server.
The #:tcp@ keyword is provided for building an SSL server.
This module also provides the exports from net/websocket/conn.
3.3 Connections
| (require net/websocket/conn) |
| (framing-mode) → (symbols 'old 'new) |
| (framing-mode mode) → void? |
| mode : (symbols 'old 'new) |
Controls whether framing is as before August 16th, 2010 or after. (Most Web browsers currently support only 'old and they are incompatible, so you must choose the correct one.) Defaults to 'old.
Returns true if x is a WebSocket connection.
| (open-ws-conn? x) → boolean? |
| x : any/c |
Returns true if x is an open WebSocket connection.
| (ws-conn-line ws) → bytes? |
| ws : ws-conn? |
Returns the request/response line of the WebSocket connection.
| (ws-conn-closed? ws) → boolean? |
| ws : ws-conn? |
Returns true if the WebSocket connection has been closed.
| (ws-conn-headers ws) → (listof header?) |
| ws : ws-conn? |
Returns the headers of the WebSocket connection.
WebSocket connection support only blocking calls:
| (ws-send! ws s) → void |
| ws : open-ws-conn? |
| s : string? |
Sends s over ws.
| (ws-recv ws) → (or/c string? eof-object?) |
| ws : open-ws-conn? |
Receives a string from ws. Returns eof if the other end closes the connection.
| (ws-close! ws) → void |
| ws : open-ws-conn? |
Closes ws.
3.4 Example
This is a WebSocket echo server compatible with the browser origin security model:
(ws-serve #:port 8080 (λ (wsc _) (let loop () (define m (ws-recv wsc)) (printf "~a\n" m) (unless (eof-object? m) (ws-send! wsc m) (loop)))) #:conn-headers (λ (_ hs) (define origin (header-value (headers-assq* #"Origin" hs))) (values (list (make-header #"Sec-WebSocket-Origin" origin) (make-header #"Sec-WebSocket-Location" #"ws://localhost:8080/")) #f)))