什么是webscoket
WebSocket是一种在单个TCP连接上进行全双工通信的协议
WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在WebSocket API中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输
现在，很多网站为了实现推送技术，所用的技术都是轮询。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP请求，然后由服务器返回最新的数据给客户端的浏览器。这种传统的模式带来很明显的缺点，即浏览器需要不断的向服务器发出请求，然而HTTP请求可能包含较长的头部，其中真正有效的数据可能只是很小的一部分，显然这样会浪费很多的带宽等资源。
而比较新的技术去做轮询的效果是Comet。这种技术虽然可以双向通信，但依然需要反复发出请求。而且在Comet中，普遍采用的长链接，也会消耗服务器资源。
在这种情况下，HTML5定义了WebSocket协议，能更好的节省服务器资源和带宽，并且能够更实时地进行通讯。
浏览器通过 JavaScript 向服务器发出建立 WebSocket 连接的请求，连接建立以后，客户端和服务器端就可以通过 TCP 连接直接交换数据。
django实现文本socket的方法
1、channels
2、dwebsocket-django3不支持(Django 3.0附带了对ASGI的支持，将Websockets添加到Django应用中不需要任何额外的依赖关系)
html的写法
<script>
function WebSocketTest()
{
if ("WebSocket" in window)
{
alert("您的浏览器支持 WebSocket!");//查询浏览器是否支持websocket
// 建立一个 websocket对象
var sokect = new WebSocket("ws:"+windows.location+"/serialcom/test_websoket");
socket.onopen = function () {
console.log('WebSocket open');//成功连接上Websocket
};
socket.onmessage = function (e) {
console.log('message: ' + e.data);//打印服务端返回的数据
};
socket.onclose=function(e){
console.log(e);
socket.close(); //关闭TCP连接
};
}
else
{
// 浏览器不支持 WebSocket
alert("您的浏览器不支持 WebSocket!");
}
}
</script>
属性和方法
| 类型 | 名称 | 描述 |
|---|---|---|
| WebSocket | 对象 | 提供到服务端的双向通道 |
| onopen | 属性 | 当websocket连接时调用的事件处理程序 |
| onmessage | 属性 | 通知接收到消息的事件处理程序 |
| onerror | 属性 | 当出现错误时调用的事件处理程序 |
| onclose | 属性 | 当套接字关闭时调用的事件处理程序 |
| readState | 属性 | 报告websocket连接状态 |
| close | 方法 | 关闭websocket |
| send | 方法 | 使用websocket向服务端发送数据 |
| url | 属性 | 报告套接字的当前URL |
| protocol | 属性 | 报告服务器所选中的协议 |
| binaryType | 属性 | 由onmessage接收的二进制数据格式 |
| bufferedAmount | 属性 | 使用send的已排队的数据字节数 |
| extensions | 属性 | 包括服务器所选中的扩展名 |
| 根据readState属性可以判断websocket的连接状态 | ||
| 属性值 | 对应常量 | 描述 |
| – | – | – |
| 0 | CONNECTING | 正在建立连接 |
| 1 | OPEN | 连接成功建立，可以进行通信 |
| 2 | CLOSING | 连接正在关闭 |
| 3 | CLOSED | 连接已关闭 |
django+dwebsocket写法
views.py
form dwebsocket.decorators import accpt_websocket
@accept_websocket
def test_websocket(request):
if request.is_websocket():
while 1:
time.sleep(1)##向前端发送消息
dit={'time':time.strftime('%Y.%m.%d %H:%M:%S',time.localtime(time.time()))}
request.websocket.send(json.dump(dit))
url.py
from . import views
urlpatterns=[
path(r'test_websoket/',views.test_websocket),
]
| 名称 | 描述 | 备注 |
|---|---|---|
| @accept_websocket | 处理websocket和HTTP请求 | 该装饰器用的较多 |
| @require_websocket | 仅处理websocket请求，拒绝HTTP请求 | |
| request.is_websocket() | 如果请求类型是websocket，返回True，否则返回False 通常与@accept_websocket装饰器搭配 | |
| request.websocket | 当websocket请求建立后，该请求具有一个websocket属性，可以通过该属性进行通信， 如果request.is_websocket()是False，则这个属性为None。 | |
| request.websocket.wait() | 阻塞接收消息 | |
| request.websocket.read() | 非阻塞接收消息 | |
| request.websocket.count_messages() | 返回队列中的消息数量 | |
| request.websocket.has_messages() | 如果有新消息返回True，否则返回False | |
| request.websocket.send() | 向客户端发送bytes类型的数据 | |
| request.websocket.close() | 服务器端主动关闭websocket服务 | |
| request.websocket.iter() | websocket迭代器 |
django+channels
在settings.py同级目录下有一个asgi.py文件，内容如下
import os
from django.core.asgi import get_asgi_application
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django3_websocket.settings')
application = get_asgi_application()
#该文件提供了默认的Django ASGI设置，并公开了一个名为application的ASGI应用程序，可以使用uvicorn或daphne等ASGI服务器运行该应用程序。 在进一步介绍之前，让我们看一下ASGI应用程序的结构。
django3使用uvicorn的配置法
https://www.jb51.net/article/180143.htm
