PHP 中使用 ElasticSearch 的最佳实践

Posted 2020-12-17 Yxh_blogs

php 中使用 ElasticSearch 的最佳实践

引言

PHP 开发者其实使用到 ES 的情况并不多，因为开发的大多数项目可能都没有快速模糊搜索的需求。
即使有这样的需求，用 mysql 的 like 查询，就基本可以搞定需求了。
也就没有必要杀鸡用宰牛刀，使用 ES 了。
正是在这种情况下，导致很多的 PHP 开发者都没有接触过 ES。
即使有一些对 ES 有兴趣的，也因为 ES 中文文档的缺乏，而放弃了。
因此，接下来的这篇文章就类比 MySQL 来使用 ES，让大多数的 PHP 开发者能使用起 ES 来。

注：ElasticSearch 在文中简称 ES。

实现思路

我先简单的描述一下需求：
实现一个商品的搜索功能，只要含有搜索关键字词的就匹配，并且按照发布时间和价格倒序。

我这里已经安装好 MySQL 和 ES 了。如果没有安装的同学，可以先自行安装。

先在 MySQL 中创建一张数据表 product，建表语句如下：

CREATE TABLE `product` (
	`product_id` int(11) UNSIGNED PRIMARY KEY AUTO_INCREMENT COMMENT ‘商品 ID‘,
	`name` varchar(64) NOT NULL DEFAULT ‘‘ COMMENT ‘商品名称‘,
	`sku` varchar(32) NOT NULL DEFAULT ‘‘ COMMENT ‘商品 SKU‘,
	`price` decimal(4, 2) NOT NULL DEFAULT 0 COMMENT ‘商品价格‘,
	`sales` int(11) NOT NULL DEFAULT 0 COMMENT ‘商品销量‘,
	`date_added` datetime COMMENT ‘创建时间‘,
	`date_modified` datetime COMMENT ‘修改时间‘
) ENGINE = InnoDB CHARACTER SET = utf8mb4;

然后对应在 ES 中创建索引 product

// 创建索引并定义属性
PUT http://127.0.0.1/product

{
 "settings": {
     "number_of_shards": 1,
     "number_of_replicas": 1
 },
 "mappings": {
     "properties": {
         "product_id": {
             "type": "integer"
         },
         "name" : {
             "type": "text"
         },
         "sku": {
             "type": "text"
         },
         "price": {
             "type": "double"
         },
         "sales": {
             "type": "integer"
         },
         "date_added": {
             "type": "date",
             "format": "yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis"
         },
         "date_modified": {
             "type": "date",
             "format": "yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || epoch_millis"
         }
     }
 }
}

创建好索引之后，我们就从 MySQL 将数据同步到 ES，同步的方案有如下三种：
1、可以直接在存储入 MySQL 之后，就直接写入 ES。
2、通过 Logstash 定时，从 MySQL 数据库中拉取数据同步到 ES。
3、可以通过第三方中间件（例如：canal、go-mysql-elasticsearch），拉取 MySQL 的 binlog 日志，之后中间件解析日志将数据同步到 ES。

创建好索引和添加数据之后，在业务的发展过程中，可能会增加字段。
这里增加一个 description 字段。

现在 MySQL 中增加字段到 product 数据表。

alter table `product` add column description varchar(255) default "" comment "商品描述";

然后向 ES 中的 product 索引，增加属性字段。

// 增加映射字段
// http://127.0.0.1:9200/product/_mapping
{
	"properties": {
		"description": {
			"type": "text"
		}
	}
}   

业务发展到中后时期的时候，可能发现字段越来越多了，这个时候想要删除一些字段。
但是，在 ES 中的 Mapping 中是不能直接删除字段的，只能重新创建。
很多情况，我们还是不建议去删除字段，因为这会增加很多不必要的成本以及带来的风险。
如果，为了节省存储空间，Boss 一定要删除字段。那就按照下面的方法，也是可以实现的。

1、创建一个新的索引
2、创建新的映射关系 mapping
3、将原索引的数据到入到新索引
4、新索引创建原索引一致的别名
5、删除原索引

下一篇文章，我将会介绍如何在 laravel 框架中使用 ES。