十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
自动注解实现Spring IOC和事务管理的示例分析,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
10年积累的网站设计制作、做网站经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站设计后付款的网站建设流程,更有东宝免费网站建设让你可以放心的选择与我们合作。
IOC即控制反转,我们要把对象的创建通过注解来实现
@Service
类中声明了@Service注解的对象,我们就对它的实例化进行管理。(这里注解的名字无所谓,我们实现相应的功能即可)
@Autowired
类中的属性声明了@Autowired注解的,我们就对该属性进行依赖注入 在程序运行前,我们通过扫描所有的类文件,然后找出声明了@Service
注解的类,进行实例化,然后加入到我们的一个Map集合中,同时查找该类中是否有声明@Autowired
注解的属性,并进行标记。 再次遍历声明了@Service
注解的类,然后注入声明@Autowired
注解属性的类。这样我们就把对象的创建以及依赖的注入完成了。
事务管理需要我们遵循事务的ACID原则
@Transactional
类中或者方法中声明了@Transactional注解的我们就要对改对象或者方法添加事务控制功能 首先我们先扫描所有类文件,找出声明了@Transactional
注解的类或者方法,准备好一个List集合,如果注解声明在类上,我们就把类中所有的方法放入集合中,如果注解是在方法上,我们直接把方法加入到List集合中。 然后我们通过代理(动态代理或者cglib代理)给这些方法添加事务控制功能
public interface ApplicationContext { Object getBean(String name);T getBean(String name, Class requiredType); }
这是一个核心配置类,主要实现了以下三个功能
获取所有配置了@Service注解的类,并实例化,放入Map中
对于类中添加@Autowired注解的属性进行依赖注入
对于添加了@Transactional注解的属性或者方法进行事务增强
public class AnnotationConfigApplicationContext implements ApplicationContext { /** * 存放bean */ private final MapbeanMap = new HashMap<>(); /** * 先把包名转换为路径,首先得到项目的classpath */ private final String CLASSPATH = this.getClass().getResource("/").getPath(); public AnnotationConfigApplicationContext(String... basePackages) { try { scanPackages(basePackages); } catch (ClassNotFoundException | InstantiationException | IllegalAccessException e) { e.printStackTrace(); } } /** * 扫描所有包 并实现bean对象的创建,依赖注入,增强事务 * @param basePackages * @throws ClassNotFoundException * @throws InstantiationException * @throws IllegalAccessException */ private void scanPackages(String[] basePackages) throws ClassNotFoundException, InstantiationException, IllegalAccessException { // 设置获取所有配置Service注解的对象 setBeanDefinition(basePackages); // 设置依赖关系 setBeanDepend(); // 设置事务增强 setTransaction(); } /** * 获取所有需要管理的对象 * * @param basePackages 需要扫描的包 * @throws ClassNotFoundException * @throws IllegalAccessException * @throws InstantiationException */ private void setBeanDefinition(String[] basePackages) throws ClassNotFoundException, IllegalAccessException, InstantiationException { // 获取所有类路径下的class文件 List classPaths = new ArrayList<>(); for (String basePackage : basePackages) { //然后把我们的包名basPath转换为路径名 basePackage = basePackage.replace(".", File.separator); //然后把classpath和basePack合并 String searchPath = CLASSPATH + basePackage; getFile(classPaths, new File(searchPath)); } // 找出所有有@Service注解的类,加入到beanMap中 for (String s : classPaths) { s = s.replace(CLASSPATH, "").replace("/", ".").replace(".class", ""); Class clazz = Class.forName(s); Service service = (Service) clazz.getAnnotation(Service.class); if (service != null) { BeanDefinition beanDefinition = new BeanDefinition(); beanDefinition.setBeanObject(clazz.newInstance()); // 设置bean name String value = service.value(); // 如果没有自定义bean name,设置bean name为class name if ("".equals(value)) { value = clazz.getName(); value = value.substring(value.lastIndexOf(".") + 1); value = value.substring(0, 1).toLowerCase() + value.substring(1); } beanDefinition.setBeanName(value); // 是否有依赖关系 Field[] declaredFields = clazz.getDeclaredFields(); for (Field declaredField : declaredFields) { declaredField.setAccessible(true); Autowired autowired = declaredField.getAnnotation(Autowired.class); // 如果类属性有@Autowired注解,把依赖对象放入BeanDefinition的dependBeanName集合中 if (autowired != null) { beanDefinition.setAutoWired(true); beanDefinition.getDependBeanName().add(declaredField.getName()); } } // 是否有父接口,为后面增强使用动态代理还是cglib代理做准备 Class[] interfaces = clazz.getInterfaces(); if (interfaces.length > 0) { beanDefinition.setHaveParent(true); } // 是否有事务注解,如果有加入到BeanDefinition对象的transactionMethods属性中 Annotation annotation = clazz.getAnnotation(Transactional.class); Method[] methods = clazz.getDeclaredMethods(); //如果@Transactional注解出现在类上面,把类下所有的方法都加入到待添加事务的列表中 if (annotation != null) { for (Method method : methods) { beanDefinition.getTransactionMethods().add(method); } } else { // 如果@Transactional在某个方法上面,把该方法加入到BeanDefinition对象的transactionMethods属性中 for (Method method : methods) { Transactional methodAnnotation = method.getAnnotation(Transactional.class); if (methodAnnotation != null) { beanDefinition.getTransactionMethods().add(method); } } } // 将添加事务之后的对象重新加入到beanMap中 beanMap.put(beanDefinition.getBeanName(), beanDefinition); } } } /** * 遍历所有bean,找出有依赖关系的bean,注入 */ private void setBeanDepend() { for (Map.Entry next : beanMap.entrySet()) { BeanDefinition beanDefinition = next.getValue(); //如果有AutoWired注解,设置值 if (beanDefinition.isAutoWired()) { Object object = beanDefinition.getBeanObject(); Class> definitionClass = object.getClass(); List beanNames = beanDefinition.getDependBeanName(); beanNames.forEach(w -> { try { // 获取需要进行注入的对象 Field declaredField = definitionClass.getDeclaredField(w); // 暴力访问 declaredField.setAccessible(true); // 给依赖对象赋值 declaredField.set(object, getBean(w)); } catch (NoSuchFieldException | IllegalAccessException e) { e.printStackTrace(); } }); // 组装好的对象重新放入map中 beanMap.put(beanDefinition.getBeanName(), beanDefinition); } } } /** * 配置事务增强 */ private void setTransaction() { for (Map.Entry next : beanMap.entrySet()) { BeanDefinition definition = next.getValue(); //获取需要开启事务管理的类下的所有方法 List transactionMethods = definition.getTransactionMethods(); ProxyFactory proxyFactory = new ProxyFactory(); // 根据代理对象是实现接口,来决定采用动态代理还是cglib代理 if (!definition.isHaveParent()) { proxyFactory = new ProxyFactory(new CglibProxy()); } //给方法配置事务增强 Object withTransaction = proxyFactory.getProxyWithTransaction(definition.getBeanObject(), transactionMethods); definition.setBeanObject(withTransaction); //把增强之后的对象重新放入到beanMap中 beanMap.put(next.getKey(), definition); } } private void getFile(List classPaths, File file) { //文件夹递归 if (file.isDirectory()) { File[] files = file.listFiles(); if (files != null) { for (File f1 : files) { getFile(classPaths, f1); } } } else { //标准文件获取class文件 if (file.getName().endsWith(Constant.FILE_TYPE_CLASS)) { //如果是class文件我们就放入我们的集合中。 classPaths.add(file.getPath()); } } } @Override public Object getBean(String name) { return beanMap.get(name).getBeanObject(); } @Override public T getBean(String name, Class requiredType) { Object o = beanMap.get(name).getBeanObject(); if (o.getClass() == requiredType) { return (T) o; } return null; } }
对于事务的增强,我们需要依赖代理来实现。代理我们使用了动态代理和cglib代理两种,对于需要代理对象实现接口的,我们使用动态代理;对于没有实现接口的对象,我们使用cglib代理。下面看下具体实现。
public interface AopProxy { /** * 创建带事务的代理 * * @param o 代理对象 * @param methods 代理对象中需要添加事务的方法 * @return 增强之后的代理对象 */ abstract Object createProxyWithTransaction(Object o, Listmethods); }
public class DynamicProxy implements AopProxy { @Override public Object createProxyWithTransaction(Object o, Listmethods) { return Proxy.newProxyInstance(o.getClass().getClassLoader(), o.getClass().getInterfaces(), (proxy, method, args) -> { Object invoke = null; boolean anyMatch = methods.stream().anyMatch(w -> w.getName().equals(method.getName())); if (anyMatch) { TransactionManager.getInstance().beginTransaction(); try { invoke = method.invoke(o, args); TransactionManager.getInstance().commit(); } catch (Exception e) { TransactionManager.getInstance().rollback(); throw e; } return invoke; } invoke = method.invoke(o, args); return invoke; }); } }
public class CglibProxy implements AopProxy { @Override public Object createProxyWithTransaction(Object o, Listmethods) { Enhancer enhancer = new Enhancer(); enhancer.setSuperclass(o.getClass()); enhancer.setCallback((MethodInterceptor) (o1, method, objects, methodProxy) -> { Object invoke; boolean anyMatch = methods.stream().anyMatch(w -> w.getName().equals(method.getName())); if (anyMatch) { TransactionManager.getInstance().beginTransaction(); try { invoke = method.invoke(o, objects); TransactionManager.getInstance().commit(); } catch (Exception e) { TransactionManager.getInstance().rollback(); throw e; } return invoke; } invoke = method.invoke(o, objects); return invoke; }); return enhancer.create(); } }
看完上述内容,你们掌握自动注解实现Spring IOC和事务管理的示例分析的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!