资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/Python3结合Sciter编写桌面程序第三节

Python3结合Sciter编写桌面程序第三节

fobnn / 2679人阅读

摘要：第三节协程继续基础框架搭好了，下面来正式的来一个项目吧全球设计师的作品展示平台就从这拉几张图吧，具体的网页解析方式网上有很多，在此略过，我已经取出了一些图片地址，保存在了里，这次就用这些吧。

第三节 协程！？

继续...基础框架搭好了，下面来正式的来一个项目吧

behance

全球设计师的作品展示平台

就从这拉几张图吧，具体的网页解析方式网上有很多，在此略过，我已经取出了一些图片地址，保存在了list.txt里，这次就用这些吧。

综合多种因素，最后选用了协程来下载图片

即asyncio

框架则用了aiohttp

实现思路：

目的

将网络上的图片（最好是缩略图）先下载到本地，记录图片信息，比如ID以便获得更高质量的图片，将图片显示到界面

问题

为了更快速的展示页面，我需要同时下载一定数量的图片...

我需要动态的将下载任务发送给后台服务...

这里可以在程序启动的时候设置一个配置列表cfg

</>复制代码 
  1. from os import path as osPath, getcwd, mkdir
  2. ...
  3. def __init__(self):
  4.     ...
  5.     self.cfg = self.initCfg()
  6. def initCfg(self):
  7.         cfg = {}
  8.         # 代理，没有可不用设置
  9.         # cfg["proxies"] = "127.0.0.1:61274"
  10.         # 加载图片列表
  11.         filename = "list.txt"
  12.         if osPath.exists(filename):
  13.             with open(filename, "r") as f:
  14.                 cfg["picList"] = f.read().strip().split("
  15. ")
  16.         # 设置图片的保存位置
  17.         current_folder = getcwd()
  18.         cfg["pic_temp"] = osPath.join( current_folder, "pic_temp")
  19.         if not osPath.isdir( cfg["pic_temp"] ):
  20.             mkdir(cfg["pic_temp"])
  21.         return cfg

然后传递给服务进程就可以了

</>复制代码 
  1. p = Process(target = startServiceP, args = ( self.GuiQueue, self.ServiceQueue, self.cfg ))

先来修改一下html的内容，添加一个自定义控件，用来存放图片：

</>复制代码 
  2.     
  3.

在服务进程ServiceEvent里添加一个方法getPicByList()

</>复制代码 
  1. def getPicByList(self, msg):
  2.         # 为图片创建占位图
  3.         imgidList = self.__creatPlaceholderImg()
  4.         for imgid in imgidList:
  5.             picHttp = self.cfg["picList"].pop(0)
  6.             file_name = picHttp.split("/")[-1]
  7.             file_path = osPath.join( self.cfg["pic_temp"], file_name )
  8.             # 图片下载完成后需要执行的任务
  9.             _GuiRecvMsgDict = {
  10.                 "fun" : "setImgBg",
  11.                 "msg" : {"id":imgid,"fpath":file_path}
  12.             }
  13.             if not osPath.isfile(file_path):
  14.                 # 将下载任务动态添加到协程循环中
  15.                 self.__run_coroutine_threadsafe(
  16.                     {"id": imgid,"http": picHttp,"fpath": file_path},
  17.                     _GuiRecvMsgDict
  18.                 )
  19.             else:
  20.                 self.__putGui( "setImgBg", {"id":imgid,"fpath":file_path} )

当用户点击下载图片的按钮后会执行到这个方法，为了更好的体验，在图片下载之前先为其占据了空间，可以在其上显示loading动画，更重要的一点是，通过它可以控制图片的显示顺序，因为用协程下载图片，你无法预知完成的顺序...

</>复制代码 
  1. def __creatPlaceholderImg(self):
  2.         # 先创建5个占位图
  3.         html = ""
  4.         imgidList = []
  5.         time_now = ""
  6.         for i in range(0, 5):
  7.             time_now = "-".join( ( str(i), str(time()) ) )
  8.             # 储存图片的id
  9.             imgidList.append( time_now )
  10.             html += self.html % ( time_now )
  11.         self.__putGui("creatPlaceholderImg", html)
  12.         return imgidList

之后就到了动态创建协程的部分了

</>复制代码 
  1. def __run_coroutine_threadsafe(self, data, _GuiRecvMsgDict):
  2.         asyncio.run_coroutine_threadsafe(self.dld.stream_download(
  3.             data,
  4.             _GuiRecvMsgDict
  5.         ), self.new_loop)

但在正式介绍run_coroutine_threadsafe()之前，我们需要先开启一个协程循环

但我们已经开启了一个用于处理队列的循环了，没办法再开一个（也不排除是咱太菜），于是另开了一个线程专来处理协程

</>复制代码 
  1. class ServiceEvent(object):
  2.     """服务进程"""
  3.     def __init__(self, _GuiQueue, cfg):
  4.         ...
  5.         # 主线程中创建一个事件循环
  6.         self.new_loop = asyncio.new_event_loop()
  7.         self.dld = AsyncioDownload( self.new_loop, self.GuiQueue, self.proxies )
</>复制代码 
  1. class AsyncioDownload(object):
  2.     """使用协程下载图片"""
  3.     def __init__(self, loop, _GuiRecvMsg, proxies=None ):
  4.         self.GuiRecvMsg = _GuiRecvMsg
  5.         self._session = None
  6.         self.loop = loop
  7.         self.prox = "".join(("http://", proxies)) if proxies else proxies
  8.         self.timeout = 10
  9.         # 启动一个线程，传递主线程中创建的事件循环
  10.         t = Thread(target=self.start_loop, args=(self.loop,))
  11.         t.setDaemon(True)    # 设置子线程为守护线程
  12.         t.start()
  13.     def start_loop(self, loop):
  14.         # 启动事件循环
  15.         asyncio.set_event_loop(loop)
  16.         loop.run_forever()
  17.     def __session(self):
  18.         if self._session is None:
  19.             self._session = aiohttp.ClientSession(loop=self.loop)
  20.         return self._session
  21.     async def stream_download(self, d, _GuiRecvMsgDict):
  22.         try:
  23.             client = self.__session()
  24.             async with client.get( d["http"], proxy=self.prox, timeout=self.timeout) as response:
  25.                 if response.status != 200:
  26.                     print("error")
  27.                     return
  28.                 # 保存图片到本地
  29.                 if not osPath.isfile(d["fpath"]):
  30.                     with open(d["fpath"], "ab") as file:
  31.                         while True:
  32.                             chunk = await response.content.read(1024)
  33.                             if not chunk:
  34.                                 break
  35.                             file.write(chunk)
  36.                 # 图片下载完成后告知主线程
  37.                 self.GuiRecvMsg.put(_GuiRecvMsgDict)
  38.         except asyncio.TimeoutError:
  39.             pass

最后，主进程获得图片的id及路径，显示到窗口中

</>复制代码 
  1. function setImgBg( d ){
  2.     var div = $(div[imgid="{d.id}"]);
  3.     if(div){
  4.         div.post( ::this.style#background-image = "url(" + d.fpath + ")" );
  5.     }
  6. }

源码

总结：

完成这个项目使用了

多进程 ---- 后台服务

多线程 ---- 事件循环

协程 ---- IO操作

相对一个单纯的爬虫脚本来说，还是有点复杂的，尤其是交互，难怪这么多人不愿意写界面...

虽然还有不足，但本次项目的内容就到这了。

谢谢。

GPU云服务器 云服务器 第三节 webrtc结合electron桌面分享 Sciter 安卓程序编写

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/40761.html

相关文章

发表评论

登陆后可评论

0条评论

fobnn

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<