发布于2020-02-27 09:39 阅读(1054) 评论(0) 点赞(3) 收藏(3)
使用的工具 flask gevent-websocket nginx python3
先来一段代码`在这里插入代码片
from flask import Flask, render_template
from geventwebsocket.websocket import WebSocket, WebSocketError
from geventwebsocket.handler import WebSocketHandler
from gevent.pywsgi import WSGIServer
from flask import request, redirect
from queue import Queue
from lib1 import get_key
import time
import json
import _ctypes
app = Flask(name)
user_socket_dict3 = {}
@app.route(’/ws/chat_room/<room_id>’)
def ws(room_id):
if not send_msg_queue_dict.get(room_id):
send_msg_queue_dict[room_id] = Queue()
user_socket=request.environ.get(“wsgi.websocket”)
if not user_socket:
return “请以WEBSOCKET方式连接”
user_agent = request.user_agent
remote_addr = request.remote_addr
key = get_key(str(user_agent)+str(remote_addr))
user_name = r.get(key)
user_socket_dict3[user_name] = user_socket
while True:
try:
socket_list = []
send_msg_queue = send_msg_queue_dict.get("room_id")
cot = send_msg_queue.get()
if not cot:
continue
msg = cot.get("msg")
from_user = cot.get("from_user")
room_id = cot.get("room_id")
if room_id == "main":
members = r.get("on_line_user")
else:
members = r.get(room_id)
data = {"from_user": from_user, "contains": msg}
for member in members:
socket_list.append(user_socket_dict3.get(member))
for socket_user in socket_list:
socket_user.send(json.dumps(data))
user_msg = json.loads(user_msg)
except EnvironmentError as e:
print(e)
if name == ‘main’:
http_serve=WSGIServer(("0.0.0.0",8070),app,handler_class=WebSocketHandler)
http_serve.serve_forever()
`
nginx的配置
配置/etc/nginx/nginx.conf
在http标签下添加
map $http_upgrade $connection_upgrade {
default upgrade;
‘’ close;
}
在/ect/nginx/conf.d/*.conf中添加
location /ws {
include uwsgi_params;
proxy_http_version 1.1; #这个是重点否则可能会不支持或者传递的数据格式会出现错误
proxy_pass http://127.0.0.1:8070;
proxy_set_header Host $host;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection “upgrade”;
}
那么我们配置好nginx服务启动flask服务和nginx服务既可以访问了
bug多多请多指教
###纪念我的第一篇技术博客
作者:学霸无敌
链接:https://www.pythonheidong.com/blog/article/234873/1eac1f786b0678c609e7/
来源:python黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容:(最多支持255个字符)
---无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事,而不是让内心的烦躁、焦虑,坏掉你本来就不多的热情和定力
Copyright © 2018-2021 python黑洞网 All Rights Reserved 版权所有,并保留所有权利。 京ICP备18063182号-1
投诉与举报,广告合作请联系vgs_info@163.com或QQ3083709327
免责声明:网站文章均由用户上传,仅供读者学习交流使用,禁止用做商业用途。若文章涉及色情,反动,侵权等违法信息,请向我们举报,一经核实我们会立即删除!