求指点！怎么用python代码开启HTTP server？

曼查克

怎么用python代码开启HTTP server？（不要在terminal输指令执行，直接脚本实现的那种！！！）
想要接收请求，处理数据，用哪些工具比较好？


20210623
现在用的是flask的app.run开启的服务，适合用于开发不适合生产。
我的需求是几十台客户端同时请求，但是数据比较多，而且都是通过同一个路由处理的。
为了避免堵住，希望处理数据的部分由子线程来做。
不知道怎么实现？

希望利用现成的框架来实现。

wp231957

做bs吗，python可以配合flask

z5560636

看你要什么类型的啊，自己创建一个http框架， 运行就是一个HTTP了， 如果是要运行别人的另外看代码，

曼查克

z5560636 发表于 2021-6-22 09:19
看你要什么类型的啊，自己创建一个http框架， 运行就是一个HTTP了， 如果是要运行别人的另外看代码，

需求是这样的：
开启HTTP服务，接收客户端发送的json信息，处理。
最好支持多线程。

曼查克

wp231957 发表于 2021-6-21 20:44
做bs吗，python可以配合flask

就简单做个server，处理客户端发送的信息。

wp231957

曼查克 发表于 2021-6-22 09:24
就简单做个server，处理客户端发送的信息。

小型服务器python+flask
或者nodejs

曼查克

wp231957 发表于 2021-6-22 09:44
小型服务器python+flask
或者nodejs

谢谢，flask了解了，但是好像只能开启开发测试服务，能不能开更适合生产使用的，可分配线程的服务呢？

wp231957

曼查克 发表于 2021-6-22 18:54
谢谢，flask了解了，但是好像只能开启开发测试服务，能不能开更适合生产使用的，可分配线程的服务呢？

如果是单位几十台局域网用的话，flask也是可以的，至于你说的多线程是啥意思呢

曼查克

wp231957 发表于 2021-6-22 18:55
如果是单位几十台局域网用的话，flask也是可以的，至于你说的多线程是啥意思呢

几十台够了；多线程的意思是，每个客户端都会发送不少数据，然后服务端来处理，接收一个处理一个的话会有问题吧？所以考虑接收到数据后处理的部分交给子线程做。

wp231957

曼查克 发表于 2021-6-22 19:00
几十台够了；多线程的意思是，每个客户端都会发送不少数据，然后服务端来处理，接收一个处理一个的话会有 ...

你方便描述一下你的具体业务吗，是否涉及数据库

曼查克

wp231957 发表于 2021-6-22 19:02
你方便描述一下你的具体业务吗，是否涉及数据库

不涉及数据库。客户端发送json文件，内容是图片编码。服务端同时接收多台客户端发送的json处理并保存。

wp231957

曼查克 发表于 2021-6-22 19:04
不涉及数据库。客户端发送json文件，内容是图片编码。服务端同时接收多台客户端发送的json处理并保存。

我没做过这方面的东西，没有话语权
不过我搜了一下，flask也能处理高并发，多线程的

nahongyan1997

我有现成的代码你要吗，socket 原生的服务器，我可以把框架代码给你。你自己写功能。前提是你得懂http协议。（我自己写的框架）

曼查克

nahongyan1997 发表于 2021-6-22 22:33
我有现成的代码你要吗，socket 原生的服务器，我可以把框架代码给你。你自己写功能。前提是你得懂http协议 ...

方便嘛，才初步接触web，对http有简单了解，有机会学习一下也好~

z5560636

曼查克 发表于 2021-6-23 09:08
方便嘛，才初步接触web，对http有简单了解，有机会学习一下也好~

  你搞复杂了，   http 服务器都是多线程的，  并不是你一个页面访问，就把后端挂死在函数里面了。  如果你对数据并发有很高的要求，可是试试 python FastAPI 框架，每秒1W条数据，还是轻轻松松的。

nahongyan1997

曼查克 发表于 2021-6-23 09:08
方便嘛，才初步接触web，对http有简单了解，有机会学习一下也好~

global_control.py

1. from time import sleep
   
2. from time import localtime
   
3. from subprocess import STARTUPINFO,CREATE_NEW_CONSOLE,STARTF_USESHOWWINDOW,SW_HIDE
   
4. from file_process import File
   
5. 
   
6. down_speed_list = {}
   
7. up_speed_list = {}
   
8. 
   
9. transmitting = []
   
10. request_method = {}
    
11. 
    
12. input_check = False           # 子线程占用输入框检查
    
13. global_input_content = None   # 子线程获取到的数据
    
14. 
    
15. first_sign = 0                # 首次开启标记
    
16. cloud_pid = None              # 主线程pid
    
17. process_pids = []             # 所有开启的进程的pid
    
18. base_dir = None               # 程序根目录
    
19. time = None                   # 当前时间(使用time.localtime获取)
    
20. 
    
21. file_open_return = None
    
22. 
    
23. ai_message = None             # 向主窗口发送的信息
    
24. main_window = None            # 主窗口状态
    
25. 
    
26. break_program = False         # 全部中断检测
    
27. break_program_number = []     # 要打断的程序
    
28. 
    
29. PROGRESS_BAR = {'RedProgressBar': "QProgressBar  {   border: 1px solid white; border-radius: 2px;} QProgressBar::chunk {background-color: #ff0000;}",
    
30.                 'YellowProgressBar': "QProgressBar {  border: 1px solid white; border-radius: 2px;} QProgressBar::chunk {background-color: #F4ECA3;}",
    
31.                 'GreenProgressBar': "QProgressBar {  border: 1px solid white; border-radius: 2px;} QProgressBar::chunk {background-color: #009688;}"}
    
32. 
    
33. 
    
34. 
    
35. response_status = {'200':'HTTP/1.1 200 OK',
    
36.                    '201':'HTTP/1.1 201 Created',
    
37.                    '206':'HTTP/1.1 206 Partial Content',
    
38.                    '404':'HTTP/1.1 404 Page Not Found',
    
39.                    '403':'HTTP/1.1 403 Forbidden'}
    
40. 
    
41. CONTENT_TYPE = {
    
42. '.load': 'text/html',
    
43. '.123': 'application/vnd.lotus-1-2-3',
    
44. '.3ds': 'image/x-3ds',
    
45. '.3g2': 'video/3gpp',
    
46. '.3ga': 'video/3gpp',
    
47. '.3gp': 'video/3gpp',
    
48. '.3gpp': 'video/3gpp',
    
49. '.602': 'application/x-t602',
    
50. '.669': 'audio/x-mod',
    
51. '.7z': 'application/x-7z-compressed',
    
52. '.a': 'application/x-archive',
    
53. '.aac': 'audio/mp4',
    
54. '.abw': 'application/x-abiword',
    
55. '.abw.crashed': 'application/x-abiword',
    
56. '.abw.gz': 'application/x-abiword',
    
57. '.ac3': 'audio/ac3',
    
58. '.ace': 'application/x-ace',
    
59. '.adb': 'text/x-adasrc',
    
60. '.ads': 'text/x-adasrc',
    
61. '.afm': 'application/x-font-afm',
    
62. '.ag': 'image/x-applix-graphics',
    
63. '.ai': 'application/illustrator',
    
64. '.aif': 'audio/x-aiff',
    
65. '.aifc': 'audio/x-aiff',
    
66. '.aiff': 'audio/x-aiff',
    
67. '.al': 'application/x-perl',
    
68. '.alz': 'application/x-alz',
    
69. '.amr': 'audio/amr',
    
70. '.ani': 'application/x-navi-animation',
    
71. '.anim[1-9j]': 'video/x-anim',
    
72. '.anx': 'application/annodex',
    
73. '.ape': 'audio/x-ape',
    
74. '.arj': 'application/x-arj',
    
75. '.arw': 'image/x-sony-arw',
    
76. '.as': 'application/x-applix-spreadsheet',
    
77. '.asc': 'text/plain',
    
78. '.asf': 'video/x-ms-asf',
    
79. '.asp': 'application/x-asp',
    
80. '.ass': 'text/x-ssa',
    
81. '.asx': 'audio/x-ms-asx',
    
82. '.atom': 'application/atom+xml',
    
83. '.au': 'audio/basic',
    
84. '.avi': 'video/x-msvideo',
    
85. '.aw': 'application/x-applix-word',
    
86. '.awb': 'audio/amr-wb',
    
87. '.awk': 'application/x-awk',
    
88. '.axa': 'audio/annodex',
    
89. '.axv': 'video/annodex',
    
90. '.bak': 'application/x-trash',
    
91. '.bcpio': 'application/x-bcpio',
    
92. '.bdf': 'application/x-font-bdf',
    
93. '.bib': 'text/x-bibtex',
    
94. '.bin': 'application/octet-stream',
    
95. '.blend': 'application/x-blender',
    
96. '.blender': 'application/x-blender',
    
97. '.bmp': 'image/bmp',
    
98. '.bz': 'application/x-bzip',
    
99. '.bz2': 'application/x-bzip',
    
100. '.c': 'text/x-csrc',
     
101. '.c++': 'text/x-c++src',
     
102. '.cab': 'application/vnd.ms-cab-compressed',
     
103. '.cb7': 'application/x-cb7',
     
104. '.cbr': 'application/x-cbr',
     
105. '.cbt': 'application/x-cbt',
     
106. '.cbz': 'application/x-cbz',
     
107. '.cc': 'text/x-c++src',
     
108. '.cdf': 'application/x-netcdf',
     
109. '.cdr': 'application/vnd.corel-draw',
     
110. '.cer': 'application/x-x509-ca-cert',
     
111. '.cert': 'application/x-x509-ca-cert',
     
112. '.cgm': 'image/cgm',
     
113. '.chm': 'application/x-chm',
     
114. '.chrt': 'application/x-kchart',
     
115. '.class': 'application/x-java',
     
116. '.cls': 'text/x-tex',
     
117. '.cmake': 'text/x-cmake',
     
118. '.cpio': 'application/x-cpio',
     
119. '.cpio.gz': 'application/x-cpio-compressed',
     
120. '.cpp': 'text/x-c++src',
     
121. '.cr2': 'image/x-canon-cr2',
     
122. '.crt': 'application/x-x509-ca-cert',
     
123. '.crw': 'image/x-canon-crw',
     
124. '.cs': 'text/x-csharp',
     
125. '.csh': 'application/x-csh',
     
126. '.css': 'text/css',
     
127. '.cssl': 'text/css',
     
128. '.csv': 'text/csv',
     
129. '.cue': 'application/x-cue',
     
130. '.cur': 'image/x-win-bitmap',
     
131. '.cxx': 'text/x-c++src',
     
132. '.d': 'text/x-dsrc',
     
133. '.dar': 'application/x-dar',
     
134. '.dbf': 'application/x-dbf',
     
135. '.dc': 'application/x-dc-rom',
     
136. '.dcl': 'text/x-dcl',
     
137. '.dcm': 'application/dicom',
     
138. '.dcr': 'image/x-kodak-dcr',
     
139. '.dds': 'image/x-dds',
     
140. '.deb': 'application/x-deb',
     
141. '.der': 'application/x-x509-ca-cert',
     
142. '.desktop': 'application/x-desktop',
     
143. '.dia': 'application/x-dia-diagram',
     
144. '.diff': 'text/x-patch',
     
145. '.divx': 'video/x-msvideo',
     
146. '.djv': 'image/vnd.djvu',
     
147. '.djvu': 'image/vnd.djvu',
     
148. '.dng': 'image/x-adobe-dng',
     
149. '.doc': 'application/msword',
     
150. '.docbook': 'application/docbook+xml',
     
151. '.docm': 'application/vnd.openxmlformats-officedocument.wordprocessingml.document',
     
152. '.docx': 'application/vnd.openxmlformats-officedocument.wordprocessingml.document',
     
153. '.dot': 'text/vnd.graphviz',
     
154. '.dsl': 'text/x-dsl',
     
155. '.dtd': 'application/xml-dtd',
     
156. '.dtx': 'text/x-tex',
     
157. '.dv': 'video/dv',
     
158. '.dvi': 'application/x-dvi',
     
159. '.dvi.bz2': 'application/x-bzdvi',
     
160. '.dvi.gz': 'application/x-gzdvi',
     
161. '.dwg': 'image/vnd.dwg',
     
162. '.dxf': 'image/vnd.dxf',
     
163. '.e': 'text/x-eiffel',
     
164. '.egon': 'application/x-egon',
     
165. '.eif': 'text/x-eiffel',
     
166. '.el': 'text/x-emacs-lisp',
     
167. '.emf': 'image/x-emf',
     
168. '.emp': 'application/vnd.emusic-emusic_package',
     
169. '.ent': 'application/xml-external-parsed-entity',
     
170. '.eps': 'image/x-eps',
     
171. '.eps.bz2': 'image/x-bzeps',
     
172. '.eps.gz': 'image/x-gzeps',
     
173. '.epsf': 'image/x-eps',
     
174. '.epsf.bz2': 'image/x-bzeps',
     
175. '.epsf.gz': 'image/x-gzeps',
     
176. '.epsi': 'image/x-eps',
     
177. '.epsi.bz2': 'image/x-bzeps',
     
178. '.epsi.gz': 'image/x-gzeps',
     
179. '.epub': 'application/epub+zip',
     
180. '.erl': 'text/x-erlang',
     
181. '.es': 'application/ecmascript',
     
182. '.etheme': 'application/x-e-theme',
     
183. '.etx': 'text/x-setext',
     
184. '.exe': 'application/x-ms-dos-executable',
     
185. '.exr': 'image/x-exr',
     
186. '.ez': 'application/andrew-inset',
     
187. '.f': 'text/x-fortran',
     
188. '.f90': 'text/x-fortran',
     
189. '.f95': 'text/x-fortran',
     
190. '.fb2': 'application/x-fictionbook+xml',
     
191. '.fig': 'image/x-xfig',
     
192. '.fits': 'image/fits',
     
193. '.fl': 'application/x-fluid',
     
194. '.flac': 'audio/x-flac',
     
195. '.flc': 'video/x-flic',
     
196. '.fli': 'video/x-flic',
     
197. '.flv': 'video/x-flv',
     
198. '.flw': 'application/x-kivio',
     
199. '.fo': 'text/x-xslfo',
     
200. '.for': 'text/x-fortran',
     
201. '.g3': 'image/fax-g3',
     
202. '.gb': 'application/x-gameboy-rom',
     
203. '.gba': 'application/x-gba-rom',
     
204. '.gcrd': 'text/directory',
     
205. '.ged': 'application/x-gedcom',
     
206. '.gedcom': 'application/x-gedcom',
     
207. '.gen': 'application/x-genesis-rom',
     
208. '.gf': 'application/x-tex-gf',
     
209. '.gg': 'application/x-sms-rom',
     
210. '.gif': 'image/gif',
     
211. '.glade': 'application/x-glade',
     
212. '.gmo': 'application/x-gettext-translation',
     
213. '.gnc': 'application/x-gnucash',
     
214. '.gnd': 'application/gnunet-directory',
     
215. '.gnucash': 'application/x-gnucash',
     
216. '.gnumeric': 'application/x-gnumeric',
     
217. '.gnuplot': 'application/x-gnuplot',
     
218. '.gp': 'application/x-gnuplot',
     
219. '.gpg': 'application/pgp-encrypted',
     
220. '.gplt': 'application/x-gnuplot',
     
221. '.gra': 'application/x-graphite',
     
222. '.gsf': 'application/x-font-type1',
     
223. '.gsm': 'audio/x-gsm',
     
224. '.gtar': 'application/x-tar',
     
225. '.gv': 'text/vnd.graphviz',
     
226. '.gvp': 'text/x-google-video-pointer',
     
227. '.gz': 'application/x-gzip',
     
228. '.h': 'text/x-chdr',
     
229. '.h++': 'text/x-c++hdr',
     
230. '.hdf': 'application/x-hdf',
     
231. '.hh': 'text/x-c++hdr',
     
232. '.hp': 'text/x-c++hdr',
     
233. '.hpgl': 'application/vnd.hp-hpgl',
     
234. '.hpp': 'text/x-c++hdr',
     
235. '.hs': 'text/x-haskell',
     
236. '.htm': 'text/html',
     
237. '.html': 'text/html',
     
238. '.hwp': 'application/x-hwp',
     
239. '.hwt': 'application/x-hwt',
     
240. '.hxx': 'text/x-c++hdr',
     
241. '.ica': 'application/x-ica',
     
242. '.icb': 'image/x-tga',
     
243. '.icns': 'image/x-icns',
     
244. '.ico': 'image/vnd.microsoft.icon',
     
245. '.ics': 'text/calendar',
     
246. '.idl': 'text/x-idl',
     
247. '.ief': 'image/ief',
     
248. '.iff': 'image/x-iff',
     
249. '.ilbm': 'image/x-ilbm',
     
250. '.ime': 'text/x-imelody',
     
251. '.imy': 'text/x-imelody',
     
252. '.ins': 'text/x-tex',
     
253. '.iptables': 'text/x-iptables',
     
254. '.iso': 'application/x-cd-image',
     
255. '.iso9660': 'application/x-cd-image',
     
256. '.it': 'audio/x-it',
     
257. '.j2k': 'image/jp2',
     
258. '.jad': 'text/vnd.sun.j2me.app-descriptor',
     
259. '.jar': 'application/x-java-archive',
     
260. '.java': 'text/x-java',
     
261. '.jng': 'image/x-jng',
     
262. '.jnlp': 'application/x-java-jnlp-file',
     
263. '.jp2': 'image/jp2',
     
264. '.jpc': 'image/jp2',
     
265. '.jpe': 'image/jpeg',
     
266. '.jpeg': 'image/jpeg',
     
267. '.jpf': 'image/jp2',
     
268. '.jpg': 'image/jpeg',
     
269. '.jpr': 'application/x-jbuilder-project',
     
270. '.jpx': 'image/jp2',
     
271. '.js': 'application/javascript',
     
272. '.json': 'application/json',
     
273. '.jsonp': 'application/jsonp',
     
274. '.k25': 'image/x-kodak-k25',
     
275. '.kar': 'audio/midi',
     
276. '.karbon': 'application/x-karbon',
     
277. '.kdc': 'image/x-kodak-kdc',
     
278. '.kdelnk': 'application/x-desktop',
     
279. '.kexi': 'application/x-kexiproject-sqlite3',
     
280. '.kexic': 'application/x-kexi-connectiondata',
     
281. '.kexis': 'application/x-kexiproject-shortcut',
     
282. '.kfo': 'application/x-kformula',
     
283. '.kil': 'application/x-killustrator',
     
284. '.kino': 'application/smil',
     
285. '.kml': 'application/vnd.google-earth.kml+xml',
     
286. '.kmz': 'application/vnd.google-earth.kmz',
     
287. '.kon': 'application/x-kontour',
     
288. '.kpm': 'application/x-kpovmodeler',
     
289. '.kpr': 'application/x-kpresenter',
     
290. '.kpt': 'application/x-kpresenter',
     
291. '.kra': 'application/x-krita',
     
292. '.ksp': 'application/x-kspread',
     
293. '.kud': 'application/x-kugar',
     
294. '.kwd': 'application/x-kword',
     
295. '.kwt': 'application/x-kword',
     
296. '.la': 'application/x-shared-library-la',
     
297. '.latex': 'text/x-tex',
     
298. '.ldif': 'text/x-ldif',
     
299. '.lha': 'application/x-lha',
     
300. '.lhs': 'text/x-literate-haskell',
     
301. '.lhz': 'application/x-lhz',
     
302. '.log': 'text/x-log',
     
303. '.ltx': 'text/x-tex',
     
304. '.lua': 'text/x-lua',
     
305. '.lwo': 'image/x-lwo',
     
306. '.lwob': 'image/x-lwo',
     
307. '.lws': 'image/x-lws',
     
308. '.ly': 'text/x-lilypond',
     
309. '.lyx': 'application/x-lyx',
     
310. '.lz': 'application/x-lzip',
     
311. '.lzh': 'application/x-lha',
     
312. '.lzma': 'application/x-lzma',
     
313. '.lzo': 'application/x-lzop',
     
314. '.m': 'text/x-matlab',
     
315. '.m15': 'audio/x-mod',
     
316. '.m2t': 'video/mpeg',
     
317. '.m3u': 'audio/x-mpegurl',
     
318. '.m3u8': 'application/x-mpegurl',
     
319. '.m4': 'application/x-m4',
     
320. '.m4a': 'audio/mp4',
     
321. '.m4b': 'audio/x-m4b',
     
322. '.m4v': 'video/mp4',
     
323. '.mab': 'application/x-markaby',
     
324. '.man': 'application/x-troff-man',
     
325. '.mbox': 'application/mbox',
     
326. '.md': 'application/x-genesis-rom',
     
327. '.mdb': 'application/vnd.ms-access',
     
328. '.mdi': 'image/vnd.ms-modi',
     
329. '.me': 'text/x-troff-me',
     
330. '.med': 'audio/x-mod',
     
331. '.metalink': 'application/metalink+xml',
     
332. '.mgp': 'application/x-magicpoint',
     
333. '.mid': 'audio/midi',
     
334. '.midi': 'audio/midi',
     
335. '.mif': 'application/x-mif',
     
336. '.minipsf': 'audio/x-minipsf',
     
337. '.mka': 'audio/x-matroska',
     
338. '.mkv': 'video/x-matroska',
     
339. '.ml': 'text/x-ocaml',
     
340. '.mli': 'text/x-ocaml',
     
341. '.mm': 'text/x-troff-mm',
     
342. '.mmf': 'application/x-smaf',
     
343. '.mml': 'text/mathml',
     
344. '.mng': 'video/x-mng',
     
345. '.mo': 'application/x-gettext-translation',
     
346. '.mo3': 'audio/x-mo3',
     
347. '.moc': 'text/x-moc',
     
348. '.mod': 'audio/x-mod',
     
349. '.mof': 'text/x-mof',
     
350. '.moov': 'video/quicktime',
     
351. '.mov': 'video/quicktime',
     
352. '.movie': 'video/x-sgi-movie',
     
353. '.mp+': 'audio/x-musepack',
     
354. '.mp2': 'video/mpeg',
     
355. '.mp3': 'audio/mpeg',
     
356. '.mp4': 'video/mp4',
     
357. '.mpc': 'audio/x-musepack',
     
358. '.mpe': 'video/mpeg',
     
359. '.mpeg': 'video/mpeg',
     
360. '.mpg': 'video/mpeg',
     
361. '.mpga': 'audio/mpeg',
     
362. '.mpp': 'audio/x-musepack',
     
363. '.mrl': 'text/x-mrml',
     
364. '.mrml': 'text/x-mrml',
     
365. '.mrw': 'image/x-minolta-mrw',
     
366. '.ms': 'text/x-troff-ms',
     
367. '.msi': 'application/x-msi',
     
368. '.msod': 'image/x-msod',
     
369. '.msx': 'application/x-msx-rom',
     
370. '.mtm': 'audio/x-mod',
     
371. '.mup': 'text/x-mup',
     
372. '.mxf': 'application/mxf',
     
373. '.n64': 'application/x-n64-rom',
     
374. '.nb': 'application/mathematica',
     
375. '.nc': 'application/x-netcdf',
     
376. '.nds': 'application/x-nintendo-ds-rom',
     
377. '.nef': 'image/x-nikon-nef',
     
378. '.nes': 'application/x-nes-rom',
     
379. '.nfo': 'text/x-nfo',
     
380. '.not': 'text/x-mup',
     
381. '.nsc': 'application/x-netshow-channel',
     
382. '.nsv': 'video/x-nsv',
     
383. '.o': 'application/x-object',
     
384. '.obj': 'application/x-tgif',
     
385. '.ocl': 'text/x-ocl',
     
386. '.oda': 'application/oda',
     
387. '.odb': 'application/vnd.oasis.opendocument.database',
     
388. '.odc': 'application/vnd.oasis.opendocument.chart',
     
389. '.odf': 'application/vnd.oasis.opendocument.formula',
     
390. '.odg': 'application/vnd.oasis.opendocument.graphics',
     
391. '.odi': 'application/vnd.oasis.opendocument.image',
     
392. '.odm': 'application/vnd.oasis.opendocument.text-master',
     
393. '.odp': 'application/vnd.oasis.opendocument.presentation',
     
394. '.ods': 'application/vnd.oasis.opendocument.spreadsheet',
     
395. '.odt': 'application/vnd.oasis.opendocument.text',
     
396. '.oga': 'audio/ogg',
     
397. '.ogg': 'video/x-theora+ogg',
     
398. '.ogm': 'video/x-ogm+ogg',
     
399. '.ogv': 'video/ogg',
     
400. '.ogx': 'application/ogg',
     
401. '.old': 'application/x-trash',
     
402. '.oleo': 'application/x-oleo',
     
403. '.opml': 'text/x-opml+xml',
     
404. '.ora': 'image/openraster',
     
405. '.orf': 'image/x-olympus-orf',
     
406. '.otc': 'application/vnd.oasis.opendocument.chart-template',
     
407. '.otf': 'application/x-font-otf',
     
408. '.otg': 'application/vnd.oasis.opendocument.graphics-template',
     
409. '.oth': 'application/vnd.oasis.opendocument.text-web',
     
410. '.otp': 'application/vnd.oasis.opendocument.presentation-template',
     
411. '.ots': 'application/vnd.oasis.opendocument.spreadsheet-template',
     
412. '.ott': 'application/vnd.oasis.opendocument.text-template',
     
413. '.owl': 'application/rdf+xml',
     
414. '.oxt': 'application/vnd.openofficeorg.extension',
     
415. '.p': 'text/x-pascal',
     
416. '.p10': 'application/pkcs10',
     
417. '.p12': 'application/x-pkcs12',
     
418. '.p7b': 'application/x-pkcs7-certificates',
     
419. '.p7s': 'application/pkcs7-signature',
     
420. '.pack': 'application/x-java-pack200',
     
421. '.pak': 'application/x-pak',
     
422. '.par2': 'application/x-par2',
     
423. '.pas': 'text/x-pascal',
     
424. '.patch': 'text/x-patch',
     
425. '.pbm': 'image/x-portable-bitmap',
     
426. '.pcd': 'image/x-photo-cd',
     
427. '.pcf': 'application/x-cisco-vpn-settings',
     
428. '.pcf.gz': 'application/x-font-pcf',
     
429. '.pcf.z': 'application/x-font-pcf',
     
430. '.pcl': 'application/vnd.hp-pcl',
     
431. '.pcx': 'image/x-pcx',
     
432. '.pdb': 'chemical/x-pdb',
     
433. '.pdc': 'application/x-aportisdoc',
     
434. '.pdf': 'application/pdf',
     
435. '.pdf.bz2': 'application/x-bzpdf',
     
436. '.pdf.gz': 'application/x-gzpdf',
     
437. '.pef': 'image/x-pentax-pef',
     
438. '.pem': 'application/x-x509-ca-cert',
     
439. '.perl': 'application/x-perl',
     
440. '.pfa': 'application/x-font-type1',
     
441. '.pfb': 'application/x-font-type1',
     
442. '.pfx': 'application/x-pkcs12',
     
443. '.pgm': 'image/x-portable-graymap',
     
444. '.pgn': 'application/x-chess-pgn',
     
445. '.pgp': 'application/pgp-encrypted',
     
446. '.php': 'application/x-php',
     
447. '.php3': 'application/x-php',
     
448. '.php4': 'application/x-php',
     
449. '.pict': 'image/x-pict',
     
450. '.pict1': 'image/x-pict',
     
451. '.pict2': 'image/x-pict',
     
452. '.pickle': 'application/python-pickle',
     
453. '.pk': 'application/x-tex-pk',
     
454. '.pkipath': 'application/pkix-pkipath',
     
455. '.pkr': 'application/pgp-keys',
     
456. '.pl': 'application/x-perl',
     
457. '.pla': 'audio/x-iriver-pla',
     
458. '.pln': 'application/x-planperfect',
     
459. '.pls': 'audio/x-scpls',
     
460. '.pm': 'application/x-perl',
     
461. '.png': 'image/png',
     
462. '.pnm': 'image/x-portable-anymap',
     
463. '.pntg': 'image/x-macpaint',
     
464. '.po': 'text/x-gettext-translation',
     
465. '.por': 'application/x-spss-por',
     
466. '.pot': 'text/x-gettext-translation-template',
     
467. '.ppm': 'image/x-portable-pixmap',
     
468. '.pps': 'application/vnd.ms-powerpoint',
     
469. '.ppt': 'application/vnd.ms-powerpoint',
     
470. '.pptm': 'application/vnd.openxmlformats-officedocument.presentationml.presentation',
     
471. '.pptx': 'application/vnd.openxmlformats-officedocument.presentationml.presentation',
     
472. '.ppz': 'application/vnd.ms-powerpoint',
     
473. '.prc': 'application/x-palm-database',
     
474. '.ps': 'application/postscript',
     
475. '.ps.bz2': 'application/x-bzpostscript',
     
476. '.ps.gz': 'application/x-gzpostscript',
     
477. '.psd': 'image/vnd.adobe.photoshop',
     
478. '.psf': 'audio/x-psf',
     
479. '.psf.gz': 'application/x-gz-font-linux-psf',
     
480. '.psflib': 'audio/x-psflib',
     
481. '.psid': 'audio/prs.sid',
     
482. '.psw': 'application/x-pocket-word',
     
483. '.pw': 'application/x-pw',
     
484. '.py': 'text/x-python',
     
485. '.pyc': 'application/x-python-bytecode',
     
486. '.pyo': 'application/x-python-bytecode',
     
487. '.qif': 'image/x-quicktime',
     
488. '.qt': 'video/quicktime',
     
489. '.qtif': 'image/x-quicktime',
     
490. '.qtl': 'application/x-quicktime-media-link',
     
491. '.qtvr': 'video/quicktime',
     
492. '.ra': 'audio/vnd.rn-realaudio',
     
493. '.raf': 'image/x-fuji-raf',
     
494. '.ram': 'application/ram',
     
495. '.rar': 'application/x-rar',
     
496. '.ras': 'image/x-cmu-raster',
     
497. '.raw': 'image/x-panasonic-raw',
     
498. '.rax': 'audio/vnd.rn-realaudio',
     
499. '.rb': 'application/x-ruby',
     
500. '.rdf': 'application/rdf+xml',
     
501. '.rdfs': 'application/rdf+xml',
     
502. '.reg': 'text/x-ms-regedit',
     
503. '.rej': 'application/x-reject',
     
504. '.rgb': 'image/x-rgb',
     
505. '.rle': 'image/rle',
     
506. '.rm': 'application/vnd.rn-realmedia',
     
507. '.rmj': 'application/vnd.rn-realmedia',
     
508. '.rmm': 'application/vnd.rn-realmedia',
     
509. '.rms': 'application/vnd.rn-realmedia',
     
510. '.rmvb': 'application/vnd.rn-realmedia',
     
511. '.rmx': 'application/vnd.rn-realmedia',
     
512. '.roff': 'text/troff',
     
513. '.rp': 'image/vnd.rn-realpix',
     
514. '.rpm': 'application/x-rpm',
     
515. '.rss': 'application/rss+xml',
     
516. '.rt': 'text/vnd.rn-realtext',
     
517. '.rtf': 'application/rtf',
     
518. '.rtx': 'text/richtext',
     
519. '.rv': 'video/vnd.rn-realvideo',
     
520. '.rvx': 'video/vnd.rn-realvideo',
     
521. '.s3m': 'audio/x-s3m',
     
522. '.sam': 'application/x-amipro',
     
523. '.sami': 'application/x-sami',
     
524. '.sav': 'application/x-spss-sav',
     
525. '.scm': 'text/x-scheme',
     
526. '.sda': 'application/vnd.stardivision.draw',
     
527. '.sdc': 'application/vnd.stardivision.calc',
     
528. '.sdd': 'application/vnd.stardivision.impress',
     
529. '.sdp': 'application/sdp',
     
530. '.sds': 'application/vnd.stardivision.chart',
     
531. '.sdw': 'application/vnd.stardivision.writer',
     
532. '.sgf': 'application/x-go-sgf',
     
533. '.sgi': 'image/x-sgi',
     
534. '.sgl': 'application/vnd.stardivision.writer',
     
535. '.sgm': 'text/sgml',
     
536. '.sgml': 'text/sgml',
     
537. '.sh': 'application/x-shellscript',
     
538. '.shar': 'application/x-shar',
     
539. '.shn': 'application/x-shorten',
     
540. '.siag': 'application/x-siag',
     
541. '.sid': 'audio/prs.sid',
     
542. '.sik': 'application/x-trash',
     
543. '.sis': 'application/vnd.symbian.install',
     
544. '.sisx': 'x-epoc/x-sisx-app',
     
545. '.sit': 'application/x-stuffit',
     
546. '.siv': 'application/sieve',
     
547. '.sk': 'image/x-skencil',
     
548. '.sk1': 'image/x-skencil',
     
549. '.skr': 'application/pgp-keys',
     
550. '.slk': 'text/spreadsheet',
     
551. '.smaf': 'application/x-smaf',
     
552. '.smc': 'application/x-snes-rom',
     
553. '.smd': 'application/vnd.stardivision.mail',
     
554. '.smf': 'application/vnd.stardivision.math',
     
555. '.smi': 'application/x-sami',
     
556. '.smil': 'application/smil',
     
557. '.sml': 'application/smil',
     
558. '.sms': 'application/x-sms-rom',
     
559. '.snd': 'audio/basic',
     
560. '.so': 'application/x-sharedlib',
     
561. '.spc': 'application/x-pkcs7-certificates',
     
562. '.spd': 'application/x-font-speedo',
     
563. '.spec': 'text/x-rpm-spec',
     
564. '.spl': 'application/x-shockwave-flash',
     
565. '.spx': 'audio/x-speex',
     
566. '.sql': 'text/x-sql',
     
567. '.sr2': 'image/x-sony-sr2',
     
568. '.src': 'application/x-wais-source',
     
569. '.srf': 'image/x-sony-srf',
     
570. '.srt': 'application/x-subrip',
     
571. '.ssa': 'text/x-ssa',
     
572. '.stc': 'application/vnd.sun.xml.calc.template',
     
573. '.std': 'application/vnd.sun.xml.draw.template',
     
574. '.sti': 'application/vnd.sun.xml.impress.template',
     
575. '.stm': 'audio/x-stm',
     
576. '.stw': 'application/vnd.sun.xml.writer.template',
     
577. '.sty': 'text/x-tex',
     
578. '.sub': 'text/x-subviewer',
     
579. '.sun': 'image/x-sun-raster',
     
580. '.sv4cpio': 'application/x-sv4cpio',
     
581. '.sv4crc': 'application/x-sv4crc',
     
582. '.svg': 'image/svg+xml',
     
583. '.svgz': 'image/svg+xml-compressed',
     
584. '.swf': 'application/x-shockwave-flash',
     
585. '.sxc': 'application/vnd.sun.xml.calc',
     
586. '.sxd': 'application/vnd.sun.xml.draw',
     
587. '.sxg': 'application/vnd.sun.xml.writer.global',
     
588. '.sxi': 'application/vnd.sun.xml.impress',
     
589. '.sxm': 'application/vnd.sun.xml.math',
     
590. '.sxw': 'application/vnd.sun.xml.writer',
     
591. '.sylk': 'text/spreadsheet',
     
592. '.t': 'text/troff',
     
593. '.t2t': 'text/x-txt2tags',
     
594. '.tar': 'application/x-tar',
     
595. '.tar.bz': 'application/x-bzip-compressed-tar',
     
596. '.tar.bz2': 'application/x-bzip-compressed-tar',
     
597. '.tar.gz': 'application/x-compressed-tar',
     
598. '.tar.lzma': 'application/x-lzma-compressed-tar',
     
599. '.tar.lzo': 'application/x-tzo',
     
600. '.tar.xz': 'application/x-xz-compressed-tar',
     
601. '.tar.z': 'application/x-tarz',
     
602. '.tbz': 'application/x-bzip-compressed-tar',
     
603. '.tbz2': 'application/x-bzip-compressed-tar',
     
604. '.tcl': 'text/x-tcl',
     
605. '.tex': 'text/x-tex',
     
606. '.texi': 'text/x-texinfo',
     
607. '.texinfo': 'text/x-texinfo',
     
608. '.tga': 'image/x-tga',
     
609. '.tgz': 'application/x-compressed-tar',
     
610. '.theme': 'application/x-theme',
     
611. '.themepack': 'application/x-windows-themepack',
     
612. '.tif': 'image/tiff',
     
613. '.tiff': 'image/tiff',
     
614. '.tk': 'text/x-tcl',
     
615. '.tlz': 'application/x-lzma-compressed-tar',
     
616. '.tnef': 'application/vnd.ms-tnef',
     
617. '.tnf': 'application/vnd.ms-tnef',
     
618. '.toc': 'application/x-cdrdao-toc',
     
619. '.torrent': 'application/x-bittorrent',
     
620. '.tpic': 'image/x-tga',
     
621. '.tr': 'text/troff',
     
622. '.ts': 'application/x-linguist',
     
623. '.tsv': 'text/tab-separated-values',
     
624. '.tta': 'audio/x-tta',
     
625. '.ttc': 'application/x-font-ttf',
     
626. '.ttf': 'application/x-font-ttf',
     
627. '.ttx': 'application/x-font-ttx',
     
628. '.txt': 'text/plain',
     
629. '.txz': 'application/x-xz-compressed-tar',
     
630. '.tzo': 'application/x-tzo',
     
631. '.ufraw': 'application/x-ufraw',
     
632. '.ui': 'application/x-designer',
     
633. '.uil': 'text/x-uil',
     
634. '.ult': 'audio/x-mod',
     
635. '.uni': 'audio/x-mod',
     
636. '.uri': 'text/x-uri',
     
637. '.url': 'text/x-uri',
     
638. '.ustar': 'application/x-ustar',
     
639. '.vala': 'text/x-vala',
     
640. '.vapi': 'text/x-vala',
     
641. '.vcf': 'text/directory',
     
642. '.vcs': 'text/calendar',
     
643. '.vct': 'text/directory',
     
644. '.vda': 'image/x-tga',
     
645. '.vhd': 'text/x-vhdl',
     
646. '.vhdl': 'text/x-vhdl',
     
647. '.viv': 'video/vivo',
     
648. '.vivo': 'video/vivo',
     
649. '.vlc': 'audio/x-mpegurl',
     
650. '.vob': 'video/mpeg',
     
651. '.voc': 'audio/x-voc',
     
652. '.vor': 'application/vnd.stardivision.writer',
     
653. '.vst': 'image/x-tga',
     
654. '.wav': 'audio/x-wav',
     
655. '.wax': 'audio/x-ms-asx',
     
656. '.wb1': 'application/x-quattropro',
     
657. '.wb2': 'application/x-quattropro',
     
658. '.wb3': 'application/x-quattropro',
     
659. '.wbmp': 'image/vnd.wap.wbmp',
     
660. '.wcm': 'application/vnd.ms-works',
     
661. '.wdb': 'application/vnd.ms-works',
     
662. '.webm': 'video/webm',
     
663. '.wk1': 'application/vnd.lotus-1-2-3',
     
664. '.wk3': 'application/vnd.lotus-1-2-3',
     
665. '.wk4': 'application/vnd.lotus-1-2-3',
     
666. '.wks': 'application/vnd.ms-works',
     
667. '.wma': 'audio/x-ms-wma',
     
668. '.wmf': 'image/x-wmf',
     
669. '.wml': 'text/vnd.wap.wml',
     
670. '.wmls': 'text/vnd.wap.wmlscript',
     
671. '.wmv': 'video/x-ms-wmv',
     
672. '.wmx': 'audio/x-ms-asx',
     
673. '.wp': 'application/vnd.wordperfect',
     
674. '.wp4': 'application/vnd.wordperfect',
     
675. '.wp5': 'application/vnd.wordperfect',
     
676. '.wp6': 'application/vnd.wordperfect',
     
677. '.wpd': 'application/vnd.wordperfect',
     
678. '.wpg': 'application/x-wpg',
     
679. '.wpl': 'application/vnd.ms-wpl',
     
680. '.wpp': 'application/vnd.wordperfect',
     
681. '.wps': 'application/vnd.ms-works',
     
682. '.wri': 'application/x-mswrite',
     
683. '.wrl': 'model/vrml',
     
684. '.wv': 'audio/x-wavpack',
     
685. '.wvc': 'audio/x-wavpack-correction',
     
686. '.wvp': 'audio/x-wavpack',
     
687. '.wvx': 'audio/x-ms-asx',
     
688. '.x3f': 'image/x-sigma-x3f',
     
689. '.xac': 'application/x-gnucash',
     
690. '.xbel': 'application/x-xbel',
     
691. '.xbl': 'application/xml',
     
692. '.xbm': 'image/x-xbitmap',
     
693. '.xcf': 'image/x-xcf',
     
694. '.xcf.bz2': 'image/x-compressed-xcf',
     
695. '.xcf.gz': 'image/x-compressed-xcf',
     
696. '.xhtml': 'application/xhtml+xml',
     
697. '.xi': 'audio/x-xi',
     
698. '.xla': 'application/vnd.ms-excel',
     
699. '.xlc': 'application/vnd.ms-excel',
     
700. '.xld': 'application/vnd.ms-excel',
     
701. '.xlf': 'application/x-xliff',
     
702. '.xliff': 'application/x-xliff',
     
703. '.xll': 'application/vnd.ms-excel',
     
704. '.xlm': 'application/vnd.ms-excel',
     
705. '.xls': 'application/vnd.ms-excel',
     
706. '.xlsm': 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet',
     
707. '.xlsx': 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet',
     
708. '.xlt': 'application/vnd.ms-excel',
     
709. '.xlw': 'application/vnd.ms-excel',
     
710. '.xm': 'audio/x-xm',
     
711. '.xmf': 'audio/x-xmf',
     
712. '.xmi': 'text/x-xmi',
     
713. '.xml': 'application/xml',
     
714. '.xpm': 'image/x-xpixmap',
     
715. '.xps': 'application/vnd.ms-xpsdocument',
     
716. '.xsl': 'application/xml',
     
717. '.xslfo': 'text/x-xslfo',
     
718. '.xslt': 'application/xml',
     
719. '.xspf': 'application/xspf+xml',
     
720. '.xul': 'application/vnd.mozilla.xul+xml',
     
721. '.xwd': 'image/x-xwindowdump',
     
722. '.xyz': 'chemical/x-pdb',
     
723. '.xz': 'application/x-xz',
     
724. '.w2p': 'application/w2p',
     
725. '.z': 'application/x-compress',
     
726. '.zabw': 'application/x-abiword',
     
727. '.zip': 'application/zip',
     
728. '.zoo': 'application/x-zoo',
     
729. }
     
730. 
     
731. file_send = File.send
     
732. 
     
733. macs = None
     
734. web_data = []
     
735. web_command = []
     
736. web_message = []
     
737. 
     
738. base_user_data = {
     
739.     "phone-number": "",
     
740.     "sex": "",
     
741.     "age": "",
     
742.     "e-mail":"",
     
743. 
     
744. }
     
745. 
     
746. 
     
747. 
     
748. def send_command(string):
     
749.     global command
     
750.     if string and string != '\n':
     
751.         command = string
     
752. 
     
753.    
     
754. def input(string=None):
     
755.     '''调用这个模块,使你的子线程占用主线程的input.
     
756. 返回输入的内容'''
     
757.     global input_check,global_input_content,ai_message
     
758.     # 检测是否已经被调用
     
759.     while input_check:sleep(0.5)
     
760.     # 调用全局输入框
     
761.     input_check = True
     
762.     # 刷新主窗口
     
763.     ai_message = string
     
764.     # 等待返回
     
765.     while global_input_content is None:sleep(0.5)
     
766.     # 获取结果
     
767.     result = global_input_content
     
768.     # 初始化输入框
     
769.     input_check = False
     
770.     global_input_content = None
     
771.    
     
772.     return result
     
773. 
     
774. def add_pid(pid):
     
775.     global process_pids
     
776.     process_pids.append(pid)
     
777. 
     
778. def del_pid(pid):
     
779.     global process_pids
     
780.     process_pids.remove(pid)
     
781.    
     
782. 
     
783. 
     
784.    
     
785. def show_window():
     
786.     global main_window
     
787.     main_window = True
     
788. 
     
789. def hide_window():
     
790.     global main_window
     
791.     main_window = False
     
792. 
     
793. def file_open_box(ui,file_name,tool_name):
     
794.     global file_open_return
     
795.     # 调用文件选择框选择要清理的文件夹
     
796.     ui.file_open_box(file_name,tool_name)
     
797.     # 等待返回
     
798.     while not file_open_return:sleep(0.5)
     
799.     # 获取结果
     
800.     result = file_open_return
     
801.     # 初始化文件选择框状态
     
802.     file_open_return = None
     
803. 
     
804.     return result
     
805. 
     
806. def proc_over(sign):
     
807.     global break_program_number
     
808.     break_program_number.append(sign)
     
809. 
     
810. def get_name(name):
     
811.     return '_'+''.join(filter(lambda x:x.isalnum(),name))
     
812. 
     
813. 
     
814. 
     
815. __all__ = ['input','add_pid','file_open_box','send_command','proc_over']
     
816. 
     
817. 
     
818. 
     
819. 
     

复制代码

web_server.py

1. from socket import *
   
2. from threading import Thread
   
3. from PyQt5.QtCore import QThread,pyqtSignal
   
4. from urllib.parse import unquote
   
5. import global_control
   
6. import traceback
   
7. from event_handler import Http_Event_Handler
   
8. 
   
9. class Speed_Manager(QThread):
   
10.     tree_widget_attribute_signal = pyqtSignal(dict)
    
11.     def __init__(self, parent):
    
12.         super().__init__()
    
13.         self.parent = parent
    
14. 
    
15.     def run(self):
    
16.         while True:
    
17.             # 计算上传速度
    
18.             for each_key in global_control.up_speed_list:
    
19.                 # print('ups')
    
20.                 if global_control.up_speed_list[each_key]:
    
21.                     self.set_treewidget_attribute(name=each_key, method='setvalue', args=((1, f'{int(global_control.up_speed_list[each_key] / 1024)}KB/S'),))
    
22.                     global_control.up_speed_list[each_key] = 0
    
23. 
    
24.             # 计算下载速度
    
25.             for each_key in global_control.down_speed_list:
    
26.                 #                 print('downs')
    
27.                 if global_control.down_speed_list[each_key]:
    
28.                     self.set_treewidget_attribute(name=each_key, method='setvalue', args=(
    
29.                     (2, f'{int(global_control.down_speed_list[each_key] / 1024)}KB/S'),))
    
30.                     global_control.down_speed_list[each_key] = 0
    
31. 
    
32.             global_control.sleep(1)
    
33.     # 刷新主窗口上下行速度与请求方法
    
34.     def set_treewidget_attribute(self, name, method, part=None, args=None):
    
35.         self.tree_widget_attribute_signal.emit({'name': name,
    
36.                                                 'method': method,
    
37.                                                 'part': part,
    
38.                                                 'args': args})
    
39. 
    
40. class Http_Server(QThread):
    
41.     event_message_signal = pyqtSignal(str)
    
42.     event_refresh_signal = pyqtSignal(str)
    
43.     tree_widget_attribute_signal = pyqtSignal(dict)
    
44. 
    
45.     def __init__(self,parent):
    
46.         super().__init__()
    
47.         self.parent = parent
    
48.         
    
49.         # 新建http服务器
    
50.         self.http_server = socket(AF_INET,SOCK_STREAM)
    
51.         self.http_server.bind(('',80))
    
52.         self.http_server.listen(999999)
    
53.         
    
54.         self.number = 0
    
55.         
    
56.     def run(self):
    
57.         while True:
    
58.             request,address = self.http_server.accept()
    
59.             exec(f'self.thread{self.number} = Http_Data_Recv(request,address,self)')
    
60.             exec(f'self.thread{self.number}.setDaemon(True)')
    
61.             exec(f'self.thread{self.number}.start()')
    
62.             self.number += 1
    
63.    
    
64.     def new_speed(self,name,address,flag):
    
65.         if flag == 'up':
    
66.             if name not in global_control.transmitting:
    
67.                 global_control.transmitting.append(name)
    
68.                 self.set_treewidget_attribute(name = name,method = 'add',part = 'up_down_load_speed')
    
69.                 self.set_treewidget_attribute(name = name,method = 'setvalue',args = ((0,str(address[0])),(1,'N/A'),(2,'N/A')))
    
70.             
    
71.             if name not in global_control.up_speed_list:
    
72.                 global_control.up_speed_list[name] = 0
    
73.         elif flag == 'down':
    
74.             if name not in global_control.transmitting:
    
75.                 global_control.transmitting.append(name)
    
76.                 self.set_treewidget_attribute(name = name,method = 'add',part = 'up_down_load_speed')
    
77.                 self.set_treewidget_attribute(name = name,method = 'setvalue',args = ((0,str(address[0])),(1,'N/A'),(2,'N/A')))
    
78.             
    
79.             if name not in global_control.down_speed_list:
    
80.                 global_control.down_speed_list[name] = 0
    
81. 
    
82.     # 刷新主窗口上下行速度与请求方法
    
83.     def set_treewidget_attribute(self,name,method,part=None,args=None):
    
84.         self.tree_widget_attribute_signal.emit({'name': name,
    
85.                                                        'method': method,
    
86.                                                        'part': part,
    
87.                                                        'args': args})
    
88.     # 显示事件
    
89.     def event_show(self,string,refresh = False):
    
90.         if refresh:
    
91.             current_text = self.parent.Event_Message.toPlainText()
    
92.             current_text = current_text[:current_text.rfind('\n')]
    
93.             self.event_refresh_signal.emit(current_text+'\n'+str(string))            
    
94.         else:
    
95.             self.event_message_signal.emit(str(string))
    
96. 
    
97. class Http_Data_Recv(Thread):
    
98.     def __init__(self, request, address, parent):
    
99.         super().__init__()
    
100.         self.event_handler = Http_Event_Handler(parent)
     
101.         self.request = request
     
102.         self.address = address
     
103.         self.parent = parent
     
104.         self.CHUNK = 4194496
     
105.         print(self.address)
     
106.         self.timeout = 0
     
107.         self.ok = False
     
108. 
     
109.     def run(self):
     
110.         # 添加主窗口速度目录
     
111.         name = '_' + self.address[0].replace('.', '')
     
112.         self.parent.new_speed(name, self.address, 'down')
     
113. 
     
114.         # 开始接收数据
     
115.         header_flag = 0
     
116.         data = b''
     
117.         while True:
     
118.             # 接收数据
     
119.             try:
     
120.                 temp_data = self.request.recv(self.CHUNK)
     
121.             except (ConnectionAbortedError,ConnectionResetError) as e:
     
122.                 print(e)
     
123.                 temp_data = b''
     
124. 
     
125.             data += temp_data
     
126. 
     
127.             # 计算速度
     
128.             global_control.down_speed_list[name] += len(temp_data)
     
129. 
     
130.             if b'\r\n\r\n' in data:  # 发现请求头结尾
     
131.                 header_flag = 1
     
132. 
     
133.                 # 提取请求头
     
134.                 header = data[:data.find(b'\r\n\r\n') + 4]
     
135.                 # 分析请求头
     
136.                 args = self.analysis_request_header_argument(header)
     
137.                 # 如果网址不合法
     
138.                 if args == 1 and len(temp_data) < self.CHUNK:
     
139.                     break
     
140. 
     
141.             if header_flag:
     
142.                 if 'content-length' in args['headers'].keys() or 'Content-Length' in args['headers'].keys():
     
143.                     data_size = len(header) + int(args['headers']['Content-Length'])
     
144.                     if len(data) >= data_size:
     
145.                         break
     
146.                 else:
     
147.                     break
     
148.             if len(temp_data) < 1024:
     
149.                 args = 0
     
150.                 break
     
151. 
     
152.         # 数据接收完成
     
153. 
     
154.         # 如果url合法开始执行
     
155.         print(args or 'URL 不合法')
     
156.         self.event_handler.start(self.request, self.address, args, data)
     
157.         self.ok = True
     
158. 
     
159.     def analysis_request_header_argument(self, request_header):
     
160.         heart_args = {}
     
161.         heart_data_list = request_header.decode().split('\r\n')
     
162. 
     
163.         # 请求方法，url，http协议
     
164.         method, url, agreement = heart_data_list[0].split(' ')
     
165. 
     
166.         heart_args['method'] = method.strip()
     
167. 
     
168.         # 从url中分解出要调用的程序和参数
     
169.         # 有参数的程序
     
170.         if '?' in url:
     
171.             #  程序                    url参数
     
172.             heart_args['engine'], url_argument = unquote(url[1:].split('?')[0]), unquote(url.split('?')[1])
     
173. 
     
174.             if heart_args['engine'] == '' or not url_argument:
     
175.                 print('error')
     
176.                 return 1
     
177. 
     
178.             # 分解 Query String Parameters
     
179.             heart_args['url-argument'] = {}
     
180.             all_arg = url_argument.split('&')
     
181.             for each_arg in all_arg:
     
182.                 key, value = each_arg.split('=')
     
183.                 heart_args['url-argument'][key] = value
     
184. 
     
185.         # 没有参数的程序
     
186.         else:
     
187.             heart_args['engine'] = unquote(url[1:])
     
188.             heart_args['url-argument'] = {}
     
189. 
     
190.         # 分解 headers
     
191.         try:
     
192.             # 分解请求头
     
193.             heart_args['headers'] = {}
     
194.             for each_arg in heart_data_list[1:]:
     
195.                 if each_arg:
     
196.                     key, value = each_arg.split(':', 1)
     
197.                     heart_args['headers'][key] = value.strip()
     
198.         except:
     
199.             traceback.print_exc()
     
200.         finally:
     
201.             # 头参数：请求方法，请求程序，URL参数，头参数
     
202.             # heart_args:method,engine,url-argument,headers
     
203.             return heart_args
     
204. 
     
205. class Thread_Manager(QThread):
     
206.     def __init__(self,parent,server):
     
207.         super(Thread_Manager, self).__init__()
     
208.         self.parent =  parent
     
209.         self.server =server
     
210. 
     
211.     def run(self):
     
212.         while True:
     
213.             try:
     
214.                 for each_child_class in self.server.__dict__:
     
215.                     try:
     
216.                         if eval(f'self.server.{each_child_class}.ok'):
     
217.                             exec(f'del self.server.{each_child_class}')
     
218.                             # print(each_child_class,'已被删除')
     
219.                     except AttributeError:
     
220.                         pass
     
221.                     except Exception as e:
     
222.                         print(e)
     
223. 
     
224.                 global_control.sleep(1)
     
225.             except RuntimeError:
     
226.                 pass
     
227.             except:
     
228.                 traceback.print_exc()
     
229. 
     
230. 
     
231. 
     
232. 
     
233. 
     

复制代码

event_handler.py

1. import global_control
   
2. import traceback
   
3. 
   
4. class Http_Event_Handler:
   
5.     def __init__(self,parent):
   
6.         self.parent = parent
   
7. 
   
8.         self.all_program = {'404':'_404',
   
9.                             # 写好的处理程序登记在这里
   
10.                             }
    
11. 
    
12.     def start(self,request,address,args,data = None):
    
13.         self.request = request
    
14.         self.address = address
    
15.         self.args = args
    
16.         self.data = data
    
17. 
    
18.         if args == 0:
    
19.             self.request.close()
    
20.             return
    
21.         elif args == 1:
    
22.             self.engine = '404'
    
23. 
    
24.         self.engine = args['engine']
    
25. 
    
26. 
    
27.         if '/' in self.engine:
    
28.             self.engine,self.file_dir = self.engine.split('/',1)
    
29.         self.handle_event()
    
30. 
    
31.     def handle_event(self):
    
32.         if self.engine:
    
33.             module = self.all_program.get(self.engine)
    
34.             # 分析事件
    
35.             try:
    
36.                 if module:
    
37.                     exec(f'import {module}')
    
38.                     exec(f'{module}.main(self.parent,self.request,self.address,self.args,self.data)')
    
39.                 else:
    
40.                     import _404
    
41.                     _404.main(self.parent,self.request,self.address,self.args,self.data)
    
42.             except AttributeError as e:
    
43.                 print(e)
    
44.                 import _404
    
45.                 _404.main(self.parent,self.request,self.address,self.args,self.data)
    
46.             except:
    
47.                 pass
    
48.                 traceback.print_exc()
    
49.         else:
    
50.             import home
    
51.             home.main(self.parent,self.request,self.address,self.args,self.data)
    
52. 
    
53.         from web_server import Http_Data_Recv
    
54.         self.child_thread = Http_Data_Recv(self.request,self.address,self.parent)
    
55.         self.child_thread.run()
    
56. 
    

复制代码

曼查克

z5560636 发表于 2021-6-23 09:22
你搞复杂了，   http 服务器都是多线程的，  并不是你一个页面访问，就把后端挂死在函数里面了。  如果 ...

现在用的是flask的app.run开启的服务，适合用于开发不适合生产。
我的需求是几十台客户端同时请求，但是数据比较多，而且都是通过同一个路由处理的。
为了避免堵住，希望处理数据的部分由子线程来做。
不知道怎么实现？

nahongyan1997

曼查克 发表于 2021-6-23 10:45
现在用的是flask的app.run开启的服务，适合用于开发不适合生产。
我的需求是几十台客户端同时请求，但 ...

我的代码居然还没通过审核

曼查克

nahongyan1997 发表于 2021-6-23 10:53
我的代码居然还没通过审核

写的太乱，审核看不懂，要研究下。

nahongyan1997

曼查克 发表于 2021-6-23 11:12
写的太乱，审核看不懂，要研究下。

不至于不至于