轻量级 Java 框架 JOxygen_浏览器插件

JOxygen轻量级Java框架

介绍

一个轻量级Java框架

oxygen-core 核心部分

基于cglib的aop实现提供缓存管理和基于注解的缓存，内置LocalCache和Ehcache实现，可扩展配置管理，支持${attrs.key:defaultValue}表达式获取配置加解密管理，提供加解密服务内置基础加密实现，例如SHA-1、SHA-256、MD5异常管理，提供异常包装，统一异常编码，便于国际化提供基于构造器注入的ioc(原因：依赖链清晰，并可任意切换ioc实现)定时任务服务，内置提供了基于注解的定时任务服务├─ src/main │─ java/.../core //oxygen-core代码目录 │ │- aop //aop实现目录 │ │- cache //缓存实现目录 │ │- config //配置实现目录 │ │- constant //常量目录 │ │- convert //类型转换实现目录 │ │- crypto //密码加密目录 │ │- domain //基础实体目录 │ │- exception //异常管理目录 │ │- io //io读写目录 │ │- ioc //ioc实现目录 │ │- job //定时任务实现目录 │ │- scan //类扫描实现目录 │ │- util //工具类目录 │ │- Bootstrap.java //框架启动引导类 │ └- Plugin.java //插件接口 └─ resources/META-INF/services └- ...core.Plugin //Plugin服务实现配置文件oxygen-jdbc jdbc实现

小巧简单的jdbc实现，纯jdk实现，无第三方jar支持多数据源基于sql进行crud，不提供类似Hibernate的链式方法（原因：sql作为数据库领域的DSL，已经很自然优雅，Less is more）├─ src/main │─ java/.../jdbc //oxygen-jdbc代码目录 │ │- config //配置数据源目录 │ │- handler //处理器目录，包括结果集处理行处理列处理 │ │- interceptor //拦截器目录，拦截sql执行前后及异常 │ │- record //基础crud │ │- Jdbc.java //Jdbc核心操作类，提供crud操作 │ │- JdbcException.java //jdbc异常封装 │ └- JdbcPlugin.java //jdbc插件，与oxygen-core配套使用 └─ resources/META-INF/services │- ...handler.ColumnHandler //列处理服务配置文件 └- ...core.Plugin //增加jdbcPlugin服务实现，与oxygen-core配套使用oxygen-web

项目使用了Servlet3.0的ServletContainerInitializer接口在servlet中可自动加载，不需要在web.xml中配置使用@Router标记路由文件使用@Mapping标记请求路径处理方法参数绑定的取值域使用@Param,@HeaderParam,@CookieParam,@PathParam指定，默认为@Param参数绑定支持简单类型 + Map<String,Object> + 用户实体类支持返回Json、视图或自定义实现(文件下载等)├─ src/main │─ java/.../web //oxygen-web代码目录 │ │- handler //参数绑定处理 │ │- //视图解析服务特性

轻量级，注释完善，使用简单使用ServiceLoader加载插件，易于扩展安装

添加依赖到你的 pom.xml:

<dependency> <groupId>vip.justlive</groupId> <artifactId>oxygen-core</artifactId> <version>${oxygen.version}</version></dependency><dependency> <groupId>vip.justlive</groupId> <artifactId>oxygen-jdbc</artifactId> <version>${oxygen.version}</version></dependency><dependency> <groupId>vip.justlive</groupId> <artifactId>oxygen-web</artifactId> <version>${oxygen.version}</version></dependency><dependency> <groupId>vip.justlive</groupId> <artifactId>oxygen-web-tomcat</artifactId> <version>${oxygen.version}</version></dependency>快速开始

基础返回

使用 Resp 作为返回

// 成功返回 code 00000Resp.success(Object obj);// 错误返回默认code 99999Resp.error(String msg);// 错误返回自定义codeResp.error(String code, String msg);异常处理

使用 Exceptions 抛出异常

// 创建 ErrorCodeErrorCode err = Exceptions.errorCode(String module, String code);ErrorCode err = Exceptions.errorMessage(String module, String code, String message);// 抛出unchecked异常throw Exceptions.wrap(Throwable e);throw Exceptions.wrap(Throwable e, String code, String message);throw Exceptions.wrap(Throwable e, ErrorCode errorCode, Object... arguments);// 抛出业务异常不含堆栈信息throw Exceptions.fail(ErrorCode errCode, Object... params);throw Exceptions.fail(String code, String message, Object... params);// 抛出故障异常包含堆栈信息throw Exceptions.fault(ErrorCode errCode, Object... params);throw Exceptions.fault(String code, String message, Object... params);throw Exceptions.fault(Throwable e, ErrorCode errCode, Object... params);throw Exceptions.fault(Throwable e, String code, String message, Object... params)IOC

通过注解使用IOC容器

// 在配置文件中添加扫包路径main.class.scan=com.xxx.xxx,com.aaa.bbb// 使用 @Configuration 和 @Bean@Configurationpublic class Conf { @Bean Inter noDepBean() { return new NoDepBean(); }}// 使用 @Bean 和 @Inject@Bean("depBean")public class DepBean implements Inter { private final NoDepBean noDepBean; @Inject public DepBean(NoDepBean noDepBean) { this.noDepBean = noDepBean; } ...}// 运行时获取beanInter inter = BeanStore.getBean("depBean", Inter.class);AOP

通过注解使用AOP

// 定义使用了Log注解的方法aop处理@Before(annotation = Log.class)public void log(Invocation invocation) { ...}// 目标方法添加注解@Logpublic void print() { ...}定时任务

使用注解 @Scheduled 标记一个方法需要作为定时任务

onApplicationStart(), cron(), fixedDelay(), or fixedRate() 必须配置其中一个

// 固定延迟任务任务结束时间-下一个开始时间间隔固定@Scheduled(fixedDelay = "500")public void run1() { ...}// 固定周期任务任务开始时间-下一个开始时间固定@Scheduled(fixedRate = "600")public void run2() { ...}// cron任务，并且程序启动后异步执行一次@Scheduled(cron = "0/5 * * * * ?", onApplicationStart = true, async = true)public void run3() { ...}缓存

使用缓存有两种方式：

JCache.cache() 获取缓存然后调用api使用 @Cacheable 注解给方法添加缓存// 使用缓存api Cache cache = JCache.cache(cacheName);T value = cache.get(key, clazz);cache.set(key, value, duration, timeUnit);...// 使用注解@Cacheablepublic Object method() { ...}@Cacheable(key = "args[0]", duration = 10, timeUnit = TimeUnit.MINUTES)public Object method(Object arg0, Object arg1) { ...}Jdbc

基础使用

可配置多数据源使用Jdbc进行crud使用ResultSetHandler 进行自定义类型转换处理开启关闭事务// 单独使用需要自己创建并添加数据源...// 添加主数据源Jdbc.addPrimaryDataSource(DataSource dataSource)// 添加多数据源Jdbc.addDataSource(String name, DataSource dataSource)// crudT Jdbc.query(String sql, Class<T> clazz, Object... params)List<T> Jdbc.queryForList(String sql, Class<T> clazz, Object... params)Map<String, Object> Jdbc.queryForMap(String sql, Object... params)List<Map<String, Object>> Jdbc.queryForMapList(String sql, Object... params)// 可自定义返回处理T Jdbc.query(String sql, ResultSetHandler<T> handler, Object... params)int Jdbc.update(String sql, Object... params)// 开启主数据源的事务Jdbc.startTx()// 开启指定数据源的事务Jdbc.startTx(String dataSourceName)// 关闭主数据源的事务Jdbc.closeTx()// 关闭指定数据源的事务Jdbc.closeTx(String dataSourceName)// 回滚事务Jdbc.rollbackTx()// 回滚指定数据源的事务Jdbc.rollbackTx(String dataSourceName)// 基础crudOption opt = new Option()...Record.insert(opt)Record.findById(Option.class, 1)Record.find(opt)Record.update(opt)Record.deleteById(Option.class, 1)Record.delete(opt);// 配合oxygen-core使用, 只需在配置文件中配置数据源即可自动装载// 多数据源名称datasource.multi=a// 主数据源datasource.logSql=truedatasource.driverClassName=org.h2.Driverdatasource.url=jdbc:h2:mem:test;DB_CLOSE_DELAY=-1datasource.username=sadatasource.password=sa// 数据源adatasource.a.driverClassName=org.h2.Driverdatasource.a.url=jdbc:h2:mem:a;DB_CLOSE_DELAY=-1datasource.a.username=sadatasource.a.password=sa自定义列类型转换

实现 ColumnHandler 接口进行自定义处理增加 META-INF/services/vip.justlive.oxygen.jdbc.handler.ColumnHandler 文件，添加实现类的类名public class MyColumnHandler implements ColumnHandler { @Override public boolean supported(Class<?> type) { ... } @Override public Object fetch(ResultSet rs, int index) throws SQLException { ... }}// 新增或修改 META-INF/services/vip.justlive.oxygen.jdbc.handler.ColumnHandler 添加自定义类名xxx.xxx.MyColumnHandler增加jdbc拦截

实现 JdbcInterceptor 接口调用 Jdbc.addJdbcInterceptor 添加拦截// 内置的sql打印拦截@Slf4jpublic class LogSqlJdbcInterceptor implements JdbcInterceptor { @Override public void before(String sql, List<Object> params) { if (log.isDebugEnabled()) { log.debug("execute sql: {} -> params: {}", sql, params); } }}// 添加拦截器Jdbc.addJdbcInterceptor(JdbcInterceptor interceptor)web

基础使用

使用@Router @Mapping @Param...等注解进行定义路由类和请求方法以及绑定参数使用View进行视图跳转，非void,View的返回值默认使用json处理线程内使用Request.current(),Response.current()获取请求和返回// 使用 @Router标记路由@Router("/common")public class CommonRouter { // 标记请求路径和请求方式，默认支持所有请求当返回值不是void且非View则为返回json @Mapping(value = "/localDate",method = =自定义视图解析

实现ViewResolver接口通过ServiceLoader或WebPlugin.addViewResolver的方式进行添加自定义视图解析// 内置的重定向和json解析器public class DefaultViewResolver implements ViewResolver { @Override public boolean supported(Object data) { // 重定向 if (data != null && data.getClass() == View.class && ((View) data).isRedirect()) { return true; } // null 或者非view 返回json return data == null || data.getClass() != View.class; } @Override public void resolveView(启动执行类

只需实现WebAppInitializer接口，容器会自动加载

public class MyWebAppInitializer implements WebAppInitializer { @Override public void onStartup(ServletContext context) { ... } @Override public int order() { ... }}使用内置容器启动

依赖 oxygen-web-tomcat在main中使用 Server.start启动<dependency> <groupId>vip.justlive</groupId> <artifactId>oxygen-web-tomcat</artifactId> <version>${oxygen.version}</version></dependency>public static void main(String[] args) { // 启动容器 Server.start(); ... // 关闭容器 Server.stop();}