From 2b2867ea9c2c3b3a56795e0897cb04674bcf4066 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?F=E5=98=89=E9=98=B3?= <fjy8018@qq.com>
Date: Sat, 19 May 2018 16:28:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3=E5=BC=80?=
 =?UTF-8?q?=E5=8F=91=E5=AE=8C=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ElasticsearchApplication.java             | 33 +++++++++++++++++++
 .../configeration/ElasticSearchConfiger.java  | 10 ++++++
 src/main/resources/application.yml            |  5 +++
 3 files changed, 48 insertions(+)
 create mode 100644 src/main/resources/application.yml

diff --git a/src/main/java/top/fjy8018/elasticsearch/ElasticsearchApplication.java b/src/main/java/top/fjy8018/elasticsearch/ElasticsearchApplication.java
index cbe3046..70e97e6 100644
--- a/src/main/java/top/fjy8018/elasticsearch/ElasticsearchApplication.java
+++ b/src/main/java/top/fjy8018/elasticsearch/ElasticsearchApplication.java
@@ -1,19 +1,52 @@
 package top.fjy8018.elasticsearch;
 
+
+import lombok.extern.slf4j.Slf4j;
+import org.elasticsearch.action.get.GetResponse;
+import org.elasticsearch.client.transport.TransportClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
 @SpringBootApplication
 @RestController
+@Slf4j
 public class ElasticsearchApplication {
 
+    @Autowired
+    private TransportClient client;
+
     @GetMapping("/")
 	public String index(){
 	    return "index";
     }
 
+    /**
+     * 根据ID查询结果
+     * @param id
+     * @return
+     */
+    @GetMapping("/get/book/novel")
+    public ResponseEntity get(@RequestParam(name = "id") String id){
+        if (id==null){
+            return new ResponseEntity(HttpStatus.NOT_FOUND);
+        }
+        GetResponse response = this.client.prepareGet("book","novel",id).get();
+
+        if (!response.isExists()){
+            log.error("【查询为空】ID="+id);
+            return new ResponseEntity(HttpStatus.NOT_FOUND);
+        }
+
+        return new ResponseEntity(response.getSource(), HttpStatus.OK);
+    }
+
 	public static void main(String[] args) {
 		SpringApplication.run(ElasticsearchApplication.class, args);
 	}
diff --git a/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java b/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java
index 1f8fd7d..2beb487 100644
--- a/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java
+++ b/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java
@@ -1,6 +1,8 @@
 package top.fjy8018.elasticsearch.configeration;
 
+import lombok.extern.slf4j.Slf4j;
 import org.elasticsearch.client.transport.TransportClient;
+import org.elasticsearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.transport.TransportAddress;
 import org.elasticsearch.transport.client.PreBuiltTransportClient;
@@ -9,12 +11,14 @@ import org.springframework.context.annotation.Configuration;
 
 import java.net.InetAddress;
 import java.net.UnknownHostException;
+import java.util.List;
 
 /**
  * @author F嘉阳
  * @date 2018-05-19 12:22
  */
 @Configuration
+@Slf4j
 public class ElasticSearchConfiger {
 
     /**
@@ -35,6 +39,12 @@ public class ElasticSearchConfiger {
 
         client.addTransportAddress(node);
 
+        List<DiscoveryNode> nodes = client.listedNodes();
+        log.info("【当前节点】");
+        for(int i = 0 ; i < nodes.size() ; i++) {
+            log.info(nodes.get(i).toString());
+        }
+
         return client;
 
     }
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
new file mode 100644
index 0000000..54dc849
--- /dev/null
+++ b/src/main/resources/application.yml
@@ -0,0 +1,5 @@
+server:
+  servlet:
+    context-path: /es
+  port: 8080
+debug: true