PanSou是一个高性能的网盘资源搜索API服务,支持TG搜索和网盘搜索引擎。系统设计以性能和可扩展性为核心,支持多频道并发搜索、结果智能排序和网盘类型分类。
- 高性能搜索:并发搜索多个Telegram频道,显著提升搜索速度;工作池设计,高效管理并发任务
- 网盘类型分类:自动识别多种网盘链接,按类型归类展示
- 智能排序:基于时间和关键词权重的多级排序策略
- 插件系统:支持通过插件扩展搜索来源,已内置多个网盘搜索插件;支持"尽快响应,持续处理"的异步搜索模式
- 两级缓存:内存+磁盘缓存机制,大幅提升重复查询速度;异步插件缓存自动保存到磁盘,系统重启后自动恢复,
- 百度网盘 (
pan.baidu.com
) - 阿里云盘 (
aliyundrive.com
,alipan.com
) - 夸克网盘 (
pan.quark.cn
) - 天翼云盘 (
cloud.189.cn
) - UC网盘 (
drive.uc.cn
) - 移动云盘 (
caiyun.139.com
) - 115网盘 (
115.com
,115cdn.com
,anxia.com
) - PikPak (
mypikpak.com
) - 迅雷网盘 (
pan.xunlei.com
) - 123网盘 (
123684.com
,123685.com
,123912.com
,123pan.com
,123pan.cn
,123592.com
) - 磁力链接 (
magnet:?xt=urn:btih:
) - 电驴链接 (
ed2k://
)
PanSou内置了多个网盘搜索插件,可以扩展搜索来源
- Go 1.18+
- 可选:SOCKS5代理(用于访问受限地区的Telegram站点)
- 克隆仓库
git clone https://github.com/fish2018/pansou.git
cd pansou
- 配置环境变量(可选)
# 默认频道
export CHANNELS="tgsearchers2,xxx"
# 缓存配置
export CACHE_ENABLED=true
export CACHE_PATH="./cache"
export CACHE_MAX_SIZE=100 # MB
export CACHE_TTL=60 # 分钟
# 异步插件配置
export ASYNC_PLUGIN_ENABLED=true
export ASYNC_RESPONSE_TIMEOUT=2 # 响应超时时间(秒)
export ASYNC_MAX_BACKGROUND_WORKERS=20 # 最大后台工作者数量
export ASYNC_MAX_BACKGROUND_TASKS=100 # 最大后台任务数量
export ASYNC_CACHE_TTL_HOURS=1 # 异步缓存有效期(小时)
# 代理配置(如需)
export PROXY="socks5://127.0.0.1:7890"
- 构建
CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -ldflags="-s -w -extldflags '-static'" -o pansou .
- 运行
./pansou
搜索网盘资源。
接口地址:/api/search
请求方法:POST
或 GET
Content-Type:application/json
(POST方法)
POST请求参数:
参数名 | 类型 | 必填 | 描述 |
---|---|---|---|
kw | string | 是 | 搜索关键词 |
channels | string[] | 否 | 搜索的频道列表,不提供则使用默认配置 |
conc | number | 否 | 并发搜索数量,不提供则自动设置为频道数+插件数+10 |
refresh | boolean | 否 | 强制刷新,不使用缓存,便于调试和获取最新数据 |
res | string | 否 | 结果类型:all(返回所有结果)、results(仅返回results)、merge(仅返回merged_by_type),默认为merge |
src | string | 否 | 数据来源类型:all(默认,全部来源)、tg(仅Telegram)、plugin(仅插件) |
plugins | string[] | 否 | 指定搜索的插件列表,不指定则搜索全部插件 |
GET请求参数:
参数名 | 类型 | 必填 | 描述 |
---|---|---|---|
kw | string | 是 | 搜索关键词 |
channels | string | 否 | 搜索的频道列表,使用英文逗号分隔多个频道,不提供则使用默认配置 |
conc | number | 否 | 并发搜索数量,不提供则自动设置为频道数+插件数+10 |
refresh | boolean | 否 | 强制刷新,设置为"true"表示不使用缓存 |
res | string | 否 | 结果类型:all(返回所有结果)、results(仅返回results)、merge(仅返回merged_by_type),默认为merge |
src | string | 否 | 数据来源类型:all(默认,全部来源)、tg(仅Telegram)、plugin(仅插件) |
plugins | string | 否 | 指定搜索的插件列表,使用英文逗号分隔多个插件名,不指定则搜索全部插件 |
POST请求示例:
{
"kw": "速度与激情",
"channels": ["tgsearchers2", "xxx"],
"conc": 2,
"refresh": true,
"res": "merge",
"src": "all",
"plugins": ["jikepan"]
}
GET请求示例:
GET /api/search?kw=速度与激情&channels=tgsearchers2,xxx&conc=2&refresh=true&res=merge&src=tg
成功响应:
{
"total": 15,
"results": [
{
"message_id": "12345",
"unique_id": "channel-12345",
"channel": "tgsearchers2",
"datetime": "2023-06-10T14:23:45Z",
"title": "速度与激情全集1-10",
"content": "速度与激情系列全集,1080P高清...",
"links": [
{
"type": "baidu",
"url": "https://pan.baidu.com/s/1abcdef",
"password": "1234"
}
],
"tags": ["电影", "合集"]
},
// 更多结果...
],
"merged_by_type": {
"baidu": [
{
"url": "https://pan.baidu.com/s/1abcdef",
"password": "1234",
"note": "速度与激情全集1-10",
"datetime": "2023-06-10T14:23:45Z"
},
// 更多百度网盘链接...
],
"aliyun": [
// 阿里云盘链接...
]
// 更多网盘类型...
}
}
错误响应:
{
"code": 400,
"message": "关键词不能为空"
}
检查API服务是否正常运行。
接口地址:/api/health
请求方法:GET
成功响应:
{
"status": "ok",
}
环境变量 | 描述 | 默认值 |
---|---|---|
CHANNELS | 默认搜索频道列表(逗号分隔) | tgsearchers2 |
CONCURRENCY | 默认并发数 | 频道数+插件数+10 |
PORT | 服务端口 | 8080 |
PROXY | SOCKS5代理 | - |
CACHE_ENABLED | 是否启用缓存 | true |
CACHE_PATH | 缓存文件路径 | ./cache |
CACHE_MAX_SIZE | 最大缓存大小(MB) | 100 |
CACHE_TTL | 缓存生存时间(分钟) | 60 |
ENABLE_COMPRESSION | 是否启用压缩 | false |
MIN_SIZE_TO_COMPRESS | 最小压缩阈值(字节) | 1024 |
GC_PERCENT | GC触发百分比 | 100 |
OPTIMIZE_MEMORY | 是否优化内存 | true |
PLUGIN_TIMEOUT | 插件执行超时时间(秒) | 30 |
ASYNC_PLUGIN_ENABLED | 是否启用异步插件 | true |
ASYNC_RESPONSE_TIMEOUT | 异步响应超时时间(秒) | 4 |
ASYNC_MAX_BACKGROUND_WORKERS | 最大后台工作者数量 | 20 |
ASYNC_MAX_BACKGROUND_TASKS | 最大后台任务数量 | 100 |
ASYNC_CACHE_TTL_HOURS | 异步缓存有效期(小时) | 1 |
PanSou 实现了多项性能优化技术:
- JSON处理优化:使用 sonic 高性能 JSON 库
- 内存优化:预分配策略、对象池化、GC参数优化
- 缓存优化:两级缓存、异步写入、优化键生成
- HTTP客户端优化:连接池、HTTP/2支持
- 并发优化:工作池、智能并发控制
- 传输压缩:支持 gzip 压缩
- 异步插件缓存:持久化缓存、即时保存、优雅关闭机制
PanSou实现了高级异步插件系统,解决了某些搜索源响应时间长的问题:
- 双级超时控制:短超时(2秒)确保快速响应,长超时(30秒)允许完整处理
- 持久化缓存:缓存自动保存到磁盘,系统重启后自动恢复
- 即时保存:缓存更新后立即触发保存,不再等待定时器
- 优雅关闭:在程序退出前保存缓存,确保数据不丢失
- 增量更新:智能合并新旧结果,保留有价值的数据
- 后台自动刷新:对于接近过期的缓存,在后台自动刷新
- 资源管理:通过工作池控制并发任务数量,避免资源耗尽
- 缓存检查:首先检查是否有有效缓存
- 快速响应:如果有缓存,立即返回;如果缓存接近过期,在后台刷新
- 双通道处理:如果没有缓存,启动快速响应通道和后台处理通道
- 超时控制:在响应超时时返回当前结果(可能为空),后台继续处理
- 缓存更新:后台处理完成后更新缓存,供后续查询使用
PanSou 实现了灵活的插件系统,允许轻松扩展搜索来源
详情参考插件开发指南.md
- 自动注册机制:插件通过init函数自动注册,无需修改主程序代码
- 统一接口:所有插件实现相同的SearchPlugin接口
- 双层超时控制:插件内部使用自定义超时时间,系统外部提供强制超时保障
- 并发执行:插件搜索与频道搜索并发执行,提高整体性能
- 结果标准化:插件返回标准化的搜索结果,便于统一处理
- 异步处理:支持异步插件,实现"尽快响应,持续处理"的模式
- 创建新的插件包:
package myplugin
import (
"pansou/model"
"pansou/plugin"
)
// 在init函数中注册插件
func init() {
plugin.RegisterGlobalPlugin(NewMyPlugin())
}
// MyPlugin 自定义插件
type MyPlugin struct {}
// NewMyPlugin 创建新的插件实例
func NewMyPlugin() *MyPlugin {
return &MyPlugin{}
}
// Name 返回插件名称
func (p *MyPlugin) Name() string {
return "myplugin"
}
// Priority 返回插件优先级
func (p *MyPlugin) Priority() int {
return 3 // 中等优先级
}
// Search 执行搜索并返回结果
func (p *MyPlugin) Search(keyword string) ([]model.SearchResult, error) {
// 实现搜索逻辑
// ...
return results, nil
}
- 在main.go中导入插件包:
import (
// 导入插件包以触发init函数
_ "pansou/plugin/myplugin"
)
"channels": ["tgsearchers2","SharePanBaidu", "yunpanxunlei", "tianyifc", "BaiduCloudDisk", "txtyzy", "peccxinpd", "gotopan", "xingqiump4", "yunpanqk", "PanjClub", "kkxlzy", "baicaoZY", "MCPH01", "share_aliyun", "pan115_share", "bdwpzhpd", "ysxb48", "pankuake_share", "jdjdn1111", "yggpan", "yunpanall", "MCPH086", "zaihuayun", "Q66Share", "NewAliPan", "Oscar_4Kmovies", "ucwpzy", "alyp_TV", "alyp_4K_Movies", "shareAliyun", "alyp_1", "yunpanpan", "hao115", "yunpanshare", "dianyingshare", "Quark_Movies", "XiangxiuNB", "NewQuark", "ydypzyfx", "kuakeyun", "ucquark", "xx123pan", "yingshifenxiang123", "zyfb123", "pan123pan", "tyypzhpd", "tianyirigeng", "cloudtianyi", "hdhhd21", "Lsp115", "oneonefivewpfx", "Maidanglaocom", "qixingzhenren", "taoxgzy", "tgsearchers115", "Channel_Shares_115", "tyysypzypd", "vip115hot", "wp123zy", "yunpan139", "yunpan189", "yunpanuc", "yydf_hzl", "alyp_Animation", "alyp_JLP","leoziyuan"]
supervisor配置参考
[program:pansou]
environment=PORT=9999,CHANNELS="SharePanBaidu,yunpanxunlei,tianyifc,BaiduCloudDisk,txtyzy,peccxinpd,gotopan,xingqiump4,yunpanqk,PanjClub,kkxlzy,baicaoZY,MCPH01,share_aliyun,pan115_share,bdwpzhpd,ysxb48,pankuake_share,jdjdn1111,yggpan,yunpanall,MCPH086,zaihuayun,Q66Share,NewAliPan,Oscar_4Kmovies,ucwpzy,alyp_TV,alyp_4K_Movies,shareAliyun,alyp_1,yunpanpan,hao115,yunpanshare,dianyingshare,Quark_Movies,XiangxiuNB,NewQuark,ydypzyfx,kuakeyun,ucquark,xx123pan,yingshifenxiang123,zyfb123,pan123pan,tyypzhpd,tianyirigeng,cloudtianyi,hdhhd21,Lsp115,oneonefivewpfx,Maidanglaocom,qixingzhenren,taoxgzy,tgsearchers115,Channel_Shares_115,tyysypzypd,vip115hot,wp123zy,yunpan139,yunpan189,yunpanuc,yydf_hzl,alyp_Animation,alyp_JLP,tgsearchers2,leoziyuan"
command=/home/work/pansou/pansou
directory=/home/work/pansou
autostart=true
autorestart=true
startsecs=5
startretries=3
exitcodes=0
stopwaitsecs=10
stopasgroup=true
killasgroup=true
nginx配置参考
server {
listen 80;
server_name pansou.252035.xyz;
# 将 HTTP 重定向到 HTTPS
return 301 https://$host$request_uri;
}
server {
listen 443 ssl http2; # 添加 http2
server_name pansou.252035.xyz;
# 证书和密钥路径
ssl_certificate /etc/letsencrypt/live/252035.xyz/fullchain.pem;
ssl_certificate_key /etc/letsencrypt/live/252035.xyz/privkey.pem;
# 增强 SSL 安全性
ssl_protocols TLSv1.2 TLSv1.3;
ssl_ciphers EECDH+AESGCM:EDH+AESGCM:AES256+EECDH:AES256+EDH;
ssl_prefer_server_ciphers on;
# 后端代理
location / {
proxy_pass http://127.0.0.1:9999;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Forwarded-Proto $scheme;
}
}