Comment implémenter Spring Rest Client pour la recherche élastique?

Question

Nous développons une application de recherche élastique dans la botte à ressort. Nous ne pouvons pas utiliser l'API Java ou l'API Java Rest Client fournie par la recherche élastique. Au lieu de cela, nous devons faire des opérations en élastique en utilisant le modèle de repos de printemps, mais élastique ne semble pas accepter les demandes d'index du client de repos. Nous avons reçu la réponse «Non acceptable». J'apprécie vraiment si quelqu'un nous donne quelques conseils ou informations. Version élastique: 5.6

Answer 1

Essayez ceci. Cela fonctionne pour moi pour Indexing Document via HTTP API en utilisant HttpURLConnection.

URL obj = new URL("http://localhost:9200/index/type"); 
String json = "{\n" + 
      " \"user\" : \"kimchy\",\n" + 
      " \"post_date\" : \"2009-11-15T14:12:12\",\n" + 
      " \"message\" : \"trying out Elasticsearch\"\n" + 
      "}"; 
HttpURLConnection con = (HttpURLConnection) obj.openConnection(); 

con.setRequestMethod("POST"); 
con.setDoInput(true); 
con.setDoOutput(true); 
con.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); 

OutputStreamWriter osw = new OutputStreamWriter(con.getOutputStream()); 
osw.write(json); 
osw.flush(); 
osw.close(); 

System.out.println(con.getResponseCode() + " : " + con.getResponseMessage()); 
if (con != null) 
    con.disconnect(); 

Effectuer une recherche simple à l'aide de HttpURLConnection.

URL obj = new URL("http://localhost:9200/index/type/_search"); 
String json = "{\n" + 
       " \"query\": {\n" + 
       " \"match_all\": {}\n" + 
       " }\n" + 
       "}"; 
HttpURLConnection con = (HttpURLConnection) obj.openConnection(); 

con.setRequestMethod("GET"); 
con.setDoInput(true); 
con.setDoOutput(true); 
con.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); 

OutputStreamWriter osw = new OutputStreamWriter(con.getOutputStream()); 
osw.write(json); 
osw.flush(); 
osw.close(); 

BufferedReader br = new BufferedReader(new InputStreamReader((con.getInputStream()))); 

System.out.println("Response : " + br.readLine()); 

System.out.println(con.getResponseCode() + " : " + con.getResponseMessage()); 

if (con != null) 
    con.disconnect();