beanbox

BeanBox是一个功能齐全且兼容性很好的一款IOC/AOP工具，用于Java6或以上环境。除了实现了IOC, Aop这些主要功能之外, 该框架还提供了大量可对外扩展的接口，方便使用者在Bean对象的生命周期中能够对对象的状态进行管理和增强。此外，该框架能够很好的和其它框架进行兼容和拓展, 并且本框架搭配我的另一个开源项目fastrpc已经进行了测试。

一.BeanBox的主要优点

功能齐全:

该框架支持 XML配置、注解配置两种配置方式，解决了支持IOC/DI(循环依赖问题)、AOP (aop多重代理),事务(事务的传播机制),监听器机制,添加自定义注解，对象的生命周期等功能。
拓展性好:

该框架提供了对外扩展的接口,使得框架使用者可以参与到IOC容器中保存对象的状态管理中.如: BeanDefinitionPostProcessor, BeanPostProcessor,AnnotationRegistryFactory等。
兼容性强:

支持大多数JSR330、JSR250标准注解，并且可以和rpc等web框架兼容。
源码简洁:

该框架在保持代码的架构清晰和简洁的基础上，实现了Spring所包含的大部分功能。

二.源码结构

三.Quick Start

此案例搭配我的另一个项目fastrpc进行展示: https://github.com/zyz610650/Fastrpc

具体测试代码可见fastrpc:

1>定义接口

/**
 * @author: @zyz
 */

public interface HelloService {

    String sayHi(User user);
}

2>RpcServer

/**
 * @author: @zyz
 *  version :服务版本
 *  group : 服务所在的组.主要用于处理一个接口有多个类实现的情况。
 */
@NoArgsConstructor
@RpcService(group = "G1",version = "v1.0.1")
public class HelloServiceImpl implements HelloService {
    static {
        System.out.println("HelloServiceImpl被创建");
    }
    @Override
    public String sayHi(User user) {
        return "Hello, I am "+user.getName();
    }
}

@NoArgsConstructor
@RpcService(group = "G2",version = "v1.0.1")
public class HiServiceImpl implements HelloService {
    static {
        System.out.println("HelloServiceImpl被创建");
    }

    @Override
    public String sayHi(User user) {
        return "Hi, I am "+user.getName();
    }
}

/**
 * @author: @zyz
 * fastrpc 配合框架使用,fastrpc会随着项目启动而自动运行
 */
@Slf4j
public class ApplicationServerMain {

    public static void main(String[] args) throws InterruptedException {
        //fastRpc会随着BeanBox框架加载而启动
       ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext ("classpath:beanbox.xml");
        log.debug ("rpc start");
        // 测试时防止fastrpc框架会随着主线程结束而结束
         Thread.sleep (100000);
    }
}

beanbox.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans>

<!--    annotation注册器 用于添加自定义注解  annotationRegistryFactory为固定名称-->
    <bean id="annotationRegistryFactory"  class="com.fastrpc.web.AnnotationRegister"/>

<!--    Bean processor接口-->
    <bean class="com.fastrpc.web.MyBeanPostProcessor"/>

<!--    Bean-->
    <bean-scan base-package="com.fastrpc"/>



</beans>

3>RpcClient

/**
 * @author: @zyz
 */
@Bean
public class HelloController {


    @RpcReference(group = "G2",version = "v1.0.1")
    private static HelloService helloService;
    @RpcReference(group = "G1",version = "v1.0.1")
    private static HelloService hiService;

    public  void sayHi()
    {
        User user=new User();
        user.setName("zyz");
        System.out.println (helloService.sayHi(user));
        user.setName("mzd");
        System.out.println (hiService.sayHi(user));

    }


}

/**
 * @author: @zyz
 */

public class ApplicationClintMain {
   public static void main(String[] args) throws InterruptedException {
     ClassPathXmlApplicationContext applicationContext=new ClassPathXmlApplicationContext ("classpath:beanbox.xml");
      HelloController helloController= (HelloController) applicationContext.getBean("helloController");
      helloController.sayHi();
   }
}

beanbox.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans>
<!--  annotation注册器-->
    <bean class="com.fastrpc.web.MyBeanPostProcessor"/>

<!--bean 扫描路径-->
    <bean-scan base-package="com.fastrpc"/>


</beans>

4>自定义注解

实现 AnnotationRegistryFactory 接口, 添加自定义注解

/**
 * @author: @zyz
 */
public class AnnotationRegister extends AbstractDefaultAnnotationRegistryFactory {

	@Override
	public void registAnnotations () {
		super.addAnnotation (new AnnotationType (RpcService.class));
	}
}

5>Bean状态管理

实现BeanPostProcessor接口，对Bean的状态进行拓展

/**
 * @author: @zyz
 */
@Slf4j
public class MyBeanPostProcessor implements BeanPostProcessor {
	private final RegistryService registryService = SingletonFactory.getInstance(RegistryServiceImpl.class);
	private final RpcRequestTransportService rpcRequestTransportService=SingletonFactory.getInstance(RpcRequestTransportServiceImpl.class);
	@Override
	public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeanException {

		Class<?> clazz=bean.getClass();

		if (clazz.isAnnotationPresent(RpcService.class))
		{
			log.info("[{}] is annotated with  [{}]", clazz.getName(), RpcService.class.getCanonicalName());
			RpcService rpcService = clazz.getAnnotation(RpcService.class);

			RpcServiceConfig rpcServiceConfig=RpcServiceConfig.builder()
					.group(rpcService.group())
					.version(rpcService.version())
					.service(bean)
					.build();
			//向注册中心发布服务
			registryService.registerRpcService(rpcServiceConfig.getRpcServcieName());

			//添加Bean缓存
			ProxyFactory.CACHE_BEAN.put(rpcServiceConfig.getRpcServcieName(),bean);
			log.info("refister to zookeeper :[{}]",rpcServiceConfig.getRpcServcieName());
		}
		return bean;
	}

	@Override
	public Object postProcessAfterInitialization(Object bean, String beanName) throws BeanException {
		Class<?> clazz=bean.getClass();
		for(Field field: clazz.getDeclaredFields())
		{
			if (field.isAnnotationPresent(RpcReference.class))
			{
				RpcReference rpcReference=field.getAnnotation(RpcReference.class);

				RpcServiceConfig rpcServiceConfig=RpcServiceConfig.builder()
						.version(rpcReference.version())
						.group(rpcReference.group())
						.service(field.getType ())
						.build();
				RpcClientProxy rpcClientProxy=new RpcClientProxy(rpcServiceConfig,rpcRequestTransportService);
				Object clientProxy = rpcClientProxy.getProxy(field.getType ());
				field.setAccessible(true);
				try {
					field.set(bean,clientProxy);
				} catch (IllegalAccessException e) {
					throw new RpcException (e);
				}
			}
		}
		return bean;
	}
}

6>结果

Hi, I am zyz

Hello, I am mzd

三.配置文件：

具体测试Demo可以见代码test模块

beanbox.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans>

<!--    循环依赖测试-->
    <bean id="wife" class="com.beanbox.test.circleDependence.Wife">
        <property name="name" value="wife"/>
        <property name="husband" ref="husband"/>
    </bean>
    <bean id="husband" class="com.beanbox.test.circleDependence.Husband">
        <property name="name" value="husband"/>
        <property name="wife" ref="wife"/>
    </bean>
    <bean class="com.beanbox.aop.proxy.DefaultAdvisorAutoProxyCreator"/>
    <bean id="beforeAdvice" class="com.beanbox.test.circleDependence.aop.SpouseAdvice"/>
    <bean id="methodInterceptor" class="com.beanbox.aop.interceptor.MethodBeforeAdviceInterceptor">
           <property name="advice" ref="beforeAdvice"/>
     </bean>
        <bean id="pointcutAdvisor" class="com.beanbox.aop.advisor.AspectJExpressionPointcutAdvisor">
            <property name="expression" value="execution(* com.beanbox.test.circleDependence.Wife.*(..))"/>
            <property name="advice" ref="methodInterceptor"/>
        </bean>

<!--    占位符赋值测试-->
    <bean id="userService" class="com.beanbox.test.pojo.UserService" scope="prototype">
        <property name="uId" value="zyz"></property>
        <property name="uId" value="zyz"></property>
        <property name="company" value="jlu"></property>
        <property name="location" value="changchun"></property>
        <property name="token" value="${token}"/>
        <!--        <property name="userDao" ref="proxyUserDao"></property>-->
    </bean>


<!--    Annotation test-->
    <bean name="higherUser1" class="com.beanbox.test.pojo.HigherUser">
        <property name="name" value="higherUser1"/>
    </bean>
    <bean name="higherUser2" class="com.beanbox.test.pojo.HigherUser">
        <property name="name" value="higherUser2"/>
    </bean>
    <bean class="com.beanbox.beans.processor.support.PropertyPlaceholderProcessor">
        <property name="location" value="classpath:property.properties"/>
    </bean>
    <bean-scan base-package="com.beanbox.test.pojo"/>



<!--    Aop test-->
    <bean id="userService" class="com.beanbox.test.pojo.UserService">
        <property name="uId" value="trqwedsadasffa54sfsd"/>
    </bean>
    <bean class="com.beanbox.aop.proxy.DefaultAdvisorAutoProxyCreator"/>
    <bean id="beforeAdvice" class="com.beanbox.test.aop.UserServiceBeforeAdvice"/>
    <bean id="methodInterceptor" class="com.beanbox.aop.interceptor.MethodBeforeAdviceInterceptor">
        <property name="advice" ref="beforeAdvice"/>
    </bean>
    <bean id="pointcutAdvisor" class="com.beanbox.aop.advisor.AspectJExpressionPointcutAdvisor">
        <property name="expression" value="execution(* com.beanbox.test.pojo.IUserService.*(..))"/>
        <property name="advice" ref="methodInterceptor"/>
    </bean>


<!--    prox test-->
    <bean id="userService" class="com.beanbox.test.pojo.UserService" scope="prototype">
    <property name="uId" value="zyz"></property>
        <property name="uId" value="zyz"></property>
        <property name="company" value="jlu"></property>
        <property name="location" value="changchun"></property>
        <property name="userDao" ref="proxyUserDao"></property>
    <bean name="proxyUserDao" class="com.beanbox.test.proxy.ProxyUserDao" ></bean>



<!--    Listener test-->
    <bean class="com.beanbox.test.event.CustomEventListener"></bean>
    <bean class="com.beanbox.test.event.ContextClosedEventListener"></bean>
    <bean class="com.beanbox.test.event.ContextRefreshedEventListener"></bean>


<!--    Processor Test-->
    <bean id="userService2" class="com.beanbox.test.service.UserService2">
        <!--          <property name="user" ref="user"></property>-->
    </bean>
    <bean id="user" class="com.beanbox.test.pojo.User">
        <property name="name" value="zyz"/>
        <property name="age" value="12"></property>
        <property name="higherUser" ref="higherUser"/>
    </bean>
    <bean id="higherUser" class="com.beanbox.test.pojo.HigherUser"/>
    <bean class="com.beanbox.test.processor.MyBeanDefinitionPostProcessor"/>
    <bean class="com.beanbox.test.processor.MyBeanProcessor"/>

    <bean id="userDao" class="com.beanbox.test.pojo.UserDao" init-method="initDataMethod" destory-method="destroyDataMethod"/>
    <bean id="userBean" class="com.beanbox.test.pojo.UserBean" />

</beans>

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">
	
 <!--    beanbox 中定义的监听器 用于启动BeanBox框架-->
    <listener>
        <listener-class>com.beanbox.web.WebAppEventListener</listener-class>
    </listener>
</web-app>

四.功能展示

1.事务（事务的传播机制）

本框架实现了的传播机制有如下7种:

    PROPAGATION_DEFAULT(1),
    PROPAGATION_REQUIRED(1),
    PROPAGATION_SUPPORTS(2),
    PROPAGATION_MANDATORY(3),
    PROPAGATION_REQUIRES_NEW(4),
    PROPAGATION_NOT_SUPPORTED(5),
    PROPAGATION_NEVER(6),
    PROPAGATION_NESTED(7);

功能展示:

由于Spring里通过JdbcTemplate对DataSource的操作进行封装，来简化了数据库的使用，目前BeanBox该版本还没有那么完善，需要自己获取DataSource来对数据库操作，使用起来很是蹩脚，后面版本会继续完善，方便使用.

1> PROPAGATION_REQUIRED

public class ApplicationMain {

	@Test
	public void test()
	{

		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:beanboxDemo.xml");
		UserContronller userContronller = applicationContext.getBean("userContronller",UserContronller.class);
		userContronller.updateUserInfo();
	}


}

package com.beanbox.test.tx;

import com.beanbox.beans.annotation.Autowired;
import com.beanbox.beans.annotation.Bean;
import com.beanbox.beans.annotation.Transactional;
import com.beanbox.enums.Propagation;
import com.beanbox.test.pojo.User;
import com.beanbox.tx.DataSourceContext;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

//@Bean("userContronller")
public class UserContronller {

//    @Autowired
//    UserService userService;

//    @Autowired
    DataSourceContext dataSourceContext;

    @Transactional(propagation = Propagation.PROPAGATION_REQUIRED)
    public void updateUserInfo()  {
        Connection conn = dataSourceContext.getFirstConn();

        int Cid=11;
        String Cname="zyz";
        int Tid=05;
        String sql = "insert into course values (?,?,?)";
        PreparedStatement pstam = null;
        try {
            pstam = conn.prepareStatement(sql);
            pstam.setInt(1,Cid);
            pstam.setString(2,Cname);
            pstam.setInt(3,Tid);

            int result = pstam.executeUpdate();
            System.out.println(result);
            throw new RuntimeException("error");
//
        } catch (SQLException e) {
          throw  new RuntimeException(e);
        }

    }

}

配置文件：

<!--    Transactional-->
    <bean id="userContronller" class="com.beanbox.test.tx.UserContronller">
        <property name="dataSourceContext" ref="dataSourceContext"/>
    </bean>
    <bean id="dataSourceContext" class="com.beanbox.tx.DataSourceContext"/>
    <bean id="txMethodInterceptor" class="com.beanbox.aop.interceptor.TransactionalInterceptor">
        <property name="dataSourceContext" ref="dataSourceContext"/>
    </bean>
    <bean id="transactionPointcutAdvisor" class="com.beanbox.aop.advisor.TransactionPointcutAdvisor">
        <property name="advice" ref="txMethodInterceptor"/>
    </bean>
    <bean class="com.beanbox.aop.proxy.DefaultAdvisorAutoProxyCreator"/>
    <bean-scan base-package="com.beanbox.test.tx"/>

结果:

11:04:56.534 [main] WARN com.beanbox.beans.factory.support.DefaultListableBeanFactory - The bean named annotationRegistryFactory is not found
11:04:56.685 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - start a new transaction 
11:04:56.705 [main] INFO com.beanbox.tx.DataSourceContext - get a new dataSource connection
11:04:56.786 [main] INFO com.alibaba.druid.pool.DruidDataSource - {dataSource-1} inited
1
11:04:57.036 [main] WARN com.beanbox.tx.AbstractTransactionalIInfoManager - rollback: the reasion is error
11:04:57.037 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - clean the transaction infomation

2> PROPAGATION_NESTED

//UserContronller 
//@Bean("userContronller")
public class UserContronller {

//    @Autowired
   UserService userService;

//    @Autowired
    DataSourceContext dataSourceContext;

    @Transactional(propagation = Propagation.PROPAGATION_REQUIRED)
    public void updateUserInfo()  {
        Connection conn = dataSourceContext.getFirstConn();

        int Cid=11;
        String Cname="I am transaction1";
        int Tid=05;
        String sql = "insert into course values (?,?,?)";
        PreparedStatement pstam = null;
        try {
            pstam = conn.prepareStatement(sql);
            pstam.setInt(1,Cid);
            pstam.setString(2,Cname);
            pstam.setInt(3,Tid);
            
            int result = pstam.executeUpdate();

            userService.update();

        } catch (SQLException e) {
          throw  new RuntimeException(e);
        }




    }

}



public class UserService {

    DataSourceContext dataSourceContext;

    @Transactional(propagation = Propagation.PROPAGATION_NESTED)
    public void update()
    {
        Connection conn = dataSourceContext.getFirstConn();

        int Cid=13;
        String Cname="I am transaction2";
        int Tid=05;
        String sql = "insert into course values (?,?,?)";
        PreparedStatement pstam = null;
        try {
            pstam = conn.prepareStatement(sql);
            pstam.setInt(1,Cid);
            pstam.setString(2,Cname);
            pstam.setInt(3,Tid);

            int result = pstam.executeUpdate();
            System.out.println(result);
            throw new RuntimeException("transaction2  rollback ");
//
        } catch (SQLException e) {
            throw  new RuntimeException(e);
        }

    }


}

配置文件:

<!--    Transactional-->
    <bean id="userContronller" class="com.beanbox.test.tx.UserContronller">
        <property name="dataSourceContext" ref="dataSourceContext"/>
        <property name="userService" ref="userService"/>
    </bean>
    <bean id="userService" class="com.beanbox.test.tx.UserService">
        <property name="dataSourceContext" ref="dataSourceContext"/>
    </bean>
    <bean id="dataSourceContext" class="com.beanbox.tx.DataSourceContext"/>
    <bean id="txMethodInterceptor" class="com.beanbox.aop.interceptor.TransactionalInterceptor">
        <property name="dataSourceContext" ref="dataSourceContext"/>
    </bean>
    <bean id="transactionPointcutAdvisor" class="com.beanbox.aop.advisor.TransactionPointcutAdvisor">
        <property name="advice" ref="txMethodInterceptor"/>
    </bean>
    <bean class="com.beanbox.aop.proxy.DefaultAdvisorAutoProxyCreator"/>
    <bean-scan base-package="com.beanbox.test.tx"/>

结果：

11:53:03.919 [main] WARN com.beanbox.beans.factory.support.DefaultListableBeanFactory - The bean named annotationRegistryFactory is not found
11:53:04.150 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - start a new transaction 
11:53:04.170 [main] INFO com.beanbox.tx.DataSourceContext - get a new dataSource connection
11:53:04.254 [main] INFO com.alibaba.druid.pool.DruidDataSource - {dataSource-1} inited
11:53:04.529 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - start a new transaction 
1
11:53:05.046 [main] WARN com.beanbox.tx.AbstractTransactionalIInfoManager - rollback: the reasion is transaction2  rollback 
11:53:05.046 [main] INFO com.beanbox.tx.AbstractTransactionalIInfoManager - rollback savepoint: com.mysql.jdbc.MysqlSavepoint@4671e53b
11:53:05.049 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - clean the transaction infomation : transactiona1
11:53:05.049 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - commit new transaction 
11:53:05.050 [main] INFO com.beanbox.aop.interceptor.TransactionalInterceptor - clean the transaction infomation : transactiona0

Process finished with exit code 0

//course表结果 可见 事务2抛出异常不影响事务1提交
01	语文	02
02	数学	01
03	英语	03
11	I am transaction1	5

Name		Name	Last commit message	Last commit date
Latest commit History 60 Commits
.idea		.idea
beanbox-commons		beanbox-commons
beanbox-core		beanbox-core
img		img
target		target
.gitignore		.gitignore
LICENSE		LICENSE
README.md		README.md
pom.xml		pom.xml

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

beanbox

一.BeanBox的主要优点

二.源码结构

三.Quick Start

三.配置文件：

四.功能展示

1.事务（事务的传播机制）

About

Releases

Packages

Languages

License

zyz610650/beanbox

Folders and files

Latest commit

History

Repository files navigation

beanbox

一.BeanBox的主要优点

二.源码结构

三.Quick Start

三.配置文件：

四.功能展示

1.事务（事务的传播机制）

About

Resources

License

Stars

Watchers

Forks

Releases

Packages 0

Languages

Packages