以Bean结尾,表示它是一个Bean,不同于普通Bean的是:它是实现了FactoryBean<T>接口的Bean,根据该Bean的ID从BeanFactory中获取的实际上是FactoryBean的getObject()返回的对象,而不是FactoryBean本身,如果要获取FactoryBean对象,请在id前面加一个&符号来获取。
例如自己实现一个FactoryBean,功能:用来代理一个对象,对该对象的所有方法做一个拦截,在调用前后都输出一行LOG,模仿ProxyFactoryBean的功能。
shiro中就利用facoryBean的getObject()返回Ini.Section对象注入动态权限
/**
* my factory bean<p>
* 代理一个类,拦截该类的所有方法,在方法的调用前后进行日志的输出
* @author daniel.zhao
*
*/
public class MyFactoryBean implements FactoryBean<Object>, InitializingBean, DisposableBean {
private static final Logger logger = LoggerFactory.getLogger(MyFactoryBean.class);
private String interfaceName;
private Object target;
private Object proxyObj;
@Override
public void destroy() throws Exception {
logger.debug("destroy......");
}
@Override
public void afterPropertiesSet() throws Exception {
proxyObj = Proxy.newProxyInstance(
this.getClass().getClassLoader(),
new Class[] { Class.forName(interfaceName) },
new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
logger.debug("invoke method......" + method.getName());
logger.debug("invoke method before......" + System.currentTimeMillis());
Object result = method.invoke(target, args);
logger.debug("invoke method after......" + System.currentTimeMillis());
return result;
}
});
logger.debug("afterPropertiesSet......");
}
@Override
public Object getObject() throws Exception {
logger.debug("getObject......");
return proxyObj;
}
@Override
public Class<?> getObjectType() {
return proxyObj == null ? Object.class : proxyObj.getClass();
}
@Override
public boolean isSingleton() {
return true;
}
public String getInterfaceName() {
return interfaceName;
}
public void setInterfaceName(String interfaceName) {
this.interfaceName = interfaceName;
}
public Object getTarget() {
return target;
}
public void setTarget(Object target) {
this.target = target;
}
public Object getProxyObj() {
return proxyObj;
}
public void setProxyObj(Object proxyObj) {
this.proxyObj = proxyObj;
}
}
XML-Bean配置如下
1 <bean id="fbHelloWorldService" class="com.ebao.xxx.MyFactoryBean"> 2 <property name="interfaceName" value="com.ebao.xxx.HelloWorldService" /> 3 <property name="target" ref="helloWorldService" /> 4 </bean>
@RunWith(JUnit4ClassRunner.class)
@ContextConfiguration(classes = { MyFactoryBeanConfig.class })
public class MyFactoryBeanTest {
@Autowired
private ApplicationContext context;
/**
* 测试验证FactoryBean原理,代理一个servcie在调用其方法的前后,打印日志亦可作其他处理
* 从ApplicationContext中获取自定义的FactoryBean
* context.getBean(String beanName) ---> 最终获取到的Object是FactoryBean.getObejct(),
* 使用Proxy.newInstance生成service的代理类
*/
@Test
public void testFactoryBean() {
HelloWorldService helloWorldService = (HelloWorldService) context.getBean("fbHelloWorldService");
helloWorldService.getBeanName();
helloWorldService.sayHello();
}
}
shiro示例:
<bean id="shiroFilter" class="org.apache.shiro.spring.web.ShiroFilterFactoryBean">
<property name="securityManager" ref="securityManager" />
<property name="loginUrl" value="/login" />
<!--<property name="successUrl" value="/login/auth" />-->
<!--<property name="successUrl" value="http://116.236.184.238:8007/" />-->
<property name="successUrl" value="${shiro.in.url}" />
<!--<property name="successUrl" value="http://10.100.82.100:8126/" />-->
<property name="unauthorizedUrl" value="/login" />
<property name="filterChainDefinitionMap" ref="chainDefinitionSectionMetaSource" />
<property name="filters">
<map>
<entry key="authc" value-ref="authenticationFilter" />
<entry key="role" value-ref="roleAuthorizationFilter" />
</map>
</property>
</bean>
<bean id="chainDefinitionSectionMetaSource" class="com.houbank.incoming.web.shrio.ChainDefinitionSectionMetaSource">
<property name="filterChainDefinitions">
<value>
/flex/rbac/preLogin.action=authc
/j_acegi_security_check=authc
/flex/uifrm/index.jsp=authc
/flex/rbac/getLoginIndex.action=authc
/logout = logout
/user/logout.action = logout
<!-- /** = authc -->
</value>
</property>
</bean>
<bean id="myShiroFilterFactory" class="com.houbank.incoming.web.shrio.MyShiroFilterFactory">
<property name="filterChainDefinitions">
<value>
/flex/rbac/preLogin.action=authc
/j_acegi_security_check=authc
/flex/uifrm/index.jsp=authc
/flex/rbac/getLoginIndex.action=authc
/logout = logout
/user/logout.action = logout
<!-- /** = authc -->
</value>
</property>
</bean>
package com.houbank.incoming.web.shrio;
import com.alibaba.dubbo.config.annotation.Reference;
import com.houbank.basic.util.response.BaseResponse;
import com.houbank.incoming.api.FinancialSalesFuncFacade;
import com.houbank.incoming.api.FinancialSalesRoleFacade;
import com.houbank.incoming.model.condition.FinancialSalesFuncCondition;
import com.houbank.incoming.model.condition.FinancialSalesRoleCondition;
import com.houbank.incoming.model.condition.FinancialSalesUserRoleCondition;
import com.houbank.incoming.model.domain.FinancialSalesFunc;
import com.houbank.incoming.model.domain.FinancialSalesFuncRole;
import com.houbank.incoming.model.domain.FinancialSalesRole;
import com.houbank.incoming.web.controller.FinancialSalesUserController;
import org.apache.shiro.config.Ini;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import java.util.*;
public class ChainDefinitionSectionMetaSource implements FactoryBean<Ini.Section>{
private String filterChainDefinitions;
@Autowired(required=false)
private RedisTemplate redisTemplate;
@Reference
private FinancialSalesFuncFacade financialSalesFuncFacade;
@Reference
private FinancialSalesRoleFacade financialSalesRoleFacade;
/**
* 默认premission字符串
*/
public static final String PREMISSION_STRING="perms["{0}"]";
public Ini.Section getObject() throws BeansException {
//获取所有Resource
Map<String,String> a = new HashMap<String,String>();
try {
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return getSectionService(filterChainDefinitions) ;
}
public Ini.Section getSectionService(String filterChainDefinitions) {
List<FinancialSalesFuncRole> list =new ArrayList<FinancialSalesFuncRole>();
List<FinancialSalesFuncRole> listAll =new ArrayList<FinancialSalesFuncRole>();
FinancialSalesUserRoleCondition financialSalesRoleCondition =new FinancialSalesUserRoleCondition();
FinancialSalesFuncCondition financialSalesFuncCondition =new FinancialSalesFuncCondition();
list = financialSalesRoleFacade.selectAll();
List<Map> branchArr = financialSalesRoleFacade.getRoleFuncUrl(financialSalesRoleCondition);//this.baseService.queryForJDBCList(sql);
BaseResponse<List<FinancialSalesFunc>> listfuncs= financialSalesFuncFacade.selectAll(financialSalesFuncCondition);
List<FinancialSalesFunc> listfunc =(List<FinancialSalesFunc>)listfuncs.getData();
Set<String> itms= new HashSet<String>();
Set<String> itmls= new HashSet<String>();
for (Iterator<Map> it1 = branchArr.iterator(); it1.hasNext();) {
Map resource = (Map)it1.next();////角色菜单信息
itmls.add(resource.get("funcId")+"");
}
Ini ini = new Ini();
ini.load(filterChainDefinitions);
Ini.Section section = ini.getSection(Ini.DEFAULT_SECTION_NAME);
Map<String,Set<String>> mapr = new HashMap<String,Set<String>>();
Set<String> roleIds=null;
Set<String> mlroleIds=null;
if(list!=null&&list.size()>0){
//双重循环讲角色和对应的菜单对应
for(int i = 0; i < listfunc.size(); i++){
FinancialSalesFunc r = (FinancialSalesFunc)listfunc.get(i);
roleIds=new HashSet<String>();
mlroleIds=new HashSet<String>();
for (Iterator<Map> it = branchArr.iterator(); it.hasNext();) {//遍历角色菜单
Map resource = it.next();
if(r.getId().equals(resource.get("funcId"))){
//如果不为空值添加到section中
roleIds.add(resource.get("roleId")+"");
}
}
if(!"".equals(r.getUrl()) && null!=r.getUrl()){
mapr.put(r.getUrl()+"", roleIds);
}
}
}
StringBuffer au=null;
String st="";
//匹配到的转化为要求格式
for(Map.Entry<String, Set<String>> en:mapr.entrySet()){
au = new StringBuffer();
au.append("authc,role[");
for(String a :en.getValue()){
au.append("""+a+"",");
}
String strau=au.substring(0,au.lastIndexOf(","));
if(strau.contains(",role[")){
strau+="]";
}
st+=en.getKey()+">>>>"+strau+"n";
section.put(en.getKey(),strau);
}
System.out.println(st);
return section;
}
/**
* 通过filterChainDefinitions对默认的url过滤定义
*
* @param filterChainDefinitions 默认的url过滤定义
*/
public void setFilterChainDefinitions(String filterChainDefinitions) {
this.filterChainDefinitions = filterChainDefinitions;
}
public Class<?> getObjectType() {
return this.getClass();
}
public boolean isSingleton() {
return false;
}
public FinancialSalesFuncFacade getFinancialSalesFuncFacade() {
return financialSalesFuncFacade;
}
public void setFinancialSalesFuncFacade(FinancialSalesFuncFacade financialSalesFuncFacade) {
this.financialSalesFuncFacade = financialSalesFuncFacade;
}
public FinancialSalesRoleFacade getFinancialSalesRoleFacade() {
return financialSalesRoleFacade;
}
public void setFinancialSalesRoleFacade(FinancialSalesRoleFacade financialSalesRoleFacade) {
this.financialSalesRoleFacade = financialSalesRoleFacade;
}
}
评论