PKW: xadmin 搭建 + wxPython 聊天小程序（第一期）
时间:2022-06-26
本文章向大家介绍PKW: xadmin 搭建 + wxPython 聊天小程序（第一期），主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。
这是 Python Knowledge Weekly（PKW）第一期，之所以做这个东西，主要还是为了激励自己，每周都能有学习输入，同时再把知识点做一个总结输出。希望自己能够坚持下来，点点滴滴，不忘初心。
本周分享知识
一、Django xadmin 的搭建指导 关于 xadmin 的相关知识，网络上已经有很多了，但是每个知识点都是零零散散的，我自己在搭建的过程中也遇到了一些问题，每次都需要重新查找资料，这里做个简单的总结，希望对大家能有帮助。
二、基于 wxPython 的聊天程序 其实这个是在实验楼上看到的课程，跟着做了下来，感觉收获还可以，记录下自己的学习心得，也许以后有的用呢。
Django xadmin 搭建
安装方式
这里有两种安装方式，pip 安装和源码安装，因为本文主要介绍 xadmin 的安装，所以一些 Django 的基础配置操作，就不再令行说明。 当前 pip 安装的 xadmin 还不支持 django 2.0，所以如果我们使用最新的 django 版本，那么就只能使用源码安装了，我这里也主要介绍该种方法。
下载源码
进入到 xadmin 的 GitHub 主页（https://github.com/sshwsfc/xadmin），切换至 django2 分支，然后下载源码到本地。
安装配置
我这使用的是 Python 3.6 + Django 2.1。 首先创建 Django 项目，不多说，例如我创建的 Django 项目名称为 test_xadmin，再创建名称为 app_xadmin 的 app 应用。在该项目的顶级目录下，即与 manage.py 文件同目录下，创建 extra_apps 目录，并将 xadmin 项目源码解压出的 xadmin 目录拷贝至该目录下。 在 Django 项目的 setting.py 文件中添加如下代码：
1import sys
2sys.path.insert(0, os.path.join(BASE_DIR, 'extra_apps'))
3INSTALL_APP = [
4'app_xadmin',
5'xadmin',
6'crispy_forms',
7]再在 url.py 中加入如下代码，注册 xadmin 路由
1import xadmin
2urlpatterns = [
3 url('xadmin/', xadmin.site.urls),
4]查看 xadmin 的源码可以看到，xadmin 还是自带了一些数据库表的，所以需要先在数据库中生成这些表，执行代码：
1python manage.py makemigrations
2然后执行
3python manage.py migrate 接下来安装一些依赖包，
1pip install future six httplib2到这里，xadmin 基本就安装完毕。我们打开页面 x.x.x.x:5000，就能够看到一个功能更加强大的 xadmin 页面了。
如果出现添加 user widget 报错的情况，需要将 xadmin/views/dashborad.py 中的 render() 函数添加一个参数 renderer=None 即可。如下所示： def render(self, name, value, attrs=None, renderer=None): …
功能完善
配置导入导出功能
xadmin 默认的功能只有导出，并不能支持文件的导入，我们需要下载 django-import-export 依赖包来支持导入导出功能。
1pip install django-import-export在setting.py中添加如下：
1INSTALLED_APPS = (
2 ...
3 'import_export',
4)在 app 应用 app_xadmin 的 models.py 文件中添加代码：
1from django.db import models
2
3class Article(models.Model):
4 title = models.CharField('title', max_length=256)
5 content = models.TextField('content')
6 pub_date = models.DateTimeField('pub_time', auto_now_add=True, editable=True)
7 update_time = models.DateTimeField('up_time', auto_now=True, null=True)
8
9 def __str__(self):
10 return self.title同时在该目录下创建 resources.py 文件，添加代码：
1from import_export import resources
2from .models import Article
3class ArticleXResource(resources.ModelResource):
4 class Meta:
5 model = Article再创建 adminx.py 文件，添加代码：
1from xadmin import views
2import xadmin
3from .models import Article
4from import_export import resources
5from .resources import ArticleXResource
6
7@xadmin.sites.register(Article)
8class ArticleAdmin(object):
9 list_display = ['title', 'content']
10 import_export_args = {'import_resource_class': ArticleXResource, 'export_resource_class': ArticleXResource}
11 list_export = () # 去掉 Django 默认的导出按钮现在页面展示如下：
运行 django 程序
使用 gunicorn 部署 django，安装 gunicorn
1pip install gunicorn首先在 url.py 中加入：
1from django.contrib.staticfiles.urls import staticfiles_urlpatterns
2
3...
4
5urlpatterns += staticfiles_urlpatterns()然后，在 manage.py 的同级目录下，运行
1/usr/local/python/bin/gunicorn test_xadmin.wsgi -b 0.0.0.0:8000这样，就在本地的 8000 端口启动了服务
如果出现默写 css 样式展示的问题，可以执行下 python manage.py collectstatic 命令，来搜集静态文件到 settings.py 中设置的 STATIC_ROOT 文件夹中。
基于 wxPython 的聊天程序
入门 Hello World
1import wx
2app = wx.App(false)
3frame = wx.Frame(None, title="Hello World")
4frame.Show() #展示
5app.MainLoop() #启动事件循环如图：
编写 server 端
使用 asynchat 和 asyncore 两个 Python 的异步通信模块
1import asynchat
2import asyncore
3
4PORT = 6666
5
6
7class EndSession(Exception):
8 pass
9
10
11class ChatSession(asynchat.async_chat):
12 def __init__(self, server, sock):
13 asynchat.async_chat.__init__(self, sock)
14 self.server = server
15 self.set_terminator(b'n')
16 self.data = []
17 self.name = None
18 self.enter(LoginRoom(server))
19
20 def enter(self, room):
21 try:
22 cur = self.room
23 except AttributeError:
24 pass
25 else:
26 cur.remove(self)
27 self.room = room
28 room.add(self)
29
30 def collect_incoming_data(self, data):
31 self.data.append(data.decode("utf-8"))
32
33 def found_terminator(self):
34 line = ''.join(self.data)
35 self.data = []
36 try:
37 self.room.handle(self, line.encode("utf-8"))
38 except EndSession:
39 self.handle_close()
40
41 def handle_close(self):
42 asynchat.async_chat.handle_close(self)
43 self.enter(LoginRoom(self.server))
44
45
46class ChatServer(asyncore.dispatcher):
47 def __init__(self, port):
48 asyncore.dispatcher.__init__(self)
49 self.create_socket()
50 self.set_reuse_addr()
51 self.bind(('', port))
52 self.listen(5)
53 self.users = {}
54 self.main_room = ChatRoom(self)
55
56 def handle_accept(self):
57 comm, addr = self.accept()
58 ChatSession(self, comm)
59
60
61class CommandHandler:
62 def unknown(self, session, cmd):
63 session.push(('Unknown command {} n'.format(cmd))).encode("utf-8")
64
65 def handle(self, session, line):
66 line = line.decode()
67 if not line.strip():
68 return
69 parts = line.split(' ', 1)
70 cmd = parts[0]
71 try:
72 line = parts[1].strip()
73 except IndexError:
74 line = ''
75 method = getattr(self, 'do_' + cmd, None)
76 try:
77 method(session, line)
78 except TypeError:
79 self.unknown(session, cmd)
80
81
82class Room(CommandHandler):
83 def __init__(self, server):
84 self.server = server
85 self.sessions = []
86
87 def add(self, session):
88 self.sessions.append(session)
89
90 def remove(self, session):
91 self.sessions.remove(session)
92
93 def broadcast(self, line):
94 for session in self.sessions:
95 session.push(line)
96
97 def do_logout(self, session, line):
98 raise EndSession
99
100
101class LoginRoom(Room):
102 def add(self, session):
103 Room.add(self, session)
104 session.push(b'Connect Success')
105
106 def do_login(self, session, line):
107 name = line.strip()
108 if not name:
109 session.push(b'UserName Empty')
110 elif name in self.server.users:
111 session.push(b'UserName Exist')
112 else:
113 session.name = name
114 session.enter(self.server.main_room)
115
116
117class LogoutRoom(Room):
118 def add(self, session):
119 try:
120 del self.server.users[session.name]
121 except KeyError:
122 pass
123
124
125class ChatRoom(Room):
126 def add(self, session):
127 session.push(b'Login Success')
128 self.broadcast((session.name + 'has entered the room.n').encode("utf-8"))
129 self.server.users[session.name] = session
130 Room.add(self, session)
131
132 def remove(self, session):
133 Room.remove(self, session)
134 self.broadcast((session.name + 'has left the room.n').encode("utf-8"))
135
136 def do_say(self, session, line):
137 self.broadcast((session.name + ':' + line + 'n').encode("utf-8"))
138
139 def do_look(self, session, line):
140 session.push(b'Online Users:n')
141 for other in self.sessions:
142 session.push((other.name + 'n').encode("utf-8"))
143
144
145if __name__ == '__main__':
146 s = ChatServer(PORT)
147 try:
148 print("chat server run at '0.0.0.0:{0}'".format(PORT))
149 asyncore.loop()
150 except KeyboardInterrupt:
151 print("chat server exit")编写 client 端
使用 telnet 的方式来登陆，所以需要用到 telnetlib 模块
1import wx
2import telnetlib
3from time import sleep
4import _thread as thread
5
6
7class LoginFrame(wx.Frame):
8 def __init__(self, parent, id, title, size):
9 wx.Frame.__init__(self, parent, id, title)
10 self.SetSize(size)
11 self.Center()
12 self.serverAddressLabel = wx.StaticText(self, label="Server Address", pos=(10, 50), size=(120, 25))
13 self.userNameLabel = wx.StaticText(self, label="UserName", pos=(40, 100), size=(120, 25))
14 self.serverAddress = wx.TextCtrl(self, pos=(120, 47), size=(150, 25))
15 self.userName = wx.TextCtrl(self, pos=(120, 97), size=(150, 25))
16 self.loginButton = wx.Button(self, label='Login', pos=(80, 145), size=(130, 30))
17 self.loginButton.Bind(wx.EVT_BUTTON, self.login)
18 self.Show()
19
20 def login(self, event):
21 try:
22 serverAddress = self.serverAddress.GetLineText(0).split(':')
23 con.open(serverAddress[0], port=int(serverAddress[1]), timeout=10)
24 response = con.read_some()
25 if response != b'Connect Success':
26 self.showDialog('Error', 'Connect Fail!', (200, 100))
27 return
28 con.write(('login ' + str(self.userName.GetLineText(0)) + 'n').encode("utf-8"))
29 response = con.read_some()
30 if response == b'UserName Empty':
31 self.showDialog('Error', 'UserName Empty!', (200, 100))
32 elif response == b'UserName Exist':
33 self.showDialog('Error', 'UserNmae Exist!', (200, 100))
34 else:
35 self.Close()
36 ChatFrame(None, 2, title='My Chat Client', size=(500, 400))
37 except Exception:
38 self.showDialog('Error', 'Connect Fail!', (95, 20))
39
40 def showDialog(self, title, content, size):
41 dialog = wx.Dialog(self, title=title, size=size)
42 dialog.Center()
43 wx.StaticText(dialog, label=content)
44 dialog.ShowModal()
45
46
47class ChatFrame(wx.Frame):
48 def __init__(self, parent, id, title, size):
49 wx.Frame.__init__(self, parent, id, title)
50 self.SetSize(size)
51 self.Center()
52 self.chatFrame = wx.TextCtrl(self, pos=(5, 5), size=(490, 310), style=wx.TE_MULTILINE | wx.TE_READONLY)
53 self.message = wx.TextCtrl(self, pos=(5, 320), size=(300, 25))
54 self.sendButton = wx.Button(self, label="Send", pos=(310, 320), size=(58, 25))
55 self.usersButton = wx.Button(self, label="Users", pos=(373, 320), size=(58, 25))
56 self.closeButton = wx.Button(self, label="Close", pos=(436, 320), size=(58, 25))
57
58 self.sendButton.Bind(wx.EVT_BUTTON, self.send)
59
60 self.usersButton.Bind(wx.EVT_BUTTON, self.lookUsers)
61
62 self.closeButton.Bind(wx.EVT_BUTTON, self.close)
63 thread.start_new_thread(self.receive, ())
64 self.Show()
65
66 def send(self, event):
67
68 message = str(self.message.GetLineText(0)).strip()
69 if message != '':
70 con.write(('say ' + message + 'n').encode("utf-8"))
71 self.message.Clear()
72
73 def lookUsers(self, event):
74
75 con.write(b'lookn')
76
77 def close(self, event):
78
79 con.write(b'logoutn')
80 con.close()
81 self.Close()
82
83 def receive(self):
84
85 while True:
86 sleep(0.6)
87 result = con.read_very_eager()
88 if result != '':
89 self.chatFrame.AppendText(result)
90
91
92if __name__ == '__main__':
93 app = wx.App()
94 con = telnetlib.Telnet()
95 LoginFrame(None, -1, title="Login", size=(320, 250))
96 app.MainLoop()这样，我们启动 server 端，开始监听。再打开两个 client 端，进行交流
非常简易的聊天程序，感兴趣的可以继续添加功能来完善。
GitHub 地址：
https://github.com/zhouwei713/PKW/tree/master/Round%201
- LSTM的简单介绍，附情感分析应用
- 使用实体嵌入的结构化数据进行深度学习
- Otter-入门篇3(Node搭建)
- PhalGo-Respones
- 数据库分库分表中间件 Sharding-JDBC 源码分析 —— SQL 改写
- Otter-入门篇2(Manager安装配置)
- Java的字符串常量相关的一个问题
- [喵咪Liunx(3)]端口转发工具rinetd
- 基于PhalApi的Smarty拓展
- PhalGo-参数验证过滤
- [喵咪Redis]Redis配置文件和主从设置
- [喵咪Redis]Redis-Sentinel
- [喵咪Redis]Redis安装与介绍
- [喵咪Liunx(4)Monit进程监控
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法