Nginx: 实现Websocket代理

概述

  • Nginx 代理模式中,大多都是基于 HTTP 的 Proxy 模块来对应设置的
  • 除此之外,Nginx 还可以实现更多细小化的协议的HTTP代理,比如 ws 的代理

WS 的建立模式

  • websocket 它其实是建立在HTTP连接上,先要建立起HTTP连接

  • 建立好连接以后,客户端会向服务端发送一个 Upgrade 的协议头将连接升级到 websocket

  • 这样的话,从HTTP连接升级到了websocket的连接

  • 它可以实现最重要的一个特点就是双向通信。

    • 就是客户端可以向服务端主动发送请求
    • 这个时候服务端也可以向客户端来发送主动请求
    • 这样就实现了一个很好的双向连接
  • 来看一下这个图,建立好了HTTP连接以后,客户端会向服务端来主动发送一个头信息

  • 就是upgrade, 服务端收到了这个头信息会将这个协议的建立升级到websocket的这个模式里面去

  • 建立好了双向的这个websocket连接,服务端这个时候也可以主动向客户端来发请求了

  • 客户端收到信息以后也可以再回应,这样的话就建立起了一个类似于长连接的这种双向通信的这个模式

  • Websocket 代理场景

    • 多人聊天
    • APP信息推送

Nginx 实现 ws 代理

  • 其实就是客户端向 Nginx 这个代理中心建立一个ws也就是websocket连接
  • Nginx 将会将这种连接代理到后端的服务端里面去,只是说把地址做了一个变化,变成一个内部的地址
  • 对客户端而言,其实就是跟Nginx建立连接的, 而代理只是说将连接做了一层转发到真实的服务端
  • wscat 是客户端测试的工具

1 ) 环境配置

  • 在linux 上安装 nodejs,$ yum install nodejs -y
  • 安装 npm 工具,$ yum install npm
  • 安装 websocket 模块,$ npm install ws
  • 安装 wscat 工具,$ npm install wscat

2 ) 准备后端nodejs程序(ws程序) server.js

console.log("Server started");
var Msg = '';
var WebSocketServer = require('ws').Server,wss = new WebSocketServer({port:8010});wss.on('connection', function(ws){ws.on('message', function(message) {console.log('Received from client: %s', message);ws.send('Server received from client: ' + message);});
});
  • 启动这个服务

3 )配置 Nginx

websocket_proxy.conf

# map 实现映射的赋值,给 $connection_upgrade 来赋值
map $http_upgrade $connection_upgrade {default upgrade;'' close;
}# 转发到 
upstream websocket {server 127.0.0.1:8010; # 这个后续换成真实的ip 这是 ws 服务
}server {listen 8020;access_log   /var/log/nginx/test_websocket.access.log   main;location / {proxy_pass                http://websocket;proxy_http_version   1.1;proxy_set_header     Upgrade  $http_upgrade;                   # 最重要的两行proxy_set_header     Connection $connection_upgrade;    # 最重要的两行}
}
  • Nginx 的 map 配置选项: 通过 map 进行变量中内容映射后赋值
    • 语法:map string $variable { … }
      • string 也可以是一个变量
    • Default: –
    • Context: http
  • 文档地址:ngx_http_map_module
  • 上面 map 配置的意义
    • map 会判断 客户端发送过来的 $http_upgrade 变量是否是有值的,如果没有值
      • 则把 $connection_upgrade 赋值为 upgrade
    • 如果客户端发送过来的 $http_upgrade 变量值为 ‘’
      • 则把 $connection_upgrade 赋值为 close 表示连接关闭
  • 启动 nginx
    • $ nginx -c /etc/nginx/nginx.conf 这个配置文件包含上述子配置文件
    • $ netstat -luntp | grep 80 可查看对应的 8010 和 8020

4 )通过 wscat 来测试

  • $ wscat --connet ws://127.0.0.1:8020 注意,这里是8020是nginx的代理端口
    • 随机在窗口中输入内容回车
    • 之后,服务端返回信息
  • 这样,就可以看到,全双工通信的过程了
  • 整个代理过程完毕

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/472661.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

TypeORM在Node.js中的高级应用

💓 博客主页:瑕疵的CSDN主页 📝 Gitee主页:瑕疵的gitee主页 ⏩ 文章专栏:《热点资讯》 TypeORM在Node.js中的高级应用 TypeORM在Node.js中的高级应用 TypeORM在Node.js中的高级应用 引言 TypeORM 基本概念 1. 实体&am…

Spring整合Redis

前言 在Spring项目中整合Redis,能显著提升数据缓存、分布式锁、会话管理等操作的效率。Jedis作为轻量级的Java Redis客户端,搭配Spring Data Redis模块,能够简化Redis的连接和数据操作,实现更高性能的读写与灵活的缓存管理。本文…

将已有的MySQL8.0单机架构变成主从复制架构

过程: 把数据库做一个完全备份, 恢复到从节点上, 恢复后从备份的那个点开始往后复制,从而保证后续数据的一致性。 步骤: 修改 master 主节点 的配置( server-id log-bin )master 主节点 完全备份( mysqldump )master 主节点 创建…

一文3000字从0到1带你进行Mock测试(建议收藏)

​什么是mock? ​mock测试是以可控的方式模拟真实的对象行为。程序员通常创造模拟对象来测试对象本身该具备的行为,很类似汽车设计者使用碰撞测试假人来模拟车辆碰撞中人的动态行为 为什么要使用Mock? 之所以使用mock测试,是因…

小程序如何完成订阅

小程序如何完成订阅 参考相关文档实践问题处理授权弹窗不再触发引导用户重新授权 参考相关文档 微信小程序实现订阅消息推送的实现步骤 发送订阅消息 小程序订阅消息(用户通过弹窗订阅)开发指南 实践 我们需要先选这一个模板,具体流程参考…

SOHO场景开局(小型,多子网):AP+管理型交换机+路由器+光猫

业务需求 1. 实现除光猫外,整网设备通过APP进行开局,开局部署完成后,能够通过APP远程运维。 2. 需要单独划分访客、办公、视频监控3个子网,其中访客子网供顾客无线上网使用,办公子网用于接入无线和有线办公终端&#x…

C++map和set(二)

1.map的opeator[] 功能: 如果访问对象存在就返回指定键的值的引用,如果指定的键不存在会插入新的键值对,键是传递给operator[]的参数,值是使用该值类型的默认构造函数构造的(对于简单类型通常是0或者空字符)。 代码示例&#xf…

[Linux]多线程详解

多线程 1.线程的概念和理解1.1线程的优点1.2线程的缺点1.3线程的设计1.4线程 VS 进程 2.线程控制2.1线程等待2.2 线程终止2.3 线程分离 3.线程互斥3.1背景3.2抢票代码演示3.3保护公共资源(加锁)3.3.1创建锁/销毁锁3.3.2申请锁/尝试申请锁/解锁 3.4解决抢…

大学语文教材电子版(第十一版)教学用书PDF及课件

大学语文课件:https://caiyun.139.com/m/i?005CiDusEVWnR 《大学语文》(第十一版)主编:徐中玉 齐森华 谭帆。 大学语文教材电子版教师用书PDF第一课《齐桓晋文之事》艺术赏析: 孟子四处游说,养成善辩的…

MySQL【七】

字符串函数 数学函数 日期函数 条件控制函数 类型转换函数 系统信息函数 自定义函数 DELIMITER  CREATE FUNCTION 函数名([参数名 参数数据类型[,…]])RETURNS 函数返回值的数据类型BEGIN函数体;RETURN 语句;ENDDELIMITER ;sql ########## 定义一个函数maxofthree()&#x…

第三百二十三节 Java线程教程 - Java同步器

Java线程教程 - Java同步器 同步器对象与一组线程一起使用。 它维护一个状态,根据它的状态,它让一个线程通过或强迫它等待。 本节将讨论四种类型的同步器: SemaphoresBarriersLatchesExchangers 信号量 信号量用于控制可以访问资源的线程…

《Java核心技术 卷I》用户界面AWT事件继承层次

AWT事件继承层次 EventObject类有一个子类AWTEvent,它是所有AWT事件类的父类。 Swing组件会生成更多其他事件对象,都直接拓展自EventObject而不是AWTEvent。 AWT将事件分为底层(low-level)事件和语义事件。 语义事件:表示用户的动作事件&…

Ubuntu从入门到精通(一)系统安装

Ubuntu从入门到精通(一) 1 Ubuntu镜像选择 下载Ubuntu 20.04系统ISO镜像 安装 Ubuntu 20.04系统,就必须有 Ubuntu 20.04系统软件安装程序可以通过浏览器访问Ubuntu20.04的官方站点, 然后在导舰栏找划 Dowwnloads->Mirrors链接&#xff…

用户自定义IP核——ZYNQ学习笔记6

一、试验任务 通过自定义一个 LED IP 核,通过 PS 端的程序来控制底板上 PL 端 LED1 呈现呼吸 灯的效果,并且 PS 可以通过 AXI 接口来控制呼吸灯的开关和呼吸的频率。 二、创建IP核 三、创建工程,调用IP #include "stdio.h" #includ…

Elasticsearch 8.16.0:革新大数据搜索的新利器

🧑 博主简介:CSDN博客专家,历代文学网(PC端可以访问:https://literature.sinhy.com/#/literature?__c1000,移动端可微信小程序搜索“历代文学”)总架构师,15年工作经验,…

python:用 sklearn 构建 K-Means 聚类模型

pip install scikit-learn 或者 直接用 Anaconda3 sklearn 提供了 preprocessing 数据预处理模块、cluster 聚类模型、manifold.TSNE 数据降维模块。 编写 test_sklearn_3.py 如下 # -*- coding: utf-8 -*- """ 使用 sklearn 构建 K-Means 聚类模型 "&…

【大数据学习 | HBASE高级】hive操作hbase

一般在查询hbase的数据的时候我们可以直接使用hbase的命令行或者是api进行查询就行了,但是在日常的计算过程中我们一般都不是为了查询,都是在查询的基础上进行二次计算,所以使用hbase的命令是没有办法进行数据计算的,并且对于hbas…

贴代码框架PasteForm特性介绍之markdown和richtext

简介 PasteForm是贴代码推出的 “新一代CRUD” ,基于ABPvNext,目的是通过对Dto的特性的标注,从而实现管理端的统一UI,借助于配套的PasteBuilder代码生成器,你可以快速的为自己的项目构建后台管理端!目前管…

ServletConfig、ServletContext、HttpServletRequest与HttpServletResponse常见API

目录 一、ServletConfig 二、ServletContext 三、ServletContext其他重要API (一)获取文件路径和上下文 (二)域对象的相关API 四、HttpServletRequest常见API (一)获取请求行/头信息相关 (二)获得请求参数相关 五、HttpServletResponse常见API 一、ServletConfig Se…

MySQL缓存使用率超过80%的解决方法

MySQL缓存使用率超过80%的解决方法 一、识别缓存使用率过高的问题1.1 使用SHOW GLOBAL STATUS命令监控1.2 监控其他相关指标二、分析缓存使用率过高的原因2.1 数据量增长2.2 查询模式变化2.3 配置不当三、解决缓存使用率过高的方法3.1 调整Buffer Pool大小3.1.1 计算合理的Buff…