huanghaosheng/VLoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 为相关业务传入消息队列

Browse Source
This commit is contained in:
Leon
2025-12-30 01:27:46 +08:00
parent 6710db6928
commit 39645868a2
1 changed files with 20 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
backend/internal/http/router.go
View File

@@ -37,7 +37,12 @@ func SetRouter(db *gorm.DB, cache *rediscache.Client, rmq *rabbitmq.RabbitMQ) *g
} }
// video // video
videoRepository := video.NewVideoRepository(db) videoRepository := video.NewVideoRepository(db)
videoService := video.NewVideoService(videoRepository, cache) popularityMQ, err := rabbitmq.NewPopularityMQ(rmq)
if err != nil {
log.Printf("PopularityMQ init failed (mq disabled): %v", err)
popularityMQ = nil
}
videoService := video.NewVideoService(videoRepository, cache, popularityMQ)
videoHandler := video.NewVideoHandler(videoService, accountService) videoHandler := video.NewVideoHandler(videoService, accountService)
videoGroup := r.Group("/video") videoGroup := r.Group("/video")
{ {
@@ -52,9 +57,14 @@ func SetRouter(db *gorm.DB, cache *rediscache.Client, rmq *rabbitmq.RabbitMQ) *g
protectedVideoGroup.POST("/publish", videoHandler.PublishVideo) protectedVideoGroup.POST("/publish", videoHandler.PublishVideo)
} }
// like // like
likeMQ, err := rabbitmq.NewLikeMQ(rmq)
if err != nil {
log.Printf("LikeMQ init failed (mq disabled): %v", err)
likeMQ = nil
}
likeRepository := video.NewLikeRepository(db) likeRepository := video.NewLikeRepository(db)
likeService := video.NewLikeService(likeRepository, videoRepository) likeService := video.NewLikeService(likeRepository, videoRepository, cache, likeMQ, popularityMQ)
likeHandler := video.NewLikeHandler(likeService, videoService) likeHandler := video.NewLikeHandler(likeService)
likeGroup := r.Group("/like") likeGroup := r.Group("/like")
protectedLikeGroup := likeGroup.Group("") protectedLikeGroup := likeGroup.Group("")
protectedLikeGroup.Use(jwt.JWTAuth(accountRepository, cache)) protectedLikeGroup.Use(jwt.JWTAuth(accountRepository, cache))
@@ -66,8 +76,13 @@ func SetRouter(db *gorm.DB, cache *rediscache.Client, rmq *rabbitmq.RabbitMQ) *g
} }
// comment // comment
commentRepository := video.NewCommentRepository(db) commentRepository := video.NewCommentRepository(db)
commentService := video.NewCommentService(commentRepository, videoRepository) commentMQ, err := rabbitmq.NewCommentMQ(rmq)
commentHandler := video.NewCommentHandler(commentService, accountService, videoService) if err != nil {
log.Printf("CommentMQ init failed (mq disabled): %v", err)
commentMQ = nil
}
commentService := video.NewCommentService(commentRepository, videoRepository, cache, commentMQ, popularityMQ)
commentHandler := video.NewCommentHandler(commentService, accountService)
commentGroup := r.Group("/comment") commentGroup := r.Group("/comment")
{ {
commentGroup.POST("/listAll", commentHandler.GetAllComments) commentGroup.POST("/listAll", commentHandler.GetAllComments)