Spring体系和Aop就不多说了，反正我也一知半解。因项目需求搭建基于Spring的框架，在考虑异常处理和权限校验的时候使用Spring的Aop进行实现。
关于Spring Aop的介绍如果需要了解推荐文章：彻底征服Spring Aop
因为不是web项目，所以springmvc提供的一些已经实现好的东西就没法直接用，只能使用aop自己去实现。当然也许本身有实现好了的我没发现而已。
研究了一下，记录下实现过程，以便之后再用直接cp过来。
使用注解方式，话不多说，具体实现如下。
1. 新建拦截器
这里是自定义的核心模块，即拦截器的逻辑实现部分。
//让spring扫描这个bean
@Component("authInterceptor")
//声明为切面，这样才能成为拦截器
@Aspect
public class AuthCheckInteceptor {
private final Logger logger = LoggerFactory.getLogger(AuthCheckInteceptor.class);
//声明切面规则，即什么类的什么方法会被joinpoint，即哪里会被拦截
@Pointcut("execution(* com.cup.ares.bdsp.magpie.rpc.impl.*.*(..))")
private void doIntercept() {
}
//在方法执行前拦截
@Before(value = "doIntercept()")
public void before(JoinPoint point) {
logger.info("BBBBBBBBBBBBBBBBBBBBBBBBefore method invoke,{}");
}
//在方法执行中拦截
/*注意此处的args(queryStr)是因为这里的around方法声明里增加了参数 String queryStr，这表示在符合上面的Pointcut规则的方法中，只有含有且仅含有一个参数为queryStr的方法才会被拦截。
此外，此处可以定义返回值，如果为void则对原方法不会有影响，如果声明了返回值，此处如果修改，将最终返回给业务方法的调用者。
*/
@Around(value = "doIntercept() and args(queryStr)")
public Object around(ProceedingJoinPoint joinpont, String queryStr) {
//实验发现这里的代码上面声明的before先执行
logger.info("ARRRRRRRRRRRRRRRRRRRRRRRRRRRound,{}", queryStr);
try {
//执行业务方法
String r = (String)joinpont.proceed();
//执行之后，可以对返回值任意操作
r=r+"xxxxxxxxxxxxxxxx";
return r;
} catch (Throwable e) {
//异常处理，可以借助这个逻辑实现异常拦截器
r="exception"+e.getMessage();
logger.info("EEEEEEEEEEEEEEEEEEEEEEEEEEE", e);
return res;
}
}
//方法执行后
@After("doIntercept()")
public void after() {
logger.info("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAfter method invoke");
}
//异常处理完成之后
@AfterThrowing(value = "doIntercept() && args(ex)")
public void afterT(Throwable ex) {
logger.error("CCCCCCCCCCCCCCCCCCCCCCatch Exception", ex);
}
}
2. 配置文件修改
使用注解给我们带来很多方便，不用再去配置。不过在spring的配置文件中还是要加上一些。
//自动扫描我们定义的拦截器，当然如果只有一个拦截器类，也可以使用普通的bean标签来定义这个拦截器
<context:component-scan base-package="com.cup.ares.bdsp.interceptor" />
//开启切面注解，这样才能使@Aspect生效
<aop:aspectj-autoproxy />
3. 被拦截的类
@Service("billDataService")
public class BillDataServiceImpl implements BillDataService {
private final Logger logger = LoggerFactory.getLogger(BillDataServiceImpl.class);
@Override
public String simpleQueryBySingle(String queryStr) {
logger.info("卡号:{}命中黄牛名单！", data.getBillValue());
return "invoke res";
}
}
可以看到被拦截的类无需任何修改，完全无感知无侵入。
附上pom清单和spring配置，可能有些不是必要的，自己删除。
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<org.springframework.groupid>org.springframework</org.springframework.groupid>
<org.springframework.version>4.3.5.RELEASE</org.springframework.version>
<org.hibernate.groupid>org.hibernate</org.hibernate.groupid>
<org.hibernate.version>4.3.9.Final</org.hibernate.version>
</properties>
<dependencies>
<dependency>
<groupId>com.cup.ares</groupId>
<artifactId>bdsp_svc_magpie</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- spring -->
<dependency>
<groupId>${org.springframework.groupid}</groupId>
<artifactId>spring-context</artifactId>
<version>${org.springframework.version}</version>
</dependency>
<dependency>
<groupId>${org.springframework.groupid}</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${org.springframework.version}</version>
</dependency>
<dependency>
<groupId>${org.springframework.groupid}</groupId>
<artifactId>spring-orm</artifactId>
<version>${org.springframework.version}</version>
</dependency>
<dependency>
<groupId>${org.springframework.groupid}</groupId>
<artifactId>spring-aspects</artifactId>
<version>${org.springframework.version}</version>
</dependency>
</dependencies>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:magpie="http://www.unionpay.com/schema/magpie"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:jpa="http://www.springframework.org/schema/data/jpa"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.unionpay.com/schema/magpie http://www.unionpay.com/schema/magpie/magpie.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa.xsd"
default-lazy-init="false">
<!-- bean自动扫描 -->
<context:component-scan base-package="com.cup.ares.bdsp.service.impl" />
<context:component-scan base-package="com.cup.ares.bdsp.interceptor" />
<!-- 扫描properties配置 -->
<bean id="propertyPlaceholderConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:server.properties</value>
</list>
</property>
</bean>
<!-- datasource -->
<bean id="dataSource" destroy-method="close"
class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="com.mysql.jdbc.Driver" />
<property name="jdbcUrl" value="${DB_Url}" />
<property name="user" value="${DB_UserName}" />
<property name="password" value="${DB_Pwd}" />
<property name="initialPoolSize" value="${DB_InitialPoolSize}" />
<property name="minPoolSize" value="${DB_MinPoolSize}" />
<property name="maxPoolSize" value="${DB_MaxPoolSize}" />
<property name="maxIdleTime" value="${DB_MaxIdleTime_Sec}" />
</bean>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.hbm2ddl.auto">update</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.format_sql">true</prop>
</props>
</property>
<property name="packagesToScan">
<list>
<!-- 注意这里写到包名就行，不要写成 xx.xx.* -->
<value>com.cup.ares.bdsp.entity</value>
</list>
</property>
</bean>
<!-- 配置Spring声明式事务 -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory"></property>
</bean>
<!-- 声明式事务实现1：注解方式 <tx:annotation-driven transaction-manager="transactionManager"
/> -->
<!-- 声明式事务实现2：配置方式 start -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="get*" read-only="true" />
<tx:method name="add*" propagation="REQUIRED" />
<tx:method name="save*" propagation="REQUIRED" />
<tx:method name="set*" propagation="REQUIRED" />
<tx:method name="*" />
</tx:attributes>
</tx:advice>
<!-- 配置事务切点，并把切点和事务属性关联起来 -->
<aop:config>
<aop:pointcut expression="execution(* com.cup.ares.bdsp.service.impl.*.*(..))"
id="txPointcut" />
<aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut" />
</aop:config>
<!-- 声明式事务实现2：配置方式 end -->
<aop:aspectj-autoproxy />
</beans>
网友评论