搜索
 找回密码
 立即注册

Cloudflare Worker自选IP反代，实现Onedrive国际版下载提速

牛气冲天 2023-06-02 11:40 570
返回列表 发新帖
开启左侧
牛气冲天
本帖最后由 牛气冲天 于 2023-6-2 11:43 编辑

1.png

最近OFB（onedrive for business）速度越来越慢了，虽然用idm这类多线程下载器也可以起一定的加速作用，但并不是每个人都有时间去研究。

网上搜到的也都是去注册应用，填写应用程序ID和客户端Key，实现展示+分享+下载文件。

但我只是需要下载啊

折腾半天，也希望后人能少走些弯路吧;-)


本实例的特点💡：

无需创建应用，无需管理员同意，即使学校账号没有开放API权限也可以使用。
仅支持单线程下载，且IDM不支持断点续传。（但浏览器可以）
IP选的好可大幅度提升大多数浏览器的下载速度，适合小白使用。

准备：
1.一个Cloudflare账号
2.一个已接入Cloudflare的域名（本实例使用sunbangyan.cn下的子域名1drv.sunbangyan.cn）
3.一个速度较快的自选IP（本实例使用104.16.127.166）
4.你的sharepoint组织名称（本实例为sunbangyan）

A.首先，打开 dash.cloudflare.com，找到左侧的Workers，打开它。

2.png

B.然后，轻点右方的“创建应用程序”,然后点下方的“创建woker”

3.png


4.png


C.然后点击“编辑代码”
5.png

D.复制下面的内容替换掉编辑器里面的内容

  1. 'use strict'

  3. /**
  4. * static files (404.html, sw.js, conf.js)
  5. */
  6. const ASSET_URL = 'https://改成你的组织名称-my.sharepoint.com'

  8. const JS_VER = 10
  9. const MAX_RETRY = 1

  11. /** @type {RequestInit} */
  12. const PREFLIGHT_INIT = {
  13.   status: 204,
  14.   headers: new Headers({
  15.     'access-control-allow-origin': '*',
  16.     'access-control-allow-methods': 'GET,POST,PUT,PATCH,TRACE,DELETE,HEAD,OPTIONS',
  17.     'access-control-max-age': '1728000',
  18.   }),
  19. }

  21. /**
  22. * @param {any} body
  23. * @param {number} status
  24. * @param {Object<string, string>} headers
  25. */
  26. function makeRes(body, status = 200, headers = {}) {
  27.   headers['--ver'] = JS_VER
  28.   headers['access-control-allow-origin'] = '*'
  29.   return new Response(body, {status, headers})
  30. }


  33. /**
  34. * @param {string} urlStr
  35. */
  36. function newUrl(urlStr) {
  37.   try {
  38.     return new URL(urlStr)
  39.   } catch (err) {
  40.     return null
  41.   }
  42. }


  45. addEventListener('fetch', e => {
  46.   const ret = fetchHandler(e)
  47.     .catch(err => makeRes('cfworker error:\n' + err.stack, 502))
  48.   e.respondWith(ret)
  49. })


  52. /**
  53. * @param {FetchEvent} e
  54. */
  55. async function fetchHandler(e) {
  56.   const req = e.request
  57.   const urlStr = req.url
  58.   const urlObj = new URL(urlStr)
  59.   const path = urlObj.href.substr(urlObj.origin.length)

  61.   if (urlObj.protocol === 'http:') {
  62.     urlObj.protocol = 'https:'
  63.     return makeRes('', 301, {
  64.       'strict-transport-security': 'max-age=99999999; includeSubDomains; preload',
  65.       'location': urlObj.href,
  66.     })
  67.   }

  69.   if (path.startsWith('/http/')) {
  70.     return httpHandler(req, path.substr(6))
  71.   }

  73.   switch (path) {
  74.   case '/http':
  75.     return makeRes('请更新 cfworker 到最新版本!')
  76.   case '/ws':
  77.     return makeRes('not support', 400)
  78.   case '/works':
  79.     return makeRes('it works')
  80.   default:
  81.     // static files
  82.     return fetch(ASSET_URL + path)
  83.   }
  84. }


  87. /**
  88. * @param {Request} req
  89. * @param {string} pathname
  90. */
  91. function httpHandler(req, pathname) {
  92.   const reqHdrRaw = req.headers
  93.   if (reqHdrRaw.has('x-jsproxy')) {
  94.     return Response.error()
  95.   }

  97.   // preflight
  98.   if (req.method === 'OPTIONS' &&
  99.       reqHdrRaw.has('access-control-request-headers')
  100.   ) {
  101.     return new Response(null, PREFLIGHT_INIT)
  102.   }

  104.   let acehOld = false
  105.   let rawSvr = ''
  106.   let rawLen = ''
  107.   let rawEtag = ''

  109.   const reqHdrNew = new Headers(reqHdrRaw)
  110.   reqHdrNew.set('x-jsproxy', '1')

  112.   // 此处逻辑和 http-dec-req-hdr.lua 大致相同
  113.   // https://github.com/EtherDream/jsproxy/blob/master/lua/http-dec-req-hdr.lua
  114.   const refer = reqHdrNew.get('referer')
  115.   const query = refer.substr(refer.indexOf('?') + 1)
  116.   if (!query) {
  117.     return makeRes('missing params', 403)
  118.   }
  119.   const param = new URLSearchParams(query)

  121.   for (const [k, v] of Object.entries(param)) {
  122.     if (k.substr(0, 2) === '--') {
  123.       // 系统信息
  124.       switch (k.substr(2)) {
  125.       case 'aceh':
  126.         acehOld = true
  127.         break
  128.       case 'raw-info':
  129.         [rawSvr, rawLen, rawEtag] = v.split('|')
  130.         break
  131.       }
  132.     } else {
  133.       // 还原 HTTP 请求头
  134.       if (v) {
  135.         reqHdrNew.set(k, v)
  136.       } else {
  137.         reqHdrNew.delete(k)
  138.       }
  139.     }
  140.   }
  141.   if (!param.has('referer')) {
  142.     reqHdrNew.delete('referer')
  143.   }

  145.   // cfworker 会把路径中的 `//` 合并成 `/`
  146.   const urlStr = pathname.replace(/^(https?):\/+/, '$1://')
  147.   const urlObj = newUrl(urlStr)
  148.   if (!urlObj) {
  149.     return makeRes('invalid proxy url: ' + urlStr, 403)
  150.   }

  152.   /** @type {RequestInit} */
  153.   const reqInit = {
  154.     method: req.method,
  155.     headers: reqHdrNew,
  156.     redirect: 'manual',
  157.   }
  158.   if (req.method === 'POST') {
  159.     reqInit.body = req.body
  160.   }
  161.   return proxy(urlObj, reqInit, acehOld, rawLen, 0)
  162. }


  165. /**
  166. *
  167. * @param {URL} urlObj
  168. * @param {RequestInit} reqInit
  169. * @param {number} retryTimes
  170. */
  171. async function proxy(urlObj, reqInit, acehOld, rawLen, retryTimes) {
  172.   const res = await fetch(urlObj.href, reqInit)
  173.   const resHdrOld = res.headers
  174.   const resHdrNew = new Headers(resHdrOld)

  176.   let expose = '*'

  178.   for (const [k, v] of resHdrOld.entries()) {
  179.     if (k === 'access-control-allow-origin' ||
  180.         k === 'access-control-expose-headers' ||
  181.         k === 'location' ||
  182.         k === 'set-cookie'
  183.     ) {
  184.       const x = '--' + k
  185.       resHdrNew.set(x, v)
  186.       if (acehOld) {
  187.         expose = expose + ',' + x
  188.       }
  189.       resHdrNew.delete(k)
  190.     }
  191.     else if (acehOld &&
  192.       k !== 'cache-control' &&
  193.       k !== 'content-language' &&
  194.       k !== 'content-type' &&
  195.       k !== 'expires' &&
  196.       k !== 'last-modified' &&
  197.       k !== 'pragma'
  198.     ) {
  199.       expose = expose + ',' + k
  200.     }
  201.   }

  203.   if (acehOld) {
  204.     expose = expose + ',--s'
  205.     resHdrNew.set('--t', '1')
  206.   }

  208.   // verify
  209.   if (rawLen) {
  210.     const newLen = resHdrOld.get('content-length') || ''
  211.     const badLen = (rawLen !== newLen)

  213.     if (badLen) {
  214.       if (retryTimes < MAX_RETRY) {
  215.         urlObj = await parseYtVideoRedir(urlObj, newLen, res)
  216.         if (urlObj) {
  217.           return proxy(urlObj, reqInit, acehOld, rawLen, retryTimes + 1)
  218.         }
  219.       }
  220.       return makeRes(res.body, 400, {
  221.         '--error': `bad len: ${newLen}, except: ${rawLen}`,
  222.         'access-control-expose-headers': '--error',
  223.       })
  224.     }

  226.     if (retryTimes > 1) {
  227.       resHdrNew.set('--retry', retryTimes)
  228.     }
  229.   }

  231.   let status = res.status

  233.   resHdrNew.set('access-control-expose-headers', expose)
  234.   resHdrNew.set('access-control-allow-origin', '*')
  235.   resHdrNew.set('--s', status)
  236.   resHdrNew.set('--ver', JS_VER)

  238.   resHdrNew.delete('content-security-policy')
  239.   resHdrNew.delete('content-security-policy-report-only')
  240.   resHdrNew.delete('clear-site-data')

  242.   if (status === 301 ||
  243.       status === 302 ||
  244.       status === 303 ||
  245.       status === 307 ||
  246.       status === 308
  247.   ) {
  248.     status = status + 10
  249.   }

  251.   return new Response(res.body, {
  252.     status,
  253.     headers: resHdrNew,
  254.   })
  255. }


  258. /**
  259. * @param {URL} urlObj
  260. */
  261. function isYtUrl(urlObj) {
  262.   return (
  263.     urlObj.host.endsWith('.googlevideo.com') &&
  264.     urlObj.pathname.startsWith('/videoplayback')
  265.   )
  266. }

  268. /**
  269. * @param {URL} urlObj
  270. * @param {number} newLen
  271. * @param {Response} res
  272. */
  273. async function parseYtVideoRedir(urlObj, newLen, res) {
  274.   if (newLen > 2000) {
  275.     return null
  276.   }
  277.   if (!isYtUrl(urlObj)) {
  278.     return null
  279.   }
  280.   try {
  281.     const data = await res.text()
  282.     urlObj = new URL(data)
  283.   } catch (err) {
  284.     return null
  285.   }
  286.   if (!isYtUrl(urlObj)) {
  287.     return null
  288.   }
  289.   return urlObj
  290. }
复制代码



E.然后回到上面，修改ASSET_URL这一行
（本示例改为https://test-my.sharepoint.com）

8.png


F.最后“保存并部署”，从左上角退出。

G.然后打开“触发器”，先在“自定义域”中，添加要作为反代服务的域名，等待3~5分钟后刷新页面，直到“证书”列显示为“有效”。

7.png

在下方点击“添加路由”，同样输入反代域名，但这里注意一点，最后一定要
  1. 加上/*
复制代码



H.打开你的域名dns页，手动添加一条A记录解析，解析到你的自选IP。并且点掉橙色云朵，改为“仅限DNS”。



保存你的解析，至此，完成✅！

使用道具 举报

随机推荐

1 回复

万州
2023-6-9 11:34:23

举报

这个不错，我试试
B Color Image Link Quote Code Smilies
游客
高级模式
返回
牛气冲天
积分
101 		主题
71 		精华
0
作者最近主题
© Powered by Dz! | DR导航 · 小黑屋
官方群： · ChatGpt交流群：
返回顶部