5-MongoDB实战演练

简介: 本文介绍某头条文章评论功能的需求分析与技术实现,基于MongoDB构建评论系统,实现增删改查、按文章ID查询、分页查询及点赞功能。采用SpringDataMongoDB与MongoTemplate优化数据操作,提升性能。

5.1 需求分析
某头条的文章评论业务如下:

早晨空腹喝水,是对还是错?

外从小喝凉水,冰水,也没见伤亡率就试我大天朝高多少?喝热水喝开水是当年我国建国初期

不少人认为,早起喝杯水,能够起到补水乃至减肥的作用.

生条件差,水不烧开了喝细菌多容易致病,而习惯性传下来喝开水而己,并不是什么别的原因

我们不应该把清晨浪费在手机上,健康很重要,杯温水幸福你我他

研究表明,刚烧开的水干万不能喝,因为烫嘴

我夏天空膜喝凉开水,冬天喝温开水

中间一条线两边是饭店17天前

我一直喝凉开水,冬天夏天都喝

厚德载物4426998517天有

|惊鸿照影|17天前

工人日报2019-08-0508:41:50

河畔半守护为伊人17天前

[捂脸[捂脸]岁月不饶人

专家说不能空腹吃饭

64条评论

FENGBETTA17天前

回复,5条回复V

你还年轻,火力旺.

回复收起回复人

TEAWEB17天前

南街村夫17天前

南街村夫17天前

写下您的评论..

查看更多评平论

12凸口

4仓回

4仓口

6凸回

8E

回复

回复

回复

评平论

回复

回复

2凸口

06

3F


需要实现以下功能:
1)基本增删改查API
2)根据文章id查询评论
3)评论点赞
5.2 表结构分析
数据库:articledb

:不可见;1:可见;

如果为0表示文章的顶级评论

评论的日期时间

MONGO的主键的字段

OBJECTLDSTRING

段名称

CREATEDATETIME

字段类型

评论人ID

字段含义

IKENUM

栏兰文章评论

ARTICLEID

点赞数

评论人呢称

COMMENT

REPYNUM

文章ID

STRING

ARENTIC

ICKNAME

NT32

备注

评论内容

ONTENT

回复数

上级ID

SERID

STRING

STRING

STATE

TRING

状态

INT32

STRING

STRING

DATE

1D

ID


5.3 技术选型
5.3.1 mongodb-driver(了解)
mongodb-driver是mongo官方推出的java连接mongoDB的驱动包,相当于JDBC驱动。我们通过一个入门的案例来了解mongodb-driver的基本使用。
官方驱动说明和下载:链接 ,官方驱动示例文档:链接
5.3.2 SpringDataMongoDB
SpringData家族成员之一,用于操作MongoDB的持久层框架,封装了底层的mongodb-driver。
官网主页: https://projects.spring.io/spring-data-mongodb/
5.4 文章微服务模块搭建
(1)搭建项目工程article,pom.xml引入依赖:
(2)创建application.yml
(3)创建启动类
cn.itcast.article.ArticleApplication
(4)启动项目,看是否能正常启动,控制台没有错误。
5.5 文章评论实体类的编写
创建实体类 创建包cn.itcast.article,包下建包po用于存放实体类,创建实体类
cn.itcast.article.po.Comment
说明:
索引可以大大提升查询效率,一般在查询字段上添加索引,索引的添加可以通过Mongo的命令来添加,也可以在Java的实体类中通过注解添加。
1)单字段索引注解@Indexed
org.springframework.data.mongodb.core.index.Indexed.class
声明该字段需要索引,建索引可以大大的提高查询效率。
Mongo命令参考:

db.comment.createIndex({"userid":1})

2)复合索引注解@CompoundIndex
org.springframework.data.mongodb.core.index.CompoundIndex.class
复合索引的声明,建复合索引可以有效地提高多字段的查询效率。
Mongo命令参考:

db.comment.createIndex({"userid":1,"nickname":-1})

5.6 文章评论的基本增删改查
(1)创建数据访问接口 cn.itcast.article包下创建dao包,包下创建接口
cn.itcast.article.dao.CommentRepository
(2)创建业务逻辑类 cn.itcast.article包下创建service包,包下创建类
cn.itcast.article.service.CommentService
(3)新建Junit测试类,测试保存和查询所有:
cn.itcast.article.service.CommentServiceTest
添加结果:

CLASS:CN.ITCAST.ARTICLE.PO.COMMENT

CREATEDATETIME:2019-08-3103:23:40.921

ID:*1167639062832615424

CONTENT:"则试式添的好居

KNAME:凯大帝

ARTIC1EID:"1OEEOE

USERID:"1EE3

REPLYNUM:E

1IKENUM:E

STATE:1


5.7 根据上级ID查询文章评论的分页列表
(1)CommentRepository新增方法定义
(2)CommentService新增方法
(3)junit测试用例:
cn.itcast.article.service.CommentServiceTest
(4)测试
使用compass快速插入一条测试数据,数据的内容是对3号评论内容进行评论。

ARTLCLEDB.COMMENT

专家说不能空腹吃饭,响健康."

5D689257EDFC962DA8DD895E

"我一直喝凉开水,冬天夏天喝."

TICLEID:"100E81

INSERTDOCUMENT

INSERTDOCUMENT

NICKNAME:凯散..

CONTENT:你年全,.

NICKNAMESTRIR

OCUMENTSO

USERID:1OE3

建康.""1003"

DOCUMENTS

伊人焦摔"

AGGRES

PARENTID:3

CANCEL

STRING

IDMIXED

OFILTER

INSERT

COMMENT

STRING

STRING

"100001"

STRING

凯撒大帝"

100001"

杰克船长

号.""1004"

ROSE"

三LS

ID:"33"

STRING

STRING

3

2"


执行测试,结果:

----总记录数:1
----当前页数据:[Comment{id='33', content='你年轻,火力大', publishtime=null, userid='1003', nickname='凯撒大帝', createdatetime=null, likenum=null, replynum=null, state='null', parentid='3', articleid='100001'}]

5.8 MongoTemplate实现评论点赞
我们看一下以下点赞的临时示例代码: CommentService 新增updateThumbup方法
以上方法虽然实现起来比较简单,但是执行效率并不高,因为我只需要将点赞数加1就可以了,没必要查询出所有字段修改后再更新所有字段。我们可以使用MongoTemplate类来实现对某列的操作。
(1)修改CommentService

Java

运行代码复制代码

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

//注入MongoTemplate

@Autowired

private MongoTemplate mongoTemplate;


/**

* 点赞数+1

* @param id

*/

public void updateCommentLikenum(String id){

//查询对象

Query query=Query.query(Criteria.where("_id").is(id));

//更新对象

Update update=new Update();

//局部更新,相当于$set

// update.set(key,value)

//递增$inc

// update.inc("likenum",1);

update.inc("likenum");

//参数1:查询对象

//参数2:更新对象

//参数3:集合的名字或实体类的类型Comment.class

mongoTemplate.updateFirst(query,update,"comment");

}

(2)测试用例:
cn.itcast.article.service.CommentServiceTest

Java

运行代码复制代码

1

2

3

4

5

6

7

8

/**

* 点赞数+1

*/

@Test

public void testUpdateCommentLikenum(){

//对3号文档的点赞数+1

commentService.updateCommentLikenum("3");

}

执行测试用例后,发现点赞数+1了:

CONTENT:"我一直喝凉开水,冬天粤天喝.

CREATEDATETIME:2019-08-0601:

ICKNAME:"杰克船长"

ARTIC1EID:"1EOE81

USERID:1EE4

1:05:06.321

1IKENUM:667

STATE:

ID:M3"


相关文章
|
2月前
|
数据采集 人工智能 安全
|
2月前
|
SQL 容灾 数据库
分布式事务Seata
本章学习分布式事务问题及解决方案,涵盖CAP、BASE理论,并深入讲解Seata框架的XA、AT、TCC、SAGA四种模式原理与实现,掌握跨服务事务一致性处理及高可用部署。
 分布式事务Seata
|
2月前
|
XML Java 数据库
SpringCloud工程部署启动
本文介绍SpringCloud微服务工程的搭建与部署,涵盖项目创建、模块配置、数据库导入及服务远程调用实现。通过RestTemplate完成服务间HTTP通信,解决跨服务数据获取问题,并引导读者理解微服务拆分与调用关系,为后续深入学习奠定基础。(239字)
 SpringCloud工程部署启动
|
2月前
|
SQL 容灾 Nacos
Seata的部署和集成
本文介绍Seata TC服务器的部署与微服务集成,包括下载、解压、配置修改、数据库表创建及启动步骤,并实现基于Nacos的高可用与异地容灾集群,提升分布式事务可靠性。
|
2月前
|
自然语言处理 Java Shell
安装ES、Kibana、IK
本文介绍了如何通过Docker部署单点Elasticsearch与Kibana,并配置IK分词器。内容涵盖网络创建、镜像加载、容器运行、DevTools使用,以及IK分词器的安装与扩展词典、停用词配置,助力中文文本分析。
 安装ES、Kibana、IK
|
2月前
|
消息中间件 存储 Java
消息中间件RabbitMQ(高级)
本文深入探讨RabbitMQ在生产环境中的高级应用,涵盖消息可靠性、延迟消息、消息堆积及集群高可用等核心问题。通过生产者确认、持久化、消费者确认机制确保消息不丢失;利用TTL与死信交换机实现延迟队列;借助惰性队列提升堆积能力;最后通过普通集群、镜像集群及仲裁队列实现高可用架构。
 消息中间件RabbitMQ(高级)
|
2月前
|
JSON Java Shell
Jmeter快速入门
本文介绍JMeter的安装与快速入门使用方法,包括环境依赖、下载解压、启动运行、中文界面设置及基本测试计划创建,涵盖线程组配置、HTTP请求添加、监听器使用等性能测试核心操作步骤。
 Jmeter快速入门
|
1月前
|
前端开发 JavaScript iOS开发
Volta:一款优秀的前端开发 JavaScript 项目管理器
前端开发者喵喵侠分享使用 Volta 管理 Node.js 版本的实战经验。Volta 可跨平台统一管理 Node、npm、pnpm 等工具版本,支持在 `package.json` 中锁定依赖,实现项目级环境自动切换,尤其解决了 Windows 下 nvm/nvs 的兼容问题,提升团队协作效率。
174 1
|
2月前
|
传感器 人工智能 BI
2025科普手册:6大智能体类型,拆解智能重塑世界的底层逻辑
智能体正从概念走向现实,2025年被誉为“智能体元年”。全球市场规模达113亿美元,中国突破69亿元。本文盘点六大主流类型:反应式、目标驱动型、认知增强型、语音、编码及多智能体协同系统,解析其核心能力与应用场景,揭示智能体如何重塑工作与生活,推动人机协作迈向新阶段。
756 1
|
8月前
|
机器学习/深度学习
解决神经网络输出尺寸过小的实战方案
在CIFAR10分类模型训练中,因网络结构设计缺陷导致“RuntimeError: Given input size: (256x1x1). Calculated output size: (256x0x0)”错误。核心问题是六层卷积后接步长为2的池化层,使特征图尺寸过度缩小至归零。解决方案包括调整池化参数(如将部分步长改为1)和优化网络结构(采用“卷积-卷积-池化”模块化设计)。两种方案均可消除报错,推荐方案二以平衡特征表达与计算效率。