* 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 *
* http://www.apache.org/licenses/LICENSE-2.0 *
* 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; } } ``` ### 2、创建测试的Service——TeacherService ``` /** * Copyright 2018-2118 the original author or authors. *
* 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 *
* http://www.apache.org/licenses/LICENSE-2.0 *
* 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; } } ``` ### 3、创建测试Service——UserService ``` /** * Copyright 2018-2118 the original author or authors. *
* 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 *
* http://www.apache.org/licenses/LICENSE-2.0 *
* 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)
到此，我们的准备工作完成。
接下来，就是实际测试的类型代码：
## 框架功能演示
### 1、添加@Async注解
```
@Async
public User addUser(User user) {
logger.info("正在添加用户{}", user.getName());
return user;
}
```
### 2、测试异步执行调用
```
@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());
}
```
### 3、测试编程式异步
```
@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("调用结束");
}
```
### 4、测试异步事件编程
```
@Test
public void testAsyncTemplate() {
AsyncTemplate.submit(new AsyncCallable