小程序的聊天室功能，后端是django+redis+nginx搭建的，但是在设置好后访问一直报错，查看nginx的日志是这样的：
recv() failed (104: Connection reset by peer) while reading response header from upstream,
no live upstreams while connecting to upstream,
小程序报错如下：
nginx设置如下：
upstream websocket {
server 服务器ip:8000;
}
server {
listen 443 ssl;
server_name 域名;
ssl_certificate *****;
ssl_certificate_key *****;
ssl_session_timeout 5m;
ssl_ciphers ECDHE-RSA-AES128-GCM-SHA256:ECDHE:ECDH:AES:HIGH:!NULL:!aNULL:!MD5:!ADH:!RC4; #使用此加密套件。
ssl_protocols TLSv1 TLSv1.1 TLSv1.2; #使用该协议进行配置。
ssl_prefer_server_ciphers on;
location / {
proxy_pass http://localhost:8000;
proxy_http_version 1.1;
proxy_read_timeout 14400;
}
location /wss {
proxy_pass http://localhost:8000;#代理到上面的地址去，
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "Upgrade";
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}
}
绑定的域名如下
request合法域名 https://www.***.top:8000
socket合法域名 wss://www.***.top
前端请求如下
webSocket: function () {
// 创建Socket
SocketTask = wx.connectSocket({
url: 'wss://www.***.top' + app_data.chat_url + 'room/wss',
data: 'data',
header: {
'content-type': 'application/json'
},
method: 'POST',
success: function (res) {
console.log('WebSocket连接创建', res)
},
fail: function (err) {
wx.showToast({
title: '网络异常！',
})
console.log(err)
},
})
}
是因为nginx的转发做错了吗 我看到有人说是和redis有关但是 redis重启后还是没有用
https://blog.csdn.net/zzhongcy/article/details/89090193
建议自行排查
不好意思哦.没有看那么深哦
后端代码是这样的
class ChatConsumer(AsyncJsonWebsocketConsumer): chats = dict() async def connect(self): self.group_name = self.scope['url_route']['kwargs']['group_name'] await self.channel_layer.group_add(self.group_name, self.channel_name) try: ChatConsumer.chats[self.group_name].add(self) except: ChatConsumer.chats[self.group_name] = {self} await self.accept() async def disconnect(self, close_code): await self.channel_layer.group_discard(self.group_name, self.channel_name) ChatConsumer.chats[self.group_name].remove(self) await self.close() async def receive_json(self, message, **kwargs): print(message) length = len(ChatConsumer.chats[self.group_name]) await self.channel_layer.group_send( self.group_name, { 'type': 'chat.message', 'user_name': message.get('user_name'), 'user_id': message.get('user_id'), 'content': message.get('content'), 'time': message.get('time') }, ) async def chat_message(self, event): await self.send_json({ 'user_name': event['user_name'], 'user_id': event['user_id'], 'content': event['content'], 'time': event['time'] })