springboot和solr结合测试使用

首先新建springboot项目

新建webapp目录

springboot没有webapp目录——手动添加

web.xml

 <?xml version="1.0" encoding="UTF-8"?>

 <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"

          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

          xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"

          version="4.0">

     <display-name>Archetype Created Web Application</display-name>

     <filter>

         <filter-name>encodingFilter</filter-name>

         <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>

         <init-param>

             <param-name>encoding</param-name>

             <param-value>UTF-8</param-value>

         </init-param>

         <init-param>

             <param-name>forceEncoding</param-name>

             <param-value>true</param-value>

         </init-param>

     </filter>

     <filter-mapping>

         <filter-name>encodingFilter</filter-name>

         <url-pattern>/*</url-pattern>

     </filter-mapping>

     <listener>

         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

     </listener>

     <listener>

         <listener-class>org.springframework.web.util.IntrospectorCleanupListener</listener-class>

     </listener>

     <servlet>

         <servlet-name>SpringMVC</servlet-name>

         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

         <init-param>

             <param-name>contextConfigLocation</param-name>

             <param-value>classpath:spring-mvc.xml</param-value>

         </init-param>

         <load-on-startup>1</load-on-startup>

         <async-supported>true</async-supported>

     </servlet>

     <servlet-mapping>

         <servlet-name>SpringMVC</servlet-name>

         <url-pattern>/</url-pattern>

     </servlet-mapping>

     <welcome-file-list>

         <welcome-file>/index</welcome-file>

     </welcome-file-list>

 </web-app>

spring-mvc.xml

 <?xml version="1.0" encoding="UTF-8"?>

 <beans xmlns="http://www.springframework.org/schema/beans"

        xmlns:mvc="http://www.springframework.org/schema/mvc"

        xmlns:aop="http://www.springframework.org/schema/aop"

        xmlns:tx="http://www.springframework.org/schema/tx"

        xmlns:context="http://www.springframework.org/schema/context"

        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

        xsi:schemaLocation="http://www.springframework.org/schema/beans

                         http://www.springframework.org/schema/beans/spring-beans-3.2.xsd

                         http://www.springframework.org/schema/mvc

                         http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd

                         http://www.springframework.org/schema/context

                         http://www.springframework.org/schema/context/spring-context-3.2.xsd

                         http://www.springframework.org/schema/aop

                         http://www.springframework.org/schema/aop/spring-aop-3.2.xsd

                         http://www.springframework.org/schema/tx

                         http://www.springframework.org/schema/tx/spring-tx-3.2.xsd">

     <!-- 把Controller交给spring管理 -->

     <context:component-scan base-package="com.xiaostudy"/>

     <!-- 配置注解处理器映射器 功能：寻找执行类Controller -->

     <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping"/>

     <!-- 配置注解处理器适配器 功能：调用controller方法，执行controller -->

     <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter"/>

     <!-- 不用了 -->

     <!-- 配置sprigmvc视图解析器：解析逻辑试图

          后台返回逻辑试图：index

         视图解析器解析出真正物理视图：前缀+逻辑试图+后缀====/WEB-INF/index.jsp -->

     <!--<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">

         <property name="prefix" value="/WEB-INF/"/>

         <property name="suffix" value=".jsp"/>

     </bean>-->

 </beans>

application.yml

 spring:

   application:

     name: solr

   data:

     solr:

       host: http://127.0.0.1:8983/solr/test  # test是core的名字，一定需要

 server:

   port: 8081 # springboot项目启动的端口号

base：User.java

 package com.xiaostudy.solr_test1.base;

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

 import java.io.Serializable;

 /**

  * Created with IntelliJ IDEA.

  * User: Administrator

  * Date: 2019/6/2

  * Time: 11:10

  * Description: No Description

  */

 public class User implements Serializable {

     //必须实现可序列化接口，要在网络上传输

     @Field("user_id")//使用这个注释，里面的名字是根据你在solr数据库中配置的来决定

     private String id;

     @Field("user_name")

     private String name;

     @Field("user_sex")

     private String sex;

     @Field("user_address")

     private String address;

     public String getId() {

         return id;

     }

     public void setId(String id) {

         this.id = id;

     }

     public String getName() {

         return name;

     }

     public void setName(String name) {

         this.name = name;

     }

     public String getSex() {

         return sex;

     }

     public void setSex(String sex) {

         this.sex = sex;

     }

     public String getAddress() {

         return address;

     }

     public void setAddress(String address) {

         this.address = address;

     }

 }

controller：SolrController.java

package com.xiaostudy.solr_test1.web.controller;

import com.xiaostudy.solr_test1.base.User;

import org.apache.solr.client.solrj.SolrClient;

import org.apache.solr.client.solrj.SolrQuery;

import org.apache.solr.client.solrj.SolrServerException;

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.util.NamedList;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import java.io.IOException;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;

import java.util.Map;

/**

 * Created with IntelliJ IDEA.

 * User: Administrator

 * Date: 2019/6/2

 * Time: 11:14

 * Description: No Description

 */

@RestController

public class SolrController {

    @Autowired

    private SolrClient solrClient;

    //批量增加

    @RequestMapping("/addUsers")

    public void addUsers() throws IOException, SolrServerException {

        List<User> users = new ArrayList<>();

        for(int i = 0; i < 3; i++) {

            User user = new User();

            user.setId("123456_" + i);

            user.setName("xiaostudy_" + i);

            user.setAddress("广州_" + i);

            user.setSex("男_" + i);

            users.add(user);

        }

        solrClient.addBeans(users);

        solrClient.commit();

    }

    //单个增加

    @RequestMapping("/addUser")

    public void addUser() throws IOException, SolrServerException {

        User user = new User();

        user.setId("45678");

        user.setName("张三");

        user.setAddress("北京市");

        user.setSex("女");

        solrClient.addBean(user);

        solrClient.commit();

    }

    //根据id查询

    @RequestMapping("/getByIdFromSolr/{id}")

    public  void getByIdFromSolr(@PathVariable("id") String id) throws IOException, SolrServerException {

        //根据id查询内容

        SolrDocument solrDocument = solrClient.getById(id);

        //获取filedName

        Collection<String> fieldNames = solrDocument.getFieldNames();

        //获取file名和内容

        Map<String, Object> fieldValueMap = solrDocument.getFieldValueMap();

//            int childDocumentCount = solrDocument.getChildDocumentCount();

        List<SolrDocument> childDocuments = solrDocument.getChildDocuments();

        System.out.println("byId=================="+solrDocument);

        System.out.println("fieldNames=================="+fieldNames);

        System.out.println("fieldValueMap=================="+fieldValueMap);

//            System.out.println("childDocumentCount=================="+childDocumentCount);

        System.out.println("childDocuments=================="+childDocuments);

    }

    //根据di删除

    @RequestMapping("/delById/{id}")

    public  void  delById(@PathVariable("id") String id) throws IOException, SolrServerException {

        //根据id删除信息

        UpdateResponse updateResponse = solrClient.deleteById(id);

        //执行的时间

        long elapsedTime = updateResponse.getElapsedTime();

        int qTime = updateResponse.getQTime();

        //请求地址

        String requestUrl = updateResponse.getRequestUrl();

        //请求的结果{responseHeader={status=0,QTime=2}}

        NamedList<Object> response = updateResponse.getResponse();

        //请求结果的头{status=0,QTime=2}

        NamedList responseHeader = updateResponse.getResponseHeader();

        //请求的状态 0

        int status = updateResponse.getStatus();

        System.out.println("elapsedTime==========="+elapsedTime);

        System.out.println("qTime==========="+qTime);

        System.out.println("requestUrl==========="+requestUrl);

        System.out.println("response==========="+response);

        System.out.println("responseHeader==========="+responseHeader);

        System.out.println("status==========="+status);

    }

    @RequestMapping("/queryFromSolr")

    public  Object  queryFromSolr() throws IOException, SolrServerException {

        //第一种方式

//        Map<String, String> queryParamMap = new HashMap<String, String>();

//        queryParamMap.put("q", "*:*");

//        queryParamMap.put("f1","id,name");

//        queryParamMap.put("sort","id asc");

//        MapSolrParams mapSolrParams = new MapSolrParams(queryParamMap);

//        solrClient.query(mapSolrParams);

        //第二种方式

        SolrQuery solrQuery  = new SolrQuery();

        solrQuery.setQuery("*:*");

//        solrQuery.addField("*");

        solrQuery.add("q","id:4567");

        solrQuery.setSort("id", SolrQuery.ORDER.asc);

        //设置查询的条数

        solrQuery.setRows(50);

        //设置查询的开始

        solrQuery.setStart(0);

        //设置高亮

        solrQuery.setHighlight(true);

        //设置高亮的字段

        solrQuery.addHighlightField("item_name");

        //设置高亮的样式

        solrQuery.setHighlightSimplePre("<font color='red'>");

        solrQuery.setHighlightSimplePost("</font>");

        System.out.println(solrQuery);

        QueryResponse response = solrClient.query(solrQuery);

        //返回高亮显示结果

        Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();

        //response.getResults();查询返回的结果

        SolrDocumentList documentList = response.getResults();

        for (SolrDocument solrDocument : documentList) {

            System.out.println("solrDocument==============" +solrDocument);

        }

        return documentList;

    }

}

测试能不能访问springboot项目，这个可以不要

IndexController.java

package com.xiaostudy.solr_test1.web.controller;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

/**

 * Created with IntelliJ IDEA.

 * User: Administrator

 * Date: 2019/6/2

 * Time: 11:15

 * Description: No Description

 */

@Controller

public class IndexController {

    @RequestMapping("/index")

    public String index() {

        return "index";

    }

}

测试

所以这里提示：除了查询，增删改都要提交事务

solrClient.commit();

solrClient.addBean(new User());// 添加一个对象

solrClient.addBeans(users);// 添加多个对象

solrClient.deleteByQuery("*:*");// 删除所有索引

solrClient.deleteById("1234");// 删除id为1234的索引

solrClient.getById("1234");// 查询id为1234的索引

参考文章：https://blog.csdn.net/weixin_42129558/article/details/82682265

巴特西

springboot和solr结合测试使用

springboot没有webapp目录——手动添加

最新文章

热门文章