Spring Boot и Elasticsearch Учебное пособие

обзор

В моей последней статье я говорил о том, как мы можем использовать проект Spring-Data-Elasticsearch для соединения с механизмом Elasticsearch и выполнения операций CRUD. Однако я также упомянул, что этот проект не обновлен, чтобы быть совместимым с последней версией механизма Elasticsearch .

Итак, в этом посте я расскажу о том, как взаимодействовать с последней версией механизма Elasticsearch с помощью библиотеки клиента транспорта. Я собираюсь использовать Spring Boot в качестве клиентского приложения, а затем добавить зависимости для других необходимых библиотек.

Предпосылки

• JDK 1.8

• специалист

• Загрузка движка Elasticsearch 5.x или 6.x (я объясню шаги как скачать)

• Затмение или VSD как IDE

Настройка Elasticsearch 

Шаг 1  — Зайдите на официальный сайт Elastic .

Шаг 2  — Выберите Elasticsearch в раскрывающемся списке, а затем версию как 5.5.0 и нажмите кнопку «Загрузить».

Шаг 3  — Он даст вам варианты, если вы хотите скачать в виде файла Zip, TAR или RPM. Я выбрал формат Zip, используя его в Windows.

Шаг 4  — Распакуйте загруженный контент и перейдите в  binпапку. Там будет файл с именем elasticsearch.bat.

Шаг 5  — Запустите этот файл в ОС Windows через командную строку, и он запустит для вас механизм Elasticsearch. После запуска он начнет прослушивать порт 9200. Поэтому URL будет  http: // localhost: 9200 / . Кроме того, порт 9300 представлен как узел кластера. Порт 9200 предназначен для связи REST и может использоваться Java или любым другим языком, а 9300 также для связи Elasticsearch Cluster Node, и Java также может подключаться к этому узлу кластера с использованием транспортного протокола.

Шаг 6  — Проверьте, чтобы все началось правильно, запустив URL с помощью команды curl. Вы можете использовать PowerShell в Windows.

curl http://localhost:9200/

StatusCode        : 200
StatusDescription : OK
Content           : {
                      "name" : "ggyBmti",
                      "cluster_name" : "elasticsearch",
                      "cluster_uuid" : "Bp6EeKIoQNqGj0iV5sHtWg",
                      "version" : {
                        "number" : "5.5.0",
                        "build_hash" : "260387d",
                        "build_date" : "2017-...
RawContent        : HTTP/1.1 200 OK
                    Content-Length: 327
                    Content-Type: application/json; charset=UTF-8

                    {
                      "name" : "ggyBmti",
                      "cluster_name" : "elasticsearch",
                      "cluster_uuid" : "Bp6EeKIoQNqGj0iV5sHtWg",
                      "versi...
Forms             : {}
Headers           : {[Content-Length, 327], [Content-Type, application/json; charset=UTF-8]}
Images            : {}
InputFields       : {}
Links             : {}
ParsedHtml        : mshtml.HTMLDocumentClass
RawContentLength  : 327

{
  "userId" :"1",
  "name" : "Rajesh",
   "userSettings" : {
   "gender" : "male",
   "occupation" : "CA",
   "hobby" : "chess"
   }
}

{
"_index": "users",
"_type": "employee",
"_id": "1",
"_version": 3,
"result": "updated",
"_shards": {
"total": 2,
"successful": 1,
"failed": 0
},
"created": false
}

{
"_index": "users",
"_type": "employee",
"_id": "1",
"_version": 3,
"found": true,
"_source": {
"userId": "1",
"name": "Rajesh",
"userSettings": {
"gender": "male",
"occupation": "CA",
"hobby": "chess"
}
}
}

 curl -XGET 'http://localhost:9200/users/employee/_search'
-H 'Content-Type: application/json' -d
' {"query": { "match": {"name" : "Rajesh" } }}'

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>5.0.0</version>
</dependency>

<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.7</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.7</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-web</artifactId>
<version>2.7</version>
</dependency>
</dependencies>

# Local Elasticsearch config
elasticsearch.host=localhost
elasticsearch.port=9300


# App config
server.port=8102
spring.application.name=BootElastic

public class User {
    private String userId;
    private String name;
    private Date creationDate = new Date();
    private Map<String, String> userSettings = new HashMap<>();
  -- getter/setter methods
}

@Configuration
public class config{

    @Value("${elasticsearch.host:localhost}") 
    public String host;
    @Value("${elasticsearch.port:9300}") 
    public int port;

    public String getHost() {
return host;
}


public int getPort() {
return port;
    }

    @Bean
    public Client client(){
        TransportClient client = null;
        try{
            System.out.println("host:"+ host+"port:"+port);
            client = new PreBuiltTransportClient(Settings.EMPTY)
            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host), port));
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        return client;
    }
}

@Autowired
    Client client;
    @PostMapping("/create")
    public String create(@RequestBody User user) throws IOException {

        IndexResponse response = client.prepareIndex("users", "employee", user.getUserId())
                .setSource(jsonBuilder()
                        .startObject()
                        .field("name", user.getName())
                        .field("userSettings", user.getUserSettings())
                        .endObject()
                )
                .get();
               System.out.println("response id:"+response.getId());
        return response.getResult().toString();
    }

 @GetMapping("/view/{id}")
    public Map<String, Object> view(@PathVariable final String id) {
        GetResponse getResponse = client.prepareGet("users", "employee", id).get();
        return getResponse.getSource();
    }

    @GetMapping("/view/name/{field}")
    public Map<String, Object> searchByName(@PathVariable final String field) {
        Map<String,Object> map = null;
        SearchResponse response = client.prepareSearch("users")
                                .setTypes("employee")
                                .setSearchType(SearchType.QUERY_AND_FETCH)
                                .setQuery(QueryBuilders..matchQuery("name", field))
                                .get()
                                ;
        List<SearchHit> searchHits = Arrays.asList(response.getHits().getHits());
        map =   searchHits.get(0).getSource();
        return map;

    }

    @GetMapping("/update/{id}")
    public String update(@PathVariable final String id) throws IOException {

        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.index("users")
                .type("employee")
                .id(id)
                .doc(jsonBuilder()
                        .startObject()
                        .field("name", "Rajesh")
                        .endObject());
        try {
            UpdateResponse updateResponse = client.update(updateRequest).get();
            System.out.println(updateResponse.status());
            return updateResponse.status().toString();
        } catch (InterruptedException | ExecutionException e) {
            System.out.println(e);
        }
        return "Exception";
    }

   @GetMapping("/delete/{id}")
    public String delete(@PathVariable final String id) {
        DeleteResponse deleteResponse = client.prepareDelete("users", "employee", id).get();
        return deleteResponse.getResult().toString();
    }

{
  "userId":"1",
  "name": "Sumit",
   "userSettings": {
   "gender" : "male",
   "occupation" : "CA",
   "hobby" : "chess"
   }
}

{
"userSettings": {
"occupation": "CA",
"gender": "male",
"hobby": "chess"
},
"name": "Rajesh"
}