Solr的安装和使用

安装

CentOS中先安装好Java和Tomcat。准备工具IK Analyzer 2012FF

和Solr-4.10.3.tgz

将solr-4.10.3文件夹中dist中的solr-4.10.3.war文件复制到Tomcat的webapps,并且更名为solr.war,下开启tomcat解压后再关闭tomcat,再删除solr.war。

将Solr-4.10.3文件中,example/lib/ext下所有jar包复制到tomcat/webapps/solr/WEB-INF/lib文件夹下。

在你愿意的位置创建一个目录叫solrhome,把Solr-4.10.3 /example下solr复制到 solrhome中,然后在solr的WEB-INF下的web.xml中配置solrhome的位置。

    <env-entry><env-entry-name>solr/home</env-entry-name><env-entry-value>/usr/local/solr/solrhome</env-entry-value><env-entry-type>java.lang.String</env-entry-type></env-entry>

 

配置业务字段

 

把IK_Analyzer 2012文件夹下的IKAnalyzer2012FF_u1的jar包复制到solr 的WEB-INF下lib文件夹中。

在WEB-INF下新建classes文件夹。复制如下三个文件到classes中

cp IKAnalyzer.cfg.xml ext_stopword.dic mydict.dic /usr/local/solr/tomcat/webapps/solr/WEB-INF/classes

 

修改solrhome/collection1/conf/schema.xml文件,在末尾添加

<fieldType name="text_ik" class="solr.TextField"><analyzer class="org.wltea.analyzer.lucene.IKAnalyzer"/>
</fieldType>
<field name="item_title" type="text_ik" indexed="true" stored="true"/>
<field name="item_sell_point" type="text_ik" indexed="true" stored="true"/>
<field name="item_price"  type="long" indexed="true" stored="true"/>
<field name="item_image" type="string" indexed="false" stored="true" />
<field name="item_category_name" type="string" indexed="true" stored="true" />
<field name="item_desc" type="text_ik" indexed="true" stored="false" /><field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_sell_point" dest="item_keywords"/>
<copyField source="item_category_name" dest="item_keywords"/>
<copyField source="item_desc" dest="item_keywords"/>

重启tomcat

简单测试

打开solr网址,http://192.168.140.133:8080/solr/,点击左侧collection1,选择Documents

在documents中输入

点击Submit Document

 点击Collection1下的Query,点击Execute Query

 

删除该测试文档,

在Documents输入

<delete>
<query>*:*</query>
</delete>
<commit/>

Document Type选择xml,然后Submmit Document。

再Execute Query就没有文档了。

  },"response": {"numFound": 0,"start": 0,"docs": []}
}

 使用Java代码来测试solr文档

添加SolrJava客户端依赖

<!-- solr客户端 --><dependency><groupId>org.apache.solr</groupId><artifactId>solr-solrj</artifactId></dependency>

测试代码

public class SolrJTest {@Testpublic void addDocument() throws Exception {//创建一连接SolrServer solrServer = new HttpSolrServer("http://192.168.25.154:8080/solr");//创建一个文档对象SolrInputDocument document = new SolrInputDocument();document.addField("id", "test001");document.addField("item_title", "测试商品2");document.addField("item_price", 54321);//把文档对象写入索引库
        solrServer.add(document);//提交
        solrServer.commit();}@Testpublic void deleteDocument() throws Exception {//创建一连接SolrServer solrServer = new HttpSolrServer("http://192.168.25.154:8080/solr");//solrServer.deleteById("test001");solrServer.deleteByQuery("*:*");solrServer.commit();}
}

使用Java代码将MySQL数据上传到Solr服务器

使用Http方式,访问http://localhost/search/import的时候,将后台MySQL几个表的数据上传到Solr服务器。

先看Controller

@Controller
public class SearchController {@Autowiredprivate ImportItemService importItemService;@RequestMapping("/search/import")@ResponseBodypublic TaotaoResult importAll() {TaotaoResult result = importItemService.importAll();return result;}

Service层总ImportItemService的实现类是

@Service
public class ImportItemServiceImpl implements ImportItemService {@Autowiredprivate ImportItemMapper iim;@Autowiredprivate SolrServer solrServer;@Overridepublic TaotaoResult importAll(){try {List<ImportItem> list = iim.importItemList();for(ImportItem item:list) {SolrInputDocument document= new SolrInputDocument();document.setField("id", item.getId());document.setField("item_title", item.getTitle());document.setField("item_sell_point", item.getSell_point());document.setField("item_price", item.getPrice());document.setField("item_image", item.getImage());document.setField("item_category_name", item.getCategory_name());document.setField("item_desc", item.getItem_des());//写入索引库
                solrServer.add(document);}solrServer.commit();} catch (Exception e) {e.printStackTrace();return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));}return TaotaoResult.ok();}}

其中ImportItem类

public class ImportItem {
//getter and setter...
...private String id;private String title;private String sell_point;private long price;private String image;private String category_name;private String item_des;}

 

DAO 层

public interface ImportItemMapper {List<ImportItem> importItemList();
}

对应XML文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.taotao.mapper.ImportItemMapper" ><select id="importItemList" resultType="com.taotao.pojo.ImportItem">SELECTa.id,a.title,a.sell_point,a.price,a.image,b. NAME category_nameFROMtb_item aLEFT JOIN tb_item_cat b ON a.cid = b.id</select></mapper>

 搜索服务发布

预热:先了解SolrJ如何访问solr服务器。

测试代码

@Testpublic void queryDocument() throws Exception {SolrServer solrServer = new HttpSolrServer("http://192.168.25.154:8080/solr");//创建一个查询对象SolrQuery query = new SolrQuery();//设置查询条件query.setQuery("*:*");query.setStart(20);query.setRows(50);//执行查询QueryResponse response = solrServer.query(query);//取查询结果SolrDocumentList solrDocumentList = response.getResults();System.out.println("共查询到记录:" + solrDocumentList.getNumFound());for (SolrDocument solrDocument : solrDocumentList) {System.out.println(solrDocument.get("id"));System.out.println(solrDocument.get("item_title"));System.out.println(solrDocument.get("item_price"));System.out.println(solrDocument.get("item_image"));}}

DAO层

public interface SearchDao {SearchResult search(SolrQuery query)throws Exception;
}
@Component
public class SearchDaoImpl implements SearchDao {@Autowiredprivate SolrServer solrServer;@Overridepublic SearchResult search(SolrQuery query) throws Exception {//返回值对象SearchResult result = new SearchResult();//根据查询条件查询索引库QueryResponse queryResponse = solrServer.query(query);//取查询结果SolrDocumentList solrDocumentList = queryResponse.getResults();//取查询结果总数量
        result.setRecordCount(solrDocumentList.getNumFound());//商品列表List<ImportItem> itemList = new ArrayList<>();//取高亮显示Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();//取商品列表for (SolrDocument solrDocument : solrDocumentList) {//创建一商品对象ImportItem item = new ImportItem();item.setId((String) solrDocument.get("id"));//取高亮显示的结果List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");String title = "";if (list != null && list.size()>0) {title = list.get(0);} else {title = (String) solrDocument.get("item_title");}item.setTitle(title);item.setImage((String) solrDocument.get("item_image"));item.setPrice((long) solrDocument.get("item_price"));item.setSell_point((String) solrDocument.get("item_sell_point"));item.setCategory_name((String) solrDocument.get("item_category_name"));//添加的商品列表
            itemList.add(item);}result.setItemList(itemList);return result;}

POJO类

public class SearchResult {//商品列表private List<ImportItem> itemList;//总记录数private long recordCount;//总页数private long pageCount;//当前页private long curPage;}

Service层

public interface SearchService {SearchResult search(String query,int page,int rows)throws Exception;
}@Service
public class SearchServiceImpl implements SearchService {@Autowiredprivate SearchDao searchDao;@Overridepublic SearchResult search(String queryString, int page, int rows) throws Exception {//创建查询对象SolrQuery query = new SolrQuery();//设置查询条件
        query.setQuery(queryString);//设置分页query.setStart((page - 1) * rows);query.setRows(rows);//设置默认搜素域query.set("df", "item_keywords");//设置高亮显示query.setHighlight(true);query.addHighlightField("item_title");query.setHighlightSimplePre("<em style=\"color:red\">");query.setHighlightSimplePost("</em>");//执行查询SearchResult searchResult = searchDao.search(query);//计算查询结果总页数long recordCount = searchResult.getRecordCount();long pageCount = recordCount / rows;if (recordCount % rows > 0) {pageCount++;}searchResult.setPageCount(pageCount);searchResult.setCurPage(page);return searchResult;}}

Controller层

@Autowiredprivate SearchService searchService;@RequestMapping(value="/query", method=RequestMethod.GET)@ResponseBodypublic TaotaoResult search(@RequestParam("q")String queryString, @RequestParam(defaultValue="1")Integer page, @RequestParam(defaultValue="60")Integer rows) {//查询条件不能为空if (StringUtils.isBlank(queryString)) {return TaotaoResult.build(400, "查询条件不能为空");}SearchResult searchResult = null;try {queryString=new String(queryString.getBytes("iso8859-1"),"utf-8");searchResult = searchService.search(queryString, page, rows);} catch (Exception e) {e.printStackTrace();return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));}return TaotaoResult.ok(searchResult);}

 

转载于:https://www.cnblogs.com/legion/p/9717724.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/249408.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

maven如何修改本地仓库与中央仓库

什么是Maven仓库 在不用Maven的时候&#xff0c;比如说以前我们用Ant构建项目&#xff0c;在项目目录下&#xff0c;往往会看到一个名为/lib的子目录&#xff0c;那里存放着各类第三方依赖jar文件&#xff0c;如 log4j.jar&#xff0c;junit.jar等等。每建立一个项目&#xff0…

Maven项目 之eclipse操作篇

使用eclipse创建maven项目大家应该都很熟悉&#xff0c;这里主要说明如何将已创建的非maven项目修改为maven项目。 1.创建测试项目 创建一个Dynamic Web Project &#xff0c;项目结构如图。 2.配置工程类型 右击项目--> Properties --> Project Facets&#xff0c;勾选…

网络工程:3.1 RIP(Routing Information Protocol)协议

遵循协议&#xff1a; 1、特网rip1标准文件&#xff1a;rfc1058 网站 &#xff1a; https://tools.ietf.org/html/rfc1058 2、因特网rip2标准文件&#xff1a;rfc1723 网站 &#xff1a;https://tools.ietf.org/html/rfc1723 使用工具&#xff1a; GNS3 使用路由器文件&a…

2:word定制工作界面

1.2&#xff0c;定制工作界面 一、功能区的折叠和展开 设计选项----右上方的向上的箭头 功能区的选项&#xff1a;三个&#xff1a;自动隐藏功能区&#xff0c;显示选项卡&#xff0c;显示选项卡和命令 二、定制快速访问工具栏 如何将一些常用的命令放到一个能便捷找到的地方 第…

二维码生成

从vs Nugets搜索ThoughtWorks.QRCode下载ThoughtWorks.QRCode.dll private byte[] CreateQrcode(string code){ string enCodeString code;QRCodeEncoder qrCodeEncoder new QRCodeEncoder();qrCodeEncoder.QRCodeEncodeMode QRCodeEncoder.ENCODE_MODE.BYTE;qrCodeEncod…

Mac系统中MongoChef链接MongoDB集群的方法

第一步&#xff1a;启动Mongochef&#xff0c;点击链接按钮&#xff1b;第二步&#xff1a;打开连接配置面板&#xff0c;填写数据库名&#xff1b;第三步&#xff1a;选择链接类型Connection Type&#xff0c;一般分为直接连接和集群链接&#xff0c;这里选择集群链接 Replica…

crm 一级菜单排序,二级菜单选中并且展开,非菜单权限的归属,权限粒度控制到按钮级别...

排序 /rbac/templatetags/rbac.py from django import template from django.conf import settings import re from collections import OrderedDict register template.Library()register.inclusion_tag(rbac/menu.html) def menu(request):ordered_dictOrderedDict()menu_d…

Maven工程的多模块

一个大项目需要一个团队来完成,然后一个大型项目就拆分成几块来同时开发,节省时间,提高效率. 大致分为以下几个模块(仅是自身经历): 依赖管理工程模块:一般现在开发都是以maven来管理jar包,方便.所以整个工程的依赖统一放在一个单独工程中,一般叫做父工程xxx-parent. 注意事项…

查询语句

1.基本查询语句 1.1 语法&#xff1a; SELECT 属性列表 FROM 表名或视图列表 WHERE 条件表达式1 GROUP BY 属性名1 | HAVING 条件表达式2 ORDER BY 属性名2 ASC DESC 2.单表查询 1.应用&#xff1a;查询表中所有的记录 2.查询指定字段&#xff1a;查询表中所有name字段的记录 …

中文词频统计与词云生成

本次作业来源于&#xff1a;https://edu.cnblogs.com/campus/gzcc/GZCC-16SE1/homework/2822 中文词频统计 1. 下载一长篇中文小说。 下载长篇小说《西游记》 本次作业小说保存在txt文档&#xff1a;xyj.txt 2. 从文件读取待分析文本。 xyj open(rF:/xyj.txt,r,encodingutf-8)…

[JZOJ5866]【NOIP2018模拟9.13】指引

Description Input Output Sample Input 6 3 2 0 3 1 1 3 4 2 0 4 5 5 Sample Output 2 Data Constraint Hint 贪心&#xff0c;把旅行者和出口的x坐标降序排序。 然后从前往后扫&#xff0c;如果是出口&#xff0c;就把y坐标插进set里&#xff0c;如果是旅行者&#xff0c;就查…

scrapy框架之递归解析和post请求

今日概要 递归爬取解析多页页面数据scrapy核心组件工作流程scrapy的post请求发送今日详情 1.递归爬取解析多页页面数据 - 需求&#xff1a;将糗事百科所有页码的作者和段子内容数据进行爬取切持久化存储 - 需求分析&#xff1a;每一个页面对应一个url&#xff0c;则scrapy工程需…

SmartGit 过期解决方案之 非商业版本安装使用

作为前端开发的小伙伴一定有这样的困惑&#xff0c;自己在日常的团队协作配合时&#xff0c;提交代码和解决冲突是我们最头疼的问题&#xff0c;但是又不喜欢使用Eclipse或者IDEA这种超级占内存的编辑器&#xff0c;使用Git命令又是那么捉襟见肘&#xff0c;所以有一个好用的轻…

vue使用webPack打包发布后页面显示空白

今天笔者将打包后&#xff0c;进行访问&#xff0c;访问到index.html&#xff0c;但是出现的是空白页。 打包命令&#xff1a;npm run build&#xff0c;打包后的文件如下&#xff1a; 这是因为index.html中引入的css ,js 的路径不对:如下图 这个是因为webpack打包的时候引入…

第一次实验报告

c程序实验报告 姓名&#xff1a;黄志乾 实验地点&#xff1a;教学楼514教室 实验时间&#xff1a;3月19日实验项目: 1、字符与ASCII码 2、运算符与表达式的应用 3、顺序结构应用程序 4、数学函数的算法描述 5、鸡兔同笼的算法描述 6、确定坐标的算法描述…

Mac下Idea安装Git报错Xcrun问题的解决

使用过IDEA的小伙伴都知道&#xff0c;它和我们之前用过的Eclipse一样强大&#xff0c;或者比他更强大。当它配合的Mac使用时&#xff0c;就会变得更得心应手&#xff0c;少去很多环境配置的环节。其中最典型的就是Git 由于Mac自带就安装了git, 大家可以通过终端输入命令“git…

关于Django路由层简单笔记

Django—路由层 URL配置(URLconf)就像Django 所支撑网站的目录。它的本质是URL与要为该URL调用的视图函数之间的映射表&#xff1b;你就是以这种方式告诉Django&#xff0c;对于客户端发来的某个URL调用哪一段逻辑代码对应执行。 1&#xff0c;简单的路由配置 from django.urls…

hdu 5183

hdu 5183(Hash处理区间问题) 题目链接:http://acm.hdu.edu.cn/showproblem.php?pid5183 题意:给出一个n个元素的数组,现在要求判断 a1-a2a3-a4...../-an 中是否存在某个某个区间使得 ai-ai1ai2...(-1)j-iaj k?? 这个题要利用Hash就可以实现几乎在 O(n) 的时间内实现查找判断…

vue-cli,webpack安装

第一步应该下载node.js这是安装vue-cli的基础工具。官网下载快捷安全可&#xff1a;https://nodejs.org/en/ 第二步打开命令面板找到你要安装的位置 第三步就是安装全局vue-cli 命令操作 npm intatll -g vue-cli 安装完毕之后 可以检查安装版本即 vue -V 如下图 这还不算完&…

CSS3笔记之定位篇(二)z-index

知识点1&#xff1a;z-index基础 z-index&#xff1a;auto; 默认值 z-index: <integer> 整数 z-index: inherit 继承 不考虑css3 还有定位元素的z-index才有作用 知识点2&#xff1a;z-index与定位元素 无嵌套&#xff1a;后来居上&#xff0c;哪个大哪个上 //在没有…