sorl6.0+jetty+mysql搭建solr服务

1.下载solr

　　官网：http://lucene.apache.org/solr/

2.目录结构如下

3.启动solr（默认使用jetty部署）

　　在path路径下将 bin文件夹对应的目录加入，然后输入 solr start（或者 solr start -p port，指定端口启动）。在浏览器中访问如下：

 

　　当然，还可以启动其他样例的服务，在example目录下有一个READEME.txt，如果感兴趣请看一下。命令格式如下：

Solr example
------------This directory contains Solr examples. Each example is contained in a 
separate directory. To run a specific example, do:bin/solr -e <EXAMPLE> where <EXAMPLE> is one of:cloud        : SolrCloud exampledih          : Data Import Handler (rdbms, mail, rss, tika)schemaless   : Schema-less example (schema is inferred from data during indexing)techproducts : Kitchen sink example providing comprehensive examples of Solr features

4.Individual SolrCore

　　在server/solr目录下，有一个README.txt的文件，其中说明了如何建立solr core。最简单的建立是直接复制solr中为我们提供好的例子，打开server/solr/configsets目录会发现里面已经有三个例子，因为我们是要从数据库导入数据，所以复制 “data_driven_schema_configs” 这个例子并改名为 “myCollections”。

 

5.导入需要的jar包

　　为了导入数据和链接mysql，我们还需要导入两个重要的jar包。由于mysql的jar包并没有在项目中，我是复制了一份放到了dist目录下面了。另外两个需要的jar包就是dist目录下带有“dataimport”标识的jar包。

　　然后打开myCollections/conf/solrconfig.xml，引用上面提到的jar包，如下。

6.建立数据库

　　建立好之后，随便写入一点儿数据。

7.添加requestHandler 

　　继续修改myCollections/conf/solrconfig.xml，搜索 <requestHandler name="/select" class="solr.SearchHandler"> ,然后在该行之上添加如下代码。

  <requestHandler name="/dataimport" class="org.apache.solr.handler.dataimport.DataImportHandler">  <lst name="defaults">  <str name="config">data-config.xml</str>  </lst>  </requestHandler>

8.建立连接配置文件

　　在myCollections/conf目录下新建data-config.xml, 内容如下。

<?xml version="1.0" encoding="UTF-8"?>  
<dataConfig>  <dataSource name="source1" type="JdbcDataSource" driver="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost:3306/solrdata" user="root" password="123456" batchSize="-1" />  <document>  <entity name="goods" pk="id"  dataSource="source1"   query="select * from  goods"  deltaImportQuery="select * from goods where id='${dih.delta.id}'"  deltaQuery="select id from goods where updateTime> '${dataimporter.last_index_time}'">  <field column="id" name="id"/>  <field column="name" name="name"/>  <field column="number" name="number"/>  <field column="updateTime" name="updateTime"/>  </entity>  </document>  
</dataConfig>

　说明：

  dataSource是数据库数据源。Entity就是一张表对应的实体，pk是主键，query是查询语句。Field对应一个字段，column是数据库里的column名，后面的name属性对应着Solr的Filed的名字。其中solrdata是数据库名，goods是表名。

  其中deltaQuery是增量索引，原理是从数据库中根据deltaQuery指定的SQL语句查询出所有需要增量导入的数据的ID号。然后根据deltaImportQuery指定的SQL语句返回所有这些ID的数据，即为这次增量导入所要处理的数据。核心思想是：通过内置变量“${dih.delta.id}”和 “${dataimporter.last_index_time}”来记录本次要索引的id和最近一次索引的时间。

9.managed-schema配置field信息

　　搜索 <field name= ，添加关联数据库表Column的信息。

　　注意：默认的 filed 不要删除哦！

10.添加我们刚刚建立的core

　　(1).点击Core Admin，配置我们建立的solr Core的信息，如下所示。

 

　　(2).点击 Add Core，如下所示。

　　(3).测试索引是否成功

　　                                 

索引成功

　　(4).监测查询成功

查询成功

11.通过代码调用solr服务

　　简单建立一个java项目，依赖上dist目录下的solr-solrj-6.0.0.jar。

　　测试代码如下。

import java.lang.reflect.Method;
import java.sql.Timestamp;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrInputDocument;
import com.entity.Good;@SuppressWarnings("deprecation")
public class Solr {private static HttpSolrServer solrServer;static {//注意请求地址格式：浏览器中的地址有 ‘#’，需要把‘#’去掉！solrServer = new HttpSolrServer("http://localhost:8983/solr/hjz");solrServer.setConnectionTimeout(5000);}/*** 添加单个文档 。* * @param article 文章对象* @param articleAddon 文章正文对象*/public static void insert(Good good) {SolrInputDocument doc = new SolrInputDocument();doc.addField("id", good.getId());doc.addField("name", good.getName());doc.addField("number", good.getNumber());doc.addField("updateTime", good.getUpdateTime());try {solrServer.add(doc);solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 根据文档id删除文档 。*/public static void deleteById(String id) {try {solrServer.deleteById(id+"");solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 删除所有文档，为安全起见，使用时再解注函数体 。*/public static void deleteAll() {try {solrServer.deleteByQuery("*:*");solrServer.commit();} catch (Exception e) {e.printStackTrace();}}/*** 更新文档，其实也是通过insert操作来完成 。* * @param article 文章对象* @param articleAddon 文章内容对象，如果不更新正文，可以为null。*/public static void update(Good good) {insert(good);}/*** 根据文档id查询单个文档 。* @return */public static <T> T getById(int id, Class<T> clazz) {SolrQuery query = new SolrQuery();query.setQuery("id:" + id);try {QueryResponse rsp = solrServer.query(query);return rsp.getBeans(clazz).get(0);} catch (Exception e) {e.printStackTrace();}return null;}    /*** @param obj 对象索引* @param idName 主键名称*/public static void deleteByObject(Object obj, String idName){try {Class<?> clazz = obj.getClass();//将idName的首字母变成大写if(Character.isLowerCase(idName.charAt(0))) idName = Character.toUpperCase(idName.charAt(0)) + idName.substring(1);Method method = clazz.getMethod("get"+idName);String idValue = (String) method.invoke(obj);deleteById(idValue);} catch (Exception e) {e.printStackTrace();}}public static void main(String[] args){Good good = new Good("123", 9999, "hjzgg5211314", new Timestamp(System.currentTimeMillis()));//Solr.update(good);//System.out.println(Solr.getById(123, Good.class));deleteByObject(good, "id");}
}
View Code

　　对应的实体类。

import java.sql.Timestamp;import org.apache.solr.client.solrj.beans.Field;public class Good{@Field("id")private String id;@Field("number")private int number;@Field("name")private String name;@Field("updateTime")private Timestamp updateTime;@Overridepublic String toString() {return "Good [id=" + id + ", number=" + number + ", name=" + name + ", updateTime=" + updateTime + "]";}public Good(){}public Good(String id, int number, String name, Timestamp updateTime) {super();this.id = id;this.number = number;this.name = name;this.updateTime = updateTime;}public String getId() {return id;}public void setId(String id) {this.id = id;}public int getNumber() {return number;}public void setNumber(int number) {this.number = number;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Timestamp getUpdateTime() {return updateTime;}public void setUpdateTime(Timestamp updateTime) {this.updateTime = updateTime;}}
View Code

　　每测试一次，可以在浏览器中通过query方式查看测试结果是否正确。

12.参考资料

　　Solr之搭建Solr6.0服务并从Mysql上导入数据

　  Solr参考指南  可以下载

转载于:https://www.cnblogs.com/hujunzheng/p/5647896.html

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

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

相关文章

Maven中安装本地Jar包到仓库中或将本地jar包上传

Maven中安装本地Jar包到仓库中或将本地jar包上传

摘要 maven install 本地jar命令格式 mvn install:install-file -DgroupId<group_name> -DartifactId<artifact_name> -Dversion<version_no> -Dfile<path_of_the_local_jar> -Dpackagingjar -DgeneratePomtrue 示例 mvn install:install-file -Dgroup…
阅读更多...
二维码登录原理及生成与解析

二维码登录原理及生成与解析

一、前言 这几天在研究二维码的扫码登录。初来乍到&#xff0c;还有好多东西不懂。在网上看到有人写了一些通过QRCode或者Zxing实现二维码的生成和解码。一时兴起&#xff0c;决定自己亲手试一试。本人是通过QRCode实现的&#xff0c;下面具体的说一下。 二、二维码原理 基础知…
阅读更多...
knockout+echarts实现图表展示

knockout+echarts实现图表展示

一、需要学习的知识 knockout, require, director, echarts, jquery。简单的入一下门&#xff0c;网上的资料很多&#xff0c;最直接就是进官网校习。 二、效果展示 三、require的配置 require.config.js中可以配置我们的自定义模块的加载。 require.config({baseUrl: ".&…
阅读更多...
Maven在Eclipse中的实用小技巧

Maven在Eclipse中的实用小技巧

前言 我们在开发的工程中很多都是Maven项目&#xff0c;这样更加便于我们jar包的管理。而我们一般使用的IDE都是Eclipse&#xff0c;由于我们在日常的开发过程中会经常要用到一些Maven的操作&#xff0c;所以我今天主要跟大家分享一下我们在日常开发中的Maven实用小知识&#x…
阅读更多...
React中使用Ant Table组件

React中使用Ant Table组件

一、Ant Design of React http://ant.design/docs/react/introduce 二、建立webpack工程 webpackreact demo下载 项目的启动&#xff0c;参考 三、简单配置 1.工程下载下来之后&#xff0c;在src目录下新建目录“table”&#xff0c;新建app.js&#xff0c;内容如下。 import R…
阅读更多...
解决“Dynamic Web Module 3.0 requires Java 1.6 or newer.”错误

解决“Dynamic Web Module 3.0 requires Java 1.6 or newer.”错误

一、问题描述 1.错误截图如下。 2.设计的问题 在Eclipse中新建了一个Maven工程, 然后更改JDK版本为1.6, 结果每次使用Maven > Update project的时候JDK版本都恢复成1.5。 二、原因分析 Maven官方文档有如下描述&#xff1a; 编译器插件用来编译项目的源文件.从3.0版本开始, …
阅读更多...
java自定义注解类

java自定义注解类

一、前言 今天阅读帆哥代码的时候&#xff0c;看到了之前没有见过的新东西, 比如java自定义注解类&#xff0c;如何获取注解&#xff0c;如何反射内部类&#xff0c;this$0是什么意思? 于是乎&#xff0c;学习并整理了一下。 二、代码示例 import java.lang.annotation.Elemen…
阅读更多...
解决cookie跨域访问

解决cookie跨域访问

一、前言 随着项目模块越来越多&#xff0c;很多模块现在都是独立部署。模块之间的交流有时可能会通过cookie来完成。比如说门户和应用&#xff0c;分别部署在不同的机器或者web容器中&#xff0c;假如用户登陆之后会在浏览器客户端写入cookie&#xff08;记录着用户上下文信息…
阅读更多...
React使用antd Table生成层级多选组件

React使用antd Table生成层级多选组件

一、需求 用户对不同的应用需要有不同的权限&#xff0c;用户一般和角色关联在一起&#xff0c;新建角色的时候会选择该角色对应的应用&#xff0c;然后对应用分配权限。于是写了一种实现的方式。首先应用是一个二级树&#xff0c;一级表示的是应用分组&#xff0c;二级表示的是…
阅读更多...
junit4进行单元测试

junit4进行单元测试

一、前言 提供服务的时候&#xff0c;为了保证服务的正确性&#xff0c;有时候需要编写测试类验证其正确性和可用性。以前的做法都是自己简单写一个控制层&#xff0c;然后在控制层里调用服务并测试&#xff0c;这样做虽然能够达到测试的目的&#xff0c;但是太不专业了。还是老…
阅读更多...
快速搭建springmvc+spring data jpa工程

快速搭建springmvc+spring data jpa工程

一、前言 这里简单讲述一下如何快速使用springmvc和spring data jpa搭建后台开发工程&#xff0c;并提供了一个简单的demo作为参考。 二、创建maven工程 http://www.cnblogs.com/hujunzheng/p/5450255.html 三、配置文件说明 1.application.properties jdbc.drivercom.mysql.jd…
阅读更多...
dubbo服务提供与消费

dubbo服务提供与消费

一、前言 项目中用到了Dubbo&#xff0c;临时抱大腿&#xff0c;学习了dubbo的简单实用方法。现在就来总结一下dubbo如何提供服务&#xff0c;如何消费服务&#xff0c;并做了一个简单的demo作为参考。 二、Dubbo是什么 Dubbo是一个分布式服务框架&#xff0c;致力于提供高性能…
阅读更多...
git亲测命令

git亲测命令

一、Git新建本地分支与远程分支关联问题 git checkout -b branch_name origin/branch_name 或者 git branch --set-upstream branch_name origin/branch_name 或者 git branch branch_name git branch --set-upstream-toorigin/branch_name branch_name 二、查看本地分支所关…
阅读更多...
mysql 7下载安装及问题解决

mysql 7下载安装及问题解决

mysql 7安装及问题解决 一、mysql下载 下载地址&#xff1a;https://www.mysql.com/downloads/Community (GPL) DownloadsMySQL Community Server (GPL)Windows (x86, 64-bit), ZIP ArchiveNo thanks, just start my download.二、mysql安装 解压到指定目录在mysql bin目录下打…
阅读更多...
RestTemplate发送请求并携带header信息

RestTemplate发送请求并携带header信息

1、使用restTemplate的postForObject方法 注&#xff1a;目前没有发现发送携带header信息的getForObject方法。 HttpHeaders headers new HttpHeaders(); Enumeration<String> headerNames request.getHeaderNames(); while (headerNames.hasMoreElements()) {String k…
阅读更多...
工作中常用到的命令

工作中常用到的命令

linux zip 和 unzip http://blog.csdn.net/shenyunsese/article/details/17556089 linux 查看日志 http://blog.chinaunix.net/uid-15463753-id-2943532.html linux 删除 http://www.jb51.net/LINUXjishu/179430.html linux查看末尾日志&#xff08;tail -f&#xff09; http:/…
阅读更多...
tomcat开发远程调试端口以及利用eclipse进行远程调试

tomcat开发远程调试端口以及利用eclipse进行远程调试

一、tomcat开发远程调试端口 方法1 WIN系统 在catalina.bat里&#xff1a; 　　SET CATALINA_OPTS-server -Xdebug -Xnoagent -Djava.compilerNONE -Xrunjdwp:transportdt_socket,servery,suspendn,address8899 　　Linux系统 在catalina.sh里&#xff1a; 　　CATALINA_OPTS&q…
阅读更多...
webpack+react+redux+es6开发模式

webpack+react+redux+es6开发模式

一、预备知识 node, npm, react, redux, es6, webpack 二、学习资源 ECMAScript 6入门 React和Redux的连接react-redux Redux 入门教程 redux middleware 详解 Redux研究 React 入门实例教程 webpack学习demo NPM 使用介绍 三、工程搭建 之前有写过 webpackreactes6开发模式…
阅读更多...
fiddler发送post请求

fiddler发送post请求

1.指定为 post 请求&#xff0c;输入 url Content-Type: application/x-www-form-urlencoded;charsetutf-8 request body中的参数格式&#xff1a;userNameadminicxp&userPassword123qwe!# 这种方式可以用 request.getParameter的方式来获得。 2.指定为 post 请求&#xff…
阅读更多...
基于spring注解AOP的异常处理

基于spring注解AOP的异常处理

一、前言 项目刚刚开发的时候&#xff0c;并没有做好充足的准备。开发到一定程度的时候才会想到还有一些问题没有解决。就比如今天我要说的一个问题&#xff1a;异常的处理。写程序的时候一般都会通过try...catch...finally对异常进行处理&#xff0c;但是我们真的能在写程序的…
阅读更多...
最新文章

Copyright @ 2022~2023