【C++】libwebsockets库的简易教程(附源码)

2023-10-14 20:10

本文主要是介绍【C++】libwebsockets库的简易教程(附源码),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

1、常用的一些api

2、服务器

3、客户端

4、踩到的一些坑


1、常用的一些api

(1)lws_create_context:创建上下文对面,管理ws

        lws_create_context是libwebsockets库中的函数,用于创建一个WebSocket上下文。WebSocket上下文是一个结构体,包含了与WebSocket相关的所有信息和状态。在创建WebSocket连接之前,需要先创建一个WebSocket上下文。lws_create_context函数的作用是初始化WebSocket上下文,并返回一个指向WebSocket上下文的指针。

(2)lws_context_destroy:销毁上下文对象

        lws_context_destroy 是一个函数,用于销毁一个 libwebsockets 应用程序的上下文。它会释放分配给上下文的所有资源,包括套接字、线程、缓冲区等。调用此函数后,应用程序将无法再使用上下文,因此应该确保在不需要上下文时才调用此函数。

(3)lws_client_connect_via_info:连接到WebSocket服务器

        lws_client_connect_via_info是libwebsockets库中的一个函数,它的作用是通过提供的连接信息来建立一个客户端连接。这个函数可以用于在客户端应用程序中连接到服务器。 

具体来说,lws_client_connect_via_info函数需要提供以下信息:

1. 连接协议的名称,例如http、https、websocket等。

2. 服务器的主机名或IP地址。

3. 服务器的端口号。

4. 连接选项,例如SSL/TLS证书等。

5. 回调函数,用于处理连接状态和接收数据。

通过提供这些信息,lws_client_connect_via_info函数可以建立一个客户端连接,并在连接建立后调用回调函数来处理连接状态和接收数据。

(4)lws_service:处理所有未处理的事件和数据

        在libwebsockets库中,lws_service是一个函数,它用于处理所有未处理的事件和数据。它在一个无限循环中运行,不断地检查是否有新的事件或数据需要处理。当有新的事件或数据到达时,它会调用相应的回调函数来处理它们。lws_service函数是libwebsockets库中最重要的函数之一,它确保了网络连接的稳定和可靠性。

(5)lws_callback_on_writable:设置服务器可以向客户端发送数据

        lws_callback_on_writable 是 libwebsockets 库中的一个函数,它的含义是将一个 websocket 连接的 writable 回调函数加入到事件循环中。当该连接的网络缓冲区变为空闲状态时,就会触发这个回调函数。这个函数通常用于在 websocket 连接中发送数据。调用该函数可以确保在网络缓冲区可写时立即发送数据,从而提高网络传输效率。

(6)常用的结构体

    struct lws                                         // websocket连接句柄
    struct lws_context                           // websocket处理器
    struct lws_context_creation_info    // context参数
    struct lws_protocols                        // 协议层传输句柄
    void* m_pUser;                               // 返回回调的对象
    struct lws_client_connect_info        // 连接参数

2、服务器

以下是使用libwebsockets编写WebSocket服务器的简单步骤:

(1)安装libwebsockets库:您可以从官方网站(https://libwebsockets.org/)下载最新版本的库。

可以通过以下命令安装libwebsockets库:

sudo apt-get install libwebsockets-dev

(2)创建WebSocket服务器

基本的步骤:

a. 创建一个libwebsocket_context对象,该对象将管理所有客户端连接。

b. 设置服务器的协议和端口号。

c. 创建一个回调函数,该函数将处理来自客户端的消息。

d. 启动服务器并等待客户端连接。

处理客户端连接:当客户端连接到服务器时,您需要编写代码来处理连接。这包括验证客户端身份,处理消息和关闭连接。

发送消息:您可以使用libwebsocket库中的函数向客户端发送消息。

下面是一个简单的WebSocket服务器的代码:

libwebsocket开源库中,lws_service回调函数的参数含义如下:

1. wsi:websocket实例,表示当前正在处理的websocket连接。

2. reason:关闭连接的原因代码。如果连接未关闭,此参数为0。

3. user:用户数据,可以使用lws_callback_on_writable函数设置。

4. in:接收到的数据缓冲区。

5. len:接收到的数据长度。

6. flags:标志位,用于指示连接状态等信息。

7. out:发送数据缓冲区。

8. out_len:发送数据长度。

9. reserved:保留参数,暂时没有使用。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <libwebsockets.h>static int callback_http(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len)
{return 0;
}static int callback_websocket(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len)
{switch (reason) {case LWS_CALLBACK_ESTABLISHED:printf("WebSocket connection established\n");break;case LWS_CALLBACK_RECEIVE:printf("Received data: %s\n", (char *)in);break;case LWS_CALLBACK_CLOSED:printf("WebSocket connection closed\n");break;default:break;}return 0;
}//注册协议,一种协议,对应一套处理方案(类似驱动中的设备树)
static struct lws_protocols protocols[] = {{"http",callback_http,0,0,},{"websocket",callback_websocket,0,0,},{ NULL, NULL, 0, 0 } /* end of list */
};int main(int argc, char **argv)
{struct lws_context_creation_info info;struct lws_context *context;int port = 9000;memset(&info, 0, sizeof(info));info.port = port;info.protocols = protocols;context = lws_create_context(&info);if (!context) {printf("Error creating WebSocket context\n");return 1;}printf("WebSocket server started on port %d\n", port);while (1) {lws_service(context, 50);}lws_context_destroy(context);return 0;
}

(3)编译和运行服务器

可以使用以下命令编译服务器:

gcc -o server server.c -lwebsockets

然后运行服务器:
 

./server

现在WebSocket服务器已经启动了,可以使用浏览器或其他WebSocket客户端连接到它。

以上是使用libwebsockets库创建WebSocket服务器的简单教程,希望对你有所帮助。

3、客户端

(1)基本步骤:

A. 在代码中引入libwebsocket库的头文件:

#include <libwebsockets.h>

B. 创建一个lws_context对象,用于管理WebSocket连接:

struct lws_context* context;

C. 定义连接参数结构体,并设置连接信息:

struct lws_client_connect_via_info connect_info = {.context = context,.address = "192.168.12.226",.port = 8081,.path = "/",.host = "192.168.12.226",.origin = "http://192.168.12.226",.protocol = NULL,.user = NULL,.password = NULL
};

D. 使用lws_client_connect_via_info()函数连接到WebSocket服务器:

lws* ws_client = lws_client_connect_via_info(&connect_info);

E. 在连接成功后,可以使用lws_write()函数向服务器发送消息:

char *message = "Hello, WebSocket Server!";
lws_write(ws_client, (unsigned char *)message, strlen(message), LWS_WRITE_TEXT);

F. 最后,在程序结束时,使用lws_context_destroy()函数释放资源:

lws_context_destroy(context);

(2)以下是使用libwebsockets库创建一个基本的WebSocket客户端的示例代码:

lws_client_connect_via_info 是一个函数,用于通过给定的连接信息连接到 WebSocket 服务器。它接受一个指向连接信息结构体的指针作为参数,并返回一个指向连接句柄的指针。连接信息结构体包含有关连接的所有必要信息,例如服务器的地址、端口号、协议等。使用该函数可以方便地连接到 WebSocket 服务器并开始进行通信。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <libwebsockets.h>static int callback_websocket(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len)
{switch (reason) {case LWS_CALLBACK_CLIENT_CONNECTION_ERROR:fprintf(stderr, "Error connecting to server\n");break;case LWS_CALLBACK_CLIENT_ESTABLISHED:fprintf(stderr, "Connected to server\n");break;case LWS_CALLBACK_CLIENT_RECEIVE:fprintf(stderr, "Received data: %s\n", (char *)in);break;case LWS_CALLBACK_CLOSED:fprintf(stderr, "Disconnected from server\n");break;default:break;}return 0;
}int main(int argc, char **argv)
{struct lws_context *context;struct lws *websocket;struct lws_client_connect_info connect_info;memset(&connect_info, 0, sizeof(connect_info));connect_info.context = context;connect_info.address = "localhost";connect_info.port = 8000;connect_info.path = "/";connect_info.host = connect_info.address;connect_info.origin = connect_info.address;connect_info.protocol = NULL;connect_info.ssl_connection = 0;struct lws_protocols protocols[] = {{ "default", callback_websocket, 0, 0 },{ NULL, NULL, 0, 0 }};context = lws_create_context(NULL, NULL, protocols, NULL, NULL, NULL, NULL, -1, -1, 0);if (context == NULL) {fprintf(stderr, "Error creating context\n");return 1;}websocket = lws_client_connect_via_info(&connect_info);if (websocket == NULL) {fprintf(stderr, "Error connecting to server\n");return 1;}while (lws_service(context, 0) >= 0);lws_context_destroy(context);return 0;
}

这个示例代码创建了一个WebSocket客户端,连接到本地主机的8000端口,并打印收到的任何数据。您可以将connect_info.address和connect_info.port更改为连接到其他WebSocket服务器。

在main()函数中,我们首先设置连接信息结构体connect_info,然后创建一个lws_context对象。接下来,我们调用lws_client_connect_via_info()连接到WebSocket服务器,并在while循环中使用lws_service()处理任何传入的数据或事件。最后,我们销毁lws_context对象并返回0,表示程序成功结束。

4、踩到的一些坑

(1)编译时候,会报错说:libwebsocket库 中lws-misc.h 变量humanize_schema_si,未知大小。

解决方法:正常这个是在linux编译器的时候不会报错,但是vs会报错。应该是vs的安全性和语法检查规则导致的。

所以windows编译器时候,改一下就好了。

 (2)客户端连接服务器的名称,记得要和服务器的名称一致,否则连不上。

这篇关于【C++】libwebsockets库的简易教程(附源码)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/212838

相关文章

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

【C++ Primer Plus习题】13.4

大家好,这里是国中之林! ❥前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。有兴趣的可以点点进去看看← 问题: 解答: main.cpp #include <iostream>#include "port.h"int main() {Port p1;Port p2("Abc", "Bcc", 30);std::cout <<

C++包装器

包装器 在 C++ 中,“包装器”通常指的是一种设计模式或编程技巧,用于封装其他代码或对象,使其更易于使用、管理或扩展。包装器的概念在编程中非常普遍,可以用于函数、类、库等多个方面。下面是几个常见的 “包装器” 类型: 1. 函数包装器 函数包装器用于封装一个或多个函数,使其接口更统一或更便于调用。例如,std::function 是一个通用的函数包装器,它可以存储任意可调用对象(函数、函数

C++11第三弹:lambda表达式 | 新的类功能 | 模板的可变参数

🌈个人主页: 南桥几晴秋 🌈C++专栏: 南桥谈C++ 🌈C语言专栏: C语言学习系列 🌈Linux学习专栏: 南桥谈Linux 🌈数据结构学习专栏: 数据结构杂谈 🌈数据库学习专栏: 南桥谈MySQL 🌈Qt学习专栏: 南桥谈Qt 🌈菜鸡代码练习: 练习随想记录 🌈git学习: 南桥谈Git 🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈�

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

06 C++Lambda表达式

lambda表达式的定义 没有显式模版形参的lambda表达式 [捕获] 前属性 (形参列表) 说明符 异常 后属性 尾随类型 约束 {函数体} 有显式模版形参的lambda表达式 [捕获] <模版形参> 模版约束 前属性 (形参列表) 说明符 异常 后属性 尾随类型 约束 {函数体} 含义 捕获:包含零个或者多个捕获符的逗号分隔列表 模板形参:用于泛型lambda提供个模板形参的名

6.1.数据结构-c/c++堆详解下篇(堆排序,TopK问题)

上篇:6.1.数据结构-c/c++模拟实现堆上篇(向下,上调整算法,建堆,增删数据)-CSDN博客 本章重点 1.使用堆来完成堆排序 2.使用堆解决TopK问题 目录 一.堆排序 1.1 思路 1.2 代码 1.3 简单测试 二.TopK问题 2.1 思路(求最小): 2.2 C语言代码(手写堆) 2.3 C++代码(使用优先级队列 priority_queue)

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL