4 Java注解：一个真实的Elasticsearch案例 _生活百科

昨天把拼了一半的注解+Elasticsearch积木放下了，因为东西太多了拼不好，还容易乱。休息了一晚上接着来。
接着昨天，创建elasticsearch文档注解（相当于数据表的注解）：
/** * elastic文档注解，定义每个elasticsearch文档上的属性 * * @author xiangwang */@Inherited@Retention(RetentionPolicy.RUNTIME)@Target({ ElementType.TYPE })public @interface Document {String index();String type() default "_doc";boolean useServerConfiguration() default false;short shards() default 1;short replicas() default 0;String refreshInterval() default "1s";String indexStoreType() default "fs";}然后再创建elasticsearch文档（相当于数据表）：
/** * elastic文档对象 * * @author xiangwang */@Document(index = "document", type = "_doc", shards = 1, replicas = 0)public class ElasticDocument {private static final long serialVersionUID = 2879048112350101009L;// 文档编码@DocField(name = "guid", type = FieldType.Keyword)protected String guid = "";// 标题@DocField(name = "title", type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_max_word")protected String title = "";// 文档创建时间（资源实际创建时间）@DocField(name = "createtime", type = FieldType.Long)protected long createtime;// 文档更新时间（资源实际更新时间）@DocField(name = "updatetime", type = FieldType.Long)protected long updatetime;public ElasticDocument() {}public String getGuid() {return guid;}public void setGuid(String guid) {this.guid = guid;}public String getTitle() {return title;}public void setTitle(String title) {this.title = title;}public long getCreatetime() {return createtime;}public void setCreatetime(long createtime) {this.createtime = createtime;}public long getUpdatetime() {return updatetime;}public void setUpdatetime(long updatetime) {this.updatetime = updatetime;}@Overridepublic String toString() {return String.format("{\"guid\":\"%s\", \"title\":\"%s\", \"createtime\":%d, " +"\"updatetime\":%d}", guid, title, createtime, updatetime);}}这里面的@Document就是刚才创建的文档注解。
最后，创建一个真正的执行者，就由它来完成所有材料的拼装：
/** * ElasticDao * * @author xiangwang */@Componentpublic class ElasticDao {// ElasticConfiguration中定义的Bean对象@Autowiredprivate RestHighLevelClient client;/*** 索引是否存在**/public boolean indexExist(final String index) {try {return client.indices().exists(new GetIndexRequest(index), RequestOptions.DEFAULT);} catch (IOException e) {System.out.println("index exist exception");}return false;}/*** 解析类注解，获取包括父类字段在内的所有字段* 因为解析的时候，会把父类及自身的一些额外字段给解析进去* 如logger、serialVersionUID等* 所以需要把这些无用的字段排除掉* 这里不存在继承，所以直接调用clazz.getDeclaredFields()* 另外，如果存在继承关系，该怎么处理呢？（可以思考一下）**/public static List<Field> getAllDeclaredFields(Class<?> clazz) {return new ArrayList<>(Arrays.asList(clazz.getDeclaredFields()));}/*** 创建索引，前面都是为了实现它作准备* 这里会通过注解，一路解析文档的字段，拼接成可执行的脚本交给elasticsearch的api去执行**/public boolean createIndex(final String index, final Class<?> clazz) {try {Document document = (Document) clazz.getAnnotation(Document.class);int shards = document.shards();int replicas = document.replicas();if (indexExist(index)) {return false;}CreateIndexRequest request = new CreateIndexRequest(index);request.settings(Settings.builder().put("index.number_of_shards", shards).put("index.number_of_replicas", replicas));StringBuilder builder = new StringBuilder();builder.append("{\n");builder.append("\"properties\": {\n");List<Field> list = getAllDeclaredFields(clazz);int length = list.size();for (int i = 0; i < length; i++) {DocField docField = list.get(i).getAnnotation(DocField.class);if (null == docField) {continue;}builder.append("\"").append(docField.name()).append("\" : {\n");builder.append("\"type\" : \"").append(docField.type().value).append("\"");if (docField.index()) {builder.append(", \n");builder.append("\"index\" : ").append(docField.index());}if (docField.fielddata()) {builder.append(", \n");builder.append("\"fielddata\" : ").append(docField.fielddata());}if (docField.store()) {builder.append(", \n");builder.append("\"store\" : ").append(docField.store());}if (StringUtils.isNotBlank(docField.analyzer())) {builder.append(", \n");builder.append("\"analyzer\" : \"").append(docField.analyzer()).append("\"");}if (StringUtils.isNotBlank(docField.format())) {builder.append(", \n");builder.append("\"format\" : \"").append(docField.format()).append("\"");}if (StringUtils.isNotBlank(docField.searchAnalyzer())) {builder.append(", \n");builder.append("\"search_analyzer\" : \"").append(docField.searchAnalyzer()).append("\"");}if (StringUtils.isNotBlank(docField.pattern())) {builder.append(", \n");builder.append("\"pattern\" : \"").append(docField.pattern()).append("\"");}if (StringUtils.isNotBlank(docField.normalizer())) {builder.append(", \n");builder.append("\"normalizer\" : \"").append(docField.normalizer()).append("\"");}if (i == length -1) {builder.append("\n}\n");} else {builder.append("\n}, \n");}}builder.append("}\n");builder.append("}\n");request.mapping(JSON.parseObject(builder.toString()).toJSONString(), XContentType.JSON);CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);boolean acknowledged = response.isAcknowledged();return acknowledged;} catch (IOException e) {System.out.println("create index exception");}return false;}}

4 Java注解：一个真实的Elasticsearch案例

推荐阅读

关于电工学非电类简述电工学非电类

2023清远灵活就业人员参保流程+材料

双子座的好奇心，是不是非常的强？好奇的双子座会做出哪些出格的事？

银耳要煮多久才熟银耳煮几分钟就熟了

炒毛豆怎么看熟了没毛豆炒鸡蛋怎么看熟了吗

【养生知识】海带如何不寒凉吃海带的禁忌

2022年女孩有气质温婉美丽的名字

2022福州万达影城各门店春节营业时间福州万达电影城

阿福乌鸦坐飞机鬼畜

关于流泗镇简述流泗镇

什么是马亨盖尖晶

为什么要去角质,去角质有什么好处怎么去角质去角质的方法

基尔霍夫第一定律和基尔霍夫第二定律基尔霍夫第一定律基尔霍夫第一定律是什么

2022CCTV新时代好少年强国有我读书成果展视频在哪观看？

2020年“二龙治水，十一牛耕田，十人分饼”——古谚要取精华、去糟粕，不尽信！ &amp;#8230; &amp;#8230;

淮山没熟透怎么看淮山熟了没

须眉是什么意思

恋爱偏方,让你更好与女生相处

民事诉讼法院给派律师么民事诉讼法院给派律师吗？

鞋带的系法小白鞋鞋带的系法有哪些