අන්තර්ජාල පරිගණකයේ, · ඒ ගැන , සහ Senior Symfony Developer ලෙස, ඔබ දන්නවා% ...% ප්රශ්න තාක්ෂණික ණය ගබඩාව වේ. “search” is not just about finding text performance relevance user experience මෙම ලිපිය විස්තර කරන්නේ කෙසේද A Symfony 7.4 හි Elasticsearch ඇතුළත් කිරීම.We are not just “installing a bundle”; we are building a resilient, zero-downtime search architecture using , සහ සඳහා . production-grade PHP 8.4 features Attributes Symfony Messenger asynchronous indexing The Architecture: Performance & Resilience – ප් රයෝජනවත්තාවය සහ ප්රතිරෝධය ජුනිටර් යෙදුමකදී, සංකේත යාවත්කාලීන කිරීම, Elasticsearch වෙත සින්ක්රෝනීය HTTP ඇමතුමක් සිදු කරයි.Elastic පහත නම්, ඔබේ පරිශීලකයාගේ දත්ත රඳවා ගත නොහැක. අපගේ නිෂ්පාදන සැලැස්ම: 
 
 
 
 Zero-Downtime Indexing: We never write directly to the live index.We write to a time-stamped index and use an Alias to point the app to the current live version.අපි කිසි විටෙකත් සජීවී ඉංජිනේරු කිරීමට සජීවී ඉංජිනේරු කරන්නෙමු. Async Indexing: Database writes යනු Symfony Messenger භාවිතා කරන Search writes වලින් වෙන් කර ගැනීමයි. ශක්තිමත් ටයිප් කිරීම: අපි DTOs සහ ශක්තිමත් ටයිප් කරන සේවා භාවිතා කරනවා, හැකි අවස්ථාවලදී "මාජ පරාසය" වළක්වා ගනිමු. අවශ් යතා & ස්ථාපනය අපි පාවිච්චි කරන්නෙ f (v7.0+). එය රතු මත හොඳම අවබෝධය ලබා දෙයි පරිගණක සන්නිවේදන සම්මත Symfony අනුගමනය. riendsofsymfony/elastica-bundle elasticsearch-php පරිසර අවශ් යතා : 
 
 
 
 PHP 8.2 + (ප් රවර්ග 8.4) සයිටම් 7.4 ඉලෙක්ට්රොයිඩ් 8.x Dependencies ස්ථාපනය කිරීම ඔබගේ Terminal හි පහත සඳහන් ක්රියාත්මක කරන්න: composer require friendsofsymfony/elastica-bundle "^7.0"
composer require symfony/messenger
composer require symfony/serializer
 පරිසරය Configuration ඔබේ එකතු කරන්න ඔබේ නිෂ්පාදිතය තුළ, මෙය රහසිගත කළමනාකරණයක් තුළ තබා ගත යුතු බව සහතික කරන්න (උදාහරණයක් ලෙස හෝ ) Elasticsearch DSN .env Symfony Secrets HashiCorp Vault # .env
ELASTICSEARCH_URL=http://localhost:9200/
 “Zero-Downtime” ස්ථාපනය කිරීම එය බොහෝ උපාධි අසාර්ථක වන තැනකි.ඔවුන් ස්ටීක් ඉංජිනේරු නාමය සකස් කරයි.We will configure an aliased strategy to allow background reindexing without taking the site down. නිර්මාණය හෝ යාවත්කාලීන : config/packages/fos_elastica.yaml # config/packages/fos_elastica.yaml
fos_elastica:
    clients:
        default:
            url: '%env(ELASTICSEARCH_URL)%'
            # Production Tip: Increase timeout for bulk operations
            config:
                connect_timeout: 5
                timeout: 10

    indexes:
        app_products:
            # "use_alias: true" is critical for zero-downtime reindexing
            use_alias: true 
            
            # Define your distinct settings (analyzers, filters)
            settings:
                index:
                    analysis:
                        analyzer:
                            app_analyzer:
                                type: custom
                                tokenizer: standard
                                filter: [lowercase, asciifolding]

            # Your Persistence strategy (Doctrine integration)
            persistence:
                driver: orm
                model: App\Entity\Product
                provider: ~
                # CRITICAL: We disable the default listener to use Messenger instead
                listener: 
                    insert: false
                    update: false
                    delete: false
                finder: ~

            # Explicit Mapping (Always prefer explicit over dynamic for production)
            properties:
                id: { type: integer }
                name: 
                    type: text 
                    analyzer: app_analyzer
                    fields:
                        keyword: { type: keyword, ignore_above: 256 }
                description: { type: text, analyzer: app_analyzer }
                price: { type: float }
                stock: { type: integer }
                created_at: { type: date }
 Domain Layer එක අපි සාමාන් ය PHP 8 අංග භාවිතා කරමු. namespace App\Entity;

use App\Repository\ProductRepository;
use Doctrine\DBAL\Types\Types;
use Doctrine\ORM\Mapping as ORM;

#[ORM\Entity(repositoryClass: ProductRepository::class)]
#[ORM\Table(name: 'products')]
class Product
{
    #[ORM\Id]
    #[ORM\GeneratedValue]
    #[ORM\Column]
    private ?int $id = null;

    #[ORM\Column(length: 255)]
    private ?string $name = null;

    #[ORM\Column(type: Types::TEXT)]
    private ?string $description = null;

    #[ORM\Column]
    private ?float $price = null;

    #[ORM\Column]
    private ?int $stock = 0;

    #[ORM\Column]
    private ?\DateTimeImmutable $createdAt = null;

    public function __construct()
    {
        $this->createdAt = new \DateTimeImmutable();
    }

    // ... Getters and Setters
    
    public function getId(): ?int
    {
        return $this->id;
    }
    
    // ...
}
 Async Indexing with Messenger (The Senior Pattern) සමඟ අමුත්තන් අමුත්තන් අමුත්තන් නොලැබීම වෙනුවට අපගේ පරිශීලක ඉල්ලීම් ඉංජිනේරු කිරීමෙන් වහාම වේගවත් කිරීමෙන්, අපි ඊ-තැපැල් යැවීමට පණිවිඩයක් යැවෙනවා. fos_elastica පණිවිඩය සරල වෙනස් වූ සංකේතය හඳුනා ගැනීම. DTO (Data Transfer Object) namespace App\Message;

final readonly class IndexProductMessage
{
    public function __construct(
        public int $productId,
        // 'index' or 'delete'
        public string $action = 'index'
    ) {}
}
 Lifecycle Event සමුදාය අපගේ පණිවිඩය ස්වයංක්රීයව යැවීමට අපි පාඨමාලාවේ සිදුවීම් ඇසෙමු. namespace App\EventListener;

use App\Entity\Product;
use App\Message\IndexProductMessage;
use Doctrine\Bundle\DoctrineBundle\Attribute\AsDoctrineListener;
use Doctrine\ORM\Event\PostPersistEventArgs;
use Doctrine\ORM\Event\PostRemoveEventArgs;
use Doctrine\ORM\Event\PostUpdateEventArgs;
use Doctrine\ORM\Events;
use Symfony\Component\Messenger\MessageBusInterface;

#[AsDoctrineListener(event: Events::postPersist, priority: 500, connection: 'default')]
#[AsDoctrineListener(event: Events::postUpdate, priority: 500, connection: 'default')]
#[AsDoctrineListener(event: Events::postRemove, priority: 500, connection: 'default')]
class ProductIndexerSubscriber
{
    public function __construct(
        private MessageBusInterface $bus
    ) {}

    public function postPersist(PostPersistEventArgs $args): void
    {
        $this->dispatch($args->getObject(), 'index');
    }

    public function postUpdate(PostUpdateEventArgs $args): void
    {
        $this->dispatch($args->getObject(), 'index');
    }

    public function postRemove(PostRemoveEventArgs $args): void
    {
        // When removing, we still need the ID, but the object is technically gone from DB.
        // Ensure you capture the ID before it's fully detached if needed, 
        // but postRemove usually still has access to the object instance.
        $this->dispatch($args->getObject(), 'delete');
    }

    private function dispatch(object $entity, string $action): void
    {
        if (!$entity instanceof Product) {
            return;
        }

        $this->bus->dispatch(new IndexProductMessage($entity->getId(), $action));
    }
}
 ගනුදෙනුකරුවා එතන තමයි සැබෑ රැකියාව පසුපසින් වැඩ කරන පුද්ගලයා තුළ සිදු වන්නේ. namespace App\MessageHandler;

use App\Entity\Product;
use App\Message\IndexProductMessage;
use App\Repository\ProductRepository;
use FOS\ElasticaBundle\Persister\ObjectPersisterInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
final class IndexProductHandler
{
    public function __construct(
        // Inject the specific persister for 'app_products' index
        // The service ID usually follows the pattern fos_elastica.object_persister.<index_name>.<type_name>
        // Or you can bind it via services.yaml if autowiring fails
        private ObjectPersisterInterface $productPersister,
        private ProductRepository $productRepository
    ) {}

    public function __invoke(IndexProductMessage $message): void
    {
        if ($message->action === 'delete') {
             // For deletion, we can't fetch the entity as it's gone. 
             // We pass the ID directly to the persister.
             // Note: In some setups, you might need a stub object or just the ID.
             // The ObjectPersisterInterface typically expects an object, 
             // but strictly speaking, Elastica needs an ID. 
             // A cleaner way for delete is often using the Elastica Client directly 
             // if the Persister insists on an Entity object.
             // For simplicity here, we assume the persister handles ID lookups or we use a custom service.
             
             // Production-grade approach: Use the Raw Index Service for deletes to avoid hydration issues
             // But for this example, let's focus on Indexing.
             return; 
        }

        $product = $this->productRepository->find($message->productId);

        if (!$product) {
            // Product might have been deleted before this worker ran
            return;
        }

        // This pushes the single object to Elasticsearch
        $this->productPersister->replaceOne($product);
    }
}
 ඔබ පැහැදිලිව ලියාපදිංචි විය යුතුය persist in 2 වාහන නිවැරදිව හෝ භාවිතා කිරීම ඔබ විවිධ ඉංජිනේරු ඇත නම්. services.yaml ObjectPersisterInterface #[Target] # config/services.yaml
services:
    _defaults:
        bind:
            # Bind the specific persister to the argument name or type
            $productPersister: '@fos_elastica.object_persister.app_products'
 ප් රවර්ගය: The Repository Pattern ඔබගේ Controller වල Elastica logic ඇතුළත් නොකරන්න. namespace App\Service\Search;

use FOS\ElasticaBundle\Finder\TransformedFinder;

class ProductSearchService
{
    public function __construct(
        // The TransformedFinder returns Doctrine Entities. 
        // If you want raw speed and arrays, use the 'index' service directly.
        private TransformedFinder $productFinder
    ) {}

    /**
     * @return array<int, \App\Entity\Product>
     */
    public function search(string $query, int $limit = 20): array
    {
        // Elastica Query Builder
        $boolQuery = new \Elastica\Query\BoolQuery();
        
        // Match name or description
        $matchQuery = new \Elastica\Query\MultiMatch();
        $matchQuery->setQuery($query);
        $matchQuery->setFields(['name^3', 'description']); // Boost name by 3x
        $matchQuery->setFuzziness('AUTO'); // Handle typos
        
        $boolQuery->addMust($matchQuery);
        
        // Filter by stock (only in stock items)
        $stockFilter = new \Elastica\Query\Range('stock', ['gt' => 0]);
        $boolQuery->addFilter($stockFilter);

        $elasticaQuery = new \Elastica\Query($boolQuery);
        $elasticaQuery->setSize($limit);

        // Returns Hydrated Doctrine Objects
        return $this->productFinder->find($elasticaQuery);
    }
}
 පරීක්ෂණය & ස්ථාපනය Index එක හදන්න ඔබගේ යෙදුම වැඩ කිරීමට පෙර, ඔබ ඉංජිනේරු ආරම්භ කළ යුතුය. php bin/console fos:elastica:create
 ජනගහණ දත්ත (Initial Load) ඔබ MySQL වල දැනට පවතින දත්ත තිබේ නම්, එය Elastic වෙත තල්ලු කරන්න. php bin/console fos:elastica:populate
 මෙම නියෝගය Zero-Downtime ලෝහය භාවිතා කරයි: එය නව ඉංජිනේරුවක් නිර්මාණය කරයි, එය සම්පූර්ණ කරයි, පසුව අමුද්රව්යයෙන් අමුද්රව්යය මාරු කරයි. CURL හරහා පරීක්ෂා කරන්න ඔබගේ mapping නිවැරදිද යන්න පරීක්ෂා කරන්න Direct in Elastic. curl -X GET "http://localhost:9200/app_products/_mapping?pretty"
 ප් රතිඵල දැන් ඔබට සොයන ආකෘතිය තිබේ: 
 
 
 
 Survives DB load: Searching hits Elastic, not MySQL. පණිවිඩය Messenger (RabbitMQ / Redis) තුළ අතුරුදහන් වන අතර පසුව නැවත ප්රවේශ වේ. Survives Reindexing: ඔබ ඔබගේ විශ්ලේෂකයින් හා mappings වෙනස් කළ හැකි, fos:elastica:populate ක්රියාත්මක හා පරිශීලකයන් කිසිවක් අවබෝධ නොකරනු ඇත. එය උසස් තත්ත්වයේ Symfony යෙදුම් සඳහා සම්මත වේ. අප සමඟ සම්බන්ධ වන්න Linkedin [ PHP & Symfony Architecture ගැන වැඩි විස්තර https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

Read My Stories

මෙම ශ්‍රව්‍යය කතාවේ මුල් භාෂාවෙන් නිෂ්පාදනය කර ඇත!

Symfony Search That Doesn't Go Down: Zero-Downtime Elasticsearch + Async Indexing - සංකේතය සංකේතය සංකේතය

About Author

අදහස්

ටැග් එල්ලන්න

මෙම ලිපිය ඉදිරිපත් කරන ලදී

Related Stories

Seamless Sign-ups on the Move: Unlock Access as You Take Action!

The Spacecoin Writing Contest by Spacecoin and HackerNoon: Round 1 ප්රතිඵල

2025 Could See Tonga Become the Web3 Tech Hub of the Pacific

Verified Writers

Seamless Sign-ups on the Move: Unlock Access as You Take Action!

The Spacecoin Writing Contest by Spacecoin and HackerNoon: Round 1 ප්රතිඵල

2025 Could See Tonga Become the Web3 Tech Hub of the Pacific

Verified Writers

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps