websocket+Django+python+paramiko 实现web 页⾯执⾏服务器命令和脚本WebSocket的⼯作流程：浏览器通过JavaScript向服务端发出建⽴WebSocket连接的请求，在WebSocket连接建⽴成功后，客户端和服务端就可以通过 TCP连接传输数据。因为WebSocket连接本质上是TCP连接，不需要每次传输都带上重复的头部数据，所以它的数据传输量⽐轮询和Comet技术⼩很多。
接下来介绍⼀个执⾏Linux服务器备份脚本的案例：
第⼀步：安装websocket，在Pycharm中很容易，只需要搜索dwebsocket然后安装就好了；
第⼆步：创建⼀个项⽬，在templates下创建⼀个index.html页⾯，代码如下：
PS：jquery没有的话⾃⼰下⼀个放在static⽬录下(如果有static⽬录，记得在Django的settings中设置static路径)，也可以使⽤在线的，⽹上搜⼀下很多的。这段代码就是提供⼀个按钮发送他的值到Django服务器，然后会在服务器中根据所传的值进⾏操作。第三步：配置urls：
第四步：实现views中的视图逻辑处理：<!DOCTYPE html ><html ><head >    <meta  http-equiv ="Content-Type" content ="text/html; charset=utf-8"/>    <title >游戏运维平台</title >    <script  src ="/static/jquery-1.12.4.js"></script >    <script  type ="text/javascript">//<![CDATA[    $(function  () {        $('#backup_all').click(function  () {            var  socket = new  WebSocket("ws://" + window.location.host
+ "/echo_once/");            pen = function  () {                console.log('WebSocket open');//成功连接上Websocket                socket.send($('#backup_all').val());//发送数据到服务端            };            ssage = function  (e) {                console.log('message: ' + e.data);//打印服务端返回的数据                $('#messagecontainer').prepend('<p><pre>' + e.data + '</pre></p>');                $('#messagecontainer').prepend('<hr />');            };        });    });    </script ></head ><body ><br ><button  style ="margin: 20px;height: 40px;background-color: #00ff00;" type ="button" id ="backup_all" value ="backup_all">    执⾏全平台备份脚本</button ><h3 style ="margin: 20px;">脚本执⾏结果:</h3><div  id ="messagecontainer" style ="margin: 20px;"></div ><hr /></body ></html >
1
2
3
4
5
6
7
8
9
10
linux循环执行命令脚本11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34from  websocket import  views urlpatterns = [    url(r'^admin/', admin.site.urls),    url(r'^echo_once', ho_once),]
1
2
3
4
5
6
视图函数也⽐较简单，就是根据前端按钮的value判断，执⾏脚本操作，使⽤的是paramiko连接Linux执⾏命令，最后把结果通过websocket发送到前端页⾯，进⾏展⽰。from  django.shortcuts import  render from  dwebsocket.decorators import  accept_websocket, require_websocket from  django.http import  HttpResponse import  paramiko def  exec_command (comm):    hostname = '你要连接的Linux 服务器IP'    username = '登陆的Linux 账号'    password = '登陆的Linux 账号密码'    ssh = paramiko.SSHClient()    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())    t(hostname=hostname, username=username, password=password)    stdin, stdout, stderr = _command(comm)    result = ad()    ssh.close()    return  result @accept_websocket def  echo_once (request):    if  not  request.is_websocket():  # 判断是不是websocket 连接        try :  # 如果是普通的http ⽅法            message = request.GET['message']            return  HttpResponse(message)        except :            return  render(request, 'index.html')    else :        for  message in  request.websocket:            message = message.decode('utf-8')            if  message == 'backup_all':#这⾥根据web 页⾯获取的值进⾏对应的操作                command = 'sh test.sh'#这⾥是要执⾏的命令或者脚本，我这⾥写死了，完全可以通过web 页⾯获取命令，然后传到这⾥                request.websocket.send(exec_command(command))  # 发送消息到客户端            else :                request.websocket.send('⼩样⼉，没权限'.encode('utf-8'))
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
这是最后的运⾏结果：
这是项⽬⼯程结构：
最后列出websocket的⼀些⽅法和属性：
⼀些⽅法和属性
如果是个websocket请求返回True，如果是个普通的http请求返回False，可以⽤这个⽅法区分它们。
在⼀个websocket请求建⽴之后，这个请求将会有⼀个websocket属性，⽤来给客户端提供⼀个简单的api通讯，如果request.is_websocket()是False，这个属性将是None。
3.WebSocket.wait()
返回⼀个客户端发送的信息，在客户端关闭连接之前他不会返回任何值，这种情况下，⽅法将返回None
ad()
如果没有从客户端接收到新的消息，read⽅法会返回⼀个新的消息，如果没有，就不返回。这是⼀个替代wait的⾮阻塞⽅法unt_messages()
返回消息队列数量
6.WebSocket.has_messages()
如果有新消息返回True，否则返回False
7.WebSocket.send(message)
向客户端发送消息
8.WebSocket.iter()
websocket迭代器

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。