备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

java 调用solr服务器 实现增删改查 及高亮显示

2016-02-28 2821
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 首先有几点需要注意 客户端要调用solr服务，首先要把solr服务端工程启动，即前面文章讲的把solr下的slor.war例子放在tomcat下，进行相关配置，并启动。 （1）Exception in thread "main" org.apache.solr.client.solrj.beans.BindingException: class: class solr.PeopleBe

首先有几点需要注意

客户端要调用solr服务，首先要把solr服务端工程启动，即前面文章讲的把solr下的slor.war例子放在tomcat下，进行相关配置，并启动。

（1）Exception in thread "main" org.apache.solr.client.solrj.beans.BindingException: class: class solr.PeopleBean does not define any fields.
是因为使用实体bean添加索引时，没有在实体属性上添加 Filed注解，导致solr无法匹配
如
@Field("name")
public void setName(String name) {
this.name = name;
}

public String[] getContent() {
return content;
}

（2）org.apache.solr.client.solrj.impl.HttpSolrServer$RemoteSolrException: Expected mime type application
是因为当solr有多个core时，solrj操作时没有指定是哪个core,以下指定使用core0的数据
private final static String URL = "http://localhost:80/solr/core0";
HttpSolrServer server = new HttpSolrServer(URL);

（3）Exception in thread "main" org.apache.solr.client.solrj.beans.BindingException: Could not instantiate object of class solr.PeopleBean

是因为当QueryResponse.getBeans(PeopleBean.class);方式查询，并返回实体bean时，必须有一个空的构造方法

public PeopleBean(){//此处应该注意，当QueryResponse.getBeans(PeopleBean.class);方式查询，并返回实体bean时，必须有一个                           空的构造方法

}

（4）当明明有数据却查不到时，要注意查询的字段，是否开启了索引。即 在shema.xml中是否设置indexed="true"

<field name="id"        type="string"   indexed="true"  stored="true"  multiValued="false" required="true"/>

<field name="name"      type="text_ik"   indexed="true"  stored="false"  multiValued="false" /> 

 <field name="content"      type="text_ik"   indexed="false"  stored="true"  multiValued="true" /> 

其中 indexed="true" 表示开启索引（当字段不需要被检索时，最好不要开启索引,） stored="true"表示存储原来数据（当字段不被检索，而只是需要通过其他字段检索而获得时，要设为true）  multiValued="true" 表示返回多值，如一个返回多个content,此时要在java代码中把 content设置 集合或数组类型如 

private String[] content;//多值，对应 multiValued="true"

（5）

需要以下jar包


上面的一些jar可以从下载的solr压缩包中获得


其他的就是一些日志依赖jar如,commons-logging-1.1.1.jar,slf4j-log4j12-1.5.8.jar,log4j-1.2.14.jar

下面附上代码（注意运行代码时先把solr服务端工程启动，路径为http://localhost:80/solr/core0）

工程大概


schema.xml文件

<?xml version="1.0" ?>
<!--
 Licensed to the Apache Software Foundation (ASF) under one or more
 contributor license agreements.  See the NOTICE file distributed with
 this work for additional information regarding copyright ownership.
 The ASF licenses this file to You under the Apache License, Version 2.0
 (the "License"); you may not use this file except in compliance with
 the License.  You may obtain a copy of the License at

     http://www.apache.org/licenses/LICENSE-2.0

 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
-->

<schema name="example core zero" version="1.5">
	<fieldType name="text_ik" class="solr.TextField">
		<analyzer type="index" isMaxWordLength="false" class="org.wltea.analyzer.lucene.IKAnalyzer"/>
		<analyzer type="query" isMaxWordLength="false" class="org.wltea.analyzer.lucene.IKAnalyzer"/>
	</fieldType>
   <fieldtype name="string"  class="solr.StrField" sortMissingLast="true" omitNorms="true"/>
   <fieldType name="long" class="solr.TrieLongField" precisionStep="0" positionIncrementGap="0"/>
  <!-- general -->
  <field name="id"        type="string"   indexed="true"  stored="true"  multiValued="false" required="true"/>

  <field name="name"      type="text_ik"   indexed="true"  stored="true"  multiValued="false" /> 
   <field name="content"      type="text_ik"   indexed="true"  stored="true"  multiValued="true" /> 
  <field name="_version_" type="long"     indexed="true"  stored="true"/>

 <!-- field to use to determine and enforce document uniqueness. -->
 <uniqueKey>id</uniqueKey>

 <!-- field for the QueryParser to use when an explicit fieldname is absent -->
 <defaultSearchField>name</defaultSearchField>

 <!-- SolrQueryParser configuration: defaultOperator="AND|OR" -->
 <solrQueryParser defaultOperator="OR"/>
</schema>

实体PeopleBean 


package solr;

import java.util.List;

import org.apache.solr.client.solrj.beans.Field;

public class PeopleBean {

	private String id;
	private String name;
	private String[] content;//多值，对应 multiValued="true"
	
	
	
	public String getId() {
		return id;
	}
	@Field
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	@Field("name")
	public void setName(String name) {
		this.name = name;
	}
	
	public String[] getContent() {
		return content;
	}
	@Field
	public void setContent(String[] content) {
		this.content = content;
	}
	public PeopleBean(){//此处应该注意，当QueryResponse.getBeans(PeopleBean.class);方式查询，并返回实体bean时，必须有一个空的构造方法
		
	}
	public PeopleBean(String id, String name, String[] content) {
		this.id = id;
		this.name = name;
		this.content = content;
	}
	


	
	
}

增加 索引 SolrAdd 

package solr;

import java.io.IOException;
import java.net.MalformedURLException;
import java.util.ArrayList;
import java.util.List;

import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Test;

public class SolrAdd {

	private final static String URL = "http://localhost:80/solr/core0";
	public static void  add(){
		
		//1、创建SolrServer对象，该对象有两个可以使用，都是线程安全的
//		HttpSolrServer：启动web服务器使用的，通过http请求的
//		EmbeddedSolrServer：内嵌式的，导入solr的jar包就可以使用了
		try {
			HttpSolrServer server = new HttpSolrServer(URL);
			//把查询出来的数据全部删除
//			server.deleteByQuery("*:*");
//			server.commit();
			
			SolrInputDocument doc = new SolrInputDocument();
			//id是必填的，并且是String类型的
			//<field name="id" type="string" indexed="true" stored="true" required="true" />
			//id是唯一的主键，当多次添加的时候，最后添加的相同id会覆盖前面的域
			doc.addField("id", "5");
			doc.addField("name", "这是我的第一个solrj程序");
			doc.addField("content", "solr程序的运行");
			server.add(doc);
			server.commit();
		} catch (MalformedURLException e) {
			e.printStackTrace();
		} catch (SolrServerException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * 基于列表的添加
	 * @throws SolrServerException
	 * @throws IOException
	 */
	public static void test2() throws SolrServerException, IOException{
		List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
		SolrInputDocument doc = new SolrInputDocument();
		doc.addField("id", "7");
		doc.addField("name", "很好，solr可以工作了");
		doc.addField("content", "solr总算可以正式工作了");
		
		docs.add(doc);
		
		doc = new SolrInputDocument();
		doc.addField("id", "8");
		doc.addField("name", "测试以下solr的添加");
		doc.addField("content", "看看能不能添加一个列表信息");
		
		docs.add(doc);
		
		HttpSolrServer server = new HttpSolrServer(URL);
		server.add(docs);
		server.commit();
	}
	
	/**
	 * 基于javabean的添加
	 * @throws SolrServerException
	 * @throws IOException
	 */
	public static void test3() throws SolrServerException, IOException{
		List<PeopleBean> msgs = new ArrayList<PeopleBean>();
		//多值域的添加使用数组
		msgs.add(new PeopleBean("9","基于javabean的添加9",new String[]{"这是content9","这是dddddddddcontent9"} ));
		msgs.add(new PeopleBean("10","基于javabean的列表数据的添加10", new String[]{"solr这是content10","这是conteooooooooont10"}));
		
		HttpSolrServer server = new HttpSolrServer(URL);
		server.addBeans(msgs);
		server.commit();
	}
	public static void main(String[] args) throws Exception {
		test3();
	}
}

根据索引查询 SolrSelect，及高亮显示字符串（高亮显示实际上是给指定的字符串添加css样式） 

package solr;

import java.net.MalformedURLException;
import java.util.List;

import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;

public class SolrSelect {
	private final static String URL = "http://localhost:80/solr/core0";//注意当多core时，要指定一个core，不然会报错
	HttpSolrServer server = new HttpSolrServer(URL);
	
	/**
	 * 返回filed
	 * @throws SolrServerException
	 * @throws MalformedURLException
	 */
	public static void select() throws SolrServerException, MalformedURLException{
		HttpSolrServer server = new HttpSolrServer(URL);
		//定义查询字符串
		SolrQuery query = new SolrQuery("基于javabean的添加9");
		String s[]=query.getFilterQueries();
		//实现分页的查询
		query.setStart(0);
		query.setRows(3);
		QueryResponse res = server.query(query);
		//查询出来的结果都保存在SolrDocumentList中
		SolrDocumentList sdl = res.getResults();
		System.out.println("总数："+sdl.getNumFound());
		for(SolrDocument sd : sdl){
			System.out.println(sd.get("id")+"#"+sd.get("name")+"#"+sd.get("content"));
		}
	}
	
	/**
	 * 返回bean
	 * @throws MalformedURLException
	 * @throws SolrServerException
	 */
	public static void select2() throws MalformedURLException, SolrServerException{
		HttpSolrServer server = new HttpSolrServer(URL);
		//相当于QueryParser
		SolrQuery query = new SolrQuery("*:*");
		query.setStart(1);
		query.setRows(3);
		QueryResponse res = server.query(query);
		//可以直接查询相应的bean对象，但是不是很常用
		//使用这种方式无法获取总数量
		List<PeopleBean> list = res.getBeans(PeopleBean.class);
		System.out.println("当前总数："+list.size());
		for(PeopleBean msg : list){
			System.out.println(msg.getId()+"#"+msg.getName()+"#"+msg.getContent());
		}
	}
	
	/**
	 * 高亮显示
	 * @throws SolrServerException
	 * @throws MalformedURLException
	 */
	 public static void color() throws SolrServerException, MalformedURLException{  
		 HttpSolrServer server = new HttpSolrServer(URL);
	        SolrQuery query = new SolrQuery("name:基于"); //高亮字符:基于
	        query.setHighlight(true).setHighlightSimplePre("<span class='red'>").setHighlightSimplePost("</span>")  
	        .setStart(0).setRows(10);  
	        //hl.fl表示高亮的field，也就是高亮的区域  
	        query.setParam("hl.fl","name","content");  //显示高亮的字段
	        QueryResponse res = server.query(query);  
	          
	        SolrDocumentList sdl = res.getResults();  
	        System.out.println("总数："+sdl.getNumFound());  
	        for(SolrDocument sd : sdl){  
//	          System.out.println(sd.get("id")+"#"+sd.get("msg_title")+"#"+sd.get("msg_content"));  
	            String id = (String) sd.get("id");  
	            //在solr这里对需要加高亮的字段必须要在索引中的store=true才行  
	            System.out.println(id+"#"+res.getHighlighting().get(id).get("name"));;  
	              
	        }  
	    }  
	public static void main(String[] args) throws Exception {
		select2();
	}

}

删除 SolrDelete 

package solr;

import org.apache.solr.client.solrj.impl.HttpSolrServer;

public class SolrDelete {
	private final static String URL = "http://localhost:80/solr/core0";
	 static HttpSolrServer solrServer = new HttpSolrServer(URL);
	 /**
	  * 根据id删除
	  * @param id
	  */
	 public static void deleteById(String id) {
	        try {
	        	
	            solrServer.deleteById(id+"");
	            solrServer.commit();
	        } catch (Exception e) {
	        	 System.out.println("错误");
	        }
	    }
	    
	    /**
	     * 删除所有文档，为安全起见，使用时再解注函数体 。
	     */
	    public static void deleteAll() {
	        try {
	            solrServer.deleteByQuery("*:*");
	            solrServer.commit();
	        } catch (Exception e) {
	            System.out.println("错误");
	        }
	    }
	public static void main(String[] args) {
		//deleteById("1");
		deleteAll();
	}
}

修改 SolrUpdate (修改实际上还是增加索引，只不过指定id，把相同id的filed覆盖掉) 


package solr;

import java.io.IOException;
import java.net.MalformedURLException;

import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;

public class SolrUpdate {
	private final static String URL = "http://localhost:80/solr/core0";
public static void  update(){
		try {
			HttpSolrServer server = new HttpSolrServer(URL);
			SolrInputDocument doc = new SolrInputDocument();
			doc.addField("id", "5");
			doc.addField("name", "这是我的第一个solrj程序");
			doc.addField("content", "solr程序的运行");
			server.add(doc);
			server.commit();
		} catch (MalformedURLException e) {
			e.printStackTrace();
		} catch (SolrServerException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
		update();//更新其实是覆盖id=**的filed
		
	}

}


注意先启动solr服务端，服务端启动后先http://localhost:80/solr/看看是否启动成功,

启动成功后的界面。


文章标签：
Java
索引
Apache
前端开发
应用服务中间件
安全
数据格式
存储
XML
关键词：
java云服务器 ECS
Java增删改查
Java服务器
云服务器 ECSjava
Java实现
lhyxcxy
目录
相关文章
骚戴
|
1月前
|
Java 数据库 Android开发
不同主题增删改查系统【纯控制台】（Java课设）
不同主题增删改查系统【纯控制台】（Java课设）
骚戴
15 1
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（IDeptService.java）
Servlet使用适配器模式进行增删改查案例（IDeptService.java）
穆雄雄.
15 0
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（EmpDaoImpl.java）
Servlet使用适配器模式进行增删改查案例（EmpDaoImpl.java）
穆雄雄.
14 0
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（DeptDaoImpl.java）
Servlet使用适配器模式进行增删改查案例（DeptDaoImpl.java）
穆雄雄.
13 0
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（IDeptDao.java和IEmpDao.java）
Servlet使用适配器模式进行增删改查案例（IDeptDao.java和IEmpDao.java）
穆雄雄.
14 0
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（IBaseDaoUtil.java）
Servlet使用适配器模式进行增删改查案例（IBaseDaoUtil.java）
穆雄雄.
21 0
洛神灬殇
|
2月前
|
存储 监控 Java
【深度挖掘Java性能调优】「底层技术原理体系」深入探索Java服务器性能监控Metrics框架的实现原理分析（Counter篇)
【深度挖掘Java性能调优】「底层技术原理体系」深入探索Java服务器性能监控Metrics框架的实现原理分析（Counter篇)
洛神灬殇
28 0
洛神灬殇
|
2月前
|
监控 算法 Java
【深度挖掘Java性能调优】「底层技术原理体系」深入探索Java服务器性能监控Metrics框架的实现原理分析（Gauge和Histogram篇)
【深度挖掘Java性能调优】「底层技术原理体系」深入探索Java服务器性能监控Metrics框架的实现原理分析（Gauge和Histogram篇)
洛神灬殇
32 0
穆雄雄.
|
2月前
Servlet使用适配器模式进行增删改查案例（IEmpService.java）
Servlet使用适配器模式进行增删改查案例（IEmpService.java）
穆雄雄.
14 0
cuicuicuic
|
3天前
|
弹性计算 运维 Java
Serverless 应用引擎产品使用之在Serverless 应用引擎中，将 Java 应用从 ECS 迁移到 SAE如何解决
阿里云Serverless 应用引擎（SAE）提供了完整的微服务应用生命周期管理能力，包括应用部署、服务治理、开发运维、资源管理等功能，并通过扩展功能支持多环境管理、API Gateway、事件驱动等高级应用场景，帮助企业快速构建、部署、运维和扩展微服务架构，实现Serverless化的应用部署与运维模式。以下是对SAE产品使用合集的概述，包括应用管理、服务治理、开发运维、资源管理等方面。
cuicuicuic
30 2

热门文章

最新文章

  • 1
    Java中的多线程编程：概念、实现与性能优化
  • 2
    使用Redis进行Java缓存策略设计
  • 3
    Java语言开发的AI智慧导诊系统源码springboot+redis 3D互联网智导诊系统源码
  • 4
    基于 java + Springboot + vue +mysql 大学生实习管理系统（含源码）
  • 5
    Java 中文官方教程 2022 版（二十九）（2）
  • 6
    使用Java代码打印log日志
  • 7
    Java 中文官方教程 2022 版（二十八）（1）
  • 8
    Java 中文官方教程 2022 版（十四）（1）
  • 9
    Java 中文官方教程 2022 版（九）（2）
  • 10
    深入理解Java并发编程：线程安全与性能优化
  • 1
    实验目的1.编译安装httpd2.优化路径3.并将鲜花网站上传到web服务器为网页目录4.在客户机访问网站http://www.bdqn.com
    165
  • 2
    服务器数据恢复—存储互斥不当导致VMFS卷损坏的数据恢复案例
    754
  • 3
    ECS性能优化建议
    182
  • 4
    阿里云ECS云监控界面
    799
  • 5
    2024年阿里云服务器租用详细价格表（CPU/内存/带宽/系统盘）
    914
  • 6
    手把手教你入门部署幻兽帕鲁服务器：2024年阿里云搭建幻兽帕鲁Palworld联机服务器新手教程
    1092
  • 7
    2024年阿里云上自建Palworld/幻兽帕鲁服务器教程
    1418
  • 8
    2024年阿里云一键搭建部署幻兽帕鲁服务器解决方案
    1458
  • 9
    视觉智能平台常见问题之服务部署在pdd的服务器上调用会报错如何解决
    178
  • 10
    阿里云第八代云服务器实例通用型g8i实例性能和适用场景介绍
    403

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 使用阿里云ECS监控您的特斯拉
  • 使用阿里云ECS安装家用内网穿透服务
  • ECS实例选型最佳实践
  • ECS服务保活和宕机启动
  • 云原生场景自动化响应ECS系统事件
  • 幻兽帕鲁联机服务快速部署【有ECS用户】
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考