我们在做微服务模块的时候,一般websocket是和微服务模块结合的,因此一般需要配置微服务的pom的yaml文件。

server:
  port: 6888
 
#netty的配置信息(端口号,webSocket路径)
webSocket:
  netty:
    port: 9009
    path: /webSocket
    readerIdleTime: 30 #读空闲超时时间设置(Netty心跳检测配置)
    writerIdleTime: 30 #写空闲超时时间设置(Netty心跳检测配置)

但我们开发完websocket服务后,就需要部署了。在K8s部署的时候,我们需要打通客户端到服务器的应用pod的流量。我采用的是nginx进行转发,但其实也可以用ingress或者gateway去做转发(这个你们可以自己看看)。

配置的前提:因为生产环境一般都有防火墙,因此要确保客户端到服务器的端口开通了。

因为环境nginx也是k8s部署的,因此总共有三个地方需要修改。
1、nginx部署的yaml文件:

---
apiVersion: v1
kind: Service
metadata:
  name: nginx-websocket
  namespace: middleware
  labels:
    app: nginx
spec:
  type: NodePort
  ports:
  - name: nginx
    port: 9009
    targetPort: 9009
    nodePort: 9009
  selector:
    app: nginx

2、微服务应用里的的yaml文件中配置的端口映射方式(需要映射,否则没法提供服务),配置片段如下:

spec:
  type: NodePort
  ports:
    - port: 6800
      name: cns
      targetPort: 6800
      nodePort: 30003
    - port: 9009
      name: weboscket
      targetPort: 9009
      nodePort: 19009

3、在nignx的.conf文件加上以下配置,该配置进行对访问路径控制和设置websocket的协议。

server{
        listen 9009;
        server_name webs;
        location /websocket  {
                proxy_pass http://微服务应用地址:19009/websocket;
                proxy_set_header   Host               $host:$server_port;
                proxy_set_header   Remote_Addr    $remote_addr;
                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 "upgrade";
        }
}

以上就是让websocket正常使用的配置了,需要自己去了解k8s的原理和nginx转发原理。
总结:实现的原理,就是把websocket应用到宿主机,在前端web请求过来的时候,通过nginx把请求引到我们的pod上去。
追加一个好玩的命令,该命令可以测试Linux上websocket的连通性:

curl --no-buffer -H 'Connection: keep-alive, Upgrade' -H 'Upgrade: websocket' -v -H 'Sec-WebSocket-Version: 13' -H 'Sec-WebSocket-Key: websocket' http://websocket地址:端口/路径 ws | od -t c
Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐