经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » Docker » 查看文章
使用Cloudflare Worker加速docker镜像
来源：cnblogs　　作者：程序设计实验室　　时间：2024/7/19 10:37:45　　对本文有异议

前言

开发者越来越难了??，现在国内的docker镜像也都???了，没有镜像要使用docker??太难了，代理??又很慢

现在就只剩下自建镜像的办法了??

GitHub上有开源项目可以快速搭建自己的镜像库，不过还是有点麻烦，还好Cloudflare暂时还活着?????

本文记录一下使用 Cloudflare Worker 搭建 docker 镜像的方法??

关于 worker

Cloudflare Workers 是 Cloudflare 提供的一个无服务器（serverless）计算平台，允许你在 Cloudflare 的全球边缘网络上运行 JavaScript、Rust、C、C++ 和 COBOL 等编写的代码。它主要用于创建高性能、高可扩展性的网页应用程序和API。??

Cloudflare Workers 非常适合处理各种网络请求，例如 API网关、内容定制和动态渲染等任务，同时还可以用来修改或决定网络请求如何响应。它为开发人员提供了在全球范围内快速部署应用程序和服务的能力。

一些关键特性：

  1. 边缘计算：由于代码直接在 Cloudflare 的边缘节点上执行，可以显著减少数据传输时间，提高响应速度。
  2. 无服务器架构：你不需要管理任何服务器或实例，只需关注代码的编写和部署。Cloudflare 负责代码的运行和扩展。
  3. 按需计费：Cloudflare Workers 的计费模式基于请求次数和执行时间，而不是预先设定的资源分配，这意味着你可以根据实际使用量付费。
  4. 高度集成：它可以与 Cloudflare 的其他服务（如 KV 存储、Durable Objects 等）紧密集成，方便数据存储和状态管理。
  5. 安全性：由于 Workers 运行在隔离的环境中，它们提供了与传统服务器或容器相比更高的安全级别。

创建 worker

打开 Cloudflare 的 Worker and Pages 页面，创建一个 worker

起个直观的名字，比如 docker-proxy 之类的

然后点【部署】按钮

编辑代码

部署完成之后?，点旁边的【编辑代码】按钮

把下面的 JavaScript????? 代码输进去

需要把 workers_url 替换成自己的域名，比如 https://docker.example.com

  1. // Docker镜像仓库主机地址
  2. let hub_host = 'registry-1.docker.io'
  3. // Docker认证服务器地址
  4. const auth_url = 'https://auth.docker.io'
  5. // 自定义的工作服务器地址
  6. let workers_url = 'https://你的域名'
  8. let 屏蔽爬虫UA = ['netcraft'];
  10. // 根据主机名选择对应的上游地址
  11. function routeByHosts(host) {
  12.   // 定义路由表
  13.   const routes = {
  14.     // 生产环境
  15.     "quay": "quay.io",
  16.     "gcr": "gcr.io",
  17.     "k8s-gcr": "k8s.gcr.io",
  18.     "k8s": "registry.k8s.io",
  19.     "ghcr": "ghcr.io",
  20.     "cloudsmith": "docker.cloudsmith.io",
  22.     // 测试环境
  23.     "test": "registry-1.docker.io",
  24.   };
  26.   if (host in routes) return [ routes[host], false ];
  27.   else return [ hub_host, true ];
  28. }
  30. /** @type {RequestInit} */
  31. const PREFLIGHT_INIT = {
  32.   // 预检请求配置
  33.   headers: new Headers({
  34.     'access-control-allow-origin': '*', // 允许所有来源
  35.     'access-control-allow-methods': 'GET,POST,PUT,PATCH,TRACE,DELETE,HEAD,OPTIONS', // 允许的HTTP方法
  36.     'access-control-max-age': '1728000', // 预检请求的缓存时间
  37.   }),
  38. }
  40. /**
  41.  * 构造响应
  42.  * @param {any} body 响应体
  43.  * @param {number} status 响应状态码
  44.  * @param {Object<string, string>} headers 响应头
  45.  */
  46. function makeRes(body, status = 200, headers = {}) {
  47.   headers['access-control-allow-origin'] = '*' // 允许所有来源
  48.   return new Response(body, { status, headers }) // 返回新构造的响应
  49. }
  51. /**
  52.  * 构造新的URL对象
  53.  * @param {string} urlStr URL字符串
  54.  */
  55. function newUrl(urlStr) {
  56.   try {
  57.     return new URL(urlStr) // 尝试构造新的URL对象
  58.   } catch (err) {
  59.     return null // 构造失败返回null
  60.   }
  61. }
  63. function isUUID(uuid) {
  64.   // 定义一个正则表达式来匹配 UUID 格式
  65.   const uuidRegex = /^[0-9a-f]{8}-[0-9a-f]{4}-[4][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i;
  67.   // 使用正则表达式测试 UUID 字符串
  68.   return uuidRegex.test(uuid);
  69. }
  71. async function nginx() {
  72.   const text = `
  73.   <!DOCTYPE html>
  74.   <html>
  75.   <head>
  76.   <title>Welcome to nginx!</title>
  77.   <style>
  78.     body {
  79.       width: 35em;
  80.       margin: 0 auto;
  81.       font-family: Tahoma, Verdana, Arial, sans-serif;
  82.     }
  83.   </style>
  84.   </head>
  85.   <body>
  86.   <h1>Welcome to nginx!</h1>
  87.   <p>If you see this page, the nginx web server is successfully installed and
  88.   working. Further configuration is required.</p>
  90.   <p>For online documentation and support please refer to
  91.   <a href="http://nginx.org/">nginx.org</a>.<br/>
  92.   Commercial support is available at
  93.   <a href="http://nginx.com/">nginx.com</a>.</p>
  95.   <p><em>Thank you for using nginx.</em></p>
  96.   </body>
  97.   </html>
  98.   `
  99.   return text ;
  100. }
  102. export default {
  103.   async fetch(request, env, ctx) {
  104.     const getReqHeader = (key) => request.headers.get(key); // 获取请求头
  106.     let url = new URL(request.url); // 解析请求URL
  107.     const userAgentHeader = request.headers.get('User-Agent');
  108.     const userAgent = userAgentHeader ? userAgentHeader.toLowerCase() : "null";
  109.     if (env.UA) 屏蔽爬虫UA = 屏蔽爬虫UA.concat(await ADD(env.UA));
  110.     workers_url = `https://${url.hostname}`;
  111.     const pathname = url.pathname;
  112.     const hostname = url.searchParams.get('hubhost') || url.hostname; 
  113.     const hostTop = hostname.split('.')[0];// 获取主机名的第一部分
  114.     const checkHost = routeByHosts(hostTop);
  115.     hub_host = checkHost[0]; // 获取上游地址
  116.     const fakePage = checkHost[1];
  117.     console.log(`域名头部: ${hostTop}\n反代地址: ${hub_host}\n伪装首页: ${fakePage}`);
  118.     const isUuid = isUUID(pathname.split('/')[1].split('/')[0]);
  120.     if (屏蔽爬虫UA.some(fxxk => userAgent.includes(fxxk)) && 屏蔽爬虫UA.length > 0){
  121.       //首页改成一个nginx伪装页
  122.       return new Response(await nginx(), {
  123.         headers: {
  124.           'Content-Type': 'text/html; charset=UTF-8',
  125.         },
  126.       });
  127.     }
  129.     const conditions = [
  130.       isUuid,
  131.       pathname.includes('/_'),
  132.       pathname.includes('/r'),
  133.       pathname.includes('/v2/user'),
  134.       pathname.includes('/v2/orgs'),
  135.       pathname.includes('/v2/_catalog'),
  136.       pathname.includes('/v2/categories'),
  137.       pathname.includes('/v2/feature-flags'),
  138.       pathname.includes('search'),
  139.       pathname.includes('source'),
  140.       pathname === '/',
  141.       pathname === '/favicon.ico',
  142.       pathname === '/auth/profile',
  143.     ];
  145.     if (conditions.some(condition => condition) && (fakePage === true || hostTop == 'docker')) {
  146.       if (env.URL302){
  147.         return Response.redirect(env.URL302, 302);
  148.       } else if (env.URL){
  149.         if (env.URL.toLowerCase() == 'nginx'){
  150.           //首页改成一个nginx伪装页
  151.           return new Response(await nginx(), {
  152.             headers: {
  153.               'Content-Type': 'text/html; charset=UTF-8',
  154.             },
  155.           });
  156.         } else return fetch(new Request(env.URL, request));
  157.       }
  159.       const newUrl = new URL("https://registry.hub.docker.com" + pathname + url.search);
  161.       // 复制原始请求的标头
  162.       const headers = new Headers(request.headers);
  164.       // 确保 Host 头部被替换为 hub.docker.com
  165.       headers.set('Host', 'registry.hub.docker.com');
  167.       const newRequest = new Request(newUrl, {
  168.         method: request.method,
  169.         headers: headers,
  170.         body: request.method !== 'GET' && request.method !== 'HEAD' ? await request.blob() : null,
  171.         redirect: 'follow'
  172.       });
  174.       return fetch(newRequest);
  175.     }
  177.     // 修改包含 %2F 和 %3A 的请求
  178.     if (!/%2F/.test(url.search) && /%3A/.test(url.toString())) {
  179.       let modifiedUrl = url.toString().replace(/%3A(?=.*?&)/, '%3Alibrary%2F');
  180.       url = new URL(modifiedUrl);
  181.       console.log(`handle_url: ${url}`)
  182.     }
  184.     // 处理token请求
  185.     if (url.pathname.includes('/token')) {
  186.       let token_parameter = {
  187.         headers: {
  188.           'Host': 'auth.docker.io',
  189.           'User-Agent': getReqHeader("User-Agent"),
  190.           'Accept': getReqHeader("Accept"),
  191.           'Accept-Language': getReqHeader("Accept-Language"),
  192.           'Accept-Encoding': getReqHeader("Accept-Encoding"),
  193.           'Connection': 'keep-alive',
  194.           'Cache-Control': 'max-age=0'
  195.         }
  196.       };
  197.       let token_url = auth_url + url.pathname + url.search
  198.       return fetch(new Request(token_url, request), token_parameter)
  199.     }
  201.     // 修改 /v2/ 请求路径
  202.     if (/^\/v2\/[^/]+\/[^/]+\/[^/]+$/.test(url.pathname) && !/^\/v2\/library/.test(url.pathname)) {
  203.       url.pathname = url.pathname.replace(/\/v2\//, '/v2/library/');
  204.       console.log(`modified_url: ${url.pathname}`)
  205.     }
  207.     // 更改请求的主机名
  208.     url.hostname = hub_host;
  210.     // 构造请求参数
  211.     let parameter = {
  212.       headers: {
  213.         'Host': hub_host,
  214.         'User-Agent': getReqHeader("User-Agent"),
  215.         'Accept': getReqHeader("Accept"),
  216.         'Accept-Language': getReqHeader("Accept-Language"),
  217.         'Accept-Encoding': getReqHeader("Accept-Encoding"),
  218.         'Connection': 'keep-alive',
  219.         'Cache-Control': 'max-age=0'
  220.       },
  221.       cacheTtl: 3600 // 缓存时间
  222.     };
  224.     // 添加Authorization头
  225.     if (request.headers.has("Authorization")) {
  226.       parameter.headers.Authorization = getReqHeader("Authorization");
  227.     }
  229.     // 发起请求并处理响应
  230.     let original_response = await fetch(new Request(url, request), parameter)
  231.     let original_response_clone = original_response.clone();
  232.     let original_text = original_response_clone.body;
  233.     let response_headers = original_response.headers;
  234.     let new_response_headers = new Headers(response_headers);
  235.     let status = original_response.status;
  237.     // 修改 Www-Authenticate 头
  238.     if (new_response_headers.get("Www-Authenticate")) {
  239.       let auth = new_response_headers.get("Www-Authenticate");
  240.       let re = new RegExp(auth_url, 'g');
  241.       new_response_headers.set("Www-Authenticate", response_headers.get("Www-Authenticate").replace(re, workers_url));
  242.     }
  244.     // 处理重定向
  245.     if (new_response_headers.get("Location")) {
  246.       return httpHandler(request, new_response_headers.get("Location"))
  247.     }
  249.     // 返回修改后的响应
  250.     let response = new Response(original_text, {
  251.       status,
  252.       headers: new_response_headers
  253.     })
  254.     return response;
  255.   }
  256. };
  258. /**
  259.  * 处理HTTP请求
  260.  * @param {Request} req 请求对象
  261.  * @param {string} pathname 请求路径
  262.  */
  263. function httpHandler(req, pathname) {
  264.   const reqHdrRaw = req.headers
  266.   // 处理预检请求
  267.   if (req.method === 'OPTIONS' &&
  268.       reqHdrRaw.has('access-control-request-headers')
  269.      ) {
  270.     return new Response(null, PREFLIGHT_INIT)
  271.   }
  273.   let rawLen = ''
  275.   const reqHdrNew = new Headers(reqHdrRaw)
  277.   const refer = reqHdrNew.get('referer')
  279.   let urlStr = pathname
  281.   const urlObj = newUrl(urlStr)
  283.   /** @type {RequestInit} */
  284.   const reqInit = {
  285.     method: req.method,
  286.     headers: reqHdrNew,
  287.     redirect: 'follow',
  288.     body: req.body
  289.   }
  290.   return proxy(urlObj, reqInit, rawLen)
  291. }
  293. /**
  294.  * 代理请求
  295.  * @param {URL} urlObj URL对象
  296.  * @param {RequestInit} reqInit 请求初始化对象
  297.  * @param {string} rawLen 原始长度
  298.  */
  299. async function proxy(urlObj, reqInit, rawLen) {
  300.   const res = await fetch(urlObj.href, reqInit)
  301.   const resHdrOld = res.headers
  302.   const resHdrNew = new Headers(resHdrOld)
  304.   // 验证长度
  305.   if (rawLen) {
  306.     const newLen = resHdrOld.get('content-length') || ''
  307.     const badLen = (rawLen !== newLen)
  309.     if (badLen) {
  310.       return makeRes(res.body, 400, {
  311.         '--error': `bad len: ${newLen}, except: ${rawLen}`,
  312.         'access-control-expose-headers': '--error',
  313.       })
  314.     }
  315.   }
  316.   const status = res.status
  317.   resHdrNew.set('access-control-expose-headers', '*')
  318.   resHdrNew.set('access-control-allow-origin', '*')
  319.   resHdrNew.set('Cache-Control', 'max-age=1500')
  321.   // 删除不必要的头
  322.   resHdrNew.delete('content-security-policy')
  323.   resHdrNew.delete('content-security-policy-report-only')
  324.   resHdrNew.delete('clear-site-data')
  326.   return new Response(res.body, {
  327.     status,
  328.     headers: resHdrNew
  329.   })
  330. }
  332. async function ADD(envadd) {
  333.   var addtext = envadd.replace(/[   |"'\r\n]+/g, ',').replace(/,+/g, ',');  // 将空格、双引号、单引号和换行符替换为逗号
  334.   //console.log(addtext);
  335.   if (addtext.charAt(0) == ',') addtext = addtext.slice(1);
  336.   if (addtext.charAt(addtext.length -1) == ',') addtext = addtext.slice(0, addtext.length - 1);
  337.   const add = addtext.split(',');
  338.   //console.log(add);
  339.   return add ;
  340. }

OK??，代码输入之后，重新点击【部署】，部署成功就可以打开 docker??hub 页面了

设置域名

刚才不是在代码里配置了域名吗?

接下来还得继续配置一下

返回【Workers 和 Pages / docker-proxy】配置页面

点【设置】-【触发器】??

在【自定义域】里点添加，输入域名，例如?? docker.example.com

搞定??，cloudflare 会自动申请 SSL 证书什么的??

配置registry

修改 /etc/docker/daemon.json 文件

  1. {
  2.   "registry-mirrors": ["https://docker.example.com"],
  3.   "insecure-registries": ["docker.example.com"]
  4. }

重新启动 docker

  1. sudo systemctl daemon-reload
  2. sudo systemctl restart docker

接下来再 pull image 速度就快到起飞??了??

参考资料

原文链接：https://www.cnblogs.com/deali/p/18310886

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Docker热门文章

  • docker部署certbot与nginx来获取ssl证书添加https及自动更新
  • 解决docker的tls(ssl)证书过期问题
  • 人工智能,丹青圣手,全平台(原生/Docker)构建Stable-Diffusion-Webui的AI绘画库教程(Python3.10/Pytorch1.13.0)
  • Docker原理
  • docker&nbsp;for&nbsp;windonws之Windows&nbsp;10&nbsp;家庭中文版安装clickhouse&nbsp;22.3版本及配置过程
  • Docker-compose command 有多个命令例子
  • docker修改容器配置文件的3种方法总结
  • 解决docker pull镜像报错的问题
  • Docker在Centos 7上的部署
  • Docker使用Prune命令清理none镜像

    • Docker推荐文章

  • 如何在Linux云服务器上通过Docker Compose部署安装Halo，搭建个人博客网站？
  • 使用Cloudflare Worker加速docker镜像
  • 如何在 Windows 使用 Podman Desktop 取代 Docker Desktop
  • Linux 提权-Docker 容器
  • 配置pod拉取harbor容器镜像仓库私有镜像：secret保存账号密码
  • Win11系统下的MindSpore环境搭建
  • 白话理解和使用DOCKER VOLUME
  • Docker 必知必会4----容器之间的通信
  • Docker 必知必会3----使用自己制作的镜像
  • 对于Docker和Podman的一点使用经验

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号