黑马程序员技术交流社区

标题: 【郑州校区】学成在线-第11天-讲义-搜索服务 一 [打印本页]
作者: 我是楠楠    时间: 2019-12-25 10:59
标题: 【郑州校区】学成在线-第11天-讲义-搜索服务 一
【郑州校区】学成在线-第11天-讲义-搜索服务 一

1 课程搜索需求分析
1.1 需求分析

1、根据分类搜索课程信息。
2、根据关键字搜索课程信息，搜索方式为全文检索，关键字需要匹配课程的名称、 课程内容。
3、根据难度等级搜索课程。
4、搜索结点分页显示。
1.2 搜索流程


1、课程管理服务将数据写到MySQL数据库
2、使用Logstash将MySQL数据库中的数据写到ES的索引库。
3、用户在前端搜索课程信息，请求到搜索服务。
4、搜索服务请求ES搜索课程信息。
2 全文检索技术研究
参考：elasticsearch研究.md研究ElasticSearch搜索方法。
3 课程索引
3.1 技术方案
如何维护课程索引信息？
1、当课程向MySQL添加后同时将课程信息添加到索引库。
采用Logstach实现，Logstach会从MySQL中将数据采集到ES索引库。
2、当课程在MySQL更新信息后同时更新该课程在索引库的信息。
采用Logstach实现。
3、当课程在MySQL删除后同时将该课程从索引库删除。
手工写程序实现，在删除课程后将索引库中该课程信息删除。

3.2 准备课程索引信息
课程发布成功在MySQL数据库存储课程发布信息，此信息作为课程索引信息。
3.2.1创建课程发布表
课程信息分布在course_base、course_pic等不同的表中。
课程发布成功为了方便进行索引将这几张表的数据合并在一张表中，作为课程发布信息。
创建course_pub表


3.2.2创建课程发布表模型
在课程管理服务创建模型：
[AppleScript] 纯文本查看 复制代码
 @Data

@ToString

@Entity

@Table(name

=

"

course_pub

"

)

@GenericGenerator(name

=

"

jpa

‐

assigned

"

, strategy

=

"

assigned

"

)

public class CoursePub implements Serializable {

private static final long serialVersionUID =

‐

916357110051689487L;

@Id

@GeneratedValue(generator =

"

jpa

‐

assigned

"

)

@Column(length =

32)

private String id;

private String name;

private String users;

private String mt;

private String st;

private String grade;

private String studymodel;

private String teachmode;

private String description;

private String pic;//图片

private Date timestamp;//时间戳

private String charge;

private String valid;

private String qq;

private Float price;

private Float price_old;

private String expires;

private String teachplan;//课程计划

@Column(name

=

"

pub_time

"

)

private String pubTime;//课程发布时间

}


3.2.3修改课程发布
在课程管理服务定义dao：
1）创建course_pub表的dao

[AppleScript] 纯文本查看 复制代码
public interface CoursePubRepository extends JpaRepository<CoursePub, String> {

}

2) 修改课程发布service

[AppleScript] 纯文本查看 复制代码
//保存CoursePub

public CoursePub saveCoursePub(String id, CoursePub coursePub){

if(StringUtils.isNotEmpty(id)){

ExceptionCast.cast(CourseCode.COURSE_PUBLISH_COURSEIDISNULL);

}

CoursePub coursePubNew = null;

Optional<CoursePub> coursePubOptional =

coursePubRepository

.findById(id);

if(coursePubOptional.isPresent()){

coursePubNew =

coursePubOptional.

get();

}

if(coursePubNew == null){

coursePubNew = new CoursePub();

}

BeanUtils.copyProperties(coursePub,coursePubNew);

//设置主键

coursePubNew.setId(id);

//更新时间戳为最新时间

coursePub.setTimestamp(new Date());

//发布时间

SimpleDateFormat simpleDateFormat

= new SimpleDateFormat(

"

YYYY

‐

MM

‐

dd HH:mm:ss

"

);

String date

=

simpleDateFormat.format(new Date());

coursePub.setPubTime(date);

coursePubRepository

.save(coursePub);

return coursePub;

}

//创建coursePub对象

private CoursePub createCoursePub(String id){

CoursePub coursePub

= new CoursePub();

coursePub.setId(id);

//基础信息

Optional<CourseBase> courseBaseOptional =

courseBaseRepository

.findById(id);

if(courseBaseOptional == null){

CourseBase courseBase

=

courseBaseOptional.

get();

BeanUtils.copyProperties(courseBase, coursePub);

}

//查询课程图片

Optional<CoursePic> picOptional =

coursePicRepository

.findById(id);

if(picOptional.isPresent()){

CoursePic coursePic

=

picOptional.

get();

BeanUtils.copyProperties(coursePic, coursePub);

}

//课程营销信息

Optional<CourseMarket> marketOptional =

courseMarketRepository

.findById(id);

if(marketOptional.isPresent()){

CourseMarket courseMarket

= marketOptional.

get();

BeanUtils.copyProperties(courseMarket, coursePub);

}

//课程计划

TeachplanNode teachplanNode

=

teachplanMapper.selectList(id);

//将课程计划转成json

String teachplanString

=

JSON.toJSONString(teachplanNode);

coursePub.setTeachplan(teachplanString);

return coursePub;

}

修改课程发布方法，添加调用saveCoursePub方法的代码，添加部分的代码如下：
[AppleScript] 纯文本查看 复制代码
 //课程发布

@Transactional

public CoursePublishResult publish(String courseId){

....

//创建课程索引

//创建课程索引信息

CoursePub coursePub

=

createCoursePub(courseId);

//向数据库保存课程索引信息

CoursePub newCoursePub

=

saveCoursePub(courseId, coursePub);

if(newCoursePub

==null){

//创建课程索引信息失败

ExceptionCast.cast(CourseCode.COURSE_PUBLISH_CREATE_INDEX_ERROR);

}

....

}







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2