1.Java连接Elasticsearch

1.1 创建SprinBoot工程，导入依赖

记得先在命令行中把elasticsearch启动，kibana最好也启动起来

  1. <dependency>
  2.         <groupId>org.elasticsearch.client</groupId>
  3.         <artifactId>elasticsearch-rest-high-level-client</artifactId>
  4.         <version>6.8.10</version>
  5.         <exclusions>
  6.                 <exclusion>
  7.                         <groupId>org.elasticsearch</groupId>
  8.                         <artifactId>elasticsearch</artifactId>
  9.                 </exclusion>
  10.                 <exclusion>
  11.                         <groupId>org.elasticsearch.client</groupId>
  12.                         <artifactId>elasticsearch-rest-client</artifactId>
  13.                 </exclusion>
  14.         </exclusions>
  15. </dependency>
  16. <dependency>
  17.         <groupId>org.elasticsearch.client</groupId>
  18.         <artifactId>elasticsearch-rest-client</artifactId>
  19.         <version>6.8.10</version>
  20. </dependency>
  21. <dependency>
  22.         <groupId>org.elasticsearch</groupId>
  23.         <artifactId>elasticsearch</artifactId>
  24.         <version>6.8.10</version>
  25. </dependency>
  26. <dependency>
  27.         <groupId>org.projectlombok</groupId>
  28.         <artifactId>lombok</artifactId>
  29.         <optional>true</optional>
  30. </dependency>

1.2 创建测试类，连接Elasticsearch

utils包下新建一个ESClient获取Elasticsearch代理

  1. public class ESClient {
  2.     public static RestHighLevelClient getClient(){
  3.         //创建HttpHost对象
  4.         HttpHost httpHost = new HttpHost("127.0.0.1",9200);
  6.         //创建RestClientBuilder
  7.         RestClientBuilder clientBuilder = RestClient.builder(httpHost);
  9.         //创建RestHighLevelClient
  10.         RestHighLevelClient client = new RestHighLevelClient(clientBuilder);
  12.         //返回
  13.         return client;
  14.     }
  15. }
  1. @SpringBootTest
  2. @ContextConfiguration(classes = ForumApplication.class)
  3. public class demo1 {
  4.     @Test
  5.     public void testConnection(){
  6.         RestHighLevelClient client = ESClient.getClient();
  7.         System.out.println("成功！！！");
  8.     }
  9. }

2.Java操作索引

2.1 创建索引

  1. public class demo2 {
  2.     RestHighLevelClient client = ESClient.getClient();
  3.     String index = "person";
  4.     String type = "man";
  6.     /**
  7.      * 创建索引
  8.      * @throws IOException
  9.      */
  10.     @Test
  11.     public void createIndex() throws IOException {
  12.         //1. 准备关于索引的settings
  13.         Settings.Builder settings = Settings.builder()
  14.                 .put("number_of_shards", 3)
  15.                 .put("number_of_replicas", 1);
  17.         //2. 准备关于索引的结构mappings
  18.         XContentBuilder mappings = JsonXContent.contentBuilder()
  19.                 .startObject()
  20.                     .startObject("properties")
  21.                         .startObject("name")
  22.                             .field("type","text")
  23.                         .endObject()
  24.                         .startObject("age")
  25.                             .field("type","integer")
  26.                         .endObject()
  27.                         .startObject("birthday")
  28.                             .field("type","date")
  29.                             .field("format","yyyy-MM-dd")
  30.                         .endObject()
  31.                     .endObject()
  32.                 .endObject();
  35.         //3. 将settings和mappings封装到一个Request对象
  36.         CreateIndexRequest request = new CreateIndexRequest(index)
  37.                 .settings(settings)
  38.                 .mapping(type,mappings);
  40.         //4. 通过client对象去连接ES并执行创建索引
  41.         CreateIndexResponse resp = client.indices().create(request, RequestOptions.DEFAULT);
  43.         //5. 输出
  44.         System.out.println("resp:" + resp.toString());
  45.     }
  46. }

2.2 检查索引是否存在

  1. @Test
  2. public void exists() throws IOException{
  3.     //1.准备request对象
  4.     GetIndexRequest request = new GetIndexRequest();
  5.     request.indices(index);
  7.     //2.通过client去操作
  8.     boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
  10.     //3.输出
  11.     System.out.println(exists);
  12. }

2.3 删除索引

  1. @Test
  2. public void delete() throws Exception{
  3.     //1.准备request对象
  4.     DeleteIndexRequest request = new DeleteIndexRequest();
  5.     request.indices(index);
  7.     //2.通过client对象执行
  8.     AcknowledgedResponse delete = client.indices().delete(request,RequestOptions.DEFAULT);
  10.     //3.获取返回结果
  11.     System.out.println(delete.isAcknowledged());
  12. }

3.Java操作文档

3.1 添加文档

  1. @Test
  2. public void createDoc() throws Exception{
  3.     //1.准备一个json数据
  4.     Person person = new Person(1, "张三", 23, new Date());
  5.     String json = mapper.writeValueAsString(person);
  7.     //2.准备一个request对象(手动指定id)
  8.     IndexRequest request = new IndexRequest(index, type, person.getId().toString());
  9.     request.source(json, XContentType.JSON);
  11.     //3.通过client对象执行添加
  12.     IndexResponse resp = client.index(request, RequestOptions.DEFAULT);
  14.     //4.输出返回结果
  15.     System.out.println(resp.getResult().toString());
  16. }

3.2 修改文档

  1. @Test
  2. public void updateDoc() throws Exception{
  3.     //1.创建一个Map,修改制定内容
  4.     HashMap<String, Object> doc = new HashMap<>();
  5.     doc.put("name","张大仙");
  6.     String docId = "1";
  8.     //2.创建request对象，封装数据
  9.     UpdateRequest request = new UpdateRequest(index, type, docId);
  10.     request.doc(doc);
  12.     //3.通过client对象执行
  13.     UpdateResponse update = client.update(request, RequestOptions.DEFAULT);
  15.     //4.输出返回结果
  16.     System.out.println(update.getResult().toString());
  17. }

3.3 删除文档

  1. @Test
  2. public void deleteDoc() throws Exception{
  3.     //1.封装Request对象
  4.     DeleteRequest request = new DeleteRequest(index,type,"1");
  6.     //2.client执行删除
  7.     DeleteResponse resp = client.delete(request, RequestOptions.DEFAULT);
  9.     //3.输出结果
  10.     System.out.println(resp.getResult().toString());
  11. }

3.4 批量添加文档

  1. @Test
  2. public void bulkCreateDoc() throws Exception{
  3.     //1.准备多个json数据
  4.     Person p1 = new Person(1, "张三", 23, new Date());
  5.     Person p2 = new Person(2, "李四", 24, new Date());
  6.     Person p3 = new Person(3, "王五", 25, new Date());
  8.     String json1 = mapper.writeValueAsString(p1);
  9.     String json2 = mapper.writeValueAsString(p2);
  10.     String json3 = mapper.writeValueAsString(p3);
  12.     //2.创建Request,将准备好的数据封装过去
  13.     BulkRequest request = new BulkRequest();
  14.     request.add(new IndexRequest(index,type,p1.getId().toString()).source(json1,XContentType.JSON));
  15.     request.add(new IndexRequest(index,type,p2.getId().toString()).source(json2,XContentType.JSON));
  16.     request.add(new IndexRequest(index,type,p3.getId().toString()).source(json3,XContentType.JSON));
  18.     //3.用client执行
  19.     BulkResponse resp = client.bulk(request, RequestOptions.DEFAULT);
  21.     //4.输出结果
  22.     System.out.println(resp.toString());
  23. }

3.4 批量删除文档

  1. @Test
  2. public void bulkDeleteDoc() throws Exception{
  3.     //1.封装Request对象
  4.     BulkRequest request = new BulkRequest();
  5.     request.add(new DeleteRequest(index,type,"1"));
  6.     request.add(new DeleteRequest(index,type,"2"));
  7.     request.add(new DeleteRequest(index,type,"3"));
  9.     //2.client执行
  10.     BulkResponse resp = client.bulk(request, RequestOptions.DEFAULT);
  12.     //3.输出
  13.     System.out.println(resp);
  14. }

4.Java操作Elasticsearch的一个练习

4.1 要求说明

创建索引，指定各个字段的类型
索引名：sms-logs-index
类型名：sms-logs-type

索引结构图

字段名称 备注
createDate 创建时间
sendDate 发送时间
longCode 发送的长号码，如”1069886622”
mobile 下发手机号，如：13800000000
corpName 发送公司名称，需要分词检索
smsContent 下发短信内容，需要分词检索
state 短信下发状态，0成功，1失败
operatorId 运营商编号，1移动，2联通，3电信
province 省份
ipAddr 下发服务器ip地址
replyTotal 短信状态报告返回时长(秒)
fee 扣费(分)

4.2 创建一个实体类

  1. @Data
  2. @NoArgsConstructor
  3. @AllArgsConstructor
  4. public class SmsLogs {
  5.     private String id;// 唯一ID 1
  6.     private Date createDate;// 创建时间
  7.     private Date sendDate; // 发送时间
  8.     private String longCode;// 发送的长号码
  9.     private String mobile;// 下发手机号
  10.     private String corpName;// 发送公司名称
  11.     private String smsContent; // 下发短信内容
  12.     private Integer state; // 短信下发状态 0 成功 1 失败
  13.     private Integer operatorId; // '运营商编号 1 移动 2 联通 3 电信
  14.     private String province;// 省份
  15.     private String ipAddr; //下发服务器IP地址
  16.     private Integer replyTotal; //短信状态报告返回时长（秒）
  17.     private Integer fee;  // 费用
  18. }

4.3 创建索引

  1. public class exe1 {
  2.     ObjectMapper mapper = new ObjectMapper();
  3.     RestHighLevelClient client = ESClient.getClient();
  4.     String index = "sms-logs-index";
  5.     String type = "sms-logs-type";
  7.     @Test
  8.     public void createSmsLogsIndex() throws IOException {
  10.         //1. settings
  11.         Settings.Builder settings = Settings.builder()
  12.                 .put("number_of_shards", 3)
  13.                 .put("number_of_replicas", 1);
  15.         //2. mapping.
  16.         XContentBuilder mapping = JsonXContent.contentBuilder()
  17.                 .startObject()
  18.                 .startObject("properties")
  19.                 .startObject("createDate")
  20.                 .field("type", "date")
  21.                 .endObject()
  22.                 .startObject("sendDate")
  23.                 .field("type", "date")
  24.                 .endObject()
  25.                 .startObject("longCode")
  26.                 .field("type", "keyword")
  27.                 .endObject()
  28.                 .startObject("mobile")
  29.                 .field("type", "keyword")
  30.                 .endObject()
  31.                 .startObject("corpName")
  32.                 .field("type", "keyword")
  33.                 .endObject()
  34.                 .startObject("smsContent")
  35.                 .field("type", "text")
  36.                 .field("analyzer", "ik_max_word")
  37.                 .endObject()
  38.                 .startObject("state")
  39.                 .field("type", "integer")
  40.                 .endObject()
  41.                 .startObject("operatorId")
  42.                 .field("type", "integer")
  43.                 .endObject()
  44.                 .startObject("province")
  45.                 .field("type", "keyword")
  46.                 .endObject()
  47.                 .startObject("ipAddr")
  48.                 .field("type", "ip")
  49.                 .endObject()
  50.                 .startObject("replyTotal")
  51.                 .field("type", "integer")
  52.                 .endObject()
  53.                 .startObject("fee")
  54.                 .field("type", "long")
  55.                 .endObject()
  56.                 .endObject()
  57.                 .endObject();
  59.         //3. 添加索引.
  60.         CreateIndexRequest request = new CreateIndexRequest(index);
  61.         request.settings(settings);
  62.         request.mapping(type,mapping);
  63.         client.indices().create(request, RequestOptions.DEFAULT);
  64.         System.out.println("OK!!");
  65.     }
  66. }

4.4 添加文档

  1. @Test
  2. public void addTestData() throws IOException {
  3.     BulkRequest request = new BulkRequest();
  5.     SmsLogs smsLogs = new SmsLogs();
  6.     smsLogs.setMobile("13800000000");
  7.     smsLogs.setCorpName("途虎养车");
  8.     smsLogs.setCreateDate(new Date());
  9.     smsLogs.setSendDate(new Date());
  10.     smsLogs.setIpAddr("10.126.2.9");
  11.     smsLogs.setLongCode("10690000988");
  12.     smsLogs.setReplyTotal(10);
  13.     smsLogs.setState(0);
  14.     smsLogs.setSmsContent("【途虎养车】亲爱的张三先生/女士，您在途虎购买的货品(单号TH123456)已 到指定安装店多日，" + "现需与您确认订单的安装情况，请点击链接按实际情况选择（此链接有效期为72H）。您也可以登录途 虎APP进入" + "“我的-待安装订单”进行预约安装。若您在服务过程中有任何疑问，请致电400-111-8868向途虎咨 询。");
  15.     smsLogs.setProvince("北京");
  16.     smsLogs.setOperatorId(1);
  17.     smsLogs.setFee(3);
  18.     request.add(new IndexRequest(index, type, "21").source(mapper.writeValueAsString(smsLogs), XContentType.JSON));
  20.     smsLogs.setMobile("13700000001");
  21.     smsLogs.setProvince("上海");
  22.     smsLogs.setSmsContent("【途虎养车】亲爱的刘红先生/女士，您在途虎购买的货品(单号TH1234526)已 到指定安装店多日，" + "现需与您确认订单的安装情况，请点击链接按实际情况选择（此链接有效期为72H）。您也可以登录途 虎APP进入" + "“我的-待安装订单”进行预约安装。若您在服务过程中有任何疑问，请致电400-111-8868向途虎咨 询。");
  23.     request.add(new IndexRequest(index, type, "22").source(mapper.writeValueAsString(smsLogs), XContentType.JSON));
  26.     // -------------------------------------------------------------------------------------------------------------------
  28.     SmsLogs smsLogs1 = new SmsLogs();
  29.     smsLogs1.setMobile("13100000000");
  30.     smsLogs1.setCorpName("盒马鲜生");
  31.     smsLogs1.setCreateDate(new Date());
  32.     smsLogs1.setSendDate(new Date());
  33.     smsLogs1.setIpAddr("10.126.2.9");
  34.     smsLogs1.setLongCode("10660000988");
  35.     smsLogs1.setReplyTotal(15);
  36.     smsLogs1.setState(0);
  37.     smsLogs1.setSmsContent("【盒马】您尾号12345678的订单已开始配送，请在您指定的时间收货不要走开 哦~配送员：" + "刘三，电话：13800000000");
  38.     smsLogs1.setProvince("北京");
  39.     smsLogs1.setOperatorId(2);
  40.     smsLogs1.setFee(5);
  41.     request.add(new IndexRequest(index, type, "23").source(mapper.writeValueAsString(smsLogs1), XContentType.JSON));
  43.     smsLogs1.setMobile("18600000001");
  44.     smsLogs1.setProvince("上海");
  45.     smsLogs1.setSmsContent("【盒马】您尾号7775678的订单已开始配送，请在您指定的时间收货不要走开 哦~配送员：" + "王五，电话：13800000001");
  46.     request.add(new IndexRequest(index, type, "24").source(mapper.writeValueAsString(smsLogs1), XContentType.JSON));
  48.     // -------------------------------------------------------------------------------------------------------------------
  50.     SmsLogs smsLogs2 = new SmsLogs();
  51.     smsLogs2.setMobile("15300000000");
  52.     smsLogs2.setCorpName("滴滴打车");
  53.     smsLogs2.setCreateDate(new Date());
  54.     smsLogs2.setSendDate(new Date());
  55.     smsLogs2.setIpAddr("10.126.2.8");
  56.     smsLogs2.setLongCode("10660000988");
  57.     smsLogs2.setReplyTotal(50);
  58.     smsLogs2.setState(1);
  59.     smsLogs2.setSmsContent("【滴滴单车平台】专属限时福利！青桔/小蓝月卡立享5折，特惠畅骑30天。" + "戳 https://xxxxxx退订TD");
  60.     smsLogs2.setProvince("上海");
  61.     smsLogs2.setOperatorId(3);
  62.     smsLogs2.setFee(7);
  63.     request.add(new IndexRequest(index, type, "25").source(mapper.writeValueAsString(smsLogs2), XContentType.JSON));
  65.     smsLogs2.setMobile("18000000001");
  66.     smsLogs2.setProvince("武汉");
  67.     smsLogs2.setSmsContent("【滴滴单车平台】专属限时福利！青桔/小蓝月卡立享5折，特惠畅骑30天。" + "戳 https://xxxxxx退订TD");
  68.     request.add(new IndexRequest(index, type, "26").source(mapper.writeValueAsString(smsLogs2), XContentType.JSON));
  71.     // -------------------------------------------------------------------------------------------------------------------
  73.     SmsLogs smsLogs3 = new SmsLogs();
  74.     smsLogs3.setMobile("13900000000");
  75.     smsLogs3.setCorpName("招商银行");
  76.     smsLogs3.setCreateDate(new Date());
  77.     smsLogs3.setSendDate(new Date());
  78.     smsLogs3.setIpAddr("10.126.2.8");
  79.     smsLogs3.setLongCode("10690000988");
  80.     smsLogs3.setReplyTotal(50);
  81.     smsLogs3.setState(0);
  82.     smsLogs3.setSmsContent("【招商银行】尊贵的李四先生,恭喜您获得华为P30 Pro抽奖资格,还可领100 元打" + "车红包,仅限1天");
  83.     smsLogs3.setProvince("上海");
  84.     smsLogs3.setOperatorId(1);
  85.     smsLogs3.setFee(8);
  86.     request.add(new IndexRequest(index, type, "27").source(mapper.writeValueAsString(smsLogs3), XContentType.JSON));
  88.     smsLogs3.setMobile("13990000001");
  89.     smsLogs3.setProvince("武汉");
  90.     smsLogs3.setSmsContent("【招商银行】尊贵的李四先生,恭喜您获得华为P30 Pro抽奖资格,还可领100 元打" + "车红包,仅限1天");
  91.     request.add(new IndexRequest(index, type, "28").source(mapper.writeValueAsString(smsLogs3), XContentType.JSON));
  93.     // -------------------------------------------------------------------------------------------------------------------
  95.     SmsLogs smsLogs4 = new SmsLogs();
  96.     smsLogs4.setMobile("13700000000");
  97.     smsLogs4.setCorpName("中国平安保险有限公司");
  98.     smsLogs4.setCreateDate(new Date());
  99.     smsLogs4.setSendDate(new Date());
  100.     smsLogs4.setIpAddr("10.126.2.8");
  101.     smsLogs4.setLongCode("10690000998");
  102.     smsLogs4.setReplyTotal(18);
  103.     smsLogs4.setState(0);
  104.     smsLogs4.setSmsContent("【中国平安】奋斗的时代，更需要健康的身体。中国平安为您提供多重健康保 障，在奋斗之路上为您保驾护航。退订请回复TD");
  105.     smsLogs4.setProvince("武汉");
  106.     smsLogs4.setOperatorId(1);
  107.     smsLogs4.setFee(5);
  108.     request.add(new IndexRequest(index, type, "29").source(mapper.writeValueAsString(smsLogs4), XContentType.JSON));
  110.     smsLogs4.setMobile("13990000002");
  111.     smsLogs4.setProvince("武汉");
  112.     smsLogs4.setSmsContent("【招商银行】尊贵的王五先生,恭喜您获得iphone 56抽奖资格,还可领5 元打" + "车红包,仅限100天");
  113.     request.add(new IndexRequest(index, type, "30").source(mapper.writeValueAsString(smsLogs4), XContentType.JSON));
  115.     // -------------------------------------------------------------------------------------------------------------------
  118.     SmsLogs smsLogs5 = new SmsLogs();
  119.     smsLogs5.setMobile("13600000000");
  120.     smsLogs5.setCorpName("中国移动");
  121.     smsLogs5.setCreateDate(new Date());
  122.     smsLogs5.setSendDate(new Date());
  123.     smsLogs5.setIpAddr("10.126.2.8");
  124.     smsLogs5.setLongCode("10650000998");
  125.     smsLogs5.setReplyTotal(60);
  126.     smsLogs5.setState(0);
  127.     smsLogs5.setSmsContent("【北京移动】尊敬的客户137****0000，5月话费账单已送达您的139邮箱，" + "点击查看账单详情 http://y.10086.cn/; " + " 回Q关闭通知，关注“中国移动139邮箱”微信随时查账单【中国移动 139邮箱】");
  128.     smsLogs5.setProvince("武汉");
  129.     smsLogs5.setOperatorId(1);
  130.     smsLogs5.setFee(4);
  131.     request.add(new IndexRequest(index, type, "31").source(mapper.writeValueAsString(smsLogs5), XContentType.JSON));
  133.     smsLogs5.setMobile("13990001234");
  134.     smsLogs5.setProvince("山西");
  135.     smsLogs5.setSmsContent("【北京移动】尊敬的客户137****1234，8月话费账单已送达您的126邮箱，\" + \"点击查看账单详情 http://y.10086.cn/; \" + \" 回Q关闭通知，关注“中国移动126邮箱”微信随时查账单【中国移动 126邮箱】");
  136.     request.add(new IndexRequest(index, type, "32").source(mapper.writeValueAsString(smsLogs5), XContentType.JSON));
  137.     // -------------------------------------------------------------------------------------------------------------------
  139.     client.bulk(request,RequestOptions.DEFAULT);
  141.     System.out.println("OK!");
  142. }