个人中心
gpt4 book ai didi

详解基于django实现的webssh简单例子

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章详解基于django实现的webssh简单例子由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

本文介绍了详解基于django实现的webssh简单例子，分享给大家，具体如下:

详解基于django实现的webssh简单例子

说明 。

新建一个 django 程序，本文为 chain.

以下仅为简单例子，实际应用 可根据自己平台情况 进行修改.

打开首页后，需要输入1，后台去登录主机，然后返回登录结果.

正常项目 可以post 主机和登录账户，进行权限判断，然后去后台读取账户密码，进行登录.

djang后台 。

需要安装以下模块 。

安装后会有一个版本号报错，不影响 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
channels = = 2.0 . 2
channels - redis = = 2.1 . 0
amqp = = 1.4 . 9
anyjson = = 0.3 . 3
asgi - redis = = 1.4 . 3
asgiref = = 2.3 . 0
async - timeout = = 2.0 . 0
attrs = = 17.4 . 0
 
cd / tmp /
wget https: / / files.pythonhosted.org / packages / 12 / 2a / e9e4fb2e6b2f7a75577e0614926819a472934b0b85f205ba5d5d2add54d0 / Twisted - 18.4 . 0.tar .bz2
tar xf Twisted - 18.4 . 0.tar .bz2
cd Twisted - 18.4 . 0
python3 setup.py install

启动redis 。

目录 。

?
1
2
3
4
5
6
7
8
chain/
     chain/
        settings.py
        asgi.py
        consumers.py
        routing.py
   templates/
       index.html

settings.py 。

?
1
2
3
4
5
6
7
8
9
10
11
12
# django-channels配置
CHANNEL_LAYERS = {
   "default" : {
     "BACKEND" : "channels_redis.core.RedisChannelLayer" ,
     "CONFIG" : {
       "hosts" : [( "127.0.0.1" , 6379 )],
     },
   },
}
 
# 配置ASGI
ASGI_APPLICATION = "chain.routing.application"

consumers.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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
from asgiref.sync import async_to_sync
from channels.generic.websocket import WebsocketConsumer
 
import paramiko
import threading
import time
 
from channels.layers import get_channel_layer
channel_layer = get_channel_layer()
 
class MyThread(threading.Thread):
   def __init__( self , id , chan):
     threading.Thread.__init__( self )
     self .chan = chan
 
   def run( self ):
     while not self .chan.chan.exit_status_ready():
       time.sleep( 0.1 )
       try :
         data = self .chan.chan.recv( 1024 )
         async_to_sync( self .chan.channel_layer.group_send)(
           self .chan.scope[ 'user' ].username,
           {
             "type" : "user.message" ,
             "text" : bytes.decode(data)
           },
         )
       except Exception as ex:
         print ( str (ex))
     self .chan.sshclient.close()
     return False
 
class EchoConsumer(WebsocketConsumer):
 
   def connect( self ):
     # 创建channels group， 命名为：用户名，并使用channel_layer写入到redis
     async_to_sync( self .channel_layer.group_add)( self .scope[ 'user' ].username, self .channel_name)
     # 返回给receive方法处理
     self .accept()
 
   def receive( self , text_data):
 
     if text_data = = '1' :
       self .sshclient = paramiko.SSHClient()
       self .sshclient.load_system_host_keys()
       self .sshclient.set_missing_host_key_policy(paramiko.AutoAddPolicy())
       self .sshclient.connect( '47.104.140.38' , 22 , 'root' , '123456' )
       self .chan = self .sshclient.invoke_shell(term = 'xterm' )
       self .chan.settimeout( 0 )
       t1 = MyThread( 999 , self )
       t1.setDaemon( True )
       t1.start()
     else :
       try :
         self .chan.send(text_data)
       except Exception as ex:
         print ( str (ex))
 
   def user_message( self , event):
     # 消费
     self .send(text_data = event[ "text" ])
 
   def disconnect( self , close_code):
     async_to_sync( self .channel_layer.group_discard)( self .scope[ 'user' ].username, self .channel_name)

asgi.py 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import os
import django
from channels.routing import get_default_application
 
os.environ.setdefault( "DJANGO_SETTINGS_MODULE" , "chain.settings" )
django.setup()
application = get_default_application()
routing.py
from channels.auth import AuthMiddlewareStack
from channels.routing import URLRouter, ProtocolTypeRouter
from django.urls import path
 
from .consumers import EchoConsumer
 
application = ProtocolTypeRouter({
   "websocket" : AuthMiddlewareStack(
     URLRouter([
       path(r "ws/" , EchoConsumer),
       # path(r"stats/", StatsConsumer),
     ])
   )
})

网页设置:

index.html 。

?
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
<!DOCTYPE html>
< html lang = "en" >
< head >
   < meta charset = "UTF-8" >
   < title >django webssh 例子</ title >
 
   < link href = "/static/css/plugins/ztree/awesomeStyle/awesome.css" rel = "external nofollow" rel = "stylesheet" >
 
   < link href = "/static/webssh_static/css/xterm.min.css" rel = "external nofollow" rel = "stylesheet" type = "text/css" />
   < style >
     body {
       padding-bottom: 30px;
     }
 
     .terminal {
       border: #000 solid 5px;
       font-family: cursive;
     {#        font-family: Arial, Helvetica, Tahoma ,"Monaco", "DejaVu Sans Mono", "Liberation Mono", sans-serif;#}{#        font-family: Tahoma, Helvetica, Arial, sans-serif;#}{#        font-family: "\5B8B\4F53","","Monaco", "DejaVu Sans Mono", "Liberation Mono", "Microsoft YaHei", monospace;#} font-size: 15px;
     {#        color: #f0f0f0;#} background: #000;
     {#        width: 893px;#}{#        height: 550px;#} box-shadow: rgba(0, 0, 0, 0.8) 2px 2px 20px;
     }
 
     .reverse-video {
       color: #000;
       background: #f0f0f0;
     }
   </ style >
</ head >
< body >
 
< div id = "terms" ></ div >
</ body >
 
< script src = "/static/webssh_static/js/xterm.min.js" ></ script >
< script >
   var socket = new WebSocket('ws://' + window.location.host + '/ws/');
 
   socket.onopen = function () {
 
     var term = new Terminal();
     term.open(document.getElementById('terms'));
 
     term.on('data', function (data) {
       console.log(data);
       socket.send(data);
     });
 
     socket.onmessage = function (msg) {
       console.log(msg);
       console.log(msg.data);
       term.write(msg.data);
     };
     socket.onerror = function (e) {
       console.log(e);
     };
 
     socket.onclose = function (e) {
       console.log(e);
       term.destroy();
     };
   };
 
</ script >
</ html >

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：http://blog.51cto.com/hequan/2145007 。

最后此篇关于详解基于django实现的webssh简单例子的文章就讲到这里了,如果你想了解更多关于详解基于django实现的webssh简单例子的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： pycharm远程linux开发和调试代码的方法
文章推荐： Flask框架各种常见装饰器示例
文章推荐： 在Django框架中编写Contact表单的教程
文章推荐： Python爬虫之网页图片抓取的方法
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com