【小工具】WebClient远程调用,返回值将Long类型转换为String,自定义注解

本文主要是介绍【小工具】WebClient远程调用,返回值将Long类型转换为String,自定义注解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

    • 1. 使用WebClient使用远程调用
    • 2. 返回值将Long类型转换为String
    • 3. 自定义注解

1. 使用WebClient使用远程调用

<!-- SpringBoot webflux -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
import org.springframework.http.HttpHeaders;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;import java.util.Map;
===========================================================================/*** 远程调用,发送post请求** @param pathUrl     请求的访问的路径 如:/art/approval* @param requestBody 请求体(也可以是自定义的某个实体类)* @return 请求返回的结果,用R接收*/
private R remotePostCall(String pathUrl, Map<String, String> requestBody) {WebClient client = WebClient.create();// 发起POST请求,并设置请求头和请求体Mono<R> responseMono = client.post().uri(uri + pathUrl)// 设置请求头.header(HttpHeaders.CONTENT_TYPE, "application/json;charset=UTF-8").header(HttpHeaders.AUTHORIZATION, "you token")// 设置请求体.body(BodyInserters.fromValue(requestBody)).retrieve()// 将返回结果转换为R类型.bodyToMono(R.class);R block = responseMono.block();return block;
}

这个请求是异步的。在代码中,使用了 Mono 来表示返回结果, Mono 是一个Reactive类型,它表示可能会在未来某个时间点返回的结果。通过使用 bodyToMono() 方法将返回结果转换为 Mono 类型,然后使用 block() 方法来阻塞等待结果的返回。这种异步的方式可以提高应用程序的性能和并发处理能力。

可以使用 subscribe() 方法来实现不阻塞等待结果的返回。通过调用 subscribe() 方法,可以注册一个回调函数来处理异步返回的结果。这样,可以在结果返回时执行相应的操作,不需要阻塞等待。

private void remotePostCall(String pathUrl, Map<String, String> requestBody) {WebClient client = WebClient.create();// 发起POST请求,并设置请求头和请求体client.post().uri(uri + pathUrl)// 设置请求头.header(HttpHeaders.CONTENT_TYPE, "application/json;charset=UTF-8").header(HttpHeaders.AUTHORIZATION, "you token")// 设置请求体.body(BodyInserters.fromValue(requestBody)).retrieve()// 处理返回结果.bodyToMono(R.class).subscribe(result -> {// 在这里处理异步返回的结果// 可以执行相应的操作System.out.println("异步结果:" + result);});
}

2. 返回值将Long类型转换为String

在分布式项目中,我们主键喜欢使用雪花Id,可能会遇到一些精度丢失或数据截断的问题,特别是在处理大整数时。将 Long 类型转换为 String 类型可以避免这些问题,并确保数据的准确性和完整性。

通过自定义Jackson的对象映射器行为,可以确保在分布式项目中处理长整型数据时的一致性和可靠性。

import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class JacksonConfiguration {@Beanpublic Jackson2ObjectMapperBuilderCustomizer jackson2ObjectMapperBuilderCustomizer() {return builder -> {// 返回结果时,统一将 Long 转换成 Stringbuilder.serializerByType(Long.class, ToStringSerializer.instance);};}
}

3. 自定义注解

  1. 自定义注解
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** @Author shang tf* @createTime 2023/8/15 10:35* @Version 1.0.0* 需要成为数商后才能访问*/
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD,ElementType.TYPE})
public @interface HasPayAuth {}
  1. 切面拦截注解
import cn.creatoo.common.core.constant.Constants;
import cn.creatoo.common.security.utils.BdSecurityUtils;
import cn.creatoo.system.exception.NotPayAuthException;
import cn.creatoo.system.domain.BdTerminalUserAuth;
import cn.creatoo.system.mapper.BdTerminalUserAuthMapper;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.time.LocalDateTime;/*** @Author shang tf* @createTime 2023/8/15 10:41* @Version 1.0.0*/
@Aspect
@Component
public class HasPayAuthAspect {@Pointcut("@annotation(xx.xxxxx.system.annotation.HasPayAuth)")private void pointcut() {}@Autowiredprivate BdTerminalUserAuthMapper bdTerminalUserAuthMapper;@Around("pointcut()")public Object around(ProceedingJoinPoint joinPoint) throws Throwable {// 查询当前登录账号信息Long userId = BdSecurityUtils.getUserId();QueryWrapper<BdTerminalUserAuth> wrapper = new QueryWrapper<>();wrapper.eq("user_id", userId);BdTerminalUserAuth bdTerminalUserAuth = bdTerminalUserAuthMapper.selectOne(wrapper);if (ObjectUtil.isEmpty(bdTerminalUserAuth)){throw new NotPayAuthException("未提交认证,请先认证");}// 账号状态if (!bdTerminalUserAuth.getStatus().equals(Constants.AUTH_AUDIT_CERTIFIED)){throw new NotPayAuthException("账号未认证,请先认证");}// 判断账号是否被禁用if (bdTerminalUserAuth.getIsAble().equals(Constants.AUTH_IS_ABLE_OFF)){throw new NotPayAuthException("账号被禁用,请联系管理员");}// 放行return joinPoint.proceed(joinPoint.getArgs());}
}
  1. 自定义异常

自定义异常时需要继承RuntimeException

/*** @Author shang tf* @createTime 2023/8/15 10:58* @Version 1.0.0* 资质认证过期或未认证异常*/
public class NotPayAuthException extends RuntimeException {public NotPayAuthException() {}public NotPayAuthException(String message){super(message);}
}

这篇关于【小工具】WebClient远程调用,返回值将Long类型转换为String,自定义注解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/321066

相关文章

Python办公自动化实战之打造智能邮件发送工具

《Python办公自动化实战之打造智能邮件发送工具》在数字化办公场景中,邮件自动化是提升工作效率的关键技能,本文将演示如何使用Python的smtplib和email库构建一个支持图文混排,多附件,多... 目录前言一、基础配置:搭建邮件发送框架1.1 邮箱服务准备1.2 核心库导入1.3 基础发送函数二、

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压:数据存储与传输的优化核心1. zip/unzip:通用压缩格式的便捷操作2.

一文详解Git中分支本地和远程删除的方法

《一文详解Git中分支本地和远程删除的方法》在使用Git进行版本控制的过程中,我们会创建多个分支来进行不同功能的开发,这就容易涉及到如何正确地删除本地分支和远程分支,下面我们就来看看相关的实现方法吧... 目录技术背景实现步骤删除本地分支删除远程www.chinasem.cn分支同步删除信息到其他机器示例步骤

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示

sqlite3 命令行工具使用指南

《sqlite3命令行工具使用指南》本文系统介绍sqlite3CLI的启动、数据库操作、元数据查询、数据导入导出及输出格式化命令,涵盖文件管理、备份恢复、性能统计等实用功能,并说明命令分类、SQL语... 目录一、启动与退出二、数据库与文件操作三、元数据查询四、数据操作与导入导出五、查询输出格式化六、实用功

Python中Tensorflow无法调用GPU问题的解决方法

《Python中Tensorflow无法调用GPU问题的解决方法》文章详解如何解决TensorFlow在Windows无法识别GPU的问题,需降级至2.10版本,安装匹配CUDA11.2和cuDNN... 当用以下代码查看GPU数量时,gpuspython返回的是一个空列表,说明tensorflow没有找到