; php.ini 推荐OPcache配置
[opcache]
opcache.enable=1
opcache.enable_cli=1
opcache.memory_consumption=256
opcache.interned_strings_buffer=16
opcache.max_accelerated_files=20000
opcache.max_wasted_percentage=10
opcache.use_cwd=1
opcache.validate_timestamps=0 ; 生产环境设置为0
opcache.revalidate_freq=60
opcache.fast_shutdown=1
opcache.enable_file_override=1
opcache.optimization_level=0x7FFFBFFF
opcache.jit_buffer_size=256M
opcache.jit=1235

// preload.php
opcache_compile_file(__DIR__.'/vendor/autoload.php');
opcache_compile_file(__DIR__.'/src/Kernel.php');// 预加载常用类
$classes = ['App\\Controller\\','App\\Entity\\','App\\Repository\\','Symfony\\Component\\HttpFoundation\\','Symfony\\Component\\Routing\\','Doctrine\\ORM\\',
];foreach ($classes as $prefix) {foreach (get_declared_classes() as $class) {if (str_starts_with($class, $prefix)) {opcache_compile_file((new ReflectionClass($class))->getFileName());}}
}

// 大数据集处理示例
function processLargeDataset(iterable $dataset): Generator {foreach ($dataset as $item) {// 处理每个数据项$result = heavyProcessing($item);// 使用yield减少内存占用yield $result;}
}// 使用示例
$data = fetchHugeDataFromDatabase(); // 返回生成器或可迭代对象
foreach (processLargeDataset($data) as $processed) {// 处理结果echo $processed . "\n";
}// 避免内存泄漏
function processRequest(): void {$bigArray = [];// 处理逻辑...// 显式释放内存unset($bigArray);gc_collect_cycles();
}

// 批量插入优化
function batchInsertUsers(array $users): void {$batchSize = 100;$em = $this->getEntityManager();foreach ($users as $i => $user) {$em->persist($user);if (($i % $batchSize) === 0) {$em->flush();$em->clear(); // 清除实体管理器释放内存}}$em->flush();$em->clear();
}// 查询构建器优化
$queryBuilder = $entityManager->createQueryBuilder()->select('u', 'p')->from(User::class, 'u')->leftJoin('u.posts', 'p')->where('u.active = :active')->setParameter('active', true)->setFirstResult(0)->setMaxResults(100)->getQuery()->setFetchMode(User::class, 'posts', ClassMetadata::FETCH_EAGER);// 使用原生SQL优化复杂查询
$sql = "SELECT u.id, u.name, COUNT(p.id) as post_countFROM users uLEFT JOIN posts p ON p.user_id = u.idWHERE u.created_at > :dateGROUP BY u.idHAVING post_count > :min_postsORDER BY post_count DESCLIMIT 100
";$result = $entityManager->getConnection()->executeQuery($sql, ['date' => '2023-01-01','min_posts' => 5
])->fetchAllAssociative();

// 数据库连接池实现
class ConnectionPool {private SplQueue $pool;private int $maxSize;private string $dsn;private string $username;private string $password;public function __construct(string $dsn,string $username,string $password,int $maxSize = 10) {$this->dsn = $dsn;$this->username = $username;$this->password = $password;$this->maxSize = $maxSize;$this->pool = new SplQueue();}public function getConnection(): PDO {if (!$this->pool->isEmpty()) {return $this->pool->dequeue();}if ($this->maxSize > 0 && $this->getCurrentSize() >= $this->maxSize) {throw new RuntimeException("Connection pool exhausted");}return new PDO($this->dsn,$this->username,$this->password,[PDO::ATTR_PERSISTENT => true,PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC]);}public function releaseConnection(PDO $connection): void {$this->pool->enqueue($connection);}public function getCurrentSize(): int {return $this->pool->count();}
}// 使用示例
$pool = new ConnectionPool('mysql:host=localhost;dbname=test','user','password',20
);$connection = $pool->getConnection();
try {$stmt = $connection->query('SELECT * FROM users LIMIT 100');$results = $stmt->fetchAll();
} finally {$pool->releaseConnection($connection);
}

class MultiLevelCache implements CacheInterface {private array $layers;private int $defaultTtl;public function __construct(array $layers, int $defaultTtl = 3600) {$this->layers = $layers;$this->defaultTtl = $defaultTtl;}public function get(string $key, callable $loader = null, int $ttl = null) {$ttl = $ttl ?? $this->defaultTtl;// 从最上层开始查找foreach ($this->layers as $layer) {$value = $layer->get($key);if ($value !== null) {// 填充上层缓存$this->warmUpperLayers($key, $value, $ttl);return $value;}}// 所有缓存层都未命中，调用加载器if ($loader !== null) {$value = $loader();$this->set($key, $value, $ttl);return $value;}return null;}public function set(string $key, $value, int $ttl = null): void {$ttl = $ttl ?? $this->defaultTtl;foreach ($this->layers as $layer) {$layer->set($key, $value, $ttl);}}private function warmUpperLayers(string $key, $value, int $ttl): void {$upperLayers = array_slice($this->layers, 0, -1);foreach ($upperLayers as $layer) {$layer->set($key, $value, $ttl);}}// 其他CacheInterface方法...
}// 使用示例
$cache = new MultiLevelCache([new ArrayCache(),          // 第一层：内存缓存new RedisCache($redis),    // 第二层：Redis缓存new FileCache('/tmp/cache')// 第三层：文件缓存
]);$value = $cache->get('expensive_query', function() {// 执行昂贵的数据库查询return $db->query('...');
}, 600);

class CacheInvalidator {private CacheInterface $cache;private EventDispatcherInterface $dispatcher;public function __construct(CacheInterface $cache,EventDispatcherInterface $dispatcher) {$this->cache = $cache;$this->dispatcher = $dispatcher;}public function onEntityUpdated(EntityEvent $event): void {$entity = $event->getEntity();// 基于实体类型和ID生成缓存键$cacheKey = $this->generateCacheKey($entity);// 直接失效缓存$this->cache->delete($cacheKey);// 发布缓存失效事件$this->dispatcher->dispatch(new CacheInvalidationEvent($cacheKey),CacheInvalidationEvent::NAME);}private function generateCacheKey(object $entity): string {return sprintf('%s_%s',get_class($entity),method_exists($entity, 'getId') ? $entity->getId() : spl_object_hash($entity));}
}// 缓存预热策略
class CacheWarmer {private CacheInterface $cache;private DataProviderInterface $dataProvider;public function __construct(CacheInterface $cache,DataProviderInterface $dataProvider) {$this->cache = $cache;$this->dataProvider = $dataProvider;}public function warmup(array $cacheKeys): void {foreach ($cacheKeys as $key) {$data = $this->dataProvider->getDataForKey($key);$this->cache->set($key, $data, 3600);}}public function warmupOnSchedule(): void {// 每天凌晨预热热门数据$hotData = $this->dataProvider->getHotData();foreach ($hotData as $key => $value) {$this->cache->set($key, $value, 86400);}}
}

// swoole_server.php
$http = new Swoole\Http\Server("0.0.0.0", 9501);// 配置选项
$http->set(['worker_num' => swoole_cpu_num() * 2,'enable_coroutine' => true,'task_worker_num' => 4,'task_enable_coroutine' => true,'max_request' => 1000,'document_root' => __DIR__.'/public','enable_static_handler' => true,
]);// 请求处理
$http->on('request', function ($request, $response) {try {// 初始化应用$kernel = new AppKernel('prod', false);$kernel->boot();// 转换Swoole请求为Symfony请求$sfRequest = transformSwooleRequest($request);// 处理请求$sfResponse = $kernel->handle($sfRequest);// 发送响应$response->status($sfResponse->getStatusCode());foreach ($sfResponse->headers->all() as $name => $values) {$response->header($name, implode(', ', $values));}$response->end($sfResponse->getContent());// 终止内核$kernel->terminate($sfRequest, $sfResponse);} catch (Throwable $e) {$response->status(500);$response->end('Internal Server Error');error_log($e->getMessage());}
});// 任务处理
$http->on('task', function ($server, $taskId, $workerId, $data) {// 处理耗时任务$result = processTask($data);// 返回任务结果return $result;
});// 任务完成回调
$http->on('finish', function ($server, $taskId, $data) {echo "Task {$taskId} finished\n";
});$http->start();function transformSwooleRequest(Swoole\Http\Request $request): Request {$get = $request->get ?? [];$post = $request->post ?? [];$files = $request->files ?? [];$server = $request->server ?? [];$headers = $request->header ?? [];return new Request($get,$post,[],[],$files,$server,$request->rawContent());
}

// 协程MySQL客户端
Co\run(function() {$mysql = new Swoole\Coroutine\MySQL();$mysql->connect(['host' => '127.0.0.1','user' => 'user','password' => 'pass','database' => 'test',]);// 并发执行多个查询$results = [];$wg = new Swoole\Coroutine\WaitGroup();$queries = ['SELECT * FROM users LIMIT 10','SELECT COUNT(*) FROM posts','SELECT * FROM products WHERE stock > 0'];foreach ($queries as $i => $query) {$wg->add();go(function() use ($wg, $mysql, $query, $i, &$results) {$results[$i] = $mysql->query($query);$wg->done();});}$wg->wait();// 处理结果foreach ($results as $result) {print_r($result);}
});// 协程HTTP客户端
Co\run(function() {$http = new Swoole\Coroutine\Http\Client('example.com', 443, true);$http->setHeaders(['Host' => 'example.com','User-Agent' => 'Chrome/91.0']);// 并发请求$wg = new Swoole\Coroutine\WaitGroup();$endpoints = ['/api/users', '/api/products', '/api/orders'];foreach ($endpoints as $endpoint) {$wg->add();go(function() use ($wg, $http, $endpoint) {$http->get($endpoint);echo "Response from {$endpoint}: {$http->statusCode}\n";$wg->done();});}$wg->wait();
});

// 生产者
class OrderEventProducer {private MessageProducer $producer;public function __construct(MessageProducer $producer) {$this->producer = $producer;}public function onOrderCreated(Order $order): void {$this->producer->send('order.created', ['order_id' => $order->getId(),'user_id' => $order->getUserId(),'amount' => $order->getTotalAmount(),'items' => array_map(fn($item) => ['product_id' => $item->getProductId(),'quantity' => $item->getQuantity(),'price' => $item->getPrice()],$order->getItems()),'created_at' => $order->getCreatedAt()->format(DateTime::ATOM)]);}
}// 消费者
class OrderEventConsumer {private OrderProcessor $processor;public function __construct(OrderProcessor $processor) {$this->processor = $processor;}public function consume(Message $message): void {try {$event = json_decode($message->getBody(), true);switch ($message->getRoutingKey()) {case 'order.created':$this->processor->processNewOrder($event);break;case 'order.paid':$this->processor->processPayment($event);break;case 'order.shipped':$this->processor->processShipping($event);break;}$message->ack();} catch (Exception $e) {$message->nack();error_log("Failed to process message: " . $e->getMessage());}}
}// 工作进程管理
class WorkerManager {private array $workers;private bool $shouldStop = false;public function addWorker(callable $worker, int $count = 1): void {for ($i = 0; $i < $count; $i++) {$this->workers[] = $worker;}}public function start(): void {pcntl_async_signals(true);pcntl_signal(SIGTERM, [$this, 'stop']);pcntl_signal(SIGINT, [$this, 'stop']);foreach ($this->workers as $worker) {$pid = pcntl_fork();if ($pid === -1) {throw new RuntimeException("Could not fork worker");} elseif ($pid === 0) {// 子进程while (!$this->shouldStop) {$worker();}exit(0);}}// 等待所有子进程while (pcntl_waitpid(0, $status) !== -1) {if (pcntl_wifexited($status)) {$exitCode = pcntl_wexitstatus($status);echo "Worker exited with code {$exitCode}\n";}}}public function stop(): void {$this->shouldStop = true;}
}

// blackfire.php
use Blackfire\Client;
use Blackfire\Profile\Configuration;$blackfire = new Client(['client_id' => $_ENV['BLACKFIRE_CLIENT_ID'],'client_token' => $_ENV['BLACKFIRE_CLIENT_TOKEN'],
]);// 自动性能分析
if (extension_loaded('blackfire')) {$probe = $blackfire->createProbe();register_shutdown_function(function() use ($blackfire, $probe) {$profile = $blackfire->endProbe($probe);// 存储分析结果file_put_contents(sprintf('profiles/profile-%s.json', date('Ymd-His')),json_encode($profile->getReport()));});
}// 自定义性能分析
function profile(callable $function, string $title): void {$config = new Configuration();$config->setTitle($title);$blackfire = new Client();$probe = $blackfire->createProbe($config);$function();$profile = $blackfire->endProbe($probe);echo "Profile for '{$title}':\n";print_r($profile->getReport());
}// 使用示例
profile(function() {// 需要分析的代码$result = expensiveOperation();
}, 'Expensive Operation Analysis');

// metrics.php
use Prometheus\CollectorRegistry;
use Prometheus\Storage\APC;$registry = new CollectorRegistry(new APC());// 注册指标
$requestCounter = $registry->registerCounter('app','http_requests_total','Total HTTP requests',['method', 'endpoint', 'status']
);$responseTimeHistogram = $registry->registerHistogram('app','http_response_time_seconds','HTTP response time',['method', 'endpoint'],[0.1, 0.5, 1, 2.5, 5, 10]
);// 中间件示例
class MetricsMiddleware implements MiddlewareInterface
{private $requestCounter;private $responseTimeHistogram;public function __construct(Counter $requestCounter,Histogram $responseTimeHistogram) {$this->requestCounter = $requestCounter;$this->responseTimeHistogram = $responseTimeHistogram;}public function process(ServerRequestInterface $request,RequestHandlerInterface $handler): ResponseInterface {$start = microtime(true);$response = $handler->handle($request);$duration = microtime(true) - $start;$path = $request->getUri()->getPath();$method = $request->getMethod();$status = $response->getStatusCode();// 记录指标$this->requestCounter->inc([$method,$path,$status]);$this->responseTimeHistogram->observe($duration, [$method,$path]);return $response;}
}// 暴露指标端点
$registry = new CollectorRegistry(new APC());
$renderer = new RenderTextFormat();
$result = $renderer->render($registry->getMetricFamilySamples());header('Content-Type: ' . RenderTextFormat::MIME_TYPE);
echo $result;

; php.ini JIT配置
[opcache]
opcache.enable=1
opcache.jit_buffer_size=256M
opcache.jit=1235

// cache_warmup.php
class CacheWarmerCommand extends Command
{protected function execute(InputInterface $input, OutputInterface $output): int{// 预热路由缓存$this->warmupRouterCache($output);// 预热配置缓存$this->warmupConfigCache($output);// 预热实体元数据缓存$this->warmupDoctrineMetadata($output);// 预热常用查询结果$this->warmupCommonQueries($output);return Command::SUCCESS;}private function warmupRouterCache(OutputInterface $output): void{$output->writeln('Warming up router cache...');$router = $this->getContainer()->get('router');$router->warmUp(dirname($router->getCacheDir()));}private function warmupCommonQueries(OutputInterface $output): void{$output->writeln('Warming up common queries...');$queries = ['popular_products' => 'SELECT * FROM products ORDER BY views DESC LIMIT 10','recent_posts' => 'SELECT * FROM posts ORDER BY created_at DESC LIMIT 5','user_stats' => 'SELECT COUNT(*) as user_count FROM users WHERE active = 1'];foreach ($queries as $key => $query) {$result = $this->getDoctrine()->getConnection()->executeQuery($query)->fetchAllAssociative();$this->getCache()->set($key, $result, 3600);}}
}

// connection_pool.php
class CoroutineConnectionPool {private SplQueue $pool;private int $maxSize;private string $dsn;private string $username;private string $password;private array $options;public function __construct(string $dsn,string $username,string $password,array $options = [],int $maxSize = 20) {$this->dsn = $dsn;$this->username = $username;$this->password = $password;$this->options = $options;$this->maxSize = $maxSize;$this->pool = new SplQueue();}public function getConnection(): CoroutineMySQLConnection {if ($this->pool->isEmpty()) {if ($this->getCurrentSize() >= $this->maxSize) {throw new RuntimeException("Connection pool exhausted");}return $this->createNewConnection();}return $this->pool->dequeue();}public function releaseConnection(CoroutineMySQLConnection $connection): void {if ($connection->connected) {$this->pool->enqueue($connection);}}private function createNewConnection(): CoroutineMySQLConnection {$connection = new CoroutineMySQLConnection();$connection->connect(['host' => $this->parseHostFromDsn(),'user' => $this->username,'password' => $this->password,'database' => $this->parseDatabaseFromDsn(),] + $this->options);return $connection;}private function parseHostFromDsn(): string {// 解析DSN获取主机信息preg_match('/host=([^;]+)/', $this->dsn, $matches);return $matches[1] ?? '127.0.0.1';}private function parseDatabaseFromDsn(): string {preg_match('/dbname=([^;]+)/', $this->dsn, $matches);return $matches[1] ?? 'test';}
}// 使用示例
Co\run(function() {$pool = new CoroutineConnectionPool('mysql:host=127.0.0.1;dbname=test','user','password',[],20);$wg = new Swoole\Coroutine\WaitGroup();for ($i = 0; $i < 100; $i++) {$wg->add();go(function() use ($wg, $pool, $i) {$conn = $pool->getConnection();try {$result = $conn->query("SELECT * FROM users WHERE id = " . ($i % 10 + 1));echo "Query {$i} result: " . count($result) . " rows\n";} finally {$pool->releaseConnection($conn);$wg->done();}});}$wg->wait();
});