Создание децентрализованной системы продажи билетов на мероприятия Web3 с использованием Symfony 7.4

Пересечение Web3 и традиционных веб-фреймворков — это то место, где начинается реальная практическая полезность. Хотя циклы ажиотажа приходят и уходят, полезность невзаимозаменяемых токенов (NFT) для подтверждения владения — особенно в билетной системе мероприятий — остается надежным вариантом использования.

В этой статье мы создадим основу децентрализованной системы продажи билетов на мероприятия с использованием Symfony 7.4 и PHP 8.3. Мы выйдем за рамки базовых руководств и реализуем производственную архитектуру, которая обрабатывает асинхронную природу блокчейн-транзакций с использованием компонента Symfony Messenger.

Архитектура

«Продвинутый» подход признает, что PHP не является долгоживущим процессом, как Node.js. Поэтому мы не прослушиваем события блокчейна в режиме реального времени в контроллере. Вместо этого мы используем гибридный подход:

1. Прямое взаимодействие (запись): Мы используем Symfony Messenger для передачи транзакций «минтинга» рабочему процессу, предотвращая тайм-ауты HTTP.
2. Опрос RPC (чтение): Мы используем запланированные команды для проверки статуса в сети.
3. Смарт контракт: Мы предполагаем стандартный контракт ERC-721, развернутый в совместимой с EVM сети (Ethereum, Polygon, Base).

Предварительные требования и стек

• PHP: 8.3+
• Symfony: 7.4 (LTS)
• Blockchain Node: Infura, Alchemy или локальный узел Hardhat.

Многие PHP Web3 библиотеки заброшены или плохо типизированы. Хотя web3p/web3.php является самой известной, строгая зависимость от нее может быть рискованной из-за пробелов в обслуживании.

Для этого руководства мы будем использовать web3p/web3.php (версия ^0.3) для кодирования ABI, но будем использовать нативный HttpClient от Symfony для фактической передачи JSON-RPC. Это дает нам полный контроль над тайм-аутами, повторными попытками и логированием — критически важными для продакшн-приложений.

Настройка проекта

Сначала установим зависимости. Нам нужны среда выполнения Symfony, HTTP-клиент и библиотека Web3.

composer create-project symfony/skeleton:"7.4.*" decentralized-ticketing cd decentralized-ticketing composer require symfony/http-client symfony/messenger symfony/uid web3p/web3.php

Убедитесь, что ваш composer.json отражает стабильность:

{ "require": { "php": ">=8.3", "symfony/http-client": "7.4.*", "symfony/messenger": "7.4.*", "symfony/uid": "7.4.*", "web3p/web3.php": "^0.3.0" } }

Сервис блокчейна

Нам нужен надежный сервис для взаимодействия с блокчейном. Мы создадим EthereumService, который оборачивает вызовы JSON-RPC.

//src/Service/Web3/EthereumService.php namespace App\Service\Web3; use Symfony\Contracts\HttpClient\HttpClientInterface; use Symfony\Component\DependencyInjection\Attribute\Autowire; use Web3\Utils; class EthereumService { private const JSON_RPC_VERSION = '2.0'; public function __construct( private HttpClientInterface $client, #[Autowire(env: 'BLOCKCHAIN_RPC_URL')] private string $rpcUrl, #[Autowire(env: 'SMART_CONTRACT_ADDRESS')] private string $contractAddress, #[Autowire(env: 'WALLET_PRIVATE_KEY')] private string $privateKey ) {} /** * Reads the owner of a specific Ticket ID (ERC-721 ownerOf). */ public function getTicketOwner(int $tokenId): ?string { // Function signature for ownerOf(uint256) is 0x6352211e // We pad the tokenId to 64 chars (32 bytes) $data = '0x6352211e' . str_pad(Utils::toHex($tokenId, true), 64, '0', STR_PAD_LEFT); $response = $this->callRpc('eth_call', [ [ 'to' => $this->contractAddress, 'data' => $data ], 'latest' ]); if (empty($response['result']) || $response['result'] === '0x') { return null; } // Decode the address (last 40 chars of the 64-char result) return '0x' . substr($response['result'], -40); } /** * Sends a raw JSON-RPC request using Symfony HttpClient. * This offers better observability than standard libraries. */ private function callRpc(string $method, array $params): array { $response = $this->client->request('POST', $this->rpcUrl, [ 'json' => [ 'jsonrpc' => self::JSON_RPC_VERSION, 'method' => $method, 'params' => $params, 'id' => random_int(1, 9999) ] ]); $data = $response->toArray(); if (isset($data['error'])) { throw new \RuntimeException('RPC Error: ' . $data['error']['message']); } return $data; } }

Запустите локальный тест доступа к getTicketOwner с известным созданным ID. Если вы получите адрес 0x, ваше подключение RPC работает.

Асинхронный минтинг с Messenger

Блокчейн-транзакции медленные (от 15 секунд до минут). Никогда не заставляйте пользователя ждать подтверждения блока в запросе браузера. Мы будем использовать Symfony Messenger для обработки этого в фоновом режиме.

Сообщение

//src/Message/MintTicketMessage.php: namespace App\Message; use Symfony\Component\Uid\Uuid; readonly class MintTicketMessage { public function __construct( public Uuid $ticketId, public string $userWalletAddress, public string $metadataUri ) {} }

Обработчик

Здесь происходит магия. Мы будем использовать вспомогательную библиотеку web3p/web3.php для локальной подписи транзакции.

Примечание: В среде с высокой безопасностью вы бы использовали службу управления ключами (KMS) или отдельный анклав подписи. Для этой статьи мы подписываем локально.

//src/MessageHandler/MintTicketHandler.php namespace App\MessageHandler; use App\Message\MintTicketMessage; use App\Service\Web3\EthereumService; use Psr\Log\LoggerInterface; use Symfony\Component\Messenger\Attribute\AsMessageHandler; use Web3\Contract; use Web3\Providers\HttpProvider; use Web3\RequestManagers\HttpRequestManager; use Web3p\EthereumTx\Transaction; #[AsMessageHandler] class MintTicketHandler { public function __construct( private EthereumService $ethereumService, // Our custom service private LoggerInterface $logger, #[Autowire(env: 'BLOCKCHAIN_RPC_URL')] private string $rpcUrl, #[Autowire(env: 'WALLET_PRIVATE_KEY')] private string $privateKey, #[Autowire(env: 'SMART_CONTRACT_ADDRESS')] private string $contractAddress ) {} public function __invoke(MintTicketMessage $message): void { $this->logger->info("Starting mint process for Ticket {$message->ticketId}"); // 1. Prepare Transaction Data (mintTo function) // detailed implementation of raw transaction signing usually goes here. // For brevity, we simulate the logic flow: try { // Logic to get current nonce and gas price via EthereumService // $nonce = ... // $gasPrice = ... // Sign transaction offline to prevent key exposure over network // $tx = new Transaction([...]); // $signedTx = '0x' . $tx->sign($this->privateKey); // Broadcast // $txHash = $this->ethereumService->sendRawTransaction($signedTx); // In a real app, you would save $txHash to the database entity here $this->logger->info("Mint transaction broadcast successfully."); } catch (\Throwable $e) { $this->logger->error("Minting failed: " . $e->getMessage()); // Symfony Messenger will automatically retry based on config throw $e; } } }

Контроллер

Контроллер остается простым. Он принимает запрос, проверяет ввод, создает сущность билета «В ожидании» в вашей базе данных (опущено для краткости) и отправляет сообщение.

//src/Controller/TicketController.php: namespace App\Controller; use App\Message\MintTicketMessage; use Symfony\Bundle\FrameworkBundle\Controller\AbstractController; use Symfony\Component\HttpFoundation\JsonResponse; use Symfony\Component\HttpFoundation\Request; use Symfony\Component\Messenger\MessageBusInterface; use Symfony\Component\Routing\Attribute\Route; use Symfony\Component\Uid\Uuid; #[Route('/api/v1/tickets')] class TicketController extends AbstractController { #[Route('/mint', methods: ['POST'])] public function mint(Request $request, MessageBusInterface $bus): JsonResponse { $payload = $request->getPayload(); $walletAddress = $payload->get('wallet_address'); // 1. Basic Validation if (!$walletAddress || !str_starts_with($walletAddress, '0x')) { return $this->json(['error' => 'Invalid wallet address'], 400); } // 2. Generate Internal ID $ticketId = Uuid::v7(); // 3. Dispatch Message (Fire and Forget) $bus->dispatch(new MintTicketMessage( $ticketId, $walletAddress, 'https://api.myapp.com/metadata/' . $ticketId->toRfc4122() )); // 4. Respond immediately return $this->json([ 'status' => 'processing', 'ticket_id' => $ticketId->toRfc4122(), 'message' => 'Minting request queued. Check status later.' ], 202); } }

Конфигурация и руководство по стилю

Следуя стилю Symfony 7.4, мы используем строгую типизацию и атрибуты. Убедитесь, что ваш messenger.yaml настроен для асинхронной передачи.

#config/packages/messenger.yaml: framework: messenger: transports: async: dsn: '%env(MESSENGER_TRANSPORT_DSN)%' retry_strategy: max_retries: 3 delay: 1000 multiplier: 2 routing: 'App\Message\MintTicketMessage': async

Верификация

Чтобы проверить, что эта реализация работает без развертывания в основную сеть:

Локальный узел: Запустите локальный блокчейн с использованием Hardhat или Anvil (Foundry).

npx hardhat node

Окружение: Настройте свой .env.local так, чтобы он указывал на localhost.

BLOCKCHAIN_RPC_URL="http://127.0.0.1:8545" WALLET_PRIVATE_KEY="<one of the test keys provided by hardhat>" SMART_CONTRACT_ADDRESS="<deployed contract address>" MESSENGER_TRANSPORT_DSN="doctrine://default"

Потребление: Запустите воркер.

php bin/console messenger:consume async -vv

Запрос:

curl -X POST https://localhost:8000/api/v1/tickets/mint \ -H "Content-Type: application/json" \ -d '{"wallet_address": "0xf39Fd6e51aad88F6F4ce6aB8827279cffFb92266"}'

Вы должны увидеть, как воркер обрабатывает сообщение, и, если вы полностью реализовали логику подписи необработанной транзакции, хеш транзакции появится в вашей консоли Hardhat.

Заключение

Создание приложений Web3 на PHP требует изменения мышления. Вы не просто создаете CRUD-приложение; вы создаете оркестратор для децентрализованного состояния.

Используя Symfony 7.4, мы задействовали:

• HttpClient для надежной, управляемой RPC-коммуникации.
• Messenger для обработки асинхронной реальности блокчейнов.
• атрибуты PHP 8.3 для чистого, читаемого кода.

Эта архитектура масштабируется. Продаете ли вы 10 билетов или 10 000, очередь сообщений выступает в качестве буфера, гарантируя, что ваши транзакции не конфликтуют, а ваш сервер не зависает.

Готовы масштабировать вашу инфраструктуру Web3?

Интеграция блокчейна требует точности. Если вам нужна помощь в аудите взаимодействия смарт-контрактов или масштабировании ваших обработчиков сообщений Symfony, давайте свяжемся.

\