【ElasticSearch】在项目中如何使用ElasticSearch跟数据库同步数据

我们在项目中是如果需要使用到ElasticSearch，那么第一步就是在保持数据库的数据跟ElasticSearch的数据同步

那么接下来我们在laravle中操作一下这个实现的过程

创建控制器

命令：php artisan make:controller EditController

这个控制器就相当于是用户进行了提交了添加数据，然后使用dispatch这个方法，这个方法里边传的是一个模型操作实例

模型

然后需要在模型里边创建一个方法，用来处理同步到ElasticSearch的字段

创建队列

命令：php artisan make:job Test

在队列里边引入模型，然后实例化模型。在直接调用模型里边处理字段的方法，直接添加到ElasticSearch

<?php

namespace App\Jobs;

use App\Models\Goods;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;

/**
 * 使用队列的方式在把数据保存数据时同步至elasticsearch
 */
class Test implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    protected $goods;
    public function __construct(Goods $goods)
    {
        $this->goods = new Goods;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $data = $this->goods->toEsArray();
        app('es')->index([
            'index' => 'goods',
            'type' => '_doc',
            'id' => $data['id'],
            'body' => $data,
        ]);
    }
}


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
 

文章来源: blog.csdn.net，作者：咔咔-，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/fangkang7/article/details/96841250