P2P文件传输不用WebRTC复杂配置，RPC调用直接传大文件

我是 webrpc 作者。SDK、Token 和开发文档在 。两台设备互传安装包、素材、镜像很多人第一反应是上 WebRTC信令、ICE、DataChannel再自己定义分片和落盘。浏览器里开实时音视频这套很合适做原生 App / 桌面端「像调一次 RPC 一样把文件推过去」配置和胶水代码往往比业务还长。这篇只讲一件事用 webrpc 在会话上直接SendFile把本机文件推到对端。不展开 WebRTC 信令 / ICE / DataChannel 细节也不重复「30GB 怎么调优」长文。技术点只保留四句绝对路径、调用阻塞、返回 1 表示对端收完、收端按帧写盘。webrpc是面向无公网 IP 的跨平台 P2P 通信 SDKToken 标识设备登录后建加密会话再用SendData/SendFile收发。官网webrpc.cn不想写代码、先体验传大文件装 File2File。个人网盘再加 mywebdisk。为什么传文件会想到 WebRTC又容易卡住WebRTC 的强项是浏览器实时媒体。你要「跨 NAT 传一份磁盘上的文件」时通常还要自己补齐信令怎么交换、房间怎么鉴权DataChannel 上怎么切包、怎么命名、怎么确认收完Native 端怎么接进度和失败怎么提示能做成但工程面大。若产品本来就不是浏览器会议而是两台电脑 / 手机和家里 NAS 互传文件连通和会话可以交给 P2P SDK业务侧只保留「打开会话 → 指定路径发送」。webrpc会话建好之后一次 SendFile主线与官网各语言示例一致New → LoginStatus 成功 → GetReceivePort本机连 127.0.0.1 读回调 → OpenSession(对端 Token) → SendFile(本机文件绝对路径)和「发一条 JSON」的差别只是把SendData换成SendFile。心智仍是 RPC拨号成功调一次发送看返回值。四个必须记住的点点含义绝对路径SendFile传入本机绝对路径对端回调里看到的文件名也是这份完整路径字符串阻塞调用线程一直等到整次发送结束才返回不要塞在 UI 线程或回调读循环里返回值1 文件发完且对端已接受成功0 失败收端写盘回调type1是文件流可能多帧底层约按 10MB 一片每帧立刻 append不要在内存里攒整文件小消息、指令继续用SendData磁盘上的文件用SendFile。两者怎么选另有专文这里不展开。推文件 Demo 要达成什么文末是一对发送端 / 接收端Go 程序接收端先登录挂上回调准备好保存目录。发送端登录后OpenSession到接收端 Token。发送端对本地./demo.bin换成绝对路径调一次SendFile。接收端把收到的内容写到你配置的保存路径发送端打印ret1即对端收完。你只要改两枚 Token、发送文件路径、接收端保存目录。同机两个进程可先验证跨网时把接收端放另一台设备即可。不需要公网 IP。复制粘贴跑通 DemoGo准备webrpc准备两枚 Token发送端、接收端各一及密码。下载当前系统对应的动态库与头文件放在工程根目录。在发送端目录放一个测试文件例如ddif/dev/urandomofdemo.binbs1mcount8Windows 可用任意小文件改名demo.bin。目录webrpc-sendfile-demo/ ├── libwebrpc-Mac.h # 按平台替换 ├── libwebrpc-Mac.dylib ├── demo.bin # 发送端要传的文件示例名 ├── sender/ │ └── main.go └── receiver/ └── main.go接收端receiver/main.go把SAVE_DIR改成你本机要落盘的目录需已存在。收到文件流后按帧 append文件名取发送路径的最后一段避免把对方绝对路径当成本机目录结构。packagemain/* #cgo CFLAGS: -I.. #cgo darwin LDFLAGS: -L.. -lwebrpc-Mac #cgo linux,amd64 LDFLAGS: -L.. -lwebrpc-Linux #cgo linux,arm64 LDFLAGS: -L.. -lwebrpc-Linux-arm64 #cgo windows LDFLAGS: -L.. -lwebrpc-Windows #if defined(__APPLE__) #include libwebrpc-Mac.h #elif defined(_WIN32) #include libwebrpc-Windows.h #elif defined(__linux__) defined(__aarch64__) #include libwebrpc-Linux-arm64.h #elif defined(__linux__) #include libwebrpc-Linux.h #else #error unsupported platform #endif #include stdlib.h */importCimport(encoding/binaryfmtiolognetosos/signalpath/filepathsyscalltimeunsafe)// 只改这里 const(tokenYOUR_TOKEN_RECEIVERpassYOUR_PASSWORD_RECEIVERsaveDir/tmp/webrpc-recv// 改成你的保存目录请先 mkdir)funcwaitLogin(h C.GoUintptr){deadline:time.Now().Add(60*time.Second)fortime.Now().Before(deadline){st:C.WebrpcClient_LoginStatus(h)log.Printf([recv] LoginStatus%d,int(st))ifst!0{return}time.Sleep(time.Second)}log.Fatal([recv] 登录超时)}funcreadCallback(portint,readychanstruct{}){conn,err:net.Dial(tcp,fmt.Sprintf(127.0.0.1:%d,port))iferr!nil{log.Printf([recv] 连回调失败: %v,err)return}deferconn.Close()log.Printf([recv] 回调已连接 127.0.0.1:%d,port)close(ready)// 同一路径可能分多帧到达按「逻辑文件名」追加写入writers:map[string]*os.File{}for{sidBuf:make([]byte,4)if_,err:io.ReadFull(conn,sidBuf);err!nil{log.Printf([recv] 读 sessionId: %v,err)return}sid:binary.BigEndian.Uint32(sidBuf)typ:make([]byte,1)if_,err:io.ReadFull(conn,typ);err!nil{return}switchtyp[0]{case1:// 文件流nameLenBuf:make([]byte,4)if_,err:io.ReadFull(conn,nameLenBuf);err!nil{return}nameLen:binary.BigEndian.Uint32(nameLenBuf)nameBytes:make([]byte,nameLen)if_,err:io.ReadFull(conn,nameBytes);err!nil{return}remoteName:string(nameBytes)// 通常是发送端的绝对路径base:filepath.Base(remoteName)ifbase||base.||basestring(filepath.Separator){baserecv.bin}outPath:filepath.Join(saveDir,base)dataLenBuf:make([]byte,4)if_,err:io.ReadFull(conn,dataLenBuf);err!nil{return}dataLen:binary.BigEndian.Uint32(dataLenBuf)chunk:make([]byte,dataLen)if_,err:io.ReadFull(conn,chunk);err!nil{return}f,ok:writers[outPath]if!ok{_os.MkdirAll(saveDir,0o755)f,erros.OpenFile(outPath,os.O_CREATE|os.O_WRONLY|os.O_TRUNC,0o644)iferr!nil{log.Printf([recv] 打开保存文件失败: %v,err)continue}writers[outPath]f log.Printf([recv] session%d 开始写入 %s 来自 %s,sid,outPath,remoteName)}if_,err:f.Write(chunk);err!nil{log.Printf([recv] 写盘失败: %v,err)continue}log.Printf([recv] session%d 已追加 %d 字节 → %s,sid,dataLen,outPath)case2:// 数据流本 Demo 跳过lenBuf:make([]byte,4)if_,err:io.ReadFull(conn,lenBuf);err!nil{return}n:binary.BigEndian.Uint32(lenBuf)io.CopyN(io.Discard,conn,int64(n))default:log.Printf([recv] 未知 type%d,typ[0])}}}funcmain(){iferr:os.MkdirAll(saveDir,0o755);err!nil{log.Fatalf([recv] 创建保存目录失败: %v,err)}ctoken:C.CString(token)cpass:C.CString(pass)cperm:C.CString()deferC.free(unsafe.Pointer(ctoken))deferC.free(unsafe.Pointer(cpass))deferC.free(unsafe.Pointer(cperm))h:C.WebrpcClient_New(ctoken,cpass,cperm)ifh0{log.Fatal([recv] WebrpcClient_New 失败)}deferC.WebrpcClient_Free(h)waitLogin(h)port:int(C.WebrpcClient_GetReceivePort(h))ready:make(chanstruct{})goreadCallback(port,ready)select{case-ready:case-time.After(5*time.Second):log.Fatal([recv] 回调未连上)}log.Printf([recv] 在线文件将写入 %s CtrlC 退出,saveDir)ch:make(chanos.Signal,1)signal.Notify(ch,syscall.SIGINT,syscall.SIGTERM)-ch}发送端sender/main.go把sendPath改成demo.bin的绝对路径peerToken填接收端那枚 Token。SendFile在独立逻辑里调用本示例在main里发完即退出避免堵在回调读线程上。packagemain/* #cgo CFLAGS: -I.. #cgo darwin LDFLAGS: -L.. -lwebrpc-Mac #cgo linux,amd64 LDFLAGS: -L.. -lwebrpc-Linux #cgo linux,arm64 LDFLAGS: -L.. -lwebrpc-Linux-arm64 #cgo windows LDFLAGS: -L.. -lwebrpc-Windows #if defined(__APPLE__) #include libwebrpc-Mac.h #elif defined(_WIN32) #include libwebrpc-Windows.h #elif defined(__linux__) defined(__aarch64__) #include libwebrpc-Linux-arm64.h #elif defined(__linux__) #include libwebrpc-Linux.h #else #error unsupported platform #endif #include stdlib.h */importCimport(encoding/binaryfmtiolognetospath/filepathtimeunsafe)// 只改这里 const(tokenYOUR_TOKEN_SENDERpassYOUR_PASSWORD_SENDERpeerTokenYOUR_TOKEN_RECEIVER// 改成 demo.bin 的绝对路径例如 /Users/你/webrpc-sendfile-demo/demo.binsendPath/ABS/PATH/TO/demo.bin)funcwaitLogin(h C.GoUintptr){deadline:time.Now().Add(60*time.Second)fortime.Now().Before(deadline){st:C.WebrpcClient_LoginStatus(h)log.Printf([send] LoginStatus%d,int(st))ifst!0{return}time.Sleep(time.Second)}log.Fatal([send] 登录超时)}funcreadCallback(portint,readychanstruct{}){conn,err:net.Dial(tcp,fmt.Sprintf(127.0.0.1:%d,port))iferr!nil{log.Printf([send] 连回调失败: %v,err)return}deferconn.Close()close(ready)// 发送端本 Demo 不处理对端回包读掉帧避免阻塞for{sidBuf:make([]byte,4)if_,err:io.ReadFull(conn,sidBuf);err!nil{return}typ:make([]byte,1)if_,err:io.ReadFull(conn,typ);err!nil{return}switchtyp[0]{case2:lenBuf:make([]byte,4)if_,err:io.ReadFull(conn,lenBuf);err!nil{return}n:binary.BigEndian.Uint32(lenBuf)io.CopyN(io.Discard,conn,int64(n))case1:nameLenBuf:make([]byte,4)if_,err:io.ReadFull(conn,nameLenBuf);err!nil{return}nameLen:binary.BigEndian.Uint32(nameLenBuf)io.CopyN(io.Discard,conn,int64(nameLen))dataLenBuf:make([]byte,4)if_,err:io.ReadFull(conn,dataLenBuf);err!nil{return}dataLen:binary.BigEndian.Uint32(dataLenBuf)io.CopyN(io.Discard,conn,int64(dataLen))}}}funcmain(){abs,err:filepath.Abs(sendPath)iferr!nil{log.Fatal(err)}ifst,err:os.Stat(abs);err!nil||st.IsDir(){log.Fatalf([send] 找不到文件请改 sendPath: %s,abs)}log.Printf([send] 将发送 %s %d 字节,abs,mustSize(abs))ctoken:C.CString(token)cpass:C.CString(pass)cperm:C.CString()deferC.free(unsafe.Pointer(ctoken))deferC.free(unsafe.Pointer(cpass))deferC.free(unsafe.Pointer(cperm))h:C.WebrpcClient_New(ctoken,cpass,cperm)ifh0{log.Fatal([send] WebrpcClient_New 失败)}deferC.WebrpcClient_Free(h)waitLogin(h)port:int(C.WebrpcClient_GetReceivePort(h))ready:make(chanstruct{})goreadCallback(port,ready)select{case-ready:case-time.After(5*time.Second):log.Fatal([send] 回调未连上)}cpeer:C.CString(peerToken)deferC.free(unsafe.Pointer(cpeer))sid:C.WebrpcClient_OpenSession(h,cpeer,cperm)ifsid0{log.Fatal([send] OpenSession0确认接收端已在线peerToken 填对端 Token)}log.Printf([send] OpenSession 成功 sessionId%d,uint32(sid))cpath:C.CString(abs)deferC.free(unsafe.Pointer(cpath))start:time.Now()// 阻塞直到成功或失败1 对端已接受整文件ret:C.WebrpcClient_SendFile(h,sid,cpath)log.Printf([send] SendFile ret%d 耗时 %v,int(ret),time.Since(start))ifret1{fmt.Println(发送成功对端已接受文件)}else{fmt.Println(发送失败检查对方在线、路径、网络后重试)os.Exit(1)}}funcmustSize(pstring)int64{st,err:os.Stat(p)iferr!nil{return0}returnst.Size()}怎么跑终端 1接收端先开cdwebrpc-sendfile-demo/receiver# 按需改 saveDir并 mkdirCGO_ENABLED1go run.终端 2发送端cdwebrpc-sendfile-demo/sender# 确认 sendPath 指向 demo.bin 的绝对路径CGO_ENABLED1go run.期望发送端SendFile ret1打印「发送成功」接收端日志里出现「开始写入 …/demo.bin」和若干「已追加 … 字节」打开saveDir能看到收到的demo.bin把sendPath换成更大的安装包或素材路径即可测大文件收端仍按帧 append峰值内存不会按整文件涨。OpenSession为 0 或SendFile为 0 时先确认接收端进程在线、Token 没填反再重试。跑通之后产品里可先SendData约定文件名 / 是否接收再SendFile本 Demo 为最短路径直接推送。需要进度条时用SendData询问对端已写字节File2File 同款思路SDK 不提供进度 API。失败时对端磁盘可能有半成品可用临时文件名确认成功后再改名。浏览器实时会议仍优先看 WebRTC原生设备间传文件优先把连通交给 webrpc业务只保留路径与落盘策略。配置好路径和保存目录先把demo.bin跑通再换成你的大文件即可。