基于DrissionPage的表情包爬虫实现与解析（含源码）

目录

​编辑

一、环境配置与技术选型

1.1 环境要求

1.2 DrissionPage优势

二、爬虫实现代码

三、代码解析

3.1 类结构设计

3.2 目录创建方法

3.3 图片链接获取

3.4 图片下载方法

四、技术升级对比

4.1 代码复杂度对比

4.2 性能测试数据

五、扩展优化建议

5.1 并发下载优化

5.2 增量爬取功能

5.3 代理支持

六、常见问题解决

6.1 图片下载失败

6.2 反爬机制应对

6.3 断点续传实现

一、环境配置与技术选型

1.1 环境要求

• 操作系统：Ubuntu 19.04+

• Python版本：Python 3.6+

• 必要依赖：

  pip install drissionpage requests

1.2 DrissionPage优势

二、爬虫实现代码

#!/usr/bin/python3
# -*- coding: utf-8 -*-
from DrissionPage import SessionPage
import re
import os

class EmojiSpider:
    def __init__(self):
        # 创建页面对象
        self.page = SessionPage()
        # 目标网站URL
        self.url = ''
        # 图片保存目录
        self.save_dir = 'emojis'
        # 初始化计数器
        self.img_count = 0
        
    def create_save_dir(self):
        """创建图片保存目录"""
        if not os.path.exists(self.save_dir):
            os.makedirs(self.save_dir)
            print(f"创建目录：{self.save_dir}")

    def get_image_links(self):
        """获取图片链接"""
        # 访问目标页面
        self.page.get(self.url)
        
        # 定位所有图片元素
        img_elements = self.page.eles('tag:img')
        
        # 提取符合要求的图片链接
        jpg_links = []
        gif_links = []
        pattern = re.compile(r'http://w...sinaimg.cn/bmiddle/.+?\.(jpg|gif)')
        
        for img in img_elements:
            src = img.attr('src')
            if src:
                match = pattern.match(src)
                if match:
                    if match.group(1) == 'jpg':
                        jpg_links.append(src)
                    else:
                        gif_links.append(src)
        
        return jpg_links, gif_links

    def download_images(self, links, ext):
        """下载并保存图片"""
        for link in links:
            try:
                # 获取图片二进制数据
                img_data = self.page.download(link, show_msg=False)
                
                # 生成文件名
                filename = f"{self.img_count}.{ext}"
                save_path = os.path.join(self.save_dir, filename)
                
                # 保存文件
                with open(save_path, 'wb') as f:
                    f.write(img_data)
                
                print(f"已下载：{filename}")
                self.img_count += 1
            except Exception as e:
                print(f"下载失败：{link}，错误：{str(e)}")

    def run(self):
        """执行爬虫"""
        self.create_save_dir()
        jpg_links, gif_links = self.get_image_links()
        
        print(f"找到 {len(jpg_links)} 张JPG图片")
        print(f"找到 {len(gif_links)} 张GIF图片")
        
        self.download_images(jpg_links, 'jpg')
        self.download_images(gif_links, 'gif')
        
        print("全部下载完成！")

if __name__ == '__main__':
    spider = EmojiSpider()
    spider.run()

三、代码解析

3.1 类结构设计

class EmojiSpider:
    def __init__(self):
        self.page = SessionPage()  # 创建会话页面对象
        self.url = ''  # 目标网址
        self.save_dir = 'emojis'  # 保存目录
        self.img_count = 0  # 图片计数器

关键点：

• 使用SessionPage实现高效请求

• 统一管理配置参数

• 计数器确保文件名唯一

3.2 目录创建方法

def create_save_dir(self):
    if not os.path.exists(self.save_dir):
        os.makedirs(self.save_dir)

作用：

• 检查并创建图片存储目录

• 避免重复创建导致的异常

3.3 图片链接获取

def get_image_links(self):
    self.page.get(self.url)  # 访问目标页面
    img_elements = self.page.eles('tag:img')  # 获取所有img元素
    
    # 使用正则筛选有效链接
    pattern = re.compile(r'http://w...sinaimg.cn/bmiddle/.+?\.(jpg|gif)')
    ...

技术细节：

• page.get()自动处理编码和重定向

• eles()方法支持CSS选择器定位元素

• 正则表达式r'http://w...sinaimg.cn/bmiddle/.+?\.(jpg|gif)'解析：

  • w...sinaimg.cn匹配包含sinaimg的域名

  • .+?非贪婪匹配任意字符

  • 分组匹配图片后缀

3.4 图片下载方法

def download_images(self, links, ext):
    for link in links:
        img_data = self.page.download(link, show_msg=False)  # 下载文件
        filename = f"{self.img_count}.{ext}"
        ...

优势：

• page.download()内置重试机制

• show_msg=False关闭控制台提示

• 统一计数器避免文件名冲突

四、技术升级对比

4.1 代码复杂度对比

4.2 性能测试数据

五、扩展优化建议

5.1 并发下载优化

from concurrent.futures import ThreadPoolExecutor

def download_images(self, links, ext):
    with ThreadPoolExecutor(max_workers=8) as executor:
        futures = []
        for link in links:
            futures.append(executor.submit(self._download_single, link, ext))
        
def _download_single(self, link, ext):
    # 单文件下载逻辑

5.2 增量爬取功能

def load_progress(self):
    if os.path.exists('progress.json'):
        with open('progress.json') as f:
            return json.load(f)
    return {'last_count': 0}

def save_progress(self):
    with open('progress.json', 'w') as f:
        json.dump({'last_count': self.img_count}, f)

5.3 代理支持

self.page.set.proxies({
    'http': 'http://user:pass@host:port',
    'https': 'https://user:pass@host:port'
})

六、常见问题解决

6.1 图片下载失败

现象：部分GIF文件无法打开
解决方案：

# 添加文件头验证
if img_data[:4] == b'GIF8':
    # 确认是有效GIF文件
elif img_data[:3] == b'\xff\xd8\xff':
    # 确认是JPG文件
else:
    print("无效图片文件")

6.2 反爬机制应对

# 设置随机请求头
headers = {
    'User-Agent': random.choice(USER_AGENT_LIST),
    'Referer': 'https://www.fabiaoqing.com/'
}
self.page.headers.update(headers)

6.3 断点续传实现

# 记录已下载文件
downloaded = set()
if filename in downloaded:
    continue

完整项目代码已托管至Github仓库，包含详细文档和测试用例。建议结合代理服务和定时任务实现企业级部署。