springboot通过注解实现多线程

最新推荐文章于 2023-06-25 22:54:25 发布
最新推荐文章于 2023-06-25 22:54:25 发布
阅读量7.9k 收藏 16
点赞数 1
分类专栏： spring
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/aiyongbo123456/article/details/86635455
版权

1、springboot启动类中添加 @EnableAsync
 

package com.zr.gktjweb;


import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class GktjwebApplication {

    public static void main(String[] args) {

        SpringApplication.run(GktjwebApplication.class, args);
    }

}

2、在调用类之外的另一个类方法中添加：


package com.zr.gktjweb.aspect;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

//@Component
public class AsyThread {
//    @Override
    @Async
    public void run() {
        System.out.println("---------异步线程---------"+Thread.currentThread().getName());
    }
}

3、在另一个类中调用此方法：

package com.zr.gktjweb.controller.login;

import com.zr.gktjweb.aspect.AsyThread;
import com.zr.gktjweb.common.HttpClientUtil;
import com.zr.gktjweb.common.ResponseBean;
import com.zr.gktjweb.constant.SysCode;
import com.zr.gktjweb.model.SysUser;
import com.zr.gktjweb.util.ComUtil;
import com.zr.gktjweb.util.JSONUtils;
import com.zr.gktjweb.util.UserUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;

@Api(tags = "登录")
@Controller
public class LoginController {
    @Value("${baseurl}")
    private String baseurl;
    @Value("${login_url}")
    private String loginUrl;
    @Value("${logout_url}")
    private String logoutUrl;
    @Value("${syslogin_url}")
    private String sysloginUrl;
    @Value("${updateUserSessionByusername_url}")
    private String updateUserSessionByusernameUrl;
    @Value("${updatePass_url}")
    private String updatePassUrl;
    private static final Logger LOGGER = LoggerFactory.getLogger(LoginController.class);

    @ApiOperation(value = "登录", notes = "登录验证")
    @ApiImplicitParams({@ApiImplicitParam(name = "username", value = "姓名", required = true, dataType = "String"),
            @ApiImplicitParam(name = "password", value = "密码", required = true, dataType = "String")
    })
    @RequestMapping(value = "/login.do", method = RequestMethod.POST)
    @ResponseBody
    public ResponseBean login(String username, String password) {
        String url = baseurl + loginUrl;
        Map<String, String> map = new HashMap<>();
        map.put("username", username);
        map.put("password", password);
        String result = "";
        new AsyThread().run();
        System.out.println("--------当前线程--------"+Thread.currentThread().getName());
        //请求服务失败
        try {
            result = HttpClientUtil.doPost(url, map);
        } catch (Exception e) {
            e.printStackTrace();
            LOGGER.error("用户登录", e);
            return new ResponseBean(SysCode.errCode, "系统异常，请联系管理员", "");
        }
        JSONObject json = JSONObject.fromObject(result);
        //登录验证未通过
        if (!json.getString("code").equals(SysCode.successCode + "")) {
            ResponseBean responseBean = JSONUtils.jsonToObject(ResponseBean.class, result);
            return responseBean;
        }
        //验证通过，在session中设置token
        JSONObject dataJson = (JSONObject) json.get("data");
        String userJson = dataJson.getString("user");
        SysUser sysUser = JSONUtils.jsonToObject(SysUser.class, userJson);
        JSONObject tokenJson = (JSONObject) dataJson.get("token");
        String token = tokenJson.getString("token");
        UserUtil.setToken(token);
        UserUtil.setUserSession(sysUser);
        //第一次登陆修改密码
        if(ComUtil.isEmpty(sysUser.getLastlogindate())){
            return new ResponseBean(SysCode.retPwdCode, "", "");
        }
        String url1 = "/index.html";
        Map<String, Object> resMap = new HashMap<>();
        resMap.put("url", url1);
        return new ResponseBean(SysCode.successCode, "登录成功", resMap);
    }

    /**
     * 注销登录
     *
     * @param request
     * @return
     */
    @RequestMapping("/loginout.do")
    public String loginOut(HttpServletRequest request) {
        request.getSession().invalidate();
        String url=baseurl+logoutUrl;
        HttpClientUtil.doGet(url);
        return "redirect:/";
    }

    @PostMapping("/users/updatePass.do")
    @ApiOperation(value = "修改密码")
    @ResponseBody
    public ResponseBean changePassword(String username, String oldPassword, String newPassword) {
        String url = baseurl + updatePassUrl;
        Map<String, String> map = new HashMap<>();
        map.put("username", username);
        map.put("oldPassword", oldPassword);
        map.put("newPassword", newPassword);
        String result = HttpClientUtil.doPost(url, map);
        ResponseBean responseBean = JSONUtils.jsonToObject(ResponseBean.class, result);
        //修改密码后重新登录
        ResponseBean loginResult=login(username,newPassword);
        //登录验证未通过
        if (!loginResult.getCode().toString().equals(SysCode.successCode + "")) {
            return loginResult;
        }
        return responseBean;
    }

    @ApiOperation(value = "当前登录用户")
    @GetMapping("/sys/login.do")
    @ResponseBody
    public SysUser getLoginInfo() {
        return UserUtil.getCurrentUser();
    }
}

调用controller层后结果如下：

实现异步失败。
5、后改为将实现异步的类，注入到controller层。通过spring生成的bean来调用异步方法：

package com.zr.gktjweb.aspect;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

@Component
public class AsyThread {
//    @Override
    @Async
    public void run() {
        System.out.println("---------异步线程---------"+Thread.currentThread().getName());
    }
}


package com.zr.gktjweb.controller.login;

import com.zr.gktjweb.aspect.AsyThread;
import com.zr.gktjweb.common.HttpClientUtil;
import com.zr.gktjweb.common.ResponseBean;
import com.zr.gktjweb.constant.SysCode;
import com.zr.gktjweb.model.SysUser;
import com.zr.gktjweb.util.ComUtil;
import com.zr.gktjweb.util.JSONUtils;
import com.zr.gktjweb.util.UserUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;

@Api(tags = "登录")
@Controller
public class LoginController {
    @Value("${baseurl}")
    private String baseurl;
    @Value("${login_url}")
    private String loginUrl;
    @Value("${logout_url}")
    private String logoutUrl;
    @Value("${syslogin_url}")
    private String sysloginUrl;
    @Value("${updateUserSessionByusername_url}")
    private String updateUserSessionByusernameUrl;
    @Value("${updatePass_url}")
    private String updatePassUrl;
    private static final Logger LOGGER = LoggerFactory.getLogger(LoginController.class);

    @Autowired
    AsyThread asyThread;


    @ApiOperation(value = "登录", notes = "登录验证")
    @ApiImplicitParams({@ApiImplicitParam(name = "username", value = "姓名", required = true, dataType = "String"),
            @ApiImplicitParam(name = "password", value = "密码", required = true, dataType = "String")
    })
    @RequestMapping(value = "/login.do", method = RequestMethod.POST)
    @ResponseBody
    public ResponseBean login(String username, String password) {
        String url = baseurl + loginUrl;
        Map<String, String> map = new HashMap<>();
        map.put("username", username);
        map.put("password", password);
        String result = "";
        asyThread.run();
        System.out.println("--------当前线程--------"+Thread.currentThread().getName());
        //请求服务失败
        try {
            result = HttpClientUtil.doPost(url, map);
        } catch (Exception e) {
            e.printStackTrace();
            LOGGER.error("用户登录", e);
            return new ResponseBean(SysCode.errCode, "系统异常，请联系管理员", "");
        }
        JSONObject json = JSONObject.fromObject(result);
        //登录验证未通过
        if (!json.getString("code").equals(SysCode.successCode + "")) {
            ResponseBean responseBean = JSONUtils.jsonToObject(ResponseBean.class, result);
            return responseBean;
        }
        //验证通过，在session中设置token
        JSONObject dataJson = (JSONObject) json.get("data");
        String userJson = dataJson.getString("user");
        SysUser sysUser = JSONUtils.jsonToObject(SysUser.class, userJson);
        JSONObject tokenJson = (JSONObject) dataJson.get("token");
        String token = tokenJson.getString("token");
        UserUtil.setToken(token);
        UserUtil.setUserSession(sysUser);
        //第一次登陆修改密码
        if(ComUtil.isEmpty(sysUser.getLastlogindate())){
            return new ResponseBean(SysCode.retPwdCode, "", "");
        }
        String url1 = "/index.html";
        Map<String, Object> resMap = new HashMap<>();
        resMap.put("url", url1);
        return new ResponseBean(SysCode.successCode, "登录成功", resMap);
    }

    /**
     * 注销登录
     *
     * @param request
     * @return
     */
    @RequestMapping("/loginout.do")
    public String loginOut(HttpServletRequest request) {
        request.getSession().invalidate();
        String url=baseurl+logoutUrl;
        HttpClientUtil.doGet(url);
        return "redirect:/";
    }

    @PostMapping("/users/updatePass.do")
    @ApiOperation(value = "修改密码")
    @ResponseBody
    public ResponseBean changePassword(String username, String oldPassword, String newPassword) {
        String url = baseurl + updatePassUrl;
        Map<String, String> map = new HashMap<>();
        map.put("username", username);
        map.put("oldPassword", oldPassword);
        map.put("newPassword", newPassword);
        String result = HttpClientUtil.doPost(url, map);
        ResponseBean responseBean = JSONUtils.jsonToObject(ResponseBean.class, result);
        //修改密码后重新登录
        ResponseBean loginResult=login(username,newPassword);
        //登录验证未通过
        if (!loginResult.getCode().toString().equals(SysCode.successCode + "")) {
            return loginResult;
        }
        return responseBean;
    }

    @ApiOperation(value = "当前登录用户")
    @GetMapping("/sys/login.do")
    @ResponseBody
    public SysUser getLoginInfo() {
        return UserUtil.getCurrentUser();
    }
}

访问contrller层后，结果如下：

成功实现异步。

【SpringBoot深入浅出系列】SpringBoot之多线程
邓邓子的博客
01-21 1216
多线程编程是提升 Spring Boot 应用性能和响应速度的重要手段。通过本文的介绍，我们了解了多线程的基本概念、Spring Boot 中的多线程应用场景、实现方式以及常见问题的解决方案。在实际开发中，我们需要根据具体的业务需求和场景，合理运用多线程技术，以实现高效、稳定的应用程序。希望本文能为读者在 Spring Boot 多线程编程方面提供有益的参考和帮助，让大家能够更好地掌握和应用这一强大的技术。
springboot 多线程实现
m0_67393295的博客
07-28 2393
有时候，，如果，系统就要，有时会。而且当线程数量太多时，
spring boot注解事务+多线程
01-25
spring boot 纯注解方法事务控制回滚，注解+简单配置文件使用多线程demo
SpringBoot里使用注解开启多线程
qq_42794038的博客
11-27 2482
1.第一步需要在主方法上加@EnableAsync注解 2.第二步创建一个配置类，如下: @Configuration @EnableAsync public class AsyncTaskConfig implements AsyncConfigurer{ @Override @Bean public Excutor getAsyncExecutor(...
Java中的线程、进程、多线程的概念
柯基的博客
09-16 402
1、线程（Thread）： 线程是进程的基本执行单元，一个进程的所有任务都在线程中执行 进程要想执行任务，必须得有线程，进程至少要有一条线程 程序启动会默认开启一条线程，这条线程被称为主线程或 UI 线程 2、进程： 进程是指在系统中正在运行的一个应用程序 每个进程之间是独立的，每个进程均运行在其专用的且受保护的内存 3、多线程的意义 优点： 能适当提高程序的执行效率 能适当提高资源的利用率（CPU，内存） 线程上的任务执行完成后，线程会自动销毁 缺点： 开启线程需要占用一定的内存空间（默认情况下，每一个线
springboot中的@Async多线程注解
Shu2018ai的博客
03-01 1758
springboot中的@Async多线程注解
SpringBoot版本的多线程下载文件，分段下载文件
11-24
本篇将深入探讨如何利用SpringBoot实现多线程下载文件以及分段下载文件的技术。 首先，多线程下载文件是一种提高下载速度的方法，通过将大文件分成多个小部分，每个部分由一个单独的线程负责下载，从而充分利用多核...
Springboot实现多线程注入bean的工具类操作
09-07
总之，Spring Boot通过`ApplicationContextAware`接口和相关的工具类，使得在多线程环境中获取和使用bean变得简单易行，避免了手动管理bean实例的问题，保证了代码的整洁和可维护性。同时，这种方式也确保了bean的...
springboot中@Async多线程注解使用
背景模版
07-02 1万+
在没有@Async注解之前我们需要写一个多线程低吗的话需要使用到JDK原生的多线程方法，代码十分冗余，当有了spring的@Async注解后就十分方便了，本次就详细介绍一下@Async注解的使用 1创建线程池 当在一个方法上标注了@Async注解之后，在被调用的时候主线程会主动使用多线程来调用此方法，但是当我们需要线程池来堆多线程进行管理的时候就需要使用到配置类线程池的Bean，如下 @Con...
SpringBoot使用多线程注解@async
zhangshengqiang168的博客
10-08 1048
1.主类 import com.cnczsq.mall.elephant.utils.SpringUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import...
Springboot中@Async多线程注解使用
Jak的博客
08-19 429
https://blog.csdn.net/weixin_43168010/article/details/94436901
SpringBoot使用多线程
热门推荐
csdn_life18的博客
02-23 3万+
一、概述 1、为什么使用多线程 在我们开发系统过程中，经常会处理一些好费时间的任务（如：向数据库中插入上百万数据，将会导致系统等待），这个时候就会自然想到使用多线程。 2、为什么使用Spring来实现多线程 使用Spring比使用JDK原生的并发API更简单。（@Async就能解决）。 一般的开发环境都会集成Spring框架，Bean也都交给Spring来管理，因此，Spring实现多线程更简单。 3、为什么需要使用异步 传统的调用方式：调用一个服务，需要等待服务调用完成后，才能执行后面的代码，
自定义注解实现springboot 多线程事务(基于@Async注解的多线程)
weixin_69672118的博客
11-14 4397
本文是基于springboot的@Async注解开启多线程, 并通过自定义注解和AOP实现的多线程事务, 避免繁琐的手动提交/回滚事务 (CV即用, 参数齐全, 无需配置)
SpringBoot异步多线程调用注解@Async使用和CountDown
liuyuinsdu的专栏
03-01 1985
关于多线成调用可能大家用的比较多的是JDK的多线程，springboot1.5+,项目框架中集成了异步多线程操作配置，在这里和大家分享一下springboot的异步多线程注解使用,先一步一步来以代码的形式讲解大家可能会遇到的问题。 一：创建方法，然后在方法上添加@Async注解，然后还需要在@SpringBootApplication启动类或者@configure注解类上 添加注解@EnableAsync启动多线程注解，@Async就会对标注的方法开启异步多线程调用，注意，这个方法的类一定要交给spri.
SpringBoot 中的多线程事务处理太繁琐？一个自定义注解直接搞定！
最新发布
好好学java
06-25 462
前言我们开发的时候常常会遇到多线程事务的问题。以为添加了@Transactional注解就行了，其实你加了注解之后会发现事务失效。原因：数据库连接spring是放在threadLocal里面，多线程场景下，拿到的数据库连接是不一样的，即是属于不同事务。本文是基于springboot的@Async注解开启多线程,，并通过自定义注解和AOP实现的多线程事务，避免繁琐的手动提交/回滚事务 (CV即用、...
Springboot使用@Async多线程注解
李小德不晓得的博客
11-06 1万+
本文主要讲解 @Async 的基本使用及和 AsyncConfigurer 接口的关系，对于线程池的作用、线程池的参数(核心线程、最大线程......)及运行原理，这里不再过多赘述。
springboot 一个自定义注解直接搞定多线程事务
huang714的专栏
06-25 778
本文是使用了两个注解共同作用实现的，主线程当做协调者，各子线程作为参与者/*** 多线程事务注解: 主事务*///子线程数量/*** 多线程事务注解: 子事务*/两个注解都是用在方法上的，须配合@Transactional(rollbackFor = Exception.class)一起使用@MainTransaction注解。
springboot通过注解实现多数据源切换
05-13
在Spring Boot中，我们可以通过注解实现多数据源切换。具体步骤如下： 1. 配置多个数据源 在application.properties文件中配置多个数据源，例如： ``` # 主数据源 spring.datasource.url=jdbc:mysql://localhost:3306/db1 spring.datasource.username=root spring.datasource.password=123456 spring.datasource.driver-class-name=com.mysql.jdbc.Driver # 从数据源 spring.datasource.secondary.url=jdbc:mysql://localhost:3306/db2 spring.datasource.secondary.username=root spring.datasource.secondary.password=123456 spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver ``` 2. 创建数据源配置类 创建两个数据源配置类，用于配置不同的数据源，例如： ``` @Configuration @MapperScan(basePackages = "com.example.demo.mapper.primary", sqlSessionTemplateRef = "primarySqlSessionTemplate") public class PrimaryDataSourceConfig { @Bean(name = "primaryDataSource") @ConfigurationProperties(prefix = "spring.datasource") public DataSource dataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "primarySqlSessionFactory") public SqlSessionFactory sqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Bean(name = "primarySqlSessionTemplate") public SqlSessionTemplate sqlSessionTemplate(@Qualifier("primarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) { return new SqlSessionTemplate(sqlSessionFactory); } } @Configuration @MapperScan(basePackages = "com.example.demo.mapper.secondary", sqlSessionTemplateRef = "secondarySqlSessionTemplate") public class SecondaryDataSourceConfig { @Bean(name = "secondaryDataSource") @ConfigurationProperties(prefix = "spring.datasource.secondary") public DataSource dataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "secondarySqlSessionFactory") public SqlSessionFactory sqlSessionFactory(@Qualifier("secondaryDataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Bean(name = "secondarySqlSessionTemplate") public SqlSessionTemplate sqlSessionTemplate(@Qualifier("secondarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) { return new SqlSessionTemplate(sqlSessionFactory); } } ``` 其中，@MapperScan注解用于扫描Mapper接口，sqlSessionTemplateRef属性指定使用的SqlSessionTemplate。 3. 创建数据源切换注解 创建一个数据源切换注解，用于动态切换数据源，例如： ``` @Target({ElementType.TYPE, ElementType.METHOD}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface DataSource { String value() default "primary"; } ``` 其中，value属性指定使用的数据源，默认为主数据源。 4. 创建数据源切换切面 创建一个数据源切换切面，用于根据注解动态切换数据源，例如： ``` @Aspect @Component public class DataSourceAspect { @Pointcut("@annotation(com.example.demo.annotation.DataSource)") public void dataSourcePointCut() { } @Before("dataSourcePointCut()") public void before(JoinPoint joinPoint) { MethodSignature signature = (MethodSignature) joinPoint.getSignature(); DataSource dataSource = signature.getMethod().getAnnotation(DataSource.class); if (dataSource != null) { DataSourceContextHolder.setDataSource(dataSource.value()); } } @After("dataSourcePointCut()") public void after(JoinPoint joinPoint) { DataSourceContextHolder.clearDataSource(); } } ``` 其中，@Pointcut注解用于定义切点，@Before注解用于在切点方法执行之前切换数据源，@After注解用于在切点方法执行之后清除数据源。 5. 创建数据源上下文 创建一个数据源上下文，用于保存当前线程使用的数据源，例如： ``` public class DataSourceContextHolder { private static final ThreadLocal<String> contextHolder = new ThreadLocal<>(); public static void setDataSource(String dataSource) { contextHolder.set(dataSource); } public static String getDataSource() { return contextHolder.get(); } public static void clearDataSource() { contextHolder.remove(); } } ``` 6. 使用注解切换数据源 在需要切换数据源的方法或类上加上@DataSource注解，例如： ``` @Service public class UserServiceImpl implements UserService { @Autowired private UserMapper userMapper; @Override @DataSource("primary") public List<User> getPrimaryUsers() { return userMapper.selectAll(); } @Override @DataSource("secondary") public List<User> getSecondaryUsers() { return userMapper.selectAll(); } } ``` 在方法上加上@DataSource注解，指定使用的数据源。 以上就是通过注解实现多数据源切换的步骤。
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值