Cloudflare Worker 是 Cloudflare 公司提供的一项服务,它允许开发者在 Cloudflare 的边缘服务器上运行自定义的 JavaScript 代码。通俗地说,它就像是一个小型的服务器,可以在互联网上的不同地点快速执行你编写的代码。
Cloudflare Worker 的主要用途包括网站加速和优化、路由请求、访问控制、CDN 功能增强、网站镜像与转发等。
本文将使用其网站镜像和访问控制的能力,实现 GitHub 站点的镜像,并通过自有域名实现在墙内的访问。
镜像 GitHub 站点
1. 创建 Worker
接着,设置一个三级域名 https://demo.93653142.workers.dev,点击 部署 按钮:
// 你要镜像的网站.const upstream = 'github.com'// 镜像网站的目录,比如你想镜像某个网站的二级目录则填写二级目录的目录名,镜像 google 用不到,默认即可.const upstream_path = '/'// 镜像站是否有手机访问专用网址,没有则填一样的.const upstream_mobile = 'github.com'// 屏蔽国家和地区.const blocked_region = ['KP', 'SY', 'PK', 'CU']// 屏蔽 IP 地址.const blocked_ip_address = ['0.0.0.0', '127.0.0.1']// 镜像站是否开启 HTTPS.const https = true// 文本替换.const replace_dict = {'$upstream': '$custom_domain', '//github.com': ''}// 以下保持默认,不要动addEventListener('fetch', event => {event.respondWith(fetchAndApply(event.request))})async function fetchAndApply(request) {const region = request.headers.get('cf-ipcountry').toUpperCase()const ip_address = request.headers.get('cf-connecting-ip')const user_agent = request.headers.get('user-agent')let response = nulllet url = new URL(request.url)let url_hostname = url.hostnameif (https == true) {url.protocol = 'https:'} else {url.protocol = 'http:'}if (await device_status(user_agent)) {var upstream_domain = upstream} else {var upstream_domain = upstream_mobile}url.host = upstream_domainif (url.pathname == '/') {url.pathname = upstream_path} else {url.pathname = upstream_path + url.pathname}if (blocked_region.includes(region)) {response = new Response('Access denied: WorkersProxy is not available in your region yet.', {status: 403})} else if (blocked_ip_address.includes(ip_address)) {response = new Response('Access denied: Your IP address is blocked by WorkersProxy.', {status: 403})} else {let method = request.methodlet request_headers = request.headerslet new_request_headers = new Headers(request_headers)new_request_headers.set('Host', url.hostname)new_request_headers.set('Referer', url.hostname)let original_response = await fetch(url.href, {method: method,headers: new_request_headers})let original_response_clone = original_response.clone()let original_text = nulllet response_headers = original_response.headerslet new_response_headers = new Headers(response_headers)let status = original_response.statusnew_response_headers.set('access-control-allow-origin', '*')new_response_headers.set('access-control-allow-credentials', true)new_response_headers.delete('content-security-policy')new_response_headers.delete('content-security-policy-report-only')new_response_headers.delete('clear-site-data')const content_type = new_response_headers.get('content-type')if (content_type.includes('text/html') && content_type.includes('UTF-8')) {original_text = await replace_response_text(original_response_clone, upstream_domain, url_hostname)} else {original_text = original_response_clone.body}response = new Response(original_text, {status,headers: new_response_headers})}return response}async function replace_response_text(response, upstream_domain, host_name) {let text = await response.text()var i, jfor (i in replace_dict) {j = replace_dict[i]if (i == '$upstream') {i = upstream_domain} else if (i == '$custom_domain') {i = host_name}if (j == '$upstream') {j = upstream_domain} else if (j == '$custom_domain') {j = host_name}let re = new RegExp(i, 'g')text = text.replace(re, j)}return text}async function device_status(user_agent_info) {var agents = ["Android", "iPhone", "SymbianOS", "Windows Phone", "iPad", "iPod"]var flag = truefor (var v = 0; v < agents.length; v++) {if (user_agent_info.indexOf(agents[v]) > 0) {flag = falsebreak}}return flag}// 你要镜像的网站. const upstream = 'github.com' // 镜像网站的目录,比如你想镜像某个网站的二级目录则填写二级目录的目录名,镜像 google 用不到,默认即可. const upstream_path = '/' // 镜像站是否有手机访问专用网址,没有则填一样的. const upstream_mobile = 'github.com' // 屏蔽国家和地区. const blocked_region = ['KP', 'SY', 'PK', 'CU'] // 屏蔽 IP 地址. const blocked_ip_address = ['0.0.0.0', '127.0.0.1'] // 镜像站是否开启 HTTPS. const https = true // 文本替换. const replace_dict = {'$upstream': '$custom_domain', '//github.com': ''} // 以下保持默认,不要动 addEventListener('fetch', event => { event.respondWith(fetchAndApply(event.request)) }) async function fetchAndApply(request) { const region = request.headers.get('cf-ipcountry').toUpperCase() const ip_address = request.headers.get('cf-connecting-ip') const user_agent = request.headers.get('user-agent') let response = null let url = new URL(request.url) let url_hostname = url.hostname if (https == true) { url.protocol = 'https:' } else { url.protocol = 'http:' } if (await device_status(user_agent)) { var upstream_domain = upstream } else { var upstream_domain = upstream_mobile } url.host = upstream_domain if (url.pathname == '/') { url.pathname = upstream_path } else { url.pathname = upstream_path + url.pathname } if (blocked_region.includes(region)) { response = new Response('Access denied: WorkersProxy is not available in your region yet.', { status: 403 }) } else if (blocked_ip_address.includes(ip_address)) { response = new Response('Access denied: Your IP address is blocked by WorkersProxy.', { status: 403 }) } else { let method = request.method let request_headers = request.headers let new_request_headers = new Headers(request_headers) new_request_headers.set('Host', url.hostname) new_request_headers.set('Referer', url.hostname) let original_response = await fetch(url.href, { method: method, headers: new_request_headers }) let original_response_clone = original_response.clone() let original_text = null let response_headers = original_response.headers let new_response_headers = new Headers(response_headers) let status = original_response.status new_response_headers.set('access-control-allow-origin', '*') new_response_headers.set('access-control-allow-credentials', true) new_response_headers.delete('content-security-policy') new_response_headers.delete('content-security-policy-report-only') new_response_headers.delete('clear-site-data') const content_type = new_response_headers.get('content-type') if (content_type.includes('text/html') && content_type.includes('UTF-8')) { original_text = await replace_response_text(original_response_clone, upstream_domain, url_hostname) } else { original_text = original_response_clone.body } response = new Response(original_text, { status, headers: new_response_headers }) } return response } async function replace_response_text(response, upstream_domain, host_name) { let text = await response.text() var i, j for (i in replace_dict) { j = replace_dict[i] if (i == '$upstream') { i = upstream_domain } else if (i == '$custom_domain') { i = host_name } if (j == '$upstream') { j = upstream_domain } else if (j == '$custom_domain') { j = host_name } let re = new RegExp(i, 'g') text = text.replace(re, j) } return text } async function device_status(user_agent_info) { var agents = ["Android", "iPhone", "SymbianOS", "Windows Phone", "iPad", "iPod"] var flag = true for (var v = 0; v < agents.length; v++) { if (user_agent_info.indexOf(agents[v]) > 0) { flag = false break } } return flag }// 你要镜像的网站. const upstream = 'github.com' // 镜像网站的目录,比如你想镜像某个网站的二级目录则填写二级目录的目录名,镜像 google 用不到,默认即可. const upstream_path = '/' // 镜像站是否有手机访问专用网址,没有则填一样的. const upstream_mobile = 'github.com' // 屏蔽国家和地区. const blocked_region = ['KP', 'SY', 'PK', 'CU'] // 屏蔽 IP 地址. const blocked_ip_address = ['0.0.0.0', '127.0.0.1'] // 镜像站是否开启 HTTPS. const https = true // 文本替换. const replace_dict = {'$upstream': '$custom_domain', '//github.com': ''} // 以下保持默认,不要动 addEventListener('fetch', event => { event.respondWith(fetchAndApply(event.request)) }) async function fetchAndApply(request) { const region = request.headers.get('cf-ipcountry').toUpperCase() const ip_address = request.headers.get('cf-connecting-ip') const user_agent = request.headers.get('user-agent') let response = null let url = new URL(request.url) let url_hostname = url.hostname if (https == true) { url.protocol = 'https:' } else { url.protocol = 'http:' } if (await device_status(user_agent)) { var upstream_domain = upstream } else { var upstream_domain = upstream_mobile } url.host = upstream_domain if (url.pathname == '/') { url.pathname = upstream_path } else { url.pathname = upstream_path + url.pathname } if (blocked_region.includes(region)) { response = new Response('Access denied: WorkersProxy is not available in your region yet.', { status: 403 }) } else if (blocked_ip_address.includes(ip_address)) { response = new Response('Access denied: Your IP address is blocked by WorkersProxy.', { status: 403 }) } else { let method = request.method let request_headers = request.headers let new_request_headers = new Headers(request_headers) new_request_headers.set('Host', url.hostname) new_request_headers.set('Referer', url.hostname) let original_response = await fetch(url.href, { method: method, headers: new_request_headers }) let original_response_clone = original_response.clone() let original_text = null let response_headers = original_response.headers let new_response_headers = new Headers(response_headers) let status = original_response.status new_response_headers.set('access-control-allow-origin', '*') new_response_headers.set('access-control-allow-credentials', true) new_response_headers.delete('content-security-policy') new_response_headers.delete('content-security-policy-report-only') new_response_headers.delete('clear-site-data') const content_type = new_response_headers.get('content-type') if (content_type.includes('text/html') && content_type.includes('UTF-8')) { original_text = await replace_response_text(original_response_clone, upstream_domain, url_hostname) } else { original_text = original_response_clone.body } response = new Response(original_text, { status, headers: new_response_headers }) } return response } async function replace_response_text(response, upstream_domain, host_name) { let text = await response.text() var i, j for (i in replace_dict) { j = replace_dict[i] if (i == '$upstream') { i = upstream_domain } else if (i == '$custom_domain') { i = host_name } if (j == '$upstream') { j = upstream_domain } else if (j == '$custom_domain') { j = host_name } let re = new RegExp(i, 'g') text = text.replace(re, j) } return text } async function device_status(user_agent_info) { var agents = ["Android", "iPhone", "SymbianOS", "Windows Phone", "iPad", "iPod"] var flag = true for (var v = 0; v < agents.length; v++) { if (user_agent_info.indexOf(agents[v]) > 0) { flag = false break } } return flag }
2. 绑定自定义域名
感谢您的来访,获取更多精彩文章请收藏本站。

© 版权声明
THE END
暂无评论内容