ws连接可以,wss无法连接nginx配置代码
ws://cdjhzx.top:8181可以连接,443不行,wss都不行
#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;
accept_mutex on; #设置网路连接序列化,防止惊群现象发生,默认为on
multi_accept on; #设置一个进程是否同时接受多个网络连接,默认为off
#use epoll; #事件驱动模型,select|poll|kqueue|epoll|resig|/dev/poll|eventport
}
http {
map $http_upgrade $connection_upgrade {
default upgrade;
'' close;
}
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;
#gzip on;
upstream runx {
server 172.31.12.193:8181;
}
server {
listen 80;
server_name cdjhzx.top;
location / {
proxy_connect_timeout 15s;
proxy_send_timeout 15s;
proxy_read_timeout 30m;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header Connection "";
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_pass http://runx; #请求转向runx 定义的服务器列表
client_max_body_size 1024m;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
# HTTPS server
#
server {
listen 443 ssl;
server_name cdjhzx.top;#域名配置
ssl_certificate /usr/local/webserver/nginx/conf/server.pem;#证书路径
ssl_certificate_key /usr/local/webserver/nginx/conf/server.key;
ssl_session_cache shared:SSL:1m;
ssl_session_timeout 5m;
ssl_ciphers ECDHE-RSA-AES128-GCM-SHA256:ECDHE:ECDH:AES:HIGH:!NULL:!aNULL:!MD5:!ADH:!RC4:!DH:!DHE;
ssl_prefer_server_ciphers on;
location /websocket {
proxy_connect_timeout 15s;
proxy_send_timeout 15s;
proxy_read_timeout 30m;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header Connection "";
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection $connection_upgrade;
proxy_pass http://runx; #请求转向runx 定义的服务器列表
client_max_body_size 1024m;
}
}
}
wbsocker源码
#! -*- coding: utf-8 -*-
import asyncio
import websockets
import mysql
websocket_users = set()
# 接收客户端消息并处理
async def recv_user_msg(websocket):
while True:
recv_sql = await websocket.recv()
print("\n\nrecv_text:", websocket.pong, recv_sql)
get = mysql.getdb(recv_sql)
'''
es = ""
for gets in get:
for e in gets:
es += str(e) + ","
if(get == ()):
get = "wrong"
else:
get = str(get)
'''
print("db:",get)
await websocket.send(str(get))
# 服务器端主逻辑
async def run(websocket, path):
while True:
try:
await recv_user_msg(websocket)
except websockets.ConnectionClosed:
print("ConnectionClosed...", path) # 链接断开
print("websocket_users old:", websocket_users)
websocket_users.remove(websocket)
print("websocket_users new:", websocket_users)
break
except websockets.InvalidState:
print("InvalidState...") # 无效状态
break
except Exception as e:
print("Exception:", e)
if __name__ == '__main__':
print("172.31.12.193:8181 websocket...")
asyncio.get_event_loop().run_until_complete(websockets.serve(run, "172.31.12.193", 8181))
asyncio.get_event_loop().run_forever()
在nginx里面,需要配置WSS