\ucc38\uc870<\/a><\/p>\n \ucc38\uc870<\/a><\/p>\n \ub300\uac15 \ubcf4\uc558\ub294\ub370, API \uac00 \uaf64\ub098 \uae54\ub054\ud558\ub2e4.<\/p>\n create_item_index.json<\/p>\n Elasticsearch Java API Client \ucc38\uc870 \ucc38\uc870 \ub300\uac15 \ubcf4\uc558\ub294\ub370, API \uac00 \uaf64\ub098 \uae54\ub054\ud558\ub2e4. \uc758\uc874\uc131 \ucd94\uac00 def elasticSearchJavaApiClientVersion = '8.3.1' dependencies { implementation "co.elastic.clients:elasticsearch-java:${elasticSearchJavaApiClientVersion}" implementation "com.fasterxml.jackson.core:jackson-databind:2.13.3" implementation "com.fasterxml.jackson.core:jackson-core:2.13.3" implementation "org.glassfish:jakarta.json:2.0.1" \/\/ implementation "jakarta.json:jakarta.json-api:2.1.0" } \ucef4\ud3ec\ub10c\ud2b8 \uc0dd\uc131 @Getter @Setter @Component @ConfigurationProperties(prefix = "elasticsearch") @RequiredArgsConstructor public class ElasticProperty { private List<ElasticProperty.Elasticsearch> server; @Getter public static class Elasticsearch { private\u2026 Read More »<\/a><\/span><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[29],"tags":[],"class_list":["post-5655","post","type-post","status-publish","format-standard","hentry","category-spring-boot-2-5"],"_links":{"self":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/5655","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=5655"}],"version-history":[{"count":10,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/5655\/revisions"}],"predecessor-version":[{"id":5880,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/5655\/revisions\/5880"}],"wp:attachment":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=5655"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=5655"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=5655"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\uc758\uc874\uc131 \ucd94\uac00<\/h2>\n
def elasticSearchJavaApiClientVersion = '8.3.1'\n\ndependencies {\n implementation "co.elastic.clients:elasticsearch-java:${elasticSearchJavaApiClientVersion}"\n implementation "com.fasterxml.jackson.core:jackson-databind:2.13.3"\n implementation "com.fasterxml.jackson.core:jackson-core:2.13.3"\n implementation "org.glassfish:jakarta.json:2.0.1"\n \/\/ implementation "jakarta.json:jakarta.json-api:2.1.0"\n}<\/code><\/pre>\n\ucef4\ud3ec\ub10c\ud2b8 \uc0dd\uc131<\/h2>\n
@Getter\n@Setter\n@Component\n@ConfigurationProperties(prefix = "elasticsearch")\n@RequiredArgsConstructor\npublic class ElasticProperty {\n\n private List<ElasticProperty.Elasticsearch> server;\n\n @Getter\n public static class Elasticsearch {\n\n private String ip;\n private int port;\n private String protocol;\n\n public HttpHost getHttpHost(){\n return new HttpHost(this.ip,this.port,this.protocol);\n }\n }\n}<\/code><\/pre>\n@Slf4j\n@Component\n@RequiredArgsConstructor\npublic class ElasticsearchClientConfig {\n\n private final ElasticProperty elasticProperty;\n\n @Bean\n ElasticsearchClient getJavaApiClient() {\n\n HttpHost[] httpHost = new HttpHost[elasticProperty.getServer().size()];\n int idx = 0;\n for(ElasticProperty.Elasticsearch elasticsearch : elasticProperty.getServer()){\n httpHost[idx++] = elasticsearch.getHttpHost();\n }\n\n RestClient restClient = RestClient.builder(httpHost).build();\n\n ObjectMapper mapper = new ObjectMapper()\n .disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES)\n .disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)\n .registerModule(new JavaTimeModule());\n\n ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper(mapper));\n\n return new ElasticsearchClient(transport);\n }\n}<\/code><\/pre>\nrepository<\/h2>\n
@Slf4j\n@Component\n@RequiredArgsConstructor\npublic class ElasticsearchRepository {\n\n private Logger logger = LoggerFactory.getLogger(this.getClass());\n\n private final ElasticsearchClient client;\n\n public boolean createIndex(CreateIndexProperty property) throws IOException {\n\n CreateIndexRequest request = CreateIndexRequest.of(builder ->\n builder.index(property.getName()).withJson(property.getSettings())\n );\n CreateIndexResponse response = client.indices().create(request);\n\n return Boolean.TRUE.equals(response.acknowledged());\n }\n\n public boolean deleteIndex(DeleteIndexProperty property) throws IOException {\n DeleteIndexRequest request = DeleteIndexRequest.of(builder ->\n builder.index(property.getName())\n );\n DeleteIndexResponse response = client.indices().delete(request);\n\n return Boolean.TRUE.equals(response.acknowledged());\n }\n\n public boolean indexExists(ExistsIndexProperty property) throws IOException {\n ExistsRequest request = ExistsRequest.of(builder ->\n builder.index(property.getName())\n );\n BooleanResponse response = client.indices().exists(request);\n\n return response.value();\n }\n\n public long createOrUpdateDocument(ItemDocument itemDocument) throws IOException {\n IndexRequest<ItemDocument> request = IndexRequest.of(builder -> builder\n .index(IndexName.ITEM)\n .id(itemDocument.getId().toString())\n .document(itemDocument)\n );\n\n IndexResponse response = client.index(request);\n\n return response.version();\n }\n\n public ItemDocument getDocument() throws IOException {\n GetResponse<ItemDocument> response = client.get(builder -> builder\n .index(IndexName.ITEM)\n .id("1"),\n ItemDocument.class\n );\n\n if (response.found()) {\n return response.source();\n } else {\n logger.info ("Document not found");\n }\n\n return null;\n }\n\n public List<Hit<ItemDocument>> search() throws IOException {\n String searchText = "test";\n\n \/\/ \uc911\uc694 : \uac80\uc0c9\uc740 create\/update \ud6c4 \uc77c\uc815\uc2dc\uac04\uc774 \uc9c0\ub098\uc57c \ub370\uc774\ud0c0\ub97c \uc870\ud68c\ud560 \uc218 \uc788\ub2e4.\n SearchResponse<ItemDocument> response = client.search(s -> s\n .index(IndexName.ITEM)\n .query(q -> q\n .match(t -> t\n .field("mimetype")\n .query(searchText)\n )\n ),\n ItemDocument.class\n );\n\n TotalHits total = response.hits().total();\n assert total != null;\n boolean isExactResult = total.relation() == TotalHitsRelation.Eq;\n\n if (isExactResult) {\n logger.info("There are " + total.value() + " results");\n Query query = SearchRequest.of(builder -> builder\n .index(IndexName.ITEM)\n .query(q -> q\n .match(t -> t\n .field("mimetype")\n .query(searchText)\n )\n )).query();\n logger.info("query : {}", query);\n\n logger.info("response : {}", response);\n logger.info("response.hits() : {}", response.hits());\n } else {\n logger.info("There are more than " + total.value() + " results");\n }\n\n return response.hits().hits();\n }\n}<\/code><\/pre>\nservice<\/h2>\n
{\n "settings": {\n "number_of_shards": 5,\n "max_ngram_diff": 2,\n "analysis": {\n "tokenizer": {\n "ngram_tokenizer": {\n "type": "ngram",\n "min_gram": "1",\n "max_gram": "3",\n "token_chars": ["letter", "digit", "punctuation", "symbol"]\n },\n "unix_path_tokenizer": {\n "type": "path_hierarchy",\n "buffer_size": 1024,\n "replacement": "\/",\n "reverse": "false",\n "skip": 0,\n "delimiter": "\/"\n },\n "whitespace_tokenizer": {\n "type": "whitespace"\n },\n "keyword_tokenizer": {\n "type": "keyword",\n "buffer_size": 1024\n }\n },\n "analyzer": {\n "ngram_analyzer": {\n "type": "custom",\n "filter": [\n "lowercase"\n ],\n "tokenizer": "whitespace"\n },\n "lowercase_analyzer": {\n "type": "custom",\n "tokenizer": "keyword",\n "filter": ["lowercase"]\n },\n "directory_path_analyzer": {\n "type": "custom",\n "tokenizer": "unix_path_tokenizer"\n },\n "whitespace_analyzer": {\n "type": "custom",\n "tokenizer": "whitespace_tokenizer"\n },\n "keyword_analyzer": {\n "type": "custom",\n "tokenizer": "keyword_tokenizer"\n }\n },\n "normalizer": {\n "lowercase_normalizer": {\n "type": "custom",\n "filter": ["lowercase"]\n }\n }\n }\n },\n "mappings": {\n "properties": {\n "name": {\n "type": "text",\n "analyzer": "ngram_analyzer",\n "fields": {\n "lowercase": {\n "type": "keyword",\n "normalizer": "lowercase_normalizer"\n }\n }\n },\n "path": {\n "type": "text",\n "analyzer": "directory_path_analyzer",\n "fields": {\n "full": {\n "type": "keyword"\n }\n }\n },\n "originalSize": {\n "type": "double",\n "store": "true"\n },\n "assetCategory": {\n "type": "text",\n "analyzer": "keyword_analyzer",\n "search_analyzer": "whitespace_analyzer",\n "fields": {\n "keyword": {\n "type": "keyword"\n }\n }\n },\n "mimetype": {\n "type": "keyword"\n },\n "importedBy": {\n "type": "integer",\n "store": "true"\n },\n "updatedBy": {\n "type": "keyword"\n },\n "importedAt": {\n "type": "date",\n "store": "true"\n },\n "updatedAt": {\n "type": "date",\n "store": "true"\n },\n "fileCreatedAt": {\n "type": "date",\n "store": "true"\n },\n "fileUpdatedAt": {\n "type": "date",\n "store": "true"\n },\n "metadataSet": {\n "type": "long"\n },\n "instanceId": {\n "type": "keyword"\n },\n "referenceId": {\n "type": "keyword"\n },\n "cutComment": {\n "type": "text",\n "analyzer": "ngram_analyzer",\n "fields": {\n "lowercase": {\n "type": "text",\n "analyzer": "lowercase_analyzer"\n }\n }\n },\n "comment": {\n "properties": {\n "userId": {\n "type": "long"\n },\n "value": {\n "type": "text",\n "analyzer": "ngram_analyzer",\n "fields": {\n "lowercase": {\n "type": "text",\n "analyzer": "lowercase_analyzer"\n }\n }\n },\n "updatedAt": {\n "type": "date"\n }\n }\n },\n "content": {\n "type": "text",\n "analyzer": "ngram_analyzer"\n },\n "shadow": {\n "type": "boolean",\n "store": "true"\n },\n "shadowUpdatedAt": {\n "type": "date",\n "store": "true"\n },\n "downloadValue": {\n "type": "long"\n },\n "collection": {\n "type": "long"\n },\n "sha1": {\n "type": "keyword"\n },\n "subtitle": {\n "type": "text",\n "analyzer": "ngram_analyzer"\n },\n "videoOcr": {\n "type": "text",\n "analyzer": "ngram_analyzer"\n },\n "version": {\n "type": "long"\n }\n },\n "dynamic_templates": [\n {\n "cmeta_str": {\n "match": "cmeta_str-*",\n "mapping": {\n "type": "text",\n "store": "true",\n "analyzer": "ngram_analyzer",\n "fields": {\n "lowercase": {\n "type": "keyword",\n "normalizer": "lowercase_normalizer"\n }\n }\n }\n }\n },\n {\n "cmeta_select": {\n "match": "cmeta_select-*",\n "mapping": {\n "type": "text",\n "store": "true",\n "analyzer": "ngram_analyzer",\n "fields": {\n "lowercase": {\n "type": "keyword",\n "normalizer": "lowercase_normalizer"\n }\n }\n }\n }\n },\n {\n "cmeta_bool": {\n "match": "cmeta_bool-*",\n "mapping": {\n "type": "boolean",\n "store": "true"\n }\n }\n },\n {\n "cmeta_double": {\n "match": "cmeta_double-*",\n "mapping": {\n "type": "double",\n "store": "true"\n }\n }\n },\n {\n "cmeta_date": {\n "match": "cmeta_date-*",\n "mapping": {\n "type": "date",\n "store": "true"\n }\n }\n },\n {\n "cmeta_multi_label": {\n "match": "cmeta_multi_label-*",\n "mapping": {\n "type": "long",\n "store": "true"\n }\n }\n }\n ]\n }\n}<\/code><\/pre>\n@Service\n@RequiredArgsConstructor\npublic class ItemIndexService {\n\n private Logger logger = LoggerFactory.getLogger(this.getClass());\n\n private final ElasticsearchRepository repository;\n\n public boolean createIndex() throws IOException {\n\n CreateIndexProperty property = new CreateIndexProperty();\n ClassPathResource resource = new ClassPathResource("json\/create_item_index.json");\n InputStream input = resource.getInputStream();\n property.setName(IndexName.ITEM);\n property.setSettings(input);\n\n ExistsIndexProperty existsIndexProperty = new ExistsIndexProperty();\n existsIndexProperty.setName(IndexName.ITEM);\n\n if (repository.indexExists(existsIndexProperty)) {\n logger.debug("index exists");\n DeleteIndexProperty deleteIndexProperty = new DeleteIndexProperty();\n deleteIndexProperty.setName(IndexName.ITEM);\n repository.deleteIndex(deleteIndexProperty);\n logger.debug("index deleted");\n }\n\n return repository.createIndex(property);\n }\n\n public void addDocument() throws IOException {\n ItemDocument itemDocument = new ItemDocument();\n itemDocument.setId(1);\n itemDocument.setMimetype("test");\n\n long version = repository.createOrUpdateDocument(itemDocument);\n logger.debug("Document version : {}", version);\n }\n\n public void getDocument() throws IOException {\n ItemDocument itemDocument = repository.getDocument();\n\n if (itemDocument != null) {\n logger.info("Mimetype : " + itemDocument.getMimetype());\n }\n }\n\n public void search() throws IOException {\n List<Hit<ItemDocument>> hits = repository.search();\n for (Hit<ItemDocument> hit: hits) {\n ItemDocument product = hit.source();\n logger.info("Found Item " + product.getMimetype() + ", score " + hit.score());\n }\n }\n}<\/code><\/pre>\ncontroller<\/h2>\n
@Slf4j\n@RequestMapping("apis\/index")\n@RestController\n@RequiredArgsConstructor\npublic class IndexController {\n\n private final ItemIndexService itemIndexService;\n\n @PostMapping("\/create\/item")\n @Operation(summary = "Item Index \uc0dd\uc131", description ="Item Index \ub97c \uc0dd\uc131 \ud55c\ub2e4")\n @ApiResponses({\n @ApiResponse(code = 0, message = "\uc694\uccad \uc131\uacf5"),\n @ApiResponse(code = 60000, message = "\uc0c9\uc778 \uc0dd\uc131\uc5d0 \uc2e4\ud328\ud558\uc600\uc2b5\ub2c8\ub2e4.")\n })\n public ResultResponse<EmptyResultModel> createItemIndex() throws Exception {\n \/\/ itemIndexService.createIndex();\n itemIndexService.addDocument();\n itemIndexService.getDocument();\n itemIndexService.search();\n return new ResultResponse<>(new EmptyResultModel(StringUtils.EMPTY));\n\n }\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"