今天有人问腾讯云CDN加速支持websocket吗?虽然大家都知道支持。但是也说不出个所以然来,今天就介绍下腾讯云如何开启websocket支持。

1. WebSocket简介

Websocket是用于服务端主动向客户端推送消息的技术。传统的HTTP/HTTPS只能由客户端向服务端发起请求,服务端对请求一一响应。在需要获取服务端状态变化的场景下,如:提交的后台任务是否执行成功,只能通过客户端轮询向服务端发起请求,不仅效率低,还浪费资源(HTTP1.0下每次轮询都需要经过TCP三次握手重新建立连接)。而WebSocket的出现较好的解决了这个问题,在TCP首次建立完连接之后,该连接不自动关闭,在有效期内客户端可以继续向服务端发送消息,服务端也能主动给客户端发送消息。

2. 腾讯云CDN对WebSocket的支持

腾讯云CDN依靠全球广泛部署的CDN节点,高效的网络存储优化方案和精准的调度策略,有效提升下载速度、降低响应时间,提供流畅的用户体验。腾讯云CDN节点自研服务器在提供静态资源访问的能力下,同时支持WebSocket访问,兼容动态资源的极速上云服务。本文将介绍如果验证腾讯云CDN节点支持WebSocket。

2.1 配置源站支持WebSocket

由于WebSocket属于动态资源,不适用于缓存服务,所有请求必定回源,所以首先需要源站支持WebSocket。以下以Python+Nginx为例介绍如何配置代理支持WebSocket。

  • 2.1.1 Websocket服务端

服务端示例代码:

#!/usr/bin/python
#coding=utf8
"""
# Created Time : 2020-05-02 11:07:02

# File Name: websocket-server.py
# Description:

"""
import socket
import base64
import hashlib
import struct
from threading import Thread
 
 
def parse_headers(data):
    headers = {}
    method = url = protocol = ''
    raw_headers = data.split('\r\n\r\n')[0].split('\r\n')
    for i in range(0, len(raw_headers)):
        if i == 0:
            elements = raw_headers[i].split(' ')
            if len(elements) == 3:
                method, url, protocol = elements
        else:
            k, v = raw_headers[i].split(':', 1)
            headers[k] = v.strip()
    print headers
    return method, url, protocol, headers

def calc_sign(data):
    message = data + '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'   #不要问为什么是这个字符串,rfc6455中定义的!
    return base64.b64encode(hashlib.sha1(message).digest())
    
def encode(data):
    token = b"\x81"
    length = len(data)
    if length < 126:
        token += struct.pack("B", length)
    elif length <= 0xFFFF:
        token += struct.pack("!BH", 126, length)
    else:
        token += struct.pack("!BQ", 127, length)
 
    return token + data

def decode(raw_data):
    payload_len = ord(raw_data[1]) & 127
    if payload_len == 126:
        extend_payload_len = raw_data[2:4]
        mask = raw_data[4:8]
        decoded = raw_data[8:]
    elif payload_len == 127:
        extend_payload_len = raw_data[2:10]
        mask = raw_data[10:14]
        decoded = raw_data[14:]
    else:
        extend_payload_len = None
        mask = raw_data[2:6]
        decoded = raw_data[6:]
 
    data = bytearray()
    for i in range(len(decoded)):
        chunk = ord(decoded[i]) ^ ord(mask[i % 4])
        data.append(chunk)
    return str(data)

def handle_request(conn):
    data = conn.recv(1024)
    print data
    method, url, protocol, headers = parse_headers(data)
    response = "HTTP/1.1 101 Switching Protocols\r\n" \
                   "Upgrade:websocket\r\n" \
                   "Connection:Upgrade\r\n" \
                   "Sec-WebSocket-Accept:%s\r\n" \
                   "WebSocket-Location:ws://%s%s\r\n\r\n" % (calc_sign(headers['Sec-WebSocket-Key']), headers['Host'], url)
    conn.send(response)
 
    while True:
        try:
            raw_data = conn.recv(1024)
        except Exception as e:
            raw_data = None
        if not raw_data:
            break
        data = decode(raw_data)
        print('recv data', data)
        if not conn.send(encode(data)):
            break
 
 
def run():
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.bind(('0.0.0.0', 8888))
    sock.listen(10)
    
    while True:
        conn, address = sock.accept()
        print('new client %s:%s' % address)
        Thread(target=handle_request, args=(conn,)).start()
 
    sock.close()
 
if __name__ == '__main__':
    run()

该服务通过socket响应客户端连接,打印出每个连接的头部,读取客户端发送的消息,并将其发回给客户端。注意websocket通信发送的不是原始消息,需要经过编码,如encode,decode函数。

  • 2.1.2 Websocket客户端

客户端同样需要编解码,也可以直接利用现有工具简化测试步骤:https://pypi.org/project/websocket_client/

  • 2.1.3 本地测试

 

分两次分别发送两次消息,123和456。

腾讯CDN支持websocket吗

请求的抓包HTTP头部内容如下:

腾讯CDN支持websocket吗
tcpdump抓包
腾讯CDN支持websocket吗
HTTP请求+响应头部

可以看到服务端总共只收到了一个TCP建立连接请求,一组HTTP头部,两组消息共用一个连接。websocket实际上发送和响应的也是标准的http头部格式,只是额外带上了鉴权头部。

  • 2.1.4 配置Nginx代理WebSocket

一般我们会在最终的服务前面挂一个代理服务支持路由+负载均衡等,如Nginx等。Nginx需要启用额外配置支持Websocket,修改Nginx配置文件配置如下:

worker_processes  1;

events {
    worker_connections  1024;
}


http {
    include       mime.types;
    default_type  application/octet-stream;
    resolver 119.29.29.29;

    # websocket
    map $http_upgrade $connection_upgrade {
        default upgrade;
        '' close;
    }
    upstream websocket {
        server 127.0.0.1:8888;
    }

    sendfile        on;

    keepalive_timeout  65;

    server {
        listen       80;
        server_name  _;
        root /usr/local/nginx/nginx/http/;
        access_log  logs/all-http.log;

            # websocket
        location ~ ^/websocket {
            proxy_pass http://websocket;
            proxy_set_header Host $host;
            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-For
            $proxy_add_x_forwarded_for;
            proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
        }

    }
}

重启nginx服务:

nginx -s reload 

客户端重新请求80端口即可。

wsdump.py ws://127.0.0.1:80/websocket
  • 2.1.5 测试CDN支持WebSocket访问。
腾讯CDN支持websocket吗
CDN访问

可以看到腾讯云CDN确实无需特殊配置即可支持WebSocket访问并透传源站。有一点在实际使用过程中需要注意的是节点默认支持10s的保活时间,10s内如果没有消息传递,将默认关闭连接。

腾讯云CDN开启websocket方法。
CDN控制台创建域名,在协议处选择“协议跟随”

腾讯CDN支持websocket吗

腾讯云CDN websocket协议设置

腾讯云WS协议额外收费吗?
目前腾讯云并没有额外对WS协议收费。且免费用户的20GB月流量包也可以使用WS协议。

目前新注册的腾讯云用户可享受免费CDN额度
1、个人用户120GB。分6个月赠送,每个月20GB。
2、企业用户360GB。分6个月赠送,每个月60GB。

 

点这里注册,选择新用户就可以获取赠送的CDN额度哦

'); })();
 
QQ在线咨询
如果您或者您的企业有业务上云需要
可以直接和我联系!