solr 7.X 与spring

solr 7.X 与spring"/>

solr 7.X 与spring

版本参数

solr 7.3.0
solrj 7.3.0
spring-data 3.0.6 RELEASE
spring:5.0.5.RELEASE

搭建Solr并用DIM导入数据

搭建solr及数据导入的步骤可以参见之前的内容。

笔者已经建好了一个环境，Document结构如下

{"responseHeader":{"status":0,"QTime":77,"params":{"q":"*:*","_":"1529904219206"}},"response":{"numFound":1000,"start":0,"docs":[{"id":"1","song_title":"棒球狂 (口白)","singer_name":"BABOO乐团","genre":"Pop 流行","song_name":"棒球狂","language":"纯音乐","public_time":"2008-01-01T00:00:00Z","_version_":1602522394494238720},{"id":"2","song_title":"保丽龙","singer_name":"BABOO乐团","genre":"Pop 流行","song_name":"保丽龙","language":"纯音乐","public_time":"1992-05-01T00:00:00Z","_version_":1602522394529890304},{...

solr 与 spring-data 集成

创建项目

创建一个Maven项目，并配置pom

<dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>5.0.5.RELEASE</version><exclusions><exclusion><artifactId>commons-logging</artifactId><groupId>commons-logging</groupId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-solr</artifactId><version>3.0.6.RELEASE</version></dependency><dependency><groupId>org.apache.solr</groupId><artifactId>solr-solrj</artifactId><version>7.3.0</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>5.0.5.RELEASE</version><scope>test</scope></dependency>

编写Model类

新建一个Music类, 该类与Solr中的MusicCore进行映射

@SolrDocument(solrCoreName = "MusicCore") 
public class Music {public static final String FIELD_RES_ID = "res_id";public static final String FIELD_SONG_ID = "song_id";public static final String FIELD_SONG_NAME = "song_name";public static final String FIELD_SINGER_NAME = "singer_name";public static final String CORE_NAME = "music_core";@Id@Indexed(name = FIELD_RES_ID, type="string")private Long resId;@Indexed(name = FIELD_SONG_ID, type="string")private Long songId;@Indexed(name = FIELD_SONG_NAME, type="string")private String songName;@Indexed(name = FIELD_SINGER_NAME, type="string")private String singerName;//TODO: 此处省略了get, set@Overridepublic String toString() {return ToStringBuilder.reflectionToString(this);}
}

SolrCoreName 为 在Solr中建立的Core对应的名字
@Id 为 Solr中的主键
@Indexed 为标注该属性与Solr中的索引对象的映射关系，name为solr中的命名， type为solr中的类型名，如pint, plong等。

创建Repository

新建MusicRepository，该接口用于实现对Solr中对应的Core进行增删查改操作

public interface MusicRepository extends SolrCrudRepository<Music, String> {
}

SolrCrudRepository 实现了大部分的常用方法，继承它后就可以进行普通的操作。SolrCrudRepository第一个参数为model类，即与document映射的类，第二个为逐渐类型

配置

首先新建一个solr.properties文件，用于存放solr的访问地址

solr.server.url=http://192.168.3.11:8983/solr/

再创建Solr的配置类，用于读取solr的链接，及注入相关对象。

@Configuration
@PropertySource("classpath:solr.properties")
@EnableSolrRepositories(basePackages = "com.ali.repository")
public class HttpSolrContext {private static final String SOLR_SERVER_URL = "solr.server.url";@Resourceprivate Environment environment;@Beanpublic SolrClient solrClient() {return new HttpSolrClient.Builder(environment.getRequiredProperty(SOLR_SERVER_URL)).withConnectionTimeout(10000).withSocketTimeout(60000).build();}@Beanpublic SolrTemplate solrTemplate(SolrClient client){return new SolrTemplate(client);}
}

测试

集成已经完成，添加测试代码来测试一下是否能与solr连接成功。

configTest

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = HttpSolrContext.class)
public class configTest {@Autowiredprivate MusicRepository musicRepository;@Testpublic void findOne(){Optional<Music> music = musicRepository.findById("13558");System.out.println(music);}
}

最后，控制台确实打印了该对象