【Java项目推荐之黑马头条】自媒体文章实现异步上下架（使用Kafka中间件实现）

迷南。 2024-02-25 05:34 15阅读 0赞

#### 自媒体文章上下架功能完成 ####

##### 需求分析 #####

![在这里插入图片描述][610ac632ed77445584097ec1515cd552.png]

##### 流程说明 #####

![在这里插入图片描述][fbafca74c3514ecd988bfd7d7db2163a.png]

##### 接口定义 #####

<table> 
 <thead> 
  <tr> 
   <th></th> 
   <th><strong>说明</strong></th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>接口路径</td> 
   <td>/api/v1/news/down_or_up</td> 
  </tr> 
  <tr> 
   <td>请求方式</td> 
   <td>POST</td> 
  </tr> 
  <tr> 
   <td>参数</td> 
   <td>DTO</td> 
  </tr> 
  <tr> 
   <td>响应结果</td> 
   <td>ResponseResult</td> 
  </tr> 
 </tbody> 
</table>

DTO

@Data
    public class WmNewsDto {
        
        
        private Integer id;
        /**
        * 是否上架  0 下架  1 上架
        */
        private Short enable;
                           
    }

ResponseResult

![image-20230218212711969][]

##### 自媒体文章上下架-功能实现 #####

接口定义

在heima-leadnews-wemedia工程下的WmNewsController新增方法

@PostMapping("/down_or_up")
    public ResponseResult downOrUp(@RequestBody WmNewsDto dto){
        
        return null;
    }

在WmNewsDto中新增enable属性 ，完整的代码如下：

package com.heima.model.wemedia.dtos;
    
    import lombok.Data;
    
    import java.util.Date;
    import java.util.List;
    
    @Data
    public class WmNewsDto {
        
        
        private Integer id;
         /**
         * 标题
         */
        private String title;
         /**
         * 频道id
         */
        private Integer channelId;
         /**
         * 标签
         */
        private String labels;
         /**
         * 发布时间
         */
        private Date publishTime;
         /**
         * 文章内容
         */
        private String content;
         /**
         * 文章封面类型  0 无图 1 单图 3 多图 -1 自动
         */
        private Short type;
         /**
         * 提交时间
         */
        private Date submitedTime; 
         /**
         * 状态 提交为1  草稿为0
         */
        private Short status;
         
         /**
         * 封面图片列表 多张图以逗号隔开
         */
        private List<String> images;
    
        /**
         * 上下架 0 下架  1 上架
         */
        private Short enable;
    }

9.4.2)业务层编写

在WmNewsService新增方法

/**
     * 文章的上下架
     * @param dto
     * @return
     */
    public ResponseResult downOrUp(WmNewsDto dto);

实现方法

/**
     * 文章的上下架
     * @param dto
     * @return
     */
    @Override
    public ResponseResult downOrUp(WmNewsDto dto) {
        
        //1.检查参数
        if(dto.getId() == null){
        
            return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
        }
    
        //2.查询文章
        WmNews wmNews = getById(dto.getId());
        if(wmNews == null){
        
            return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST,"文章不存在");
        }
    
        //3.判断文章是否已发布
        if(!wmNews.getStatus().equals(WmNews.Status.PUBLISHED.getCode())){
        
            return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"当前文章不是发布状态，不能上下架");
        }
    
        //4.修改文章enable
        if(dto.getEnable() != null && dto.getEnable() > -1 && dto.getEnable() < 2){
        
            update(Wrappers.<WmNews>lambdaUpdate().set(WmNews::getEnable,dto.getEnable())
                    .eq(WmNews::getId,wmNews.getId()));
        }
        return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
    }

9.4.3)控制器

@PostMapping("/down_or_up")
    public ResponseResult downOrUp(@RequestBody WmNewsDto dto){
        
        return wmNewsService.downOrUp(dto);
    }

9.4.4)测试

##### 消息通知article端文章上下架 #####

在heima-leadnews-common模块下导入kafka依赖

<dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
    </dependency>

9.5.2)在自媒体端的nacos配置中心配置kafka的生产者

spring:
      kafka:
        bootstrap-servers: 172.20.10.2:9092
        producer:
          retries: 10
          key-serializer: org.apache.kafka.common.serialization.StringSerializer
          value-serializer: org.apache.kafka.common.serialization.StringSerializer

9.5.3)在自媒体端文章上下架后发送消息

//发送消息，通知article端修改文章配置
    if(wmNews.getArticleId() != null){
        
        Map<String,Object> map = new HashMap<>();
        map.put("articleId",wmNews.getArticleId());
        map.put("enable",dto.getEnable());
        kafkaTemplate.send(WmNewsMessageConstants.WM_NEWS_UP_OR_DOWN_TOPIC,JSON.toJSONString(map));
    }

常量类：

public class WmNewsMessageConstants {
        
    
        public static final String WM_NEWS_UP_OR_DOWN_TOPIC="wm.news.up.or.down.topic";
    }

9.5.4)在article端的nacos配置中心配置kafka的消费者

spring:
      kafka:
        bootstrap-servers: 172.20.10.2:9092
        consumer:
          group-id: ${
        spring.application.name}
          key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
          value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

9.5.5)在article端编写监听，接收数据

package com.heima.article.listener;
    
    import com.alibaba.fastjson.JSON;
    import com.heima.article.service.ApArticleConfigService;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.commons.lang3.StringUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.kafka.annotation.KafkaListener;
    import org.springframework.stereotype.Component;
    
    import java.util.Map;
    
    @Component
    @Slf4j
    public class ArtilceIsDownListener {
        
    
        @Autowired
        private ApArticleConfigService apArticleConfigService;
    
        @KafkaListener(topics = WmNewsMessageConstants.WM_NEWS_UP_OR_DOWN_TOPIC)
        public void onMessage(String message){
        
            if(StringUtils.isNotBlank(message)){
        
                Map map = JSON.parseObject(message, Map.class);
                apArticleConfigService.updateByMap(map);
                log.info("article端文章配置修改，articleId={}",map.get("articleId"));
            }
        }
    }

9.5.6)修改ap\_article\_config表的数据

新建ApArticleConfigService

package com.heima.article.service;
    
    import com.baomidou.mybatisplus.extension.service.IService;
    import com.heima.model.article.pojos.ApArticleConfig;
    
    import java.util.Map;
    
    public interface ApArticleConfigService extends IService<ApArticleConfig> {
        
    
        /**
         * 修改文章配置
         * @param map
         */
        public void updateByMap(Map map);
    }

实现类：

package com.heima.article.service.impl;
    
    import com.baomidou.mybatisplus.core.toolkit.Wrappers;
    import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    import com.heima.article.mapper.ApArticleConfigMapper;
    import com.heima.article.service.ApArticleConfigService;
    import com.heima.model.article.pojos.ApArticleConfig;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    import java.util.Map;
    
    @Service
    @Slf4j
    @Transactional
    public class ApArticleConfigServiceImpl extends ServiceImpl<ApArticleConfigMapper, ApArticleConfig> implements ApArticleConfigService {
        
    
    
        /**
         * 修改文章配置
         * @param map
         */
        @Override
        public void updateByMap(Map map) {
        
            //0 下架 1 上架
            Object enable = map.get("enable");
            boolean isDown = true;
            if(enable.equals(1)){
        
                isDown = false;
            }
            //修改文章配置
            update(Wrappers.<ApArticleConfig>lambdaUpdate().eq(ApArticleConfig::getArticleId,map.get("articleId")).set(ApArticleConfig::getIsDown,isDown));
    
        }
    }

[610ac632ed77445584097ec1515cd552.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/25/37523ba8be8447e38df049be3d55afe8.png
[fbafca74c3514ecd988bfd7d7db2163a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/25/ad122b60bce04000aea8c70bb7089362.png
[image-20230218212711969]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/25/734452880c614993921a9fdde6be7ff3.png