k8s部署Netty实现WebSocket消息推送
k8s部署Netty实现WebSocket消息推送
·
我们在做微服务模块的时候,一般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
更多推荐
已为社区贡献9条内容
所有评论(0)