201206030/novel-plus
1
0
Fork 0
mirror of https://github.com/201206030/novel-plus.git synced 2025-07-04 00:16:39 +00:00
Code Issues Packages Releases Wiki Activity

引入rabbitmq流量削峰，累积点击量后统一更新

Browse Source
This commit is contained in:
xiongxiaoyang
2020-05-25 21:06:51 +08:00
parent 5dbddbdd96
commit e4dd5bcb71
10 changed files with 197 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
novel-front/src/main/java/com/java2nb/novel/controller/BookController.java
View File

@ -12,6 +12,8 @@ import com.java2nb.novel.service.BookService;
import com.java2nb.novel.vo.BookVO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
@ -33,6 +35,11 @@ public class BookController extends BaseController{
private final BookService bookService;
private final RabbitTemplate rabbitTemplate;
@Value("${spring.rabbitmq.enable}")
private Integer enableMq;
/**
* 查询首页小说设置列表数据
@ -105,7 +112,11 @@ public class BookController extends BaseController{
* */
@PostMapping("addVisitCount")
public ResultBean addVisitCount(Long bookId){
bookService.addVisitCount(bookId);
if(enableMq == 1) {
rabbitTemplate.convertAndSend("ADD-BOOK-VISIT-EXCHANGE", null, bookId);
}else {
bookService.addVisitCount(bookId);
}
return ResultBean.ok();
}