Java调用solrj5.5.3接口,查询数据

简介:

前期准备

搭建solr服务

参考上一篇,搭建solr搜索服务。

添加依赖

maven工程的话,添加如下依赖,

<!-- https://mvnrepository.com/artifact/org.apache.solr/solr-solrj -->
<dependency>
    <groupId>org.apache.solr</groupId>
    <artifactId>solr-solrj</artifactId>
    <version>5.5.3</version>
</dependency>

也可以自己导入jar包

在solr安装目录下,找到solr-5.5.3\dist\solrj-lib路径,添加里面所有的jar包到自己的工程,别忘了在外面的文件夹还有个solr-solrj-5.5.3.jar包,一起拷贝。

编写调用代码

这里简单给个示例(包含分页),Spring mvc工程的:

复制代码
    @ResponseBody
    @RequestMapping(value = "/searchByKeyWord", method =
    { RequestMethod.GET }, produces = "application/json; charset=utf-8")
    @ApiOperation(value = "搜索接口", notes = "", httpMethod = "GET")
    public BaseResponse<Map<String, Object>> search(HttpServletRequest request,
        HttpServletResponse response,
        @RequestParam(value = "keyWord", defaultValue = "") String keyWord,
        @RequestParam(value = "pageSize", defaultValue = "10") long pageSize,
        @RequestParam(value = "pageOffset", defaultValue = "0") long pageOffset)
    {
        System.out.println(pageSize + "," + pageOffset);
        try
        {
            SolrClient solr = new HttpSolrClient(solrServiceUrl);
            SolrQuery query = new SolrQuery();
            String kw = URLDecoder.decode(keyWord, "UTF-8");
            query.set("q", "title:" + kw + " and content:" + kw);
            query.set("start", String.valueOf(pageOffset * pageSize));
            query.set("rows", String.valueOf(pageSize));
            query.addHighlightField("content");
            query.setHighlight(true).setHighlightSnippets(1);
            query.setParam("hl.fl", "title,content");
            query.setHighlightFragsize(300);
            QueryResponse queryResponse = solr.query(query);
            Map<String, Map<String, List<String>>> highlightMap = queryResponse.getHighlighting();
            Map<String, Object> result = new HashMap<String, Object>();
            List<SearchModel> rstList = queryResponse.getBeans(SearchModel.class);
            for (SearchModel obj : rstList)
            {
                Map<String, List<String>> hiStr = highlightMap.get(obj.getUrl());
                List<String> contentList = hiStr.get("content");
                if (contentList != null && contentList.size() > 0)
                    obj.setContentHighlight(contentList.get(0));
                List<String> titleList = hiStr.get("title");
                if (titleList != null && titleList.size() > 0)
                    obj.setTitleHighlight(titleList.get(0));
            }
            result.put("success", true);
            result.put("key", URLDecoder.decode(keyWord, "UTF-8"));
            result.put("list", rstList);
            result.put("totalCount", queryResponse.getResults().getNumFound());
            solr.close();
            return BaseResponse.buildSuccessResponse(result);
        }
        catch (Exception e)
        {
            LOGGER.error(e.toString(), e);
            return BaseResponse
                .buildFailResponse(HttpStatus.INTERNAL_SERVER_ERROR.value(), "搜索异常.");
        }

    }
复制代码

以下是SearchModel类,注意要与data-config.xml配置的字段对应起来,还有就是不要忘了在字段前面加上@Field注解(org.apache.solr.client.solrj.beans.Field)。

复制代码
package com.cetiti.eppsas.model;

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

public class SearchModel
{
    private String origin;
    private String title;
    private String content;
    private String linkUrl;
    private String keyWord;
    private long postTime;
    private String url;
    private String titleHighlight;
    private String contentHighlight;

    /**
     * @return the origin
     */
    public String getOrigin()
    {
        return origin;
    }

    /**
     * @param origin the origin to set
     */
    @Field("origin")
    public void setOrigin(String origin)
    {
        this.origin = origin;
    }

    /**
     * @return the title
     */
    public String getTitle()
    {
        return title;
    }

    /**
     * @param title the title to set
     */
    @Field("title")
    public void setTitle(String title)
    {
        this.title = title;
    }

    /**
     * @return the content
     */
    public String getContent()
    {
        return content;
    }

    /**
     * @param content the content to set
     */
    @Field("content")
    public void setContent(String content)
    {
        this.content = content;
    }

    /**
     * @return the linkUrl
     */
    public String getLinkUrl()
    {
        return linkUrl;
    }

    /**
     * @param linkUrl the linkUrl to set
     */
    @Field("linkUrl")
    public void setLinkUrl(String linkUrl)
    {
        this.linkUrl = linkUrl;
    }

    /**
     * @return the keyWord
     */
    public String getKeyWord()
    {
        return keyWord;
    }

    /**
     * @param keyWord the keyWord to set
     */
    @Field("keyWord")
    public void setKeyWord(String keyWord)
    {
        this.keyWord = keyWord;
    }



    /**
     * @return the url
     */
    public String getUrl()
    {
        return url;
    }

    /**
     * @param url the url to set
     */
    @Field("url")
    public void setUrl(String url)
    {
        this.url = url;
    }



    /**
     * @return the postTime
     */
    public long getPostTime()
    {
        return postTime;
    }

    /**
     * @param postTime the postTime to set
     */
    @Field("postTime")
    public void setPostTime(long postTime)
    {
        this.postTime = postTime;
    }

    /**
     * @return the titleHighlight
     */
    public String getTitleHighlight()
    {
        return titleHighlight;
    }

    /**
     * @param titleHighlight the titleHighlight to set
     */
    public void setTitleHighlight(String titleHighlight)
    {
        this.titleHighlight = titleHighlight;
    }

    /**
     * @return the contentHighlight
     */
    public String getContentHighlight()
    {
        return contentHighlight;
    }

    /**
     * @param contentHighlight the contentHighlight to set
     */
    public void setContentHighlight(String contentHighlight)
    {
        this.contentHighlight = contentHighlight;
    }

}
复制代码

前端示例

其它的根据业务需求具体扩展吧,在前端可以对查询到的数据进行一些自定义展示(关键字标红高亮,每条记录分类,点击跳转到记录详情页面)。


本文转自风一样的码农博客园博客,原文链接:http://www.cnblogs.com/chenpi/p/6055061.html,如需转载请自行联系原作者

相关文章
|
19天前
|
Java
Java——抽象类和接口
抽象类是一种不能被实例化的类,至少包含一个抽象方法(无实现体的方法),常用于定义一组相关类的共同特征,并强制子类实现特定方法。抽象方法不能被 `static` 或 `final` 修饰,且必须被重写。 接口则是一个完全抽象的类,用于规范类的行为。接口使用 `interface` 关键字定义,不能实例化,并且类与接口之间是实现关系。 内部类是在一个类内定义的类,分为成员内部类、静态内部类、局部内部类和匿名内部类。成员内部类可被修饰符修饰,静态内部类只能访问外部类的静态成员,局部内部类定义在方法内,匿名内部类则隐藏了名字,直接通过 `new` 关键字定义并实现接口或继承类。
14 5
Java——抽象类和接口
|
19天前
|
Java
Java——接口的使用实例
Comparable接口用于自定义类的对象比较。通过实现此接口并重写`compareTo`方法,可以定义自定义类型的比较规则。 接下来介绍了Comparator接口,它提供了一种更灵活的比较方式。通过实现Comparator接口并重写`compare`方法,可以根据不同属性定义不同的比较规则。例如,定义一个`BrandComparator`类来比较汽车的品牌。 最后,介绍了Cloneable接口,用于实现对象的克隆。实现该接口并重写`clone`方法后,可以创建对象的浅拷贝或深拷贝。浅拷贝仅复制对象本身,深拷贝则会递归复制所有成员变量。
15 4
Java——接口的使用实例
|
4天前
|
SQL Java
使用java在未知表字段情况下通过sql查询信息
使用java在未知表字段情况下通过sql查询信息
11 1
|
4天前
|
Java 测试技术
Java接口的生产环境应用注意点
在Java生产环境中,合理使用接口对提升代码质量至关重要。设计接口时应遵循单一职责原则,采用清晰命名,并控制方法数量。默认方法应谨慎使用,避免与实现类产生冲突。通过版本化管理接口更新,确保向后兼容。实现接口时需明确行为,保持实现与接口分离,利用多态增强灵活性。关注性能影响,适当文档注释及充分测试确保接口稳定可靠。综合运用这些策略,可以显著提高系统的可扩展性和维护性。
|
4天前
|
Java
Java 接口的简化理解
Java 接口是一种强大的概念,用于定义方法签名而非具体实现,作为行为规范,强调功能而非实现细节。接口是特殊的引用类型,包含常量和方法签名。其特点包括:无实现方法体、支持多重继承、内置常量定义。通过示例展示了如何定义和实现接口,以及如何通过接口引用调用实现类的方法。接口的应用场景包括抽象化、插件架构和松耦合设计。从 Java 8 起,接口还支持默认方法和静态方法,进一步增强了其灵活性和扩展性。理解接口是 Java 编程的基础之一。
|
6天前
|
安全 Java 开发者
Java修饰符与封装:理解访问权限、行为控制与数据隐藏的重要性
Java中的修饰符和封装概念是构建健壯、易维护和扩展的Java应用程序的基石。通过合理利用访问权限修饰符和非访问修饰符,开发者能够设计出更加安全、灵活且高效的代码结构。封装不仅是面向对象编程的核心原则之一,也是提高软件项目质量和可维护性的关键策略。
10 1
|
5天前
|
Java
接口和抽象类【Java面向对象知识回顾②】
本文讨论了Java中抽象类和接口的概念与区别。抽象类是不能被实例化的类,可以包含抽象和非抽象方法,常用作其他类的基类。接口是一种纯抽象类型,只包含抽象方法和常量,不能被实例化,且实现接口的类必须实现接口中定义的所有方法。文章还比较了抽象类和接口在实现方式、方法类型、成员变量、构造方法和访问修饰符等方面的不同,并探讨了它们的使用场景。
接口和抽象类【Java面向对象知识回顾②】
|
13天前
|
Java
领略Lock接口的风采,通过实战演练,让你迅速掌握这门高深武艺,成为Java多线程领域的武林盟主
领略Lock接口的风采,通过实战演练,让你迅速掌握这门高深武艺,成为Java多线程领域的武林盟主
22 7
|
9天前
|
JSON 前端开发 JavaScript
java中post请求调用下载文件接口浏览器未弹窗而是返回一堆json,为啥
客户端调接口需要返回另存为弹窗,下载文件,但是遇到的问题是接口调用成功且不报错,浏览器F12查看居然返回一堆json,而没有另存为弹窗; > 正确的效果应该是:接口调用成功且浏览器F12不返回任何json,而是弹窗另存为窗口,直接保存文件即可。
35 2
|
25天前
|
Java 数据库连接 数据库
Java服务提供接口(SPI)的设计与应用剖析
Java SPI提供了一种优雅的服务扩展和动态加载机制,使得Java应用程序可以轻松地扩展功能和替换组件。通过合理的设计与应用,SPI可以大大增强Java应用的灵活性和可扩展性。
48 18
下一篇
无影云桌面