WebSocket协议实现了客户端与服务器间的持续、双向通讯，确保了连接的持久性和低延迟。在Kubernetes集群外部访问WebSocket服务时，云原生API网关承担了请求接收和转发的角色，根据预定的路由规则将请求分发到相应的后端服务。本文介绍了如何在容器服务 Kubernetes 版集群部署WebSocket应用，并通过云原生API网关进行流量转发。
前提条件
步骤一：使用容器服务部署WebSocket应用
应用部署的具体操作，请参见创建无状态工作负载Deployment。
在本示例中，使用容器服务K8s原生的服务发现方式，即通过声明式Service API资源将后端服务注册到CoreDNS。示例中的后端服务提供了多个WebSocket接口，在容器服务ACK中应用如下资源：
apiVersion: apps/v1
kind: Deployment
metadata:
labels:
app: sockbin
name: sockbin-app
namespace: default
spec:
progressDeadlineSeconds: 600
replicas: 2
revisionHistoryLimit: 10
selector:
matchLabels:
app: sockbin
strategy:
rollingUpdate:
maxSurge: 25%
maxUnavailable: 25%
type: RollingUpdate
template:
metadata:
labels:
app: sockbin
spec:
containers:
- image: therebelrobot/sockbin
imagePullPolicy: Always
name: sockbin
ports:
- containerPort: 4080
protocol: TCP
resources:
limits:
cpu: 500m
terminationMessagePath: /dev/termination-log
terminationMessagePolicy: File
dnsPolicy: ClusterFirst
restartPolicy: Always
schedulerName: default-scheduler
securityContext: {}
terminationGracePeriodSeconds: 30
---
apiVersion: v1
kind: Service
metadata:
labels:
app: sockbin
name: sockbin-service
namespace: default
spec:
ports:
- name: http
port: 4080
protocol: TCP
targetPort: 4080
selector:
app: sockbin
sessionAffinity: None
type: NodePort步骤二：使用云原生API网关作为WebSocket的路由分发
添加ACK集群作为网关的服务来源并添加Sockbin服务。
添加服务来源
登录云原生API网关控制台。
在左侧导航栏，选择实例，并在顶部菜单栏选择地域。
在实例页面，单击目标网关实例名称。
在左侧导航栏，选择服务，并单击来源页签。
单击创建来源并配置相关参数，配置完成后单击确定。
配置项
描述
来源类型
选择容器服务服务来源。
ACK/ACK Serverless集群
选择后端服务所在的集群。
监听K8s Ingress
开启监听Ingress配置后，云原生API网关会自动监听Ingress资源的变化，并生效Ingress资源中域名、路由的相关配置。
关闭监听Ingress配置后，云原生API网关会放弃监听Ingress资源，同时，之前已监听的Ingress资源中域名、路由相关配置会失效。
说明通过管控手动配置的域名、路由的相关配置的优先级高于Ingress资源。
添加服务
登录云原生API网关控制台。
在左侧导航栏，选择实例，并在顶部菜单栏选择地域。
在实例页面，单击目标网关实例名称。
在左侧导航栏，选择服务，并单击服务页签。
单击创建服务并配置相关参数，然后单击确定。
配置项
说明
服务来源
选择容器服务。
命名空间
选择目标集群的命名空间。
服务列表
在服务列表中选择服务。
添加网关到Sockbin服务的路由
创建HTTP API，具体操作，请参见创建HTTP API。
单击目标API，在左上角单击创建路由。
在创建路由面板配置相关参数，然后单击保存并发布。
配置项
说明
路由名称
设置为
sockbin-route。域名
选择默认关联域名*。
路径（Path）
选择匹配条件为前缀是，Path以
/开头。使用场景
选择使用场景为单服务。
后端服务
选择目标服务以及服务端口。
结果验证
本文为您提供两种方式来验证WebSocket服务可用性。
方式一：通过Sockbin服务的界面直接进行测试
网关会根据WebSocket握手时携带的域名和Path进行路由，使用如下配置访问网关即可得到Sockbin服务的界面。
方式二：使用各种语言的WebSocket客户端进行测试
例如，使用Python的WebSocket客户端来得到一个延迟1秒的服务端响应。
#!/usr/bin/env python
import asyncio
import websockets
async def hello():
async with websockets.connect("ws://ip_addr/delay/1000") as websocket:
await websocket.send("Hello Test")
text = await websocket.recv()
print(text)
asyncio.run(hello())