springboot 多线程 查询 实例
时间: 2023-11-14 13:03:06 浏览: 43
以下是一个使用Spring Boot多线程进行查询的示例:
首先,在pom.xml中添加以下依赖:
```
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
```
在application.properties中配置数据库连接信息:
```
spring.datasource.url=jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.jpa.show-sql=true
spring.jpa.hibernate.ddl-auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5InnoDBDialect
```
创建一个实体类User:
```
@Entity
@Table(name = "user")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
private String name;
private Integer age;
//省略getter和setter方法
}
```
创建一个Repository接口UserRepository:
```
public interface UserRepository extends JpaRepository<User, Long> {
}
```
创建一个Service类UserService:
```
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
@Async
public CompletableFuture<List<User>> findAll() {
List<User> userList = userRepository.findAll();
return CompletableFuture.completedFuture(userList);
}
}
```
在上面的代码中,我们使用了@Async注解来将findAll方法标记为异步方法。findAll方法返回一个CompletableFuture对象,它表示异步操作的结果。在方法内部,我们通过调用userRepository.findAll()方法来查询所有的用户信息。
创建一个Controller类UserController:
```
@RestController
public class UserController {
@Autowired
private UserService userService;
@GetMapping("/users")
public CompletableFuture<List<User>> findAll() {
return userService.findAll();
}
}
```
在上面的代码中,我们注入了UserService,并在findAll方法上添加了@GetMapping注解来将该方法映射到"/users"路径。在方法内部,我们调用userService.findAll()方法来异步查询所有的用户信息。
最后,运行应用程序并访问http://localhost:8080/users,您将看到所有用户的信息。
注意:在使用@Async注解时,需要在启动类上添加@EnableAsync注解来启用异步方法。