记一次Meilisearch轻量级搜索引擎使用

以前使用的是mysql的全文索引、最开始还行。后续觉得就不好用了，但是服务器资源有限，没法上ES，只好找一个轻量级的搜索引擎、找了半天，决定使用这一个，目前效果还不错的。

参考网址
官网：https://www.meilisearch.com/docs/reference/api/overview
java第三方sdk：https://github.com/meilisearch/meilisearch-java/issues

0、docker安装 很快的

略

安装好你可以通过 host:7700打开web页面

1、客户端的创建

package xxx.x.x;

import cn.hutool.core.util.ObjectUtil;
import com.meilisearch.sdk.Client;
import com.meilisearch.sdk.Config;
import com.meilisearch.sdk.json.JacksonJsonHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class MeilisearchConfig {

@Value("${meilisearch.url:http://127.0.01:7700}")
private String meilisearchUrl;
@Value("${meilisearch.masterKey:}")
private String masterKey = "masterKey";

private volatile Client client;

/**
 * 获取 MeiliSearch 客户端
 *
 * @return
 */
public Client getClient() {
if (ObjectUtil.isNull(client)) {
synchronized (this) {
if (ObjectUtil.isNull(client)) {
client = buildClient();
}
}
}
return client;
}

/**
 * 构建 MeiliSearch 客户端
 *
 * @return
 */
public Client buildClient() {
Config config = new Config(meilisearchUrl, masterKey, new JacksonJsonHandler());
client = new Client(config);
log.info("MeiliSearch Client 初始化完成");
return client;
}

}

2、简单工具类

package xxx.util;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import cn.hutool.log.Log;
import cn.hutool.log.LogFactory;
import com.meilisearch.sdk.Client;
import com.meilisearch.sdk.Index;
import com.meilisearch.sdk.model.TaskInfo;
import top.shareus.bot.common.eumn.meilisearch.MeilisearchIndexEnums;

import java.util.List;

public class MeilisearchUtil {

private final static Log log = LogFactory.getCurrentLogFactory().getLog(MeilisearchUtil.class);

/**
 * 添加文档
 *
 * @param meilisearchClient
 * @param indexEnums
 * @param objList
 * @param <T>
 */
public static <T> void addDocuments(Client meilisearchClient, MeilisearchIndexEnums indexEnums, List<T> objList) {
if (ObjectUtil.hasNull(meilisearchClient, indexEnums) || CollUtil.isEmpty(objList)) {
return;
}
log.info("-----------------------------------------------------");

JSONArray array = new JSONArray();

List<JSONObject> objectList = objList.stream().map(JSONObject::new).toList();
log.info("待添加文档数量: {}", objectList.size());

array.put(objectList);
String documents = array.getJSONArray(0).toString();

Index index = meilisearchClient.index(indexEnums.getIndex());

String primaryKey = indexEnums.getPrimaryKey();
TaskInfo taskInfo;
if (StrUtil.isBlank(primaryKey)) {
taskInfo = index.addDocuments(documents);
} else {
taskInfo = index.addDocuments(documents, primaryKey);
}

log.info("添加文档任务ID: {}", taskInfo.getTaskUid());
log.info("添加文档任务状态: {}", taskInfo.getStatus());
log.info("添加文档任务信息：{}", JSONUtil.toJsonStr(taskInfo));

log.info("添加文档任务结果：{}", JSONUtil.toJsonStr(index.getTask(taskInfo.getTaskUid())));
log.info("-----------------------------------------------------");
}

/**
 * 删除索引
 *
 * @param meilisearchClient
 * @param indexEnums
 */
public static void delIndex(Client meilisearchClient, MeilisearchIndexEnums indexEnums) {
if (ObjectUtil.hasNull(meilisearchClient, indexEnums)) {
return;
}
meilisearchClient.deleteIndex(indexEnums.getIndex());
}
}

3、练手的单元测试、索引创建、简单查询

主要用户对索引的创建、及简单的查询

Client meilisearchClient = meilisearchConfig.getClient();
Index index = meilisearchClient.index(MeilisearchIndexEnums.ARCHIVED_FILE.getIndex());
meilisearchClient.deleteIndex(MeilisearchIndexEnums.ARCHIVED_FILE.getIndex());
// 这里记得 每次创建索引 需要重新把你的一些筛选字段和排序字段重新添加一下
TaskInfo taskInfo = index.updateFilterableAttributesSettings(new String[]{"name", "delFlag", "enabled", "archiveDate"});
taskInfo = index.updateSortableAttributesSettings(new String[]{"archiveDate"});
List<ArchivedFile> archivedFileList = archivedFileService.list();
MeilisearchUtil.addDocuments(meilisearchClient, MeilisearchIndexEnums.ARCHIVED_FILE, archivedFileList);

SearchRequest searchRequest = SearchRequest.builder()
.limit(10)
.page(1)
.hitsPerPage(10)
.sort(new String[]{"archiveDate:desc"})
.showRankingScore(true)
.attributesToSearchOn(new String[]{"name"})
.matchingStrategy(MatchingStrategy.FREQUENCY)
.rankingScoreThreshold(0.2)
.filterArray(new String[][]{new String[]{"delFlag = 0", "enabled = 0"}})
.q("笑对")
.build();

Searchable searchable = index.search(searchRequest);
ArrayList<HashMap<String, Object>> searchableHits = searchable.getHits();
List<ArchivedFile> copyToList = BeanUtil.copyToList(searchableHits, ArchivedFile.class);

4、设置index的区域

官方说这样会对中文更好一点，虽然不设置他也会自己检测 但是难免跑偏

PUT修改 GET查看
url: http://host:7700/indexes/{index}/settings/localized-attributes
body

[
  {
    "locales": [
      "cmn"
    ],
    "attributePatterns": [
      "*"
    ]
  }
]

原文地址：https://blog.csdn.net/qq_43652321/article/details/142446017

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！