Ao amin'ny sehatry ny tranonkala vaovao, Izany dia momba Ny Ary Amin'ny maha-Senior Symfony Developer ianao, fantatrao fa ny fanontaniana LIKE %...% dia tranga ara-teknika. “search” is not just about finding text performance relevance user experience Ity lahatsoratra ity dia mamaritra ny fomba hanaovana Ny fametrahana ny Elasticsearch ao amin'ny Symfony 7.4 dia tsy "mampiasa ny bundle" fotsiny isika; Mampiasa ny rafitra fikarohana azo antoka sy tsy misy fotoana fohy izahay. Ny Ary Ny . production-grade PHP 8.4 features Attributes Symfony Messenger asynchronous indexing Ny famolavolana: Performance & Resilience Ao amin'ny fametrahana junior, ny fanavaozana entity dia miteraka antso HTTP synchronous amin'ny Elasticsearch. Raha Elastic dia ambany, ny mpampiasa dia tsy afaka mamonjy ny angon-drakitra. Ny drafitry ny famokarana: 
 
 
 
 Zero-Downtime Indexing: Tsy manoratra mivantana amin'ny live index isika. Manoratra amin'ny indices voamarina amin'ny fotoana ary mampiasa Alias mba hampitandrina ny fampiharana amin'ny famoahana velona amin'izao fotoana izao. Async Indexing: Ny rakitra Database dia miala amin'ny rakitra Search amin'ny fampiasana ny Symfony Messenger. Strict Typing: Mampiasa DTOs sy serivisy matanjaka izahay, manakana ny "magic array" raha azo atao. Ny fepetra takiana & fametrahana Noho izany dia hampiasa f (v7.0+). Manome ny tsara indrindra amin'ny abstraktion amin'ny Ny mpanjifa dia mifanaraka amin'ny fitsipika konfiguration ny Symfony. riendsofsymfony/elastica-bundle elasticsearch-php Ny fepetra momba ny tontolo iainana: 
 
 
 
 PHP 8.2 + (nitranga in-1) Ny fivoaran'ny 7.4 Amin'ny alalan'ny Elasticsearch 8.x Ny fametrahana ny dependencies Ataovy ao amin'ny terminal anao ny zavatra manaraka: composer require friendsofsymfony/elastica-bundle "^7.0"
composer require symfony/messenger
composer require symfony/serializer
 Ny tontolo iainana Configuration Ampiasao ny Ny anao Ao amin'ny famokarana, ataovy azo antoka fa voatahiry ao amin'ny mpitantana tsiambaratelo (ohatra Ary Ny Elasticsearch DSN .env Symfony Secrets HashiCorp Vault # .env
ELASTICSEARCH_URL=http://localhost:9200/
 Ny fametrahana ny “Zero-Downtime” Izany no mahatonga ny ankamaroan'ny fampiofanana tsy mahomby. Izy ireo dia mametraka anarana index static. Hisafidy drafitra aliased mba hahafahan'ny background reindexing tsy mampihena ny tranonkala. Mamorona na manatsara : 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 }
 Ny sehatry ny Domain Aoka isika hotsaraina amin'ny entity vokatra ankapobeny. Hampiasa ny toetra PHP 8 ankapobeny izahay. 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 amin'ny Messenger (Ny Pattern Senior) Fa raha tsy mamela mampihena ny fangatahan'ny mpampiasa amin'ny alàlan'ny indexing avy hatrany, dia handefa hafatra amin'ny fiara. fos_elastica Ny hafatra Ny tsotra mba hanana ny ID ny orinasa izay niova. DTO (Data Transfer Object) namespace App\Message;

final readonly class IndexProductMessage
{
    public function __construct(
        public int $productId,
        // 'index' or 'delete'
        public string $action = 'index'
    ) {}
}
 Ny fifanarahana amin'ny lifecycle Mihaino ny zava-nitranga ao amin'ny Doktrina isika mba handefa ny hafatra. 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));
    }
}
 Ny mpandraharaha Izany no mahatonga ny asa tena mitranga ao amin'ny mpiara-miasa amin'ny loharano. 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);
    }
}
 Tsy maintsy misoratra anarana ny persister mazava tsara ao amin'ny Ny fiara tsara, na amin'ny fampiasana Raha manana indices maromaro ianao. 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'
 Searching: Ny Pattern ny Repository Aza mametraka ny Elastica logic ao amin'ny Controller. Mamorona serivisy manokana. 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);
    }
}
 Ny fanamarinana sy ny fametrahana Ampiasao ny Index Alohan'ny ahafahana miasa ny fampiharana, dia tsy maintsy manomboka ny indices ianao. php bin/console fos:elastica:create
 Ny angon-drakitra momba ny mponina (Initial Load) Raha manana angon-drakitra misy anao ao amin'ny MySQL ianao, tsindrio izany amin'ny Elastic. php bin/console fos:elastica:populate
 Ity baiko ity dia mampiasa ny logic Zero-Downtime: dia mamorona indices vaovao, mameno azy ary avy eo manova ny antso atomika. Ataovy azo antoka amin'ny alalan'ny cURL Ataovy azo antoka fa ny fametrahana dia marina mivantana ao amin'ny Elastic. curl -X GET "http://localhost:9200/app_products/_mapping?pretty"
 Ny famaranana Ankehitriny dia manana rafitra fikarohana ianao izay: 
 
 
 
 Mahavita ny fandefasana DB: Ny fikarohana dia mahita Elastic, fa tsy MySQL. Mijanona amin'ny fialan-tsasatra Elastic: Messages mandeha eo amin'ny Messenger (RabbitMQ / Redis) ary miverina amin'ny farany. Survives Reindexing: Azonao atao ny manova ny analyzers sy ny mappings, mihazakazaka fos:elastica:populate ary ny mpampiasa dia tsy hahita zavatra iray. Izany no fitsipika ho an'ny fampiharana Symfony avo lenta. Mifandray amiko amin'ny LinkedIn [ ] ho an'ny fahatsapana bebe kokoa momba ny PHP & Symfony architecture. https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

Read My Stories

Ity horonam-peo ity dia novokarina tamin'ny fiteny niandohan'ny tantara!

Ny fikarohana Symfony izay tsy midina: Zero-Downtime Elasticsearch + Async Indexing

About Author

COMMENTS

HANG TAGS

ITY ARTICLE ITY NO NARESAKA TAMIN'NY

Related Stories

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps