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。