Solr配置中文分词器IKAnalyzer及增删改查调用-程序员宅基地

一、配置IKAnalyzer中文分词器

Solr 版本5.2.1

IKAnalyzer2012_u6.jar报错 ,用IKAnalyzer2012_FF_hf1.jar 替换可解决

解决lucene4.0与IKAnalyzer的冲突。解决Exception in thread "main" java.lang.VerifyError: class org.wltea.analyzer.lucene.IKAnalyzer overrides final method tokenStream.(Ljava/lang/String;Ljava/io/Reader;)Lorg/apache/lucene/analysis/TokenStream;原因IKAnalyzer中参考手册中的例子是使用的lucene3.4，与4.0已经是不兼容了。使用IKAnalyzer2012_FF_hf1.jar可以解决问题

java.lang.AbstractMethodError

Caused by: java.lang.AbstractMethodError
	at org.apache.lucene.analysis.Analyzer.tokenStream(Analyzer.java:179)

lucene版本跟IK分词版本不一致导致，这块版本一定要对应上

由于solr版本较高暂时无法解决

         <field name="messageId" type="string" indexed="true" stored="true" required="true" multiValued="false"/>
        <field name="msg_title" type="text_ik" stored="true" indexed="true"/>
        <field name="msg_content" type="text_ik" stored="true" indexed="true" multiValued="true"/>
        <uniqueKey>messageId</uniqueKey>
        
           <!-- IKAnalyzer 中文分词-->
    <fieldType name="text_ik" class="solr.TextField">
       <analyzer type="index" class="org.wltea.analyzer.lucene.IKAnalyzer" />
       <analyzer type="query" class="org.wltea.analyzer.lucene.IKAnalyzer" />
    </fieldType>

二、添加、删除、查询索引

需要除了solr相关包还需要下面的jar包

Message.java

package org.itat.lucene.solr.test;

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

public class Message {
    
    

    private String messageId;
    private String title;
    private String[] content;
    
    
    public Message() {
        super();
    }

    public Message(String messageId, String title, String[] content) {
        super();
        this.messageId = messageId;
        this.title = title;
        this.content = content;
    }

    public String getMessageId() {
        return messageId;
    }

    @Field
    public void setMessageId(String messageId) {
        this.messageId = messageId;
    }
    public String getTitle() {
        return title;
    }
    
    @Field("msg_title")
    public void setTitle(String title) {
        this.title = title;
    }
    public String[] getContent() {
        return content;
    }
    
    @Field("msg_content")
    public void setContent(String[] content) {
        this.content = content;
    }
}

增删改查demo

package org.itat.lucene.solr.test;

import java.io.IOException;
import java.net.MalformedURLException;
import java.util.ArrayList;
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.CloudSolrServer;
import org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrServer;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.client.solrj.response.UpdateResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Before;
import org.junit.Test;

public class SolrTest {
    private final static String URL = "http://localhost:8080/solr/mail";
    private HttpSolrServer server = null;
    
    @Before
    public void init() {
        server = new HttpSolrServer(URL);
    }

    
    @Test
    public void addOneOrDelete() {
        
    /*HttpSolrServer server=new HttpSolrServer(URL);*/
    /*ConcurrentUpdateSolrServer cs=new ConcurrentUpdateSolrServer(URL,1,1);
     *新版已被ConcurrentUpdateSolrClient取代
     * */
    /*CloudSolrServer css=new CloudSolrServer("192.168.0.1");//zookeeper地址
     *已被CloudSolrClient
     */        
    
    HttpSolrClient server= new HttpSolrClient(URL);//新版已经取代了HttpSolrServer
    
        SolrInputDocument doc = new SolrInputDocument();
        //id是唯一的主键，当多次添加的时候，最后添加的相同id的域会覆盖前面的域
        doc.addField("messageId","3");
        doc.addField("msg_title", "这是我的第一个solrj的程序");
        doc.addField("msg_content","我的solrj的程序究竟能不能跑得起来呢？");
        try {
            UpdateResponse ur=server.add(doc);
            System.out.println(ur);
            
            /*server.deleteByQuery("*:*");*/
            server.commit(null,true,true,false);
                    server.close();
        } catch (SolrServerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    
    //一下添加多个
    @Test
    public void addList() {
        try {
            List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
            SolrInputDocument doc = new SolrInputDocument();
            doc.addField("messageId", "2");
            doc.addField("msg_title", "很好！solr可以工作了");
            doc.addField("msg_content","slor总算可以正式工作了");
            docs.add(doc);
            doc = new SolrInputDocument();
            doc.addField("messageId", "3");
            doc.addField("msg_title", "测试一下solr的添加");
            doc.addField("msg_content","看看能不能添加一个列表信息");
            docs.add(doc);
            server.add(docs);
            server.commit();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    
    //基于java bean的添加
    @Test
    public void addBean() {
        try {
            List<Message> msgs = new ArrayList<Message>();
            msgs.add(new Message("4","基于java bean的添加",
                     new String[]{"通过java bean完成添加","java bean的添加附件"}));
            msgs.add(new Message("5","基于java bean的列表数据的添加",
                     new String[]{"测试如何通过一个对象完成添加","通过对象完成添加的附件"}));
            server.addBeans(msgs);
            server.commit();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    //查询
    @Test
    public void test04() {
        try {
            //定义查询字符串
            SolrQuery query = new SolrQuery("*");
            query.setStart(0);
            query.setRows(5);
            QueryResponse resp=null;
            try {
                resp = server.query(query);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            //查询出来的结果都保存在SolrDocumentList中
            SolrDocumentList sdl = resp.getResults();
            System.out.println(sdl.getNumFound());
            for(SolrDocument sd:sdl) {
//                System.out.println(sd);
                System.out.println(sd.getFieldValue("msg_title")+","+sd.getFieldValue("msg_content"));
            }
        } catch (SolrServerException e) {
            e.printStackTrace();
        }
    }
    
    
    //基于javabean查询
    @Test
    public void test05() {
        try {
            SolrQuery query = new SolrQuery("*");
            query.setStart(0);
            query.setRows(5);
            QueryResponse resp=null;
            try {
                resp = server.query(query);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            //可以直接查询相应的bean对象，但是不是很常用,无法得到查询总条数
            List<Message> list = resp.getBeans(Message.class);
            System.out.println(list.size());
            for(Message msg:list) {
                System.out.println(msg.getTitle());
            }
        } catch (SolrServerException e) {
            e.printStackTrace();
        }
    }
    
    //高亮
    @Test
    public void test06() {
        try {
            SolrQuery query = new SolrQuery("msg_content:测试 OR msg_title:测试");
            query.setHighlight(true).setHighlightSimplePre("<span class='highligter'>")
                                .setHighlightSimplePost("</span>")
                                .setStart(0).setRows(5);
            query.setParam("hl.fl", "msg_title,msg_content");
            QueryResponse resp=null;
            try {
                resp = server.query(query);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            //查询出来的结果都保存在SolrDocumentList中
            SolrDocumentList sdl = resp.getResults();
            System.out.println(sdl.getNumFound());
            for(SolrDocument sd:sdl) {
                String id = (String)sd.getFieldValue("messageId");
                System.out.println(resp.getHighlighting().get(id).get("msg_content"));
                //高亮结果以唯一索引为key
            }
        } catch (SolrServerException e) {
            e.printStackTrace();
        }
    }
}

转载于:https://blog.51cto.com/tianxingzhe/1753167

本文链接：https://blog.csdn.net/weixin_34211761/article/details/91828193

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

OpenStack之keystone（身份认证服务）_openstack中最重要的身份服务是什么?是如何运作的?-程序员宅基地

文章浏览阅读5.3k次。keystone概述概念Keystone (OpenStack ldentity Service）是OpenStack中的一个独立的提供安全认证的模块，主要负责openstack用户的身份认证、令牌管理、提供访问资源的服务目录、以及基于用户角色的访问控制。Keystone类似一个服务总线，或者说是整个Openstack框架的注册表,其他服务通过keystone来注册其服务的Endpoint(服务访问的URL)，任何服务之间相互的调用，需要经过Keystone的身份验证，来获得目标服务的Endpoi_openstack中最重要的身份服务是什么?是如何运作的?

Vuejs2.0开发仿QQ音乐webpp案例分析-程序员宅基地

文章浏览阅读2.1k次。仿QQ音乐webapp是基于Vue2.0，vuex，vue-router，axios和html5的flexible box布局与及css3的transform，animation，transition组成。Vuejs是一套MVVM框架，主要注重于view层，实现数据双向绑定与及虚拟DOM，解放你的双手，让你不用直接和真实的DOM进行操作，只要数据改变，vue自动检查DOM结构不同，更新DOM元素..._webpp

实现多模交互融合的四个阶段-程序员宅基地

文章浏览阅读2.9k次。多模交互融合是普适计算和自然交互中最重要的组成部分。笔者认为，实现完整的多模交互融合需要分成四个阶段，分别为独立工作阶段、初步融合阶段、语义理解阶段和任务自适应阶段。01独立工作阶段各自..._多模态融合阶段

C++设计模式-建造者模式-程序员宅基地

文章浏览阅读5.2k次，点赞23次，收藏25次。目录基本概念代码与实例基本概念建造者模式（Builder）：将一个复杂对象的构建与它的表示分离，使得同样的构建过程可以创建不同的表示。建造者模式是在当创建复杂对象的算法应该独立于该对象的组成部分以及它们装配方式时适用的模式。下面给出一个UML实例：代码与实例程序运行截图如下：源码如下：Head.h#include ..._建造者模式

苹果手机怎么录屏苹果录屏方法步骤详解-程序员宅基地

文章浏览阅读1.3w次。苹果手机使用的是ios苹果系统，在操作上与传统的安卓手机相比会有一定差异，因此一些刚使用苹果手机的网友会不清楚一些基础功能的使用方法，比如苹果手机录屏等。2、需要录屏的时候直接打开控制中心，点击屏幕录制图标，倒计时3秒之后开始录屏，想要结束录屏直接点击左上方的红色区域，然后点击停止即可，录制的视频就自动保存到相册中了。我们还可以使用第三方的工具进行苹果手机录屏，而且体验更多更丰富的功能。3、这些都设置好之后就可以开始录屏，在录屏开始前可以开启摇一摇结束录屏的功能，想要结束录屏的时候只需要晃动手机就可以。_苹果手机怎么录屏

error: resource android:attr/fontVariationSettings not found. (flutter项目解决方案)-程序员宅基地

文章浏览阅读3.1k次。原因：是编译的targer SDK版本过低（support v7-28.0.0会包这个问题）纯android项目只需要修改build.gradle中 compileSdkVersion 版本>=28。flutter项目，稍微有些不一样。flutter用的一些插件有些compileSdkVersion需要单独改。这是我的错误，如下：FAILURE: Build failed with an exception. ..._error: resource android:attr/fontvariationsettings not found.

随便推点

微软Windows操作系统全面兼容机器人操作系统ROS1和ROS2_ros2_java for windows-程序员宅基地

文章浏览阅读7.4k次，点赞4次，收藏10次。微软Windows操作系统全面兼容机器人操作系统ROS1和ROS2turtlebot2：https://github.com/bfjelds/turtlebot2-win10文档：https://libraries.io/github/bfjelds/turtlebot2-win10安装在/opt/ros/melodic/x64文件夹下，依据如下教程即可安装成功。ROS..._ros2_java for windows

qt 子窗口向父窗口发送信息_qt中对话框返回信息给父页面-程序员宅基地

文章浏览阅读4.3k次，点赞7次，收藏20次。场景：点击父窗口按钮1，弹出子窗口。点击子窗口查询按钮，隐藏子窗口并把查询结果显示在父窗口上。参考文献Qt实例–主窗口和子窗口互发信号简化需求为：子窗口点击按钮，向父窗口发送消息，并显示在子窗口上：子窗口 DatasetQueryConditionWgt.h要定义两个函数：点击按钮，发送信号的槽函数SlotQueryBtnClicked()，注意带上slots发送信息的函数 SignalQueryConditionBtnClicked(QVariantMap m_queryCondition)_qt中对话框返回信息给父页面