Echo-tomcat安装及配置教程

package com.greate.community; import com.greate.community.dao.DiscussPostMapper; import com.greate.community.dao.elasticsearch.DiscussPostRepository; import com.greate.community.entity.DiscussPost; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder; import org.elasticsearch.search.fetch.subphase.highlight.HighlightField; import org.elasticsearch.search.sort.SortBuilders; import org.elasticsearch.search.sort.SortOrder; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.Pageable; import org.springframework.data.elasticsearch.core.ElasticsearchTemplate; import org.springframework.data.elasticsearch.core.SearchResultMapper; import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage; import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl; import org.springframework.data.elasticsearch.core.query.NativeSearchQuery; import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder; import org.springframework.data.elasticsearch.core.query.SearchQuery; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringRunner; import java.util.ArrayList; import java.util.Date; import java.util.List; @RunWith(SpringRunner.class) @ContextConfiguration(classes = CommunityApplication.class) @SpringBootTest public class ElasticsearchTests { @Autowired private DiscussPostMapper discussPostMapper; @Autowired private DiscussPostRepository discussPostRepository; @Autowired private ElasticsearchTemplate elasticsearchTemplate; /** * 测试插入数据 */ @Test public void testInsert() { discussPostRepository.save(discussPostMapper.selectDiscussPostById(241)); discussPostRepository.save(discussPostMapper.selectDiscussPostById(242)); discussPostRepository.save(discussPostMapper.selectDiscussPostById(243)); } /** * 测试批量插入数据 */ @Test public void testInsetList() { discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(101, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(102, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(103, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(111, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(112, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(131, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(132, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(133, 0, 100, 0)); discussPostRepository.saveAll(discussPostMapper.selectDiscussPosts(134, 0, 100, 0)); } /** * 测试修改数据 */ @Test public void testUpdate() { DiscussPost discussPost = discussPostMapper.selectDiscussPostById(231); discussPost.setContent("Great Elasticsearch"); discussPostRepository.save(discussPost); } /** * 测试删除数据（注意数据库中的数据并未被删除） */ @Test public void testDelete() { discussPostRepository.deleteById(231); // discussPostRepository.deleteAll(); } /** * 测试使用 ElasticsearchRepository 进行搜索 */ @Test public void testSearchByRepository() { SearchQuery searchQuery = new NativeSearchQueryBuilder() .withQuery(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content")) .withSort(SortBuilders.fieldSort("type").order(SortOrder.DESC)) .withSort(SortBuilders.fieldSort("score").order(SortOrder.DESC)) .withSort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)) .withPageable(PageRequest.of(0, 10)) .withHighlightFields( new HighlightBuilder.Field("title").preTags("<em>").postTags("</em>"), new HighlightBuilder.Field("content").preTags("<em>").postTags("</em>") ).build(); // elasticsearchTemplate.queryForPage(searchQuery, class, SearchResultMapper); // 底层获取到了高亮显示的值，但是没有做处理（所以想要更加完善的话需要使用 ElasticsearchTemplate) Page<DiscussPost> page = discussPostRepository.search(searchQuery); System.out.println(page.getTotalElements()); System.out.println(page.getTotalPages()); System.out.println(page.getNumber()); System.out.println(page.getSize()); for (DiscussPost post : page) { System.out.println(post); } } /** * 测试使用 ElasticsearchTemplate 进行搜索 */ @Test public void testSearchTemplate() { SearchQuery searchQuery = new NativeSearchQueryBuilder() .withQuery(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content")) .withSort(SortBuilders.fieldSort("type").order(SortOrder.DESC)) .withSort(SortBuilders.fieldSort("score").order(SortOrder.DESC)) .withSort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)) .withPageable(PageRequest.of(0, 10)) .withHighlightFields( new HighlightBuilder.Field("title").preTags("<em>").postTags("</em>"), new HighlightBuilder.Field("content").preTags("<em>").postTags("</em>") ).build(); Page<DiscussPost> page = elasticsearchTemplate.queryForPage(searchQuery, DiscussPost.class, new SearchResultMapper() { @Override public <T> AggregatedPage<T> mapResults(SearchResponse searchResponse, Class<T> aClass, Pageable pageable) { SearchHits hits = searchResponse.getHits(); if (hits.getTotalHits() <= 0) { return null; } List<DiscussPost> list = new ArrayList<>(); for (SearchHit hit : hits) { DiscussPost post = new DiscussPost(); String id = hit.getSourceAsMap().get("id").toString(); post.setId(Integer.valueOf(id)); String userId = hit.getSourceAsMap().get("userId").toString(); post.setUserId(Integer.valueOf(userId)); String title = hit.getSourceAsMap().get("title").toString(); post.setTitle(title); String content = hit.getSourceAsMap().get("content").toString(); post.setContent(content); String status = hit.getSourceAsMap().get("status").toString(); post.setStatus(Integer.valueOf(status)); String createTime = hit.getSourceAsMap().get("createTime").toString(); post.setCreateTime(new Date(Long.valueOf(createTime))); String commentCount = hit.getSourceAsMap().get("commentCount").toString(); post.setCommentCount(Integer.valueOf(commentCount)); // 处理高亮显示的内容 HighlightField titleField = hit.getHighlightFields().get("title"); if (titleField != null) { post.setTitle(titleField