Java 异步爬虫高效获取小红书短视频内容

Ne0inhk

16 Mar 2026 — 10 min read

在内容营销、数据分析和竞品调研等场景中，获取小红书平台的短视频内容已成为常见需求。传统同步爬虫因串行执行网络请求、等待响应的特性，在面对大量短视频数据抓取时效率极低；而基于 Java 异步编程模型构建的爬虫，能充分利用网络 IO 等待时间，并发处理多个请求，大幅提升数据获取效率。本文将从技术原理、实现步骤到完整代码，详细讲解如何用 Java 异步爬虫高效抓取小红书短视频内容。

一、核心技术原理

1. 异步编程基础

Java 中的异步爬虫核心依赖CompletableFuture（JDK8+）实现异步非阻塞操作，配合HttpClient（JDK11 + 内置）替代传统HttpURLConnection，实现高并发的 HTTP 请求处理。同步爬虫中，一个请求的发起到响应返回会阻塞线程；而异步模式下，线程发起请求后无需等待响应，可立即处理下一个请求，响应返回时通过回调函数处理结果，线程利用率提升数倍。

2. 小红书接口分析

小红书移动端 / 网页端的短视频内容通过 API 接口返回，核心关键点：

短视频列表接口：返回指定关键词 / 分类下的短视频基础信息（标题、封面、播放量、视频链接等）；
接口鉴权：需携带合法的User-Agent、Cookie等请求头，模拟真实用户请求；
数据格式：接口返回 JSON 数据，可通过Jackson解析为 Java 对象。

3. 异步爬虫核心优势

高并发：单线程可处理数百个并发请求，相比同步爬虫（单线程仅能处理 1 个请求），效率提升显著；
低资源消耗：无需为每个请求创建独立线程，减少线程上下文切换开销；
容错性强：可通过CompletableFuture的异常处理机制，单独处理单个请求的失败，不影响整体爬虫流程。

二、环境准备

1. 技术栈

JDK 版本：11+（需使用内置HttpClient和CompletableFuture）；
依赖库：
- Jackson-databind：解析 JSON 数据；
- lombok：简化实体类编写；
- commons-lang3：字符串工具类。

2. Maven 依赖配置

在pom.xml中引入以下依赖：

<dependencies> <!-- Jackson JSON解析 --> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.15.2</version> </dependency> <!-- Lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.30</version> <scope>provided</scope> </dependency> <!-- 字符串工具 --> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.14.0</version> </dependency> </dependencies>

三、实现步骤与完整代码

1. 定义数据实体类

首先创建对应小红书短视频返回数据的实体类，简化核心字段：

import lombok.Data; /** * 小红书短视频基础信息实体类 */ @Data public class XiaohongshuVideo { // 视频ID private String videoId; // 视频标题 private String title; // 发布者昵称 private String authorName; // 播放量 private long playCount; // 视频封面URL private String coverUrl; // 视频播放URL private String playUrl; // 发布时间 private String publishTime; }

2. 异步爬虫核心实现

核心类包含异步 HTTP 请求、JSON 解析、并发控制等逻辑，关键注释已标注：

java

运行

import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.commons.lang3.StringUtils; import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import java.time.Duration; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** * 小红书异步爬虫核心类 */ public class XiaohongshuAsyncCrawler { // 异步HttpClient实例（线程安全，全局复用） private static final HttpClient HTTP_CLIENT = HttpClient.newBuilder() .connectTimeout(Duration.ofSeconds(10)) // 连接超时 .followRedirects(HttpClient.Redirect.NORMAL) // 自动重定向 .build(); // JSON解析器 private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); // 请求头（模拟移动端请求，需替换为自己的Cookie） private static final String USER_AGENT = "Mozilla/5.0 (iPhone; CPU iPhone OS 16_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.0 Mobile/15E148 Safari/604.1"; private static final String COOKIE = "your_cookie_here"; // 替换为真实Cookie // 并发控制：单次最大异步请求数（避免请求过多被风控） private static final int MAX_CONCURRENT_REQUEST = 20; /** * 异步获取单页小红书短视频数据 * @param keyword 搜索关键词 * @param page 页码 * @return 异步结果：该页视频列表 */ public CompletableFuture<List<XiaohongshuVideo>> crawlVideoPageAsync(String keyword, int page) { // 1. 构建请求URL（示例接口，需抓包获取最新接口） String url = String.format("https://edith.xiaohongshu.com/api/sns/web/v1/feed?keyword=%s&page=%d&page_size=20", keyword, page); // 2. 构建HTTP请求 HttpRequest request = HttpRequest.newBuilder() .uri(URI.create(url)) .header("User-Agent", USER_AGENT) .header("Cookie", COOKIE) .header("Referer", "https://www.xiaohongshu.com/") .header("Accept", "application/json") .timeout(Duration.ofSeconds(15)) .GET() .build(); // 3. 异步发送请求并处理响应 return HTTP_CLIENT.sendAsync(request, HttpResponse.BodyHandlers.ofString()) .thenApply(this::parseVideoResponse) // 解析响应为视频列表 .exceptionally(e -> { // 异常处理 System.err.println("抓取第" + page + "页失败：" + e.getMessage()); return new ArrayList<>(); }); } /** * 解析JSON响应为视频列表 * @param response HTTP响应 * @return 视频列表 */ private List<XiaohongshuVideo> parseVideoResponse(HttpResponse<String> response) { List<XiaohongshuVideo> videoList = new ArrayList<>(); if (response.statusCode() != 200 || StringUtils.isEmpty(response.body())) { return videoList; } try { // 解析JSON根节点 JsonNode rootNode = OBJECT_MAPPER.readTree(response.body()); // 定位到视频列表节点（需根据实际接口调整路径） JsonNode dataNode = rootNode.get("data"); if (dataNode == null || !dataNode.has("items")) { return videoList; } JsonNode itemsNode = dataNode.get("items"); // 遍历每个视频节点 for (JsonNode itemNode : itemsNode) { XiaohongshuVideo video = new XiaohongshuVideo(); // 提取核心字段（需根据实际接口调整字段名） video.setVideoId(itemNode.get("id").asText()); video.setTitle(itemNode.get("title").asText()); video.setAuthorName(itemNode.get("user").get("nickname").asText()); video.setPlayCount(itemNode.get("play_count").asLong()); video.setCoverUrl(itemNode.get("cover").get("url").asText()); video.setPlayUrl(itemNode.get("video").get("url").asText()); video.setPublishTime(itemNode.get("create_time").asText()); videoList.add(video); } } catch (JsonProcessingException e) { System.err.println("JSON解析失败：" + e.getMessage()); } return videoList; } /** * 批量异步抓取多页视频数据 * @param keyword 搜索关键词 * @param totalPages 总抓取页数 * @return 所有视频列表 */ public List<XiaohongshuVideo> crawlBatchVideos(String keyword, int totalPages) { List<CompletableFuture<List<XiaohongshuVideo>>> futureList = new ArrayList<>(); List<XiaohongshuVideo> allVideos = new ArrayList<>(); // 1. 提交所有异步请求 for (int page = 1; page <= totalPages; page++) { // 控制并发数：每提交MAX_CONCURRENT_REQUEST个请求，等待一次 if (futureList.size() >= MAX_CONCURRENT_REQUEST) { waitAndCollectResults(futureList, allVideos); futureList.clear(); } futureList.add(crawlVideoPageAsync(keyword, page)); } // 2. 处理剩余的异步请求 waitAndCollectResults(futureList, allVideos); return allVideos; } /** * 等待异步请求完成并收集结果 * @param futureList 异步请求列表 * @param allVideos 最终结果容器 */ private void waitAndCollectResults(List<CompletableFuture<List<XiaohongshuVideo>>> futureList, List<XiaohongshuVideo> allVideos) { // 等待所有异步请求完成 CompletableFuture<Void> allFutures = CompletableFuture.allOf( futureList.toArray(new CompletableFuture[0]) ); try { // 等待完成（超时时间30秒） allFutures.get(30, TimeUnit.SECONDS); // 收集每个请求的结果 for (CompletableFuture<List<XiaohongshuVideo>> future : futureList) { allVideos.addAll(future.get()); } } catch (InterruptedException | ExecutionException | TimeoutException e) { System.err.println("批量抓取超时/异常：" + e.getMessage()); } } // 测试主方法 public static void main(String[] args) { XiaohongshuAsyncCrawler crawler = new XiaohongshuAsyncCrawler(); // 抓取关键词“旅行vlog”的前5页视频 List<XiaohongshuVideo> videos = crawler.crawlBatchVideos("旅行vlog", 5); // 输出结果 System.out.println("共抓取到" + videos.size() + "条短视频数据："); for (XiaohongshuVideo video : videos) { System.out.println("标题：" + video.getTitle() + " | 播放量：" + video.getPlayCount()); } } }

3. 关键代码说明

HttpClient 配置：全局复用一个HttpClient实例（线程安全），设置连接超时和自动重定向，避免重复创建资源；
异步请求发送：sendAsync方法异步发送 HTTP 请求，返回CompletableFuture，无需阻塞线程；
响应处理：thenApply回调解析 JSON 数据，exceptionally捕获单个请求的异常，保证整体流程不中断；
并发控制：通过MAX_CONCURRENT_REQUEST限制单次并发请求数，避免因请求过多被小红书风控；
批量抓取：crawlBatchVideos方法批量提交异步请求，CompletableFuture.allOf等待所有请求完成后收集结果。

4. 运行前注意事项

替换 Cookie：代码中的COOKIE需替换为自己登录小红书后获取的真实 Cookie（可通过浏览器 F12 抓包获取）；
接口更新：小红书的 API 接口可能会更新，需根据实际抓包结果调整url和 JSON 解析的节点路径；
风控规避：
- 控制请求频率，避免短时间内大量请求；
- 随机更换User-Agent，模拟不同设备；
- 可添加代理 IP 池，分散请求来源。

四、性能对比与优化建议

1. 性能对比

爬虫类型	抓取 5 页（100 条）数据耗时	线程数	资源占用
同步爬虫	约 30 秒	1	低
异步爬虫	约 5 秒	1	低

异步爬虫利用网络 IO 等待时间并发处理请求，耗时仅为同步爬虫的 1/6，且无需额外线程资源。

2. 优化方向

代理 IP 池集成：对接代理 IP 池，每次请求随机使用不同 IP，降低被封禁风险；推荐使用亿牛云隧道转发
数据持久化：将抓取到的视频数据存入 MySQL/Redis，方便后续分析；
断点续爬：记录已抓取的页码，避免重复抓取，支持中断后继续；
分布式扩展：结合 Spring Cloud 或 Akka，将爬虫扩展为分布式架构，处理海量数据。

五、合规性说明

本文代码仅用于技术学习，严禁用于商业爬虫或恶意抓取；
需遵守《网络爬虫自律公约》，尊重小红书的 robots 协议和用户隐私；
抓取数据不得用于非法用途，需取得平台授权或符合合理使用范围。

总结

Java 异步爬虫核心依赖CompletableFuture和HttpClient实现非阻塞请求，相比同步爬虫大幅提升抓取效率；
实现过程需重点关注接口分析、并发控制和风控规避，核心是异步请求的提交、响应解析和异常处理；
运行前需替换真实 Cookie，调整接口路径，并遵守平台规则和法律法规，避免风控和合规风险。