websocket
- 网易聊天室?
- web微信?
- 直播?
假如你工作以后,你的老板让你来开发一个内部的微信程序,你需要怎么办?我们先来分析一下里面的技术难点
- 消息的实时性?
- 实现群聊
现在有这样一个需求,老板给到你了,关乎你是否能转正?你要怎么做?
我们先说消息的实时性,按照我们目前的想法是我需要用http协议来做,那么http协议怎么来做那?
是不是要一直去访问我们的服务器,问服务器有没有人给我发消息,有没有人给我发消息?那么大家认为我多长时间去访问一次服务比较合适那? 1分钟1次?1分钟60次?那这样是不是有点问题那?咱们都知道http发起一次请求就需要三次握手,四次断开,那么这样是不是对我服务器资源是严重的浪费啊?对我本地的资源是不是也是严重的浪费啊?这种方式咱们是不是一直去服务器问啊?问有没有我的信息?有我就显示?这种方式咱们一般称为轮询
http协议:
一次请求 一次相应 断开
无状态的 - 你曾经来过 session or cookie
在断开的情况下如果有数据只能等下次再访问的时候返回
那么我们先来总结一下,轮询优缺点
轮询02年之前使用的都是这种技术
每分钟访问60次服务器
优点:消息就基本实时
缺点:双资源浪费
长轮询2000-现在一直在使用
客户端发送一个请求- 服务器接受请求-不返回- 阻塞等待客户端-如果有消息了-返回给客户端
然后客户端立即请求服务器
优点:节省了部分资源,数据实时性略差
缺点:断开连接次数过多
那有没有一种方法是:我的服务器知道我的客户端在哪?有客户端的消息的时候我就把数据发给客户端
websocket是一种基于tcp的新网络协议,它实现了浏览器和服务器之间的双全工通信,允许服务端直接向客户端发送数据
websocket 是一个长连接
现在咱们的前端已经支持websocket协议了,可以直接使用websocket
简单应用
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
<body>
<!-- 输入内容-->
<input type="text" id="input">
<!-- 提交数据-->
<button> 提交数据</button>
<!-- 显示内容-->
<div>
<div ></div>
</div>
<script>
var input=document.getelementbyid('input');
var button=document.queryselector('button');
var message=document.queryselector('div');
//websocket在浏览器端如何使用
//现在html已经提供了websocket,我们可以直接使用
var socket= new websocket('ws://echo.websocket.org');
socket.onopen=function () {
message.innerhtml='连接成功了'
};
//socket.addeventlistener('open',function (data) {
// message.innerhtml='连接成功了'
//});
//点击事件
button.onclick=function () {
request=input.value;
socket.send(request)
}
//获取返回数据
socket.onmessage=function (data) {
message.innerhtml=data.data
};
socket.onclose=function (data) {
message.innerhtml=data.data
}
</script>
</body>
|
优化前端代码
|
1
2
3
4
5
6
7
8
9
10
11
12
|
button.onclick=function () {
request=input.value;
socket.send(request);
input.value=''
}
//获取返回数据
socket.onmessage = function (data) {
var dv=document.createelement('div');
dv.innerhtml=data.data;
message.appendchild(dv)
};
|
websocket 事件
| 事件 | 事件处理函数 | 描述 |
|---|---|---|
| open | socket.onopen | 连接建立是触发 |
| message | socket.onmessage | 客户端收到服务端数据是触发 |
| error | socket.error | 通信发生错误时触发 |
| close | socket.close | 连接关闭时触发 |
websocket方法
| 方法 | 描述 |
|---|---|
| socket.send() | 使用连接发送数据 |
| socket.close() | 关闭连接 |
websocke treadystate值的状态
| 值 | 描述 |
|---|---|
| 0 (connecting) | 正在链接中 |
| 1 (open) | 已经链接并且可以通讯 |
| 2 (closing) | 连接正在关闭 |
| 3 (closed) | 连接已关闭或者没有链接成功 |
自建websocket服务端
准备前端页面
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
<!-- chat/templates/chat/index.html -->
<!doctype html>
<html>
<head>
<meta charset="utf-8"/>
<title>chat rooms</title>
</head>
<body>
what chat room would you like to enter?<br/>
<input id="room-name-input" type="text" size="100"/><br/>
<input id="room-name-submit" type="button" value="enter"/>
<script>
document.queryselector('#room-name-input').focus();
document.queryselector('#room-name-input').onkeyup = function(e) {
if (e.keycode === 13) { // enter, return
document.queryselector('#room-name-submit').click();
}
};
document.queryselector('#room-name-submit').onclick = function(e) {
var roomname = document.queryselector('#room-name-input').value;
window.location.pathname = '/web/' + roomname + '/';
};
</script>
</body>
</html>
|
编辑django的views，使其返回数据
|
1
2
3
4
5
|
# chat/views.py
from django.shortcuts import render
def index(request):
return render(request, 'chat/index.html', {})
|
修改url
|
1
2
3
4
5
6
|
from django.conf.urls import url
from .views import *
urlpatterns = [
url(r'^$', index, name='index'),
]
|
跟settings同级目录下创建routing.py 文件
|
1
2
3
4
5
6
|
# mysite/routing.py
from channels.routing import protocoltyperouter
application = protocoltyperouter({
# (http->django views is added by default)
})
|
编辑settings文件,将channels添加到installed_apps里面
|
1
2
3
4
5
6
7
8
9
10
|
installed_apps = [
'channels',
'chat',
'django.contrib.admin',
'django.contrib.auth',
'django.contrib.contenttypes',
'django.contrib.sessions',
'django.contrib.messages',
'django.contrib.staticfiles',
]
|
并添加channel的配置信息
|
1
|
asgi_application = 'mysite.routing.application'
|
准备聊天室的页面
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
<!-- chat/templates/chat/room.html -->
<!doctype html>
<html>
<head>
<meta charset="utf-8"/>
<title>chat room</title>
</head>
<body>
<textarea id="chat-log" cols="100" rows="20"></textarea><br/>
<input id="chat-message-input" type="text" size="100"/><br/>
<input id="chat-message-submit" type="button" value="send"/>
</body>
<script>
var roomname = {{ room_name_json|safe }};
var chatsocket = new websocket(
'ws://' + window.location.host +
'/ws/chat/' + roomname + '/');
chatsocket.onmessage = function(e) {
var data = json.parse(e.data);
var message = data['message'];
document.queryselector('#chat-log').value += (message + '\n');
};
chatsocket.onclose = function(e) {
console.error('chat socket closed unexpectedly');
};
document.queryselector('#chat-message-input').focus();
document.queryselector('#chat-message-input').onkeyup = function(e) {
if (e.keycode === 13) { // enter, return
document.queryselector('#chat-message-submit').click();
}
};
document.queryselector('#chat-message-submit').onclick = function(e) {
var messageinputdom = document.queryselector('#chat-message-input');
var message = messageinputdom.value;
chatsocket.send(json.stringify({
'message': message
}));
messageinputdom.value = '';
};
</script>
</html>
|
准备views文件，使其返回页面
|
1
2
3
4
|
def room(request, room_name):
return render(request, 'chat/room.html', {
'room_name_json':json.dumps(room_name)
})
|
修改url
|
1
2
3
4
5
6
7
8
|
from django.conf.urls import url
from . import views
urlpatterns = [
url(r'^$', views.index, name='index'),
url(r'^(?p<room_name>[^/]+)/$', views.room, name='room'),
]
|
实现简单的发送返回
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
from channels.generic.websocket import websocketconsumer
import json
class chatconsumer(websocketconsumer):
def connect(self):
self.accept()
def disconnect(self, close_code):
pass
def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
self.send(text_data=json.dumps({
'message': message
}))
|
创建ws的路由
|
1
2
3
4
5
6
7
8
|
# chat/routing.py
from django.conf.urls import url
from . import consumers
websocket_urlpatterns = [
url(r'^ws/chat/(?p<room_name>[^/]+)/$', consumers.chatconsumer),
]
|
修改application的信息
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
# mysite/routing.py
from channels.auth import authmiddlewarestack
from channels.routing import protocoltyperouter, urlrouter
import chat.routing
application = protocoltyperouter({
# (http->django views is added by default)
'websocket': authmiddlewarestack(
urlrouter(
chat.routing.websocket_urlpatterns
)
),
})
|
执行数据库的迁移命令
|
1
|
python manage.py migrate
|
要实现群聊功能，还需要准备redis
|
1
2
|
docker run -p 6379:6379 -d redis:2.8
pip3 install channels_redis
|
将redis添加到settings的配置文件中
|
1
2
3
4
5
6
7
8
9
10
11
|
# mysite/settings.py
# channels
asgi_application = 'mysite.routing.application'
channel_layers = {
'default': {
'backend': 'channels_redis.core.redischannellayer',
'config': {
"hosts": [('127.0.0.1', 6379)],
},
},
}
|
修改consumer.py文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
from asgiref.sync import async_to_sync
from channels.generic.websocket import websocketconsumer
import json
class chatconsumer(websocketconsumer):
def connect(self):
self.room_name = self.scope['url_route']['kwargs']['room_name']
self.room_group_name = 'chat_%s' % self.room_name
# join room group
async_to_sync(self.channel_layer.group_add)(
self.room_group_name,
self.channel_name
)
self.accept()
def disconnect(self, close_code):
# leave room group
async_to_sync(self.channel_layer.group_discard)(
self.room_group_name,
self.channel_name
)
# receive message from websocket
def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
# send message to room group
async_to_sync(self.channel_layer.group_send)(
self.room_group_name,
{
'type': 'chat_message',
'message': message
}
)
# receive message from room group
def chat_message(self, event):
message = event['message']
# send message to websocket
self.send(text_data=json.dumps({
'message': message
}))
|
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.51cto.com/wangfeng7399/2376042