出站 Worker

Outbound Workers 位于您客户的 Worker 和公共 Internet 之间。它们使您能够了解用户 Worker 中所有发出的 fetch() 请求。

常见用例

Outbound Workers 可用于：

记录所有子请求，以识别恶意域或使用模式。
为用户 Worker 请求的主机名创建、允许或阻止列表。
在后台为您背后的 API 配置身份验证（无需最终开发人员设置凭据）。

使用 Outbound Workers

要使用 Outbound Workers：

创建一个旨在用作您的 Outbound Worker 的 Worker。
可以在项目的 Wrangler 配置文件中，将出站 Worker 指定为分派命名空间绑定中的可选参数。或者，为了将数据从动态分派 Worker 传递到出站 Worker，可以在 parameters（参数） 下指定变量名称。

确保您已安装 wrangler@3.3.0 或更高版本。

{
	"dispatch_namespaces": [
		{
			"binding": "dispatcher",
			"namespace": "<NAMESPACE_NAME>",
			"outbound": {
				"service": "<SERVICE_NAME>",
				"parameters": [
					"params_object"
				]
			}
		}
	]
}

[[dispatch_namespaces]]
binding = "dispatcher"
namespace = "<NAMESPACE_NAME>"

  [dispatch_namespaces.outbound]
  service = "<SERVICE_NAME>"
  parameters = [ "params_object" ]

编辑您的动态分派 Worker 以调用出站 Worker 并声明变量以在 dispatcher.get() 传递。

export default {
	async fetch(request, env) {
		try {
			// parse the URL, read the subdomain
			let workerName = new URL(request.url).host.split(".")[0];

			let context_from_dispatcher = {
				customer_name: workerName,
				url: request.url,
			};

			let userWorker = env.dispatcher.get(
				workerName,
				{},
				{
					// outbound arguments. object name must match parameters in the binding
					outbound: {
						params_object: context_from_dispatcher,
					},
				},
			);
			return await userWorker.fetch(request);
		} catch (e) {
			if (e.message.startsWith("Worker not found")) {
				// we tried to get a worker that doesn't exist in our dispatch namespace
				return new Response("", { status: 404 });
			}
			return new Response(e.message, { status: 500 });
		}
	},
};

现在，当用户 Worker 发出任何 fetch() 请求时，都会调用 Outbound Worker。用户 Worker 将在 Outbound Worker 上触发 FetchEvent。绑定中声明的变量可以在 Outbound Worker 中通过 env.<VAR_NAME> 访问。

以下是 Outbound Worker 的示例，该示例记录来自用户 Worker 的 fetch 请求，如果 fetch 请求与 api.example.com 匹配，则创建 JWT。

export default {
	// this event is fired when the dispatched Workers make a subrequest
	async fetch(request, env, ctx) {
		// env contains the values we set in `dispatcher.get()`
		const customer_name = env.customer_name;
		const original_url = env.url;

		// log the request
		ctx.waitUntil(
			fetch("https://logs.example.com", {
				method: "POST",
				body: JSON.stringify({
					customer_name,
					original_url,
				}),
			}),
		);

		const url = new URL(original_url);
		if (url.host === "api.example.com") {
			// pre-auth requests to our API
			const jwt = make_jwt_for_customer(customer_name);

			let headers = new Headers(request.headers);
			headers.set("Authorization", `Bearer ${jwt}`);

			// clone the request to set new headers using existing body
			let new_request = new Request(request, { headers });

			return fetch(new_request);
		}

		return fetch(request);
	},
};