websocket_common.h

#include <stdio.h>   
#include <stdlib.h>  
#include <string.h>     // 使用 malloc, calloc等动态分配内存方法
#include <stdbool.h>
#include <time.h>       // 获取系统时间
 
#include <errno.h>
#include <netinet/in.h>  
#include <fcntl.h>      // socket设置非阻塞模式
#include <sys/types.h>  
#include <sys/socket.h>  
#include <sys/un.h> 
#include <sys/epoll.h>  // epoll管理服务器的连接和接收触发

#include <unistd.h>

#include <openssl/ssl.h>

struct tty_conn {
    int use_ssl;
    int fd;
    SSL *ssl;
};
int conn_write(struct tty_conn *tty_conn, void*buffer, int len);
int conn_read(struct tty_conn *tty_conn, void*buffer, int len);

 
// websocket根据data[0]判别数据包类型    比如0x81 = 0x80 | 0x1 为一个txt类型数据包
typedef enum{
    WCT_MINDATA = -20,      // 0x0：标识一个中间数据包
    WCT_TXTDATA = -19,      // 0x1：标识一个txt类型数据包
    WCT_BINDATA = -18,      // 0x2：标识一个bin类型数据包
    WCT_DISCONN = -17,      // 0x8：标识一个断开连接类型数据包
    WCT_PING = -16,     // 0x8：标识一个断开连接类型数据包
    WCT_PONG = -15,     // 0xA：表示一个pong类型数据包
    WCT_ERR = -1,
    WCT_NULL = 0
}Websocket_CommunicationType;
 
// client向server发送http连接请求, 并处理返回
int webSocket_clientLinkToServer(struct tty_conn *conn, char *ip, int port, char *interface_path);
 
// server回复client的http请求
int webSocket_serverLinkToClient(struct tty_conn *conn, char *recvBuf, unsigned int bufLen);
 
int webSocket_send(struct tty_conn *conn, unsigned char *data, unsigned int dataLen, bool mod, Websocket_CommunicationType type);
int webSocket_recv(struct tty_conn *conn, unsigned char *data, unsigned int dataMaxLen);

int webSocket_dePackage(unsigned char *data, unsigned int dataLen, unsigned char *package, unsigned int packageMaxLen, unsigned int *packageLen);