作者：冰河
QQ：2711098650
微信公众号： 冰河技术
mykit架构中独立出来的mykit-async异步编程框架，本异步框架实现了在Spring的基础上重写和扩展了异步执行的流程，主要提供了如下功能：
1、提供注解声明方式异步执行，对原代码无侵入（解决spring-async对有返回结果的需包装成Future对象问题）；
2、提供编程式异步方法；
3、提供异步事件编程；
4、解决多层异步嵌套带来的线程阻塞问题（目前spring-async依然存在此问题）；
mykit-async 是一个基于Spring的异步并行框架；对高并发下的业务提供异步操作的能力，同时解决了Spring异步多层嵌套带来的线程阻塞问题，主要包括以下几个方面的功能，具体如下：
1、提供注解声明方式异步执行，对原代码无侵入（解决spring-async对有返回结果的需包装成Future对象问题）；
2、提供编程式异步方法；
3、提供异步事件编程；
4、解决多层异步嵌套带来的线程阻塞问题（目前spring-async依然存在此问题）；
mykit-async 架构下主要以Spring为基础实现的异步编程框架，重写和扩展了Spring异步编程的接口和实现，并提供了Spring异步编程中一些没有的功能；
主要是对mykit-async-spring提供的测试工程，测试入口为：io.mykit.async.spring.test.AsyncTest
1、引用mykit-async-spring说明
1)在pom.xml中添加如下配置：
<dependency>
<groupId>io.mykit.async</groupId>
<artifactId>mykit-async-spring</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
2)在项目的Spring配置文件中加上如下配置：
<context:component-scan base-package="io.mykit.async.spring"/>
或者在需要开启异步功能的类上加上如下注解
@EnableAsync
注意：此注解类为：io.mykit.async.spring.annotation.EnableAsync
在Spring的配置文件中加入如下配置：
<context:property-placeholder location="classpath*:properties/async-default.properties, classpath*: properties/async.properties" ignore-unresolvable="true"/>
来引入异步配置文件，classpath*:properties/async-default.properties文件为框架默认提供的异步配置文件
classpath*: properties/async.properties文件为自定义的异步配置文件，注意配置顺序必须为上述示例中的配置顺序，
这样自定义的配置文件属性会覆盖框架默认的配置文件属性。
框架默认的异步配置文件的内容如下：
#核心线程数(默认CPU核数*4)
async.corePoolSize=8
#最大线程数
async.maxPoolSize=24
#最大队列size
async.maxAcceptCount=100
#线程空闲时间
async.keepAliveTime=10000
#拒绝服务处理方式 (不建议修改)
async.rejectedExecutionHandler=CALLERRUN
#是否允许线程自动超时销毁(不建议修改)
async.allowCoreThreadTimeout=true
/**
* Copyright 2018-2118 the original author or authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.mykit.async.spring.test.entity;
/**
* @author liuyazhuang
* @date 2018/9/9 22:31
* @description 测试实体类
* @version 1.0.0
*/
public class User {
private String name;
private int age;
public User() {
}
public User(int age, String name) {
this.age = age;
this.name = name;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
/**
* Copyright 2018-2118 the original author or authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.mykit.async.spring.test.service;
import io.mykit.async.spring.test.entity.User;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
* @author liuyazhuang
* @date 2018/9/9 22:32
* @description 教师Service类
* @version 1.0.0
*/
@Service
public class TeacherService {
private final static Logger logger = LoggerFactory.getLogger(TeacherService.class);
public User addTeacher(User user) {
logger.info("正在添加教师{}", user.getName());
return user;
}
}
/**
* Copyright 2018-2118 the original author or authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.mykit.async.spring.test.service;
import io.mykit.async.spring.annotation.Async;
import io.mykit.async.spring.test.entity.User;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
/**
* @author liuyazhuang
* @date 2018/9/9 22:32
* @description 用户Service类
* @version 1.0.0
*/
@Service
public class UserService {
private final static Logger logger = LoggerFactory.getLogger(TeacherService.class);
@Async
public User addUser(User user) {
logger.info("正在添加用户{}", user.getName());
return user;
}
}
注意：这里的addUser方法，我们加上了@Async注解(这里的注解为：io.mykit.async.spring.annotation.Async)
到此，我们的准备工作完成。
接下来，就是实际测试的类型代码：
@Async
public User addUser(User user) {
logger.info("正在添加用户{}", user.getName());
return user;
}
@Test
public void testAsyncAnnotation() {
User user1 = userService.addUser(new User(34, "李一"));
User user2 = userService.addUser(new User(35, "李二"));
logger.info("异步任务已执行");
logger.info("执行结果 任务1：{} 任务2：{}", user1.getName(), user2.getName());
}
@Test
public void testAsyncSaveUser() {
User user = new User();
user.setName("张三");
user.setAge(18);
UserService service = AsyncTemplate.buildProxy(this.userService, 1000);
service.addUser(user);
logger.info("调用结束");
}
@Test
public void testAsyncTemplate() {
AsyncTemplate.submit(new AsyncCallable<User>() {
@Override
public User doAsync() {
return teacherService.addTeacher(new User(12, "李三"));
}
}, new AsyncFutureCallback<User>() {
@Override
public void onSuccess(User user) {
logger.info("添加用户成功：{}", user.getName());
}
@Override
public void onFailure(Throwable t) {
logger.info("添加用户失败：{}", t);
}
});
logger.info("调用结束");
}
具体测试用例请参见mykit-async-spring-test工程
你在刷抖音，玩游戏的时候，别人都在这里学习，成长，提升，人与人最大的差距其实就是思维。你可能不信，优秀的人，总是在一起。
扫一扫关注冰河技术微信公众号
