作者 王勇

ES索引名修改,以及分词器选择修改

@@ -23,7 +23,7 @@ import java.util.Date; @@ -23,7 +23,7 @@ import java.util.Date;
23 @Builder 23 @Builder
24 @AllArgsConstructor 24 @AllArgsConstructor
25 @NoArgsConstructor 25 @NoArgsConstructor
26 -@Document(indexName = "message_note") 26 +@Document(indexName = "message")
27 public class MessageNote implements Serializable { 27 public class MessageNote implements Serializable {
28 28
29 private static final long serialVersionUID = -2119333801860569470L; 29 private static final long serialVersionUID = -2119333801860569470L;
@@ -42,7 +42,7 @@ public class MessageNote implements Serializable { @@ -42,7 +42,7 @@ public class MessageNote implements Serializable {
42 /** 42 /**
43 * 所属用户登陆名称 43 * 所属用户登陆名称
44 */ 44 */
45 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 45 + @Field(type = FieldType.Keyword)
46 private String username; 46 private String username;
47 47
48 /** 48 /**
@@ -54,7 +54,7 @@ public class MessageNote implements Serializable { @@ -54,7 +54,7 @@ public class MessageNote implements Serializable {
54 /** 54 /**
55 * 所属服务器名称 55 * 所属服务器名称
56 */ 56 */
57 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 57 + @Field(type = FieldType.Keyword)
58 private String serverName; 58 private String serverName;
59 59
60 /** 60 /**
@@ -66,7 +66,7 @@ public class MessageNote implements Serializable { @@ -66,7 +66,7 @@ public class MessageNote implements Serializable {
66 /** 66 /**
67 * 所属虚拟主机名称 67 * 所属虚拟主机名称
68 */ 68 */
69 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 69 + @Field(type = FieldType.Keyword)
70 private String virtualHostName; 70 private String virtualHostName;
71 71
72 /** 72 /**
@@ -78,7 +78,7 @@ public class MessageNote implements Serializable { @@ -78,7 +78,7 @@ public class MessageNote implements Serializable {
78 /** 78 /**
79 * 所属交换机名称 79 * 所属交换机名称
80 */ 80 */
81 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 81 + @Field(type = FieldType.Keyword)
82 private String exchangeName; 82 private String exchangeName;
83 83
84 /** 84 /**
@@ -90,7 +90,7 @@ public class MessageNote implements Serializable { @@ -90,7 +90,7 @@ public class MessageNote implements Serializable {
90 /** 90 /**
91 * 所属队列名称 91 * 所属队列名称
92 */ 92 */
93 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 93 + @Field(type = FieldType.Keyword)
94 private String queueName; 94 private String queueName;
95 95
96 /** 96 /**
@@ -102,7 +102,7 @@ public class MessageNote implements Serializable { @@ -102,7 +102,7 @@ public class MessageNote implements Serializable {
102 /** 102 /**
103 * 所属路由键的名称 103 * 所属路由键的名称
104 */ 104 */
105 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 105 + @Field(type = FieldType.Keyword)
106 private String routingKeyName; 106 private String routingKeyName;
107 107
108 /** 108 /**
@@ -141,7 +141,7 @@ public class MessageNote implements Serializable { @@ -141,7 +141,7 @@ public class MessageNote implements Serializable {
141 /** 141 /**
142 * 发送消息内容,别名 142 * 发送消息内容,别名
143 */ 143 */
144 - @Field(type = FieldType.Text, analyzer = "ik_max_word") 144 + @Field(type = FieldType.Text, analyzer = "ik_smart", searchAnalyzer = "ik_max_word")
145 private String alias_sendContent; 145 private String alias_sendContent;
146 146
147 /** 147 /**
@@ -51,7 +51,7 @@ public class ElasticsearchService { @@ -51,7 +51,7 @@ public class ElasticsearchService {
51 public ResultJson selectMessageNoteList(MessageNote messageNote, Integer pageNum, Integer pageSize) throws IOException 51 public ResultJson selectMessageNoteList(MessageNote messageNote, Integer pageNum, Integer pageSize) throws IOException
52 { 52 {
53 // 条件搜索 53 // 条件搜索
54 - SearchRequest searchRequest = new SearchRequest("message_note"); 54 + SearchRequest searchRequest = new SearchRequest("message");
55 SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); 55 SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
56 56
57 // 高亮设置 57 // 高亮设置