快捷導(dǎo)航

C++實(shí)現(xiàn)WebSocket服務(wù)器的案例分享

更新時(shí)間：2024年05月24日 09:12:09 作者：我要出家當(dāng)?shù)朗?

WebSocket是一種在單個(gè)TCP連接上進(jìn)行全雙工通信的通信協(xié)議,與HTTP協(xié)議不同,它允許服務(wù)器主動(dòng)向客戶端發(fā)送數(shù)據(jù),而不需要客戶端明確地請求,本文主要給大家介紹了C++實(shí)現(xiàn)WebSocket服務(wù)器的案例,需要的朋友可以參考下

一、概述

實(shí)現(xiàn) WebSocket 服務(wù)器主要參考 RFC 協(xié)議。鏈接如下：

RFC 6455: The WebSocket Protocol (rfc-editor.org)

具體的實(shí)現(xiàn)思路：

1、實(shí)現(xiàn)一個(gè)典型的 TCP 服務(wù)器。

2、TCP服務(wù)器處理客戶端請求時(shí)，依據(jù)上述文檔描述，分三個(gè)階段處理 WS Client 請求（握手階段、傳輸階段、分手階段）。

詳細(xì)代碼已上傳到 gitcode和github。

項(xiàng)目目錄預(yù)覽 - GitCode

GitHub - AtaoistPriest/ws_server: This is a web socket server implemented with C.

二、基本特征

1、指定服務(wù)器 IP 、Port 和 transmission 階段的消息回調(diào)函數(shù)后即可快速啟動(dòng)服務(wù)器。

2、內(nèi)置輕量級(jí)日志打印器。

三、使用案例

1、客戶端 HTML 代碼

<html>
<head>
    <script>
        let ws;
 
        function doConnect(addr) {
            ws = new WebSocket("ws://" + addr);
            ws.onopen = () => {
                document.getElementById("log").value += (" Connection opened\n");
            };
            ws.onmessage = (event) => {
                document.getElementById("log").value += (" Receive: " + event.data + "\n\n"); // JSON.stringify()
            };
            ws.onclose = () => {
                document.getElementById("log").value += (" Connection closed\n");
            };
        }
		
		function doClose(addr) {
			ws.close();
		}
 
        document.addEventListener("DOMContentLoaded", (event) => {
            document.getElementById("btn_open_connect").onclick = () => {
                let server_addr = document.getElementById("server_addr").value;
                doConnect(server_addr);
            };
			
			document.getElementById("btn_close_connect").onclick = () => {
                doClose();
                document.getElementById("log").value += (" Client Close Connection\n");
            };
 
            document.getElementById("btn_send").onclick = () => {
                let msg = document.getElementById("message").value;
                ws.send(msg);
                document.getElementById("log").value += (" Send: " + msg + "\n");
            };
			
            document.getElementById("btn_clear").onclick = () => {
                document.getElementById("log").value = ("");
            };
        });
    </script>
</head>
<body>
 
<div id="header">
    <h1 align="left">WebSocket Client</h1>
    Server: <input id="server_addr" type="text" value="39.105.122.85:52323">
    <input id="btn_open_connect" type="button" value="Connect">
	<input id="btn_close_connect" type="button" value="DisConnect">
	<br/><br/>
 
    Message: <input id="message" type="text" value="">
    <input id="btn_send" type="button" value="Send">
    <input id="btn_clear" type="button" value="Clear">
	<br/><br/>
 
    <textarea cols="250" id="log" rows="50"></textarea>
</div>
</body>
</html>

2、服務(wù)端 C 代碼

#include "./src/wbsocket_server.h"
 
long msg_switch(unsigned char *req, long req_len, unsigned char *res, long res_len)
{
	bzero(res, res_len);
	long len = sprintf((char *)res, "Recv %s Successfully", req);
	return len;
}
 
void test_ws_server()
{
	logger_init("./log");
 
	start_server("172.17.83.59", "52323", msg_switch);
 
	logger_destroy();
}
 
int main(void)
{
	test_ws_server();
	return 0;
}