个人中心
文章发布
退出
作者热门文章
- Java锁的逻辑（结合对象头和ObjectMonitor）
- 还在用饼状图？来瞧瞧这些炫酷的百分比可视化新图形（附代码实现）⛵
- 自动注册实体类到EntityFrameworkCore上下文，并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
24
4
随着数据量的增长，发现系统在与其他系统交互时，批量接口会出现超时现象，发现原批量接口在实现时，没有做分片处理，当数据过大时或超过其他系统阈值时，就会出现错误。由于与其他系统交互比较多，一个一个接口做分片优化，改动量较大，所以考虑通过AOP解决此问题.
AOP （Aspect Orient Programming）,直译过来就是 面向切面编程。AOP 是一种编程思想，是面向对象编程（OOP）的一种补充。面向对象编程将程序抽象成各个层次的对象，而面向切面编程是将程序抽象成各个切面.
Spring 中的 AOP 是通过动态代理实现的。 Spring AOP 不能拦截对对象字段的修改，也不支持构造器连接点,我们无法在 Bean 创建时应用通知.
自定义分片处理分三个部分：自定义注解（MethodPartAndRetryer）、重试器（RetryUtil）、切面实现(RetryAspectAop).
源码 。
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public
@interface MethodPartAndRetryer {
/*
*
* 失败重试次数
* @return
*/
int
times()
default
3
;
/*
*
* 失败间隔执行时间 300毫秒
* @return
*/
long
waitTime()
default
300L
;
/*
*
* 分片大小
* @return
*/
int
parts()
default
200
;
}
。
@interface说明这个类是个注解。 @Target是这个注解的作用域 。
public
enum
ElementType {
/*
* 类、接口(包括注释类型)或枚举声明
*/
TYPE,
/*
* 字段声明(包括枚举常量)
*/
FIELD,
/*
* 方法声明
*/
METHOD,
/*
* 正式的参数声明
*/
PARAMETER,
/*
* 构造函数声明
*/
CONSTRUCTOR,
/*
* 局部变量声明
*/
LOCAL_VARIABLE,
/*
* 注释类型声明
*/
ANNOTATION_TYPE,
/*
* 程序包声明
*/
PACKAGE,
/*
*类型参数声明
*/
TYPE_PARAMETER,
/*
*类型的使用
*/
TYPE_USE
}
@Retention注解的生命周期
public
enum
RetentionPolicy {
/*
* 编译器处理完后不存储在class中
*/
SOURCE,
/*
*注释将被编译器记录在类文件中，但不需要在运行时被VM保留。 这是默认值
*/
CLASS,
/*
*编译器存储在class中，可以由虚拟机读取
*/
RUNTIME
}
。
3.2 RetryUtil 。
源码 。
public
class
RetryUtil<V>
{
public
Retryer<V> getDefaultRetryer(
int
times,
long
waitTime) {
Retryer
<V> retryer = RetryerBuilder.<V>
newBuilder()
.retryIfException()
.retryIfRuntimeException()
.retryIfExceptionOfType(Exception.
class
)
.withWaitStrategy(WaitStrategies.fixedWait(waitTime, TimeUnit.MILLISECONDS))
.withStopStrategy(StopStrategies.stopAfterAttempt(times))
.build();
return
retryer;
}
}
。
说明 。
源码:
public
class
RetryAspectAop {
public
Object around(final ProceedingJoinPoint point) throws Throwable {
Object result
=
null
;
final Object[] args
=
point.getArgs();
boolean isHandler1
=
isHandler(args);
if
(isHandler1) {
String className
=
point.getSignature().getDeclaringTypeName();
String methodName
=
point.getSignature().getName();
Object firstArg
= args[
0
];
List
<Object> paramList = (List<Object>
) firstArg;
//
获取方法信息
Method method =
getCurrentMethod(point);
//
获取注解信息
MethodPartAndRetryer retryable = AnnotationUtils.getAnnotation(method, MethodPartAndRetryer.
class
);
//
重试机制
Retryer<Object> retryer =
new
RetryUtil<Object>
().getDefaultRetryer(retryable.times(),retryable.waitTime());
//
分片
List<List<Object>> requestList =
Lists.partition(paramList, retryable.parts());
for
(List<Object>
partList : requestList) {
args[
0
] =
partList;
Object tempResult
= retryer.call(
new
Callable<Object>
() {
@Override
public
Object call() throws Exception {
try
{
return
point.proceed(args);
}
catch
(Throwable throwable) {
log.error(String.format(
"
分片重试报错,类%s-方法%s
"
,className,methodName),throwable);
throw
new
RuntimeException(
"
分片重试出错
"
);
}
}
});
if
(
null
!=
tempResult) {
if
(tempResult instanceof Boolean) {
if
(!
((Boolean) tempResult)) {
log.error(String.format(
"
分片执行报错返回类型不能转化bolean,类%s-方法%s
"
,className,methodName));
throw
new
RuntimeException(
"
分片执行报错!
"
);
}
result
=
tempResult;
}
else
if
(tempResult instanceof List) {
if
(result ==
null
){
result
=
Lists.newArrayList();
}
((List) result).addAll((List) tempResult);
}
else
{
log.error(String.format(
"
分片执行返回的类型不支持,类%s-方法%s
"
,className,methodName));
throw
new
RuntimeException(
"
不支持该返回类型
"
);
}
}
else
{
log.error(String.format(
"
分片执行返回的结果为空,类%s-方法%s
"
,className,methodName));
throw
new
RuntimeException(
"
调用结果为空
"
);
}
}
}
else
{
result
=
point.proceed(args);
}
return
result;
}
private
boolean isHandler(Object[] args) {
boolean isHandler
=
false
;
if
(
null
!= args && args.length >
0
) {
Object firstArg
= args[
0
];
//
如果第一个参数是list 并且数量大于1
if
(firstArg!=
null
&&firstArg instanceof List &&((List) firstArg).size()>
1
) {
isHandler
=
true
;
}
}
return
isHandler;
}
private
Method getCurrentMethod(ProceedingJoinPoint point) {
try
{
Signature sig
=
point.getSignature();
MethodSignature msig
=
(MethodSignature) sig;
Object target
=
point.getTarget();
return
target.getClass().getMethod(msig.getName(), msig.getParameterTypes());
}
catch
(NoSuchMethodException e) {
throw
new
RuntimeException(e);
}
}
}
。
说明:
getCurrentMethod：获取方法信息即要做分片的批量调用的接口。 isHandler1：判断是否要做分片处理，只有第一参数是list并且list 的值大于1时才做分片处理。 around：具体分片逻辑.
。
@MethodPartAndRetryer(parts=
100
)
public
Boolean writeBackOfGoodsSN(List<SerialDTO> listSerial,ObCheckWorker workerData)
。
只要在需要做分片的批量接口方法上，加上MethodPartAndRetryer注解就可以，重试次数、重试间隔时间和分片大小可以在注解时设置，也可以使用默认值.
通过自定义分片工具，可以快速地对老代码进行分片处理，而且增加了重试机制，提高了程序的可用性，提高了对老代码的重构效率.
。
最后此篇关于基于Spring-AOP的自定义分片工具的文章就讲到这里了,如果你想了解更多关于基于Spring-AOP的自定义分片工具的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
24
4
0
我在同一类中的方法之间进行方法调用并应用事务建议时遇到问题。 Spring Framework .NET 文档声明它支持基于组合和继承的代理，并且您可以强制 Spring 创建要实例化的基于继承的代理
我理解这些原则，但我很难看到实际应用程序在少数几个之外。请赐教；) 最佳答案 问任何支持人员:日志记录不是 AOP 的一个好的应用程序。他们不在乎应用程序内部调用了什么方法。他们关心应用程序正在执行的
我知道以前有人问过这个问题，但这是一年半前的事了，尽管我认为现在可能是重新提问的时候了。我也认识到它可能被视为主观的，但我想有一些客观的原因支持/反对 AOP。 我会对 感兴趣谁在使用 AOP 在软件
我想这个问题以前有人问过，但我无法立即找到相关的 SO 问题或其他地方的相关文章。 令我震惊的是，AOP 中的某些术语相当奇怪。看来我不是唯一一个-这个article ，例如，指出“不幸的是，AOP
面向切面编程可能的和严重的缺点是什么？ 例如:新手的神秘调试(可读性影响) 最佳答案 工具链支持不佳 - 调试器、分析器等可能不了解 AOP，因此可能会在代码上工作，就好像所有方面都已被过程代码替换
这两种AOP框架的优缺点是什么？我使用 Unity 作为我的 aop 框架，但我猜想编译时 aop 框架(例如 postsharp)可能比运行时 aop 框架具有更好的性能？看起来运行时 aop 框架
我现在正在学习 spring aop，我不知道将上下文参数传递给建议。 请注意，我指的是 context 参数，而不是 normal 参数。 传递普通参数很简单，例如: a join point: p
来自类路径资源 [ApplicationContextAOP.xml] 的 XML 文档中的第 13 行无效；嵌套异常是 org.xml.sax.SAXParseException: cvc-comp
我使用 spring boot 2 和 spring security。 使用 aop，我搜索以获取调用该方法的用户。 @Aspect @Component public class LogAspec
我最近一直在一个非常简单的应用程序上尝试 Spring 的 AOP 功能，并且我坚持在适当的时间运行该方法，这意味着该部分中定义的方法应该在 中定义的方法之后运行 在我的代码中，这两个方法都在主方法中
我试图在网上找到如何通过 Ninject 使用 AOP 的例子。有人可以确认 AOP 在 Ninject 2 中是否可用而不使用外部库(即 CaSTLe Windsor？)。 如果可以的话，您能否发布
Aop配置已经在我的项目中完成了。为此添加了以下配置。问题是当下面的代码没有注释时，不会调用 formService 中的方法。因此我得到空指针异常。知道问题出在哪里吗？我附上了下面的代码.. AOP
我是 AOP 的新手。我遇到了这样的问题。 package org.suman.Aspect; import org.aspectj.lang.annotation.Aspect; import or
在我们的企业应用程序中，我们希望将日志记录、度量等横切关注点作为方面。我们已经准备好了 aspectj 建议(来自我们现有的 java 应用程序)，但我没有找到将 aspectj 与 Grails 集
我正在向外部系统编写 Web 服务。 我的服务包装类有许多方法可以调用Web服务的所有soap接口(interface)。该调用可能会引发异常，然后该异常会自动触发重新连接到 Web 服务。 为了处理
已结束。此问题不符合 Stack Overflow guidelines .它目前不接受答案。 我们不允许提出有关书籍、工具、软件库等方面的建议的问题。您可以编辑问题，以便用事实和引用来回答它。 关闭
我是 spring 框架的新手，正在尝试一些示例来理解 AOP，这是我到目前为止所做的，但它不起作用。 问题是我一添加 对于 spring.xml，我的构建失败说无法创建具有空指针异常的 bean。但
下面是我要创建的方面。我想将两个切入点表达式合并为一个。我已经看到这可以使用带注释的切入点来完成，但是 xml 中的相同语法失败了。谁能帮帮我？ 提前致谢 最佳答案
我对 Spring 事务管理感到困惑。在我的应用程序中，我在服务类中使用 @Transactional 实现了事务管理。我配置的 spring.xml 如下:
我知道围绕 Controller 方法编写 AOP 建议的标准方法，并且如果在 Controller 方法中声明，您可以访问 HttpServletRequest arg。 但我的情况是我有一个翻译服
我是一名优秀的程序员,十分优秀！