k8s部署Netty实现WebSocket消息推送

我们在做微服务模块的时候，一般websocket是和微服务模块结合的，因此一般需要配置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 $h os t :$ 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

k8s部署Netty实现WebSocket消息推送

相关推荐