如何在 Magento 中安全集成 AmpHP 实现并行处理

magento 的 objectmanager 无法在 amphp 子进程（worker）中自动初始化，因其依赖完整的应用内核启动流程；正确做法是将耗时逻辑封装为独立 http api 接口，并通过异步 http 请求（如 `amp\http\client`）调用，而非直接在 `parallelmap` 中执行 magento 业务代码。

Magento 是一个高度耦合、生命周期严格的全栈框架，其核心服务（如 ObjectManager、事件系统、配置加载、插件机制等）仅在 Magento\Framework\App\Bootstrap 启动后才可用。而 AmpHP 的 Amp\Parallel\Worker 会 fork 出全新、隔离的 PHP 进程，该进程不继承父进程的运行时状态——即使 Composer 自动加载器已注册，Magento 的依赖类虽可被加载，但整个 DI 容器、模块注册、环境配置等均未初始化，因此抛出 "ObjectManager isn't initialized" 异常。

✅ 正确实践：API 解耦 + 异步 HTTP 调用
将原本需并行处理的 Magento 业务逻辑（如 $this->getCustomItems($item, $arg1)）封装为轻量级 REST API 接口，例如：

// 在 Magento 中新增 Controller（示例路径：Controller/Api/ProcessItem.php）
class ProcessItem extends \Magento\Framework\App\Action\Action
{
    public function execute()
    {
      
  $params = $this->getRequest()->getParams();
        $item = $params['item'] ?? null;
        $arg1 = $params['arg1'] ?? null;

        if (!$item || !$arg1) {
            $this->getResponse()->setStatusCode(400);
            return $this->getResponse()->representJson(['error' => 'Missing params']);
        }

        try {
            $result = $this->getCustomItems($item, $arg1); // 此处可安全使用完整 Magento 上下文
            $this->getResponse()->representJson(['success' => true, 'data' => $result]);
        } catch (\Exception $e) {
            $this->getResponse()->setStatusCode(500);
            $this->getResponse()->representJson(['error' => $e->getMessage()]);
        }
    }
}

然后，在自定义模块中使用 AmpHP 的异步 HTTP 客户端并发请求该接口：

use Amp\Http\Client\HttpClient;
use Amp\Http\Client\HttpClientBuilder;
use Amp\Promise;
use Amp\Success;

require_once BP . '/app/autoload.php'; // 确保 Magento autoloader 可用（仅用于当前进程）

$httpClient = HttpClientBuilder::buildDefault();

$promises = array_map(function ($item) use ($httpClient, $arg1) {
    $uri = 'https://your-magento-site.com/rest/V1/custom/process-item';
    $body = json_encode(['item' => $item, 'arg1' => $arg1]);

    return $httpClient->request(
        new Amp\Http\Client\Request($uri, 'POST', $body)
            ->addHeader('Content-Type', 'application/json')
            ->addHeader('Authorization', 'Bearer ' . $this->getAdminToken()) // 如需认证，请按需实现
    )->then(function (Amp\Http\Client\Response $response) {
        return json_decode($response->getBody(), true);
    });
}, $items);

try {
    $results = await(Amp\Promise\all($promises));
    foreach ($results as $result) {
        // 处理每个响应
        var_dump($result);
    }
} catch (Amp\MultiReasonException $e) {
    foreach ($e->getReasons() as $reason) {
        error_log('Request failed: ' . $reason->getMessage());
    }
}

⚠️ 注意事项：

• 避免在 Worker 中加载 Magento 框架：Amp\Parallel\Worker 不支持共享 ObjectManager 或任何运行时状态，强行尝试会导致不可预测错误；
• API 接口需无状态、幂等设计：确保每个请求完全独立，不依赖 Session、全局变量或未声明的上下文；
• 性能权衡：HTTP 调用有网络开销，建议配合连接池（HttpClientBuilder::setConnectionLimit()）与合理超时设置；
• 安全与认证：生产环境务必启用 Token/Bearer 认证或 IP 白名单，防止未授权调用；
• 错误处理必须完备：网络超时、5xx 响应、JSON 解析失败等均需捕获并降级处理。

总结：AmpHP 与 Magento 并非天然兼容，核心矛盾在于“进程隔离”与“框架上下文强依赖”的冲突。解耦为 HTTP 接口是目前最稳定、可维护、符合分层架构原则的方案，既保留了 AmpHP 的高并发能力，又严格遵循了 Magento 的生命周期规范。