仿牛客论坛项目全面大总结_牛客项目亮点

1.核心功能：

 

     - 发帖、评论、私信、转发；

     - 点赞、关注、通知、搜索；

     - 权限、统计、调度、监控；

2.核心技术：

     - Spring Boot、SSM

     - Redis、Kafka、ElasticSearch

     - Spring Security、Quatz、Caffeine

3.项目亮点：

     - 项目构建在Spring Boot+SSM框架之上，并统一的进行了状态管理、事务管理、异常处理；

     - 利用Redis实现了点赞和关注功能；

     - 利用Kafka实现了异步的站内通知；

     - 利用ElasticSearch实现了全文搜索功能，可准确匹配搜索结果，并高亮显示关键词；

     - 利用Caffeine+Redis实现了两级缓存，并优化了热门帖子的访问。

     - 利用Spring Security实现了权限控制，实现了多重角色、URL级别的权限管理；

     - 利用HyperLogLog、Bitmap分别实现了UV、DAU的统计功能，100万用户数据只需*M内存空间；

     - 利用Quartz实现了任务调度功能，并实现了定时计算帖子分数、定时清理垃圾文件等功能；

     - 利用Actuator对应用的Bean、缓存、日志、路径等多个维度进行了监控，并通过自定义的端点对数据库连接进行了监控。

实现了项目部署上线，日访问量到达200+（很欣慰了）

 开始总结

咋们就从核心功能处开始捋，一个一个功能点开始总结实现过程：

核心功能：

   发帖：

      点击发布帖子按钮，输入帖子标题内容等信息后发布，以JS异步请求的方式进行提交，首先判断该线程中有无用户信息（在登录成功是会将用户信息与本线程的id进行键值对存储，保证了多线程情况下安全）即判断有无登录，已登录则初始化帖子信息将其添加至DB中，并且触发发帖事件，采用kafka信息队列来完成，将帖子信息添加至ES中，通知再将其存入Redis中计算帖子的分值，用来在最热列表中展示出来：

添加帖子

// 发布帖子
    @RequestMapping(path = "/add",method = RequestMethod.POST)
    @ResponseBody
    public String addDiscussPost(String title,String content){
        User users = hostHolder.getUsers();
        if(users == null){
            return CommunityUtil.getJSONString(403,"你还没有登录！");
        }
 
        DiscussPost post=new DiscussPost();
        post.setUserId(users.getId());
        post.setTitle(title);
        post.setContent(content);
        post.setCreateTime(new Date());
        discussPostService.addDiscussPost(post);
 
        // 触发发帖事件  添加至es中
        Event event = new Event()
                .setTopic(TOPIC_PUBLISH)
                .setUserId(users.getId())
                .setEntityType(ENTITY_TYPE_POST)
                .setEntityId(post.getId());
        eventProducer.fireEvent(event);
 
        // 计算帖子分数
        String redisKey= RediskeyUtil.getPostScoreKey();
        redisTemplate.opsForSet().add(redisKey,post.getId());
 
        return CommunityUtil.getJSONString(0,"发布成功！");
    }

// 消费  发帖事件 es添加数据
    @KafkaListener(topics = {TOPIC_PUBLISH})
    public void handlePublishMessage(ConsumerRecord record){
        if(record == null && record.value() == null){
            logger.error("消息的内容为空！");
            return;
        }
 
        Event event = JSONObject.parseObject(record.value().toString(), Event.class);
        if(event == null){
            logger.error("消息格式错误！");
            return;
        }
 
        DiscussPost discussPost = 
        discussPostService.selectDiscussPostById(event.getEntityId());
        elasticsearchService.saveDiscussPost(discussPost);
    }

评论：

  评论这一块