Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

场景

SpringBoot+Vue整合WebSocket实现前后端消息推送:

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/114392573

在上面集成Websocket实现消息推送的基础上。

除给web端页面进行推送数据,还需要给Android端推送数据。

在特殊的业务场景下,Android会经常性断网和关机,SpringBoot后台jar包部署在Windows服务器上。

当终端过多且累计一段时间后,因频繁断网和关机导致的与后台jar包tcp连接数不会关闭,

当超过最大连接数时(8000),则该服务会提示拒绝连接。

Windows上查看连接数除了使用命令之外,还可以借助于其它第三方工具比如Cports端口扫描工具等。

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

在jar包所在服务上运行exe,如果该服务器上还有其他端口服务存在,可进行筛选指定端口的连接

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

比如只筛选7777端口,在筛选器中输入

include:both:tcp:7777

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

注:

博客:
https://blog.csdn.net/badao_liumang_qizhi
关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

1、用Android模拟器以及websocket测试软件来模拟上面异常关闭连接(断网)连接数不变的情况

首先建立起多个连接,可以看到连接数会增多。

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

然后将APP的网络突然断掉,此时可以看到连接数并不会被关掉

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

当网络再次恢复时,连接数会持续增多

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

此时可以通过cports工具选中连接数并关闭

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

或者直接重启后台jar包,则连接会断开

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

2、Nginx配置Websocket代理

可以参考官网文档

http://nginx.org/en/docs/http/websocket.html

To turn a connection between a client and server from HTTP/1.1 into WebSocket, the protocol switch mechanism available in HTTP/1.1 is used.

There is one subtlety however: since the “Upgrade” is a hop-by-hop header, it is not passed from a client to proxied server. With forward proxying, clients may use the CONNECT method to circumvent this issue. This does not work with reverse proxying however, since clients are not aware of any proxy servers, and special processing on a proxy server is required.

Since version 1.3.13, nginx implements special mode of operation that allows setting up a tunnel between a client and proxied server if the proxied server returned a response with the code 101 (Switching Protocols), and the client asked for a protocol switch via the “Upgrade” header in a request.

As noted above, hop-by-hop headers including “Upgrade” and “Connection” are not passed from a client to proxied server, therefore in order for the proxied server to know about the client’s intention to switch a protocol to WebSocket, these headers have to be passed explicitly:

location /chat/ {
    proxy_pass http://backend;
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection "upgrade";
}

A more sophisticated example in which a value of the “Connection” header field in a request to the proxied server depends on the presence of the “Upgrade” field in the client request header:

http {
    map $http_upgrade $connection_upgrade {
        default upgrade;
        ''      close;
    }

    server {
        ...

        location /chat/ {
            proxy_pass http://backend;
            proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
        }
    }

By default, the connection will be closed if the proxied server does not transmit any data within 60 seconds. This timeout can be increased with the proxy_read_timeout directive. Alternatively, the proxied server can be configured to periodically send WebSocket ping frames to reset the timeout and check if the connection is still alive.

3、按照官方文档的示例和说明修改nginx的配置文件

按照示例配置,首先需要配置一个上游服务器upstream,示例配置中叫backend,这里叫websocket

upstream websocket {
  server 10.229.36.139:7777;
 }

添加位置

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

这里的server指定的是原来的ip和端口。

然后按照示例代码添加其他配置

map $http_upgrade $connection_upgrade {
        default upgrade;
        ''      close;
    }

    #gzip  on;

 upstream websocket {
  server 10.229.36.139:7777;
 }

    server {
        listen       88;
        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {
            root   html;
            index  index.html index.htm;
        }

  location /websocket/ {
            proxy_pass http://websocket;
            proxy_http_version 1.1;
   proxy_read_timeout 10s;
   proxy_send_timeout 10s;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
        }

主要添加这两块

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

与示例代码不同的是,这里还按照官方说明添加了超时的时间设置,这里为10s,意思就是说十秒之内没有

任何通讯和消息传输就会关闭该连接。

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

完整nginx.conf配置文件

#user  nobody;
worker_processes  1;

#error_log  logs/error.log;
#error_log  logs/error.log  notice;
#error_log  logs/error.log  info;

#pid        logs/nginx.pid;

events {
    worker_connections  1024;
}

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

    #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
    #                  '$status $body_bytes_sent "$http_referer" '
    #                  '"$http_user_agent" "$http_x_forwarded_for"';

    #access_log  logs/access.log  main;

    sendfile        on;
    #tcp_nopush     on;

    #keepalive_timeout  0;
    keepalive_timeout  65;

 map $http_upgrade $connection_upgrade {
        default upgrade;
        ''      close;
    }

    #gzip  on;

 upstream websocket {
  server 10.229.36.139:7777;
 }

    server {
        listen       88;
        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {
            root   html;
            index  index.html index.htm;
        }

  location /websocket/ {
            proxy_pass http://websocket;
            proxy_http_version 1.1;
   proxy_read_timeout 10s;
   proxy_send_timeout 10s;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection $connection_upgrade;
        }

        #error_page  404              /404.html;

        # redirect server error pages to the static page /50x.html
        #
        error_page   500 502 503 504  /50x.html;
        location = /50x.html {
            root   html;
        }

        # proxy the PHP scripts to Apache listening on 127.0.0.1:80
        #
        #location ~ \.php$ {
        #    proxy_pass   http://127.0.0.1;
        #}

        # pass the PHP scripts to FastCGI server listening on 127.0.0.1:9000
        #
        #location ~ \.php$ {
        #    root           html;
        #    fastcgi_pass   127.0.0.1:9000;
        #    fastcgi_index  index.php;
        #    fastcgi_param  SCRIPT_FILENAME  /scripts$fastcgi_script_name;
        #    include        fastcgi_params;
        #}

        # deny access to .htaccess files, if Apache's document root
        # concurs with nginx's one
        #
        #location ~ /\.ht {
        #    deny  all;
        #}
    }

    # another virtual host using mix of IP-, name-, and port-based configuration
    #
    #server {
    #    listen       8000;
    #    listen       somename:8080;
    #    server_name  somename  alias  another.alias;

    #    location / {
    #        root   html;
    #        index  index.html index.htm;
    #    }
    #}

    # HTTPS server
    #
    #server {
    #    listen       443 ssl;
    #    server_name  localhost;

    #    ssl_certificate      cert.pem;
    #    ssl_certificate_key  cert.key;

    #    ssl_session_cache    shared:SSL:1m;
    #    ssl_session_timeout  5m;

    #    ssl_ciphers  HIGH:!aNULL:!MD5;
    #    ssl_prefer_server_ciphers  on;

    #    location / {
    #        root   html;
    #        index  index.html index.htm;
    #    }
    #}

}

4、配置之后启动Nginx

此时websocket可以通过代理的88端口进行连接

并且在不断网情况下,超过10秒没有消息就会关闭连接。

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

异常断网的情况也是如此

Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

Original: https://www.cnblogs.com/badaoliumangqizhi/p/16536639.html
Author: 霸道流氓
Title: Nginx代理websocket配置(解决websocket异常断开连接tcp连接不断问题)

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/543603/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • 一个JDBC封装工具类

    前言 在使用Java操作MySQL数据库的时候,会使用到JDBC驱动,但是在每次连接并使时都需要创建一堆的类和相关参数,还是有点麻烦的。在这里有一个封装好的JDBC工具类,里面包含…

    Java 2023年6月8日
    065
  • Java序列化流的奇妙之旅

    Java序列化流有何奇妙之处呢?通过一个个案例逐一感受序列化流。 !!!好戏在后头!!! 1.IO流读写文件 先从一个普通文件读写字符串开始讲起。 例子:输出字符串到文件,再从文件…

    Java 2023年6月5日
    087
  • oracle踩坑

    好久没有写博客了,就分享一些乱七八糟的东西吧! 1.oracle递归查询 大家应该使用有的时候会使用递归查询数据库菜单的吧,比如下面这样的(偷的图)( ̄▽ ̄)ノ 这种一般是业务管理…

    Java 2023年6月6日
    096
  • 求求你们,别再刷 Star 了!这跟“爱国”没关系!

    这几年,随着几大互联网公司的强大,纷纷投入云计算产业的建设,开源项目作为维护潜在客户群体(开发者)的重要手段,是各大云计算厂商都在努力做的事。 这几年也诞生了很多真正优秀和看似优秀…

    Java 2023年6月9日
    075
  • Netty源码解读(一)-前置准备

    前置条件 源码版本netty4.1 了解Java NIO、Reactor模型和Netty的基本使用。 解释一下: Java NIO:了解BIO和NIO的区别以及Java NIO基础…

    Java 2023年6月16日
    067
  • Git命令集锦

    Git命令集锦 前言 正文 主体git操作 TEST 列出所有本地分支: git branch 列出所有远程分支: git branch -r 列出所有本地分支和远程分支: git…

    Java 2023年6月5日
    085
  • 二叉树的最小深度(递归)

    二叉树的最小深度(递归) 问题重述: 给定一个二叉树,找出其最小深度。 最小深度是从根节点到最近叶子节点的最短路径上的节点数量。 说明:叶子节点是指没有子节点的节点。 示例 1: …

    Java 2023年6月7日
    072
  • 【Java学习】API接口数据规范

    在日常开发中,一个优雅的API,必须提供简单明了的响应值,然后根据状态码就可以大概知道问题的所在。这里主要整理一下HTTP状态码和自定义状态码。 1、HTTP状态码 当浏览者访问一…

    Java 2023年6月5日
    097
  • (解决)IntelliJ IDEA 中 Error:java: 无效的源发行版: 9

    (解决)IntelliJ IDEA 中 Error:java: 无效的源发行版: 9 (解决)IntelliJ IDEA 中 Error:java: 无效的源发行版: 9 &#82…

    Java 2023年6月9日
    091
  • Z-blog csrf漏洞学习

    Z-blog csrf 环境搭建 1. 首先我在本地搭了一个z-blog。 ​ 思路:csrf并不侧重于哪种功能点,只要检测不规范,就可能利用成功,所以我考虑了一下后台添加管理员的…

    Java 2023年6月6日
    083
  • [ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法

    本文主要讲解使用多线程模块QThread解决PyQt界面程序唉执行耗时操作时,程序卡顿出现的无响应以及界面输出无法实时显示的问题。用户使用工具过程中出现这些问题时会误以为程序出错,…

    Java 2023年5月29日
    044
  • .net 使用Docker开发

    .NET多年以前已经开始支持Docker,但由于国内.net现状,生产过程中几乎用不到docker支持,趁着有点时间捣鼓下~。 先期工作 1、首先安装 Docker Desktop…

    Java 2023年6月9日
    038
  • Eclipse 使用配置全面讲解

    首次使用的必要设置 1、Eclipse 的安装 下载地址:64位neon版eclipse下载 (阿里云盘下载地址,使用7-zip的自释放压缩,下载后直接双击解压,无法解压的话请下载…

    Java 2023年6月8日
    091
  • Java HashMap深入理解增删改查 源码学习 学习笔记

    Java源码解读(三)— HashMap深入理解之增删查改 学习地址:[HashMap深入理解之增删查改]: https://blog.csdn.net/dongmuyang/ar…

    Java 2023年6月5日
    0103
  • java利用itext导出pdf

    项目中有一功能是导出历史记录,可以导出pdf和excel,这里先说导出pdf。在网上查可以用那些方式导出pdf,用itext比较多广泛。 导出pdf可以使用两种方式,一是可以根据已…

    Java 2023年6月13日
    090
  • IDEA 如何根据一个关键字检索项目中的所有代码呢?

    今天笔者接到一个需求,项目中提示 “****”错误信息,那么如何处理呢? 由于笔者第一次接触这个项目,所以只能进行全文检索获取相应的信息,那么如何全文检索呢…

    Java 2023年6月15日
    072
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球