错误 在请求是报错bitsum在请求提交按钮时 将按钮误用成submit 导致数据提交后就刷新界面 数据还没有被读取到 就结束了api访问导致的bug 报错 http请求显示为cancel 完善后的关于读取jd数据的service层
public List
<Map
<String ,Object>> SreachPag(String keywork
, int PagNo
, int PagSize
) throws IOException
{
if (PagNo
<= 1) {
PagNo
= 1;
}
SearchRequest searchRequest
= new SearchRequest("jd_goods");
SearchSourceBuilder sourceBuilder
= new SearchSourceBuilder();
sourceBuilder
.from(PagNo
);
sourceBuilder
.size(PagSize
);
MatchQueryBuilder matchQueryBuilder
= new MatchQueryBuilder("title", keywork
);
sourceBuilder
.query(matchQueryBuilder
);
sourceBuilder
.timeout(new TimeValue(60, TimeUnit
.SECONDS
));
HighlightBuilder highlightBuilder
= new HighlightBuilder();
highlightBuilder
.field("title");
highlightBuilder
.requireFieldMatch(false);
highlightBuilder
.preTags("<span style='color:red'>");
highlightBuilder
.postTags("</span>");
sourceBuilder
.highlighter(highlightBuilder
);
searchRequest
.source(sourceBuilder
);
SearchResponse searchResponse
= estHighLevelClient
.search(searchRequest
, RequestOptions
.DEFAULT
);
ArrayList
<Map
<String, Object>> list
= new ArrayList<>();
for (SearchHit hit
: searchResponse
.getHits().getHits()) {
Map
<String, HighlightField> highlightFields
= hit
.getHighlightFields();
HighlightField title
= highlightFields
.get("title");
Map
<String, Object> sourceAsMap
= hit
.getSourceAsMap();
if (title
!= null
) {
Text
[] fragments
= title
.fragments();
String n_title
= "";
for (Text text
: fragments
) {
n_title
+= text
;
}
sourceAsMap
.put("title", n_title
);
}
list
.add(sourceAsMap
);
}
return list
;
}
config配置
@Configuration
public class ESConfig {
@Bean
public RestHighLevelClient estHighLevelClient
(){
RestHighLevelClient restHighLevelClient
= new RestHighLevelClient(
RestClient
.builder(
new HttpHost(Name
.IP
,Name
.PROT
,Name
.SECHENM
)
)
);
return restHighLevelClient
;
}
}