【项目】黑马头条 - 自媒体端

🕗 发布于 2025-02-04 22:09 微服务 spring cloud 分布式id 自动审核敏感词过滤

图片上传

在这里插入图片描述

前端发请求后到达网关，网关会解析用户token后可以得到用户信息，把用户信息放入请求头中继续向自媒体微服务发请求，在自媒体用户微服务的拦截器中就可以获得用户信息。
在自媒体微服务会把图片存储到minio中，并在数据库中存储图片的路径

网关传递userId给自媒体微服务：

@Component
@Slf4j
public class AuthorizeFilter implements Ordered, GlobalFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        //1.获取request和response对象
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        //2.判断是否是登录
        if(request.getURI().getPath().contains("/login")){
            //放行
            return chain.filter(exchange);
        }
        //3.获取token
        String token = request.getHeaders().getFirst("token");
        //4.判断token是否存在
        if(StringUtils.isBlank(token)){
            response.setStatusCode(HttpStatus.UNAUTHORIZED);
            return response.setComplete();
        }
        //5.判断token是否有效
        try {
            Claims claimsBody = AppJwtUtil.getClaimsBody(token);
            //是否是过期
            int result = AppJwtUtil.verifyToken(claimsBody);
            if(result == 1 || result  == 2){
                response.setStatusCode(HttpStatus.UNAUTHORIZED);
                return response.setComplete();
            }
            // token没问题
            Object userId = claimsBody.get("id");
            // 把token放入请求头中传给自媒体微服务
            ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {
                httpHeaders.add("userId", userId + "");
            }).build();
            exchange.mutate().request(serverHttpRequest);// 重置请求
        } catch (Exception e) {
            e.printStackTrace();
        }
        //6.放行
        return chain.filter(exchange);
    }
    /**
     * 优先级设置  值越小  优先级越高
     * @return
     */
    @Override
    public int getOrder() {
        return 0;
    }
}

自媒体微服务的拦截器拦截到userId后存入ThreadLocal中

public class LoginInterceptor implements HandlerInterceptor {
    // 前置方法（得到header中的用户信息并存入当前线程中）
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1.从请求头中获取用户信息
        String userId = request.getHeader("userId");
        // 2.存入ThreadLocal中
        if(StringUtils.isNotBlank(userId)) {
            WmUser wmUser = new WmUser();
            wmUser.setApUserId(Integer.parseInt(userId));
            WmThreadLocalUtil.setUser(wmUser);
        }
        // 3. 放行
        return true;
    }
    
    // 后置方法（清理线程中的数据）
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 清理用户
        WmThreadLocalUtil.clear();
    }
}

配置使自定义拦截器生效

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new LoginInterceptor()).addPathPatterns("/**");
    }
}

文章自动审核流程

文章发布后，系统自动审核，主要是通过第三方接口对文章内容进行审核（成功、失败、不确定）。
自动审核返回不确定信息时，转到人工审核，由平台管理员进行审核。

先审核文章，再审核图片，如果文章和图片都通过了，修改文章状态；如果有一个没有审核通过，转为人工审核。
其中审核时调用阿里云的第三方接口

内容安全第三方接口

内容安全是识别服务，支持对图片、视频、文本、语音等对象进行多样化场景检测，有效降低内容违规风险。
阿里云内容安全文档
 文本审核

分布式id

随着业务的增长，文章表可能会占用很大的物理存储空间，为了解决该问题，后期使用数据库分片技术，将一个数据库进行拆分，通过数据库中间件连接。如果数据库中该表选用id自增策略，则可能产生重复的id，就可以使用分布式id生成策略。
在这里插入图片描述

分布式id生成策略

在这里插入图片描述
雪花算法：

在实体类中的id上加入以下配置：

@TableId(value = "id",type = IdType.ID_WORKER)
private Long id;

在配置文件中配置数据中心id和机器id

mybatis-plus:
  mapper-locations: classpath*:mapper/*.xml
  # 设置别名包扫描路径，通过该属性可以给包中的类注册别名
  type-aliases-package: com.heima.model.article.pojos
  global-config:
    datacenter-id: 1 # 数据中心id（范围：0-31）
    workerId: 1 # 机器id（范围：0-31）

Feign远程调用服务降级处理

编写降级逻辑

 @Component
public class IArticleClientFallback implements IArticleClient {
    @Override
    public ResponseResult saveArticle(ArticleDto articleDto) {
        return ResponseResult.errorResult(AppHttpCodeEnum.SERVER_ERROR, "获取数据失败");
    }
}

远程接口中指向降级代码

@FeignClient(value = "leadnews-article", fallback = IArticleClientFallback.class) // 指向降级代码
public interface IArticleClient {
    @PostMapping("/api/v1/article/save")
    public ResponseResult saveArticle(@RequestBody ArticleDto articleDto);
}

客户端开启对熔断降级的支持

feign:
  # 开启feign对hystrix熔断降级的支持
  hystrix:
    enabled: true
  # 修改调用超时时间
  client:
    config:
      default:
        connectTimeout: 2000
        readTimeout: 2000

同步调用和异步调用

在这里插入图片描述

同步：发出一个调用后，没有得到结果之前，该调用不返回（实时处理）
异步：调用在发出后，这个调用直接返回了，没有返回结果（分时处理）

SpringBoot集成异步线程调用

在自动审核的方法上加@Async注解（标明要异步调用）
在文章发布成功后异步调用审核的方法
在自媒体引导类中使用@EnableAsync注解开启异步调用

自管理敏感词过滤

自管理敏感词过滤（文本）

在这里插入图片描述

DFA确定有穷自动机

一次性把所有的敏感词存储到多个map中。
在这里插入图片描述

实现原理：

在这里插入图片描述

自管理敏感词过滤（图片）

图片文字识别OCR

在这里插入图片描述
Tess4J支持多种输出格式：纯文本、hOCR（HTML）、PDF等

导入依赖：

<dependency>
    <groupId>net.sourceforge.tess4j</groupId>
    <artifactId>tess4j</artifactId>
    <version>4.1.1</version>
</dependency>

导入中文字体库
识别图片中的文字

public static void main( String[] args ) throws TesseractException {
    // 创建实例
    ITesseract tesseract = new Tesseract();
    // 设置字体库路径
    tesseract.setDatapath("D:\\project\\kaiFa\\heiMaProject\\weiFuWu\\leadnews");
    // 设置语言
    tesseract.setLanguage("chi_sim");
    // 识别图片
    File file = new File("D:\\project\\kaiFa\\heiMaProject\\weiFuWu\\leadnews\\image-20210524161243572.png");
    String res = tesseract.doOCR(file);
    System.out.println(res.replaceAll("\\r|\\n", "-"));
}

原文地址：https://blog.csdn.net/qq_57882997/article/details/145323274

免责声明：本站文章内容转载自网络资源，如侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：使用IDEA社区版搭建Springboot、jsp开发环境
下一篇：高效接口限流：基于自定义注解与RateLimiter的实践

深入理解JavaScript中的Promise：详细指南
Hi，我是布兰妮甜！异步代码的美妙之处在于它使我们可以以同步的方式思考，同时以异步的方式执行。本文将深入探讨Promise的概念、使用方法以及其带来的优势。
阅读更多2025-02-12
Java在大数据处理中的应用：从MapReduce到Spark
大数据时代的到来让数据的存储、处理和分析变得前所未有的重要。随着数据量的剧增，传统的单机计算方式已经无法满足处理需求。为了解决这个问题，许多分布式计算框架应运而生，其中MapReduce和Apache
阅读更多2025-02-12
美团智能外呼机器人意图训练全流程
语音外呼机器人主要采用主流程+知识库FAQ来实现外呼交互。
阅读更多2025-02-12
关于SoC产品介绍：ICNM8001
功能：支持2路HDMI2.0接收机支持HDCP1.4和HDCP2.22；支持HDCP1.4和HDCP2.2。这个是一款关于QHD显示器，主控芯片scaler IC。
阅读更多2025-02-12
【05】RUST常用的集合&函数&宏&类型
常用的一些代码
阅读更多2025-02-12
更新无忧：用 Docker 数据卷确保 Open WebUI 数据持久化
在使用 Docker 部署 Open WebUI 时，如何在更新容器的同时确保数据不丢失，始终是工程师们关注的焦点。每次拉取新版镜像、停止并重启容器时，如果没有正确挂载数据卷，配置和数据库数据极易流失
阅读更多2025-02-12
01.Docker 概述
docker 官网: http://www.docker.com帮助文档链接: https://docs.docker.com/docker 镜像: https://hub.docker.c
阅读更多2025-02-12
IDEA中打包maven项目，提示Compilation failure
解决方法：在pom文件中指定JDK版本即可。
阅读更多2025-02-12
使用mermaid画流程图
本文介绍使用mermaid画流程图，并给出几个示例。
阅读更多2025-02-12
BGP基础协议详解
BGP是一种实现自治系统AS之间的路由可达，并选择最佳路由的矢量性协议。早期发布的三个版本分别是BGP-1（RFC1105）、BGP-2（RFC1163）和BGP-3（RFC1267），1994年开始
阅读更多2025-02-12

【项目】黑马头条 - 自媒体端

图片上传

文章自动审核流程

内容安全第三方接口

分布式id

分布式id生成策略

Feign远程调用服务降级处理

同步调用和异步调用

SpringBoot集成异步线程调用

自管理敏感词过滤

自管理敏感词过滤（文本）

DFA确定有穷自动机

实现原理：

自管理敏感词过滤（图片）

图片文字识别OCR

相关文章