找回密码
 立即注册
CeraNetworksBGVM服务器主机交流IP归属甄别会员请立即修改密码
查看: 36|回复: 2

Workers如何实现类似Nginx location的功能?

[复制链接]

4

主题

579

回帖

1634

积分

金牌会员

积分
1634
发表于 2021-7-10 19:18:32 | 显示全部楼层 |阅读模式
本帖最后由 MoeWang 于 2021-7-10 19:11 编辑

如题,是这样的,我把原来vercel的b2对象存储反代移到workers来了(看中了带宽联盟),然后我就找了找论坛里的workers反代隐藏path,然后就卡在这里了。。原因是我在vercel里面设置过不同的路由,比如/avatar/的path是用来反代gravatar的,传入的path符合条件的话(比如https://workers/avatar/xxxxxx)就执行反代gravatar的代码;

如果传入的URL不包含avatar(比如https://workers/test.jpg或者https://workers/public/123.js)就继续反代对象存储。

让我写个nginx或者vercel的那种path路由我会,但是换用service workers就真的不会了,

主要是如何监听不同路径这块代码不是很熟悉。如果要想复杂些的话这种要用if吗?

然后可能真的没找对关键词,网上我就没搜着service workers 分path执行的相关教程,所以来问问各位大佬。能给我一篇讲如何监听不同目录的文档或者教程也行。。吐了。。。救救孩子吧

目前搜到的代码如下:
[ol]
  • //gravatar反代
  • addEventListener(
  •   "fetch",event => {
  •     let url=new URL(event.request.url);
  •     url.hostname="secure.gravatar.com";
  •     url.pathname="/avatar/";
  •     let request=new Request(url,event.request);
  •      event. respondWith(
  •        fetch(request)
  •        )
  •        }
  •         )
  • //gravatar反代 结束
  • //B2 存储隐藏桶 开始
  • 'use strict';
  • const b2Domain = 'cdn.xxxxx'; // configure this as per instructions above
  • const b2Bucket = 'xxxxxxx; // configure this as per instructions above
  • const b2UrlPath = `/file/${b2Bucket}/`;
  • addEventListener('fetch', event => {
  •         return event.respondWith(fileReq(event));
  • });
  • // define the file extensions we wish to add basic access control headers to
  • const corsFileTypes = ['png', 'jpg', 'gif', 'jpeg', 'webp'];
  • // backblaze returns some additional headers that are useful for debugging, but unnecessary in production. We can remove these to save some size
  • const removeHeaders = [
  •         'x-bz-content-sha1',
  •         'x-bz-file-id',
  •         'x-bz-file-name',
  •         'x-bz-info-src_last_modified_millis',
  •         'X-Bz-Upload-Timestamp',
  •         'Expires'
  • ];
  • const expiration = 31536000; // override browser cache for images - 1 year
  • // define a function we can re-use to fix headers
  • const fixHeaders = function(url, status, headers){
  •         let newHdrs = new Headers(headers);
  •         // add basic cors headers for images
  •         if(corsFileTypes.includes(url.pathname.split('.').pop())){
  •                 newHdrs.set('Access-Control-Allow-Origin', '*');
  •         }
  •         // override browser cache for files when 200
  •         if(status === 200){
  •                 newHdrs.set('Cache-Control', "public, max-age=" + expiration);
  •         }else{
  •                 // only cache other things for 5 minutes
  •                 newHdrs.set('Cache-Control', 'public, max-age=300');
  •         }
  •         // set ETag for efficient caching where possible
  •         const ETag = newHdrs.get('x-bz-content-sha1') || newHdrs.get('x-bz-info-src_last_modified_millis') || newHdrs.get('x-bz-file-id');
  •         if(ETag){
  •                 newHdrs.set('ETag', ETag);
  •         }
  •         // remove unnecessary headers
  •         removeHeaders.forEach(header => {
  •                 newHdrs.delete(header);
  •         });
  •         return newHdrs;
  • };
  • async function fileReq(event){
  •         const cache = caches.default; // Cloudflare edge caching
  •         const url = new URL(event.request.url);
  •         if(url.host === b2Domain && !url.pathname.startsWith(b2UrlPath)){
  •                 url.pathname = b2UrlPath + url.pathname;
  •         }
  •         let response = await cache.match(url); // try to find match for this request in the edge cache
  •         if(response){
  •                 // use cache found on Cloudflare edge. Set X-Worker-Cache header for helpful debug
  •                 let newHdrs = fixHeaders(url, response.status, response.headers);
  •                 newHdrs.set('X-Worker-Cache', "true");
  •                 return new Response(response.body, {
  •                         status: response.status,
  •                         statusText: response.statusText,
  •                         headers: newHdrs
  •                 });
  •         }
  •         // no cache, fetch image, apply Cloudflare lossless compression
  •         response = await fetch(url, {cf: {polish: "lossless"}});
  •         let newHdrs = fixHeaders(url, response.status, response.headers);
  •   if(response.status === 200){
  •     response = new Response(response.body, {
  •       status: response.status,
  •       statusText: response.statusText,
  •       headers: newHdrs
  •     });
  •   }else{
  •     response = new Response('Not Found!', { status: 404 })
  •   }
  •         event.waitUntil(cache.put(url, response.clone()));
  •         return response;
  • }
  • //B2 存储桶 结束[/ol]复制代码
    另外本帖不会255,我也没有255的习惯
  • 回复

    使用道具 举报

    0

    主题

    128

    回帖

    414

    积分

    中级会员

    积分
    414
    发表于 2021-7-10 19:22:34 | 显示全部楼层
    https://github.com/kwhitley/itty-router
    https://github.com/cfworker/cfworker/tree/main/packages/web
    https://github.com/berstend/tiny-request-router
    回复

    使用道具 举报

    4

    主题

    579

    回帖

    1634

    积分

    金牌会员

    积分
    1634
     楼主| 发表于 2021-7-10 19:25:56 | 显示全部楼层

    滴滴单车 发表于 2021-7-10 19:22

    https://github.com/kwhitley/itty-router
    https://github.com/cfworker/cfworker/tree/main/packages/web
    ...

    感谢大佬,有头绪了,待会试试
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    Archiver|手机版|小黑屋|HS2V主机综合交流论坛

    GMT+8, 2024-6-10 07:25 , Processed in 0.052183 second(s), 3 queries , Gzip On, Redis On.

    Powered by Discuz! X3.5

    © 2001-2023 Discuz! Team.

    快速回复 返回顶部 返回列表