「造个轮子」——cicada(轻量级 WEB 框架)

前言

俗话说 「不要重复造轮子」,关因而否有必要再也不本次讨论范围。java

建立这个项目的主要目的仍是提高本身,看看和知名类开源项目的差距以及学习优秀的开源方式。git

好了,如今着重来谈谈 cicada 这个项目的核心功能。github

我把他定义为一个快速、轻量级 WEB 框架;没有过多的依赖,核心 jar 包仅 30KB。json

也仅须要一行代码便可启动一个 HTTP 服务。tomcat


特性

如今来谈谈重要的几个特性。bash

当前版本主要实现了基本的请求、响应、自定义参数以及拦截器功能。服务器

功能虽少,但五脏俱全。并发

在从此的迭代过程当中会逐渐完善上图功能,有好的想法也欢迎提 github.com/crossoverJi…框架

快速启动

下面来看看如何快速启动一个 HTTP 服务。ide

只须要建立一个 Maven 项目,并引入核心包。

<dependency>
    <groupId>top.crossoverjie.opensource</groupId>
    <artifactId>cicada-core</artifactId>
    <version>1.0.0</version>
</dependency>
复制代码

如上图所示,再配置一个启动类便可。

public class MainStart {

    public static void main(String[] args) throws InterruptedException {
        CicadaServer.start(MainStart.class,"/cicada-example") ;
    }
}
复制代码

配置业务 Action

固然咱们还须要一个实现业务逻辑的地方。cicada 提供了一个接口,只须要实现该接口便可实现具体逻辑。

建立业务 Action 实现 top.crossoverjie.cicada.server.action.WorkAction 接口。

@CicadaAction(value = "demoAction")
public class DemoAction implements WorkAction {


    private static final Logger LOGGER = LoggerBuilder.getLogger(DemoAction.class) ;

    private static AtomicLong index = new AtomicLong() ;

    @Override
    public WorkRes<DemoResVO> execute(Param paramMap) throws Exception {
        String name = paramMap.getString("name");
        Integer id = paramMap.getInteger("id");
        LOGGER.info("name=[{}],id=[{}]" , name,id);

        DemoResVO demoResVO = new DemoResVO() ;
        demoResVO.setIndex(index.incrementAndGet());
        WorkRes<DemoResVO> res = new WorkRes();
        res.setCode(StatusEnum.SUCCESS.getCode());
        res.setMessage(StatusEnum.SUCCESS.getMessage());
        res.setDataBody(demoResVO) ;
        return res;
    }

}
复制代码

同时须要再自定义类中加上 @CicadaAction 注解,并须要指定一个 value,该 value 主要是为了在请求路由时能找到业务类。

这样启动应用并访问

http://127.0.0.1:7317/cicada-example/demoAction?name=12345&id=10

便能执行业务逻辑同时获得服务端的返回。

目前默认支持的是 json 响应,后期也会加上模板解析。

服务中也会打印相关日志。

灵活的参数配置

这里全部的请求参数都封装在 Param 中,能够利用其中的各类 API 获取请求数据。

之因此是灵活的:咱们甚至能够这样请求:

http://127.0.0.1:7317/cicada-example/demoAction?jsonData="info": {
    "age": 22,
    "name": "zhangsan"
  }
复制代码

这样就能够传递任意结构的数据,只要业务处理时进行解析便可。

自定义拦截器

拦截器是一个框架的基本功能,能够利用拦截器实现日志记录、事务提交等通用工做。

为此 cicada 提供一个接口: top.crossoverjie.cicada.server.intercept.CicadaInterceptor

咱们只须要实现该接口便可编写拦截功能:

@Interceptor(value = "executeTimeInterceptor")
public class ExecuteTimeInterceptor implements CicadaInterceptor {

    private static final Logger LOGGER = LoggerBuilder.getLogger(ExecuteTimeInterceptor.class);

    private Long start;

    private Long end;

    @Override
    public void before(Param param) {
        start = System.currentTimeMillis();
    }

    @Override
    public void after(Param param) {
        end = System.currentTimeMillis();

        LOGGER.info("cast [{}] times", end - start);
    }
}
复制代码

这里演示的是记录全部 action 的执行时间。

目前默认只实现了 action 的拦截,后期也会加入自定义拦截器。

拦截适配器

虽然说在拦截器中提供了 before/after 两个方法,但也不是全部的方法都须要实现。

所以 cicada 提供了一个适配器:

top.crossoverjie.cicada.server.intercept.AbstractCicadaInterceptorAdapter

咱们须要继承他即可按需实现其中的某个方法,以下所示:

@Interceptor(value = "loggerInterceptor")
public class LoggerInterceptorAbstract extends AbstractCicadaInterceptorAdapter {

    private static final Logger LOGGER = LoggerBuilder.getLogger(LoggerInterceptorAbstract.class) ;

    @Override
    public void before(Param param) {
        LOGGER.info("logger param=[{}]",param.toString());
    }

}
复制代码

性能测试

既然是一个 HTTP 服务框架,那性能天然也得保证。

在测试条件为:300 并发连续压测两轮;1G 内存、单核 CPU、1Mbps。用 Jmeter 压测状况以下:

一样的服务器用 Tomcat 来压测看看结果。

Tomcat 的线程池配置:

<Executor name="tomcatThreadPool" namePrefix="consumer-exec-" maxThreads="510" minSpareThreads="10"/>
复制代码

我这里请求的是 Tomcat 的一个 doc 目录,虽然说结果看似 cicada 的性能比 Tomcat 还强。

但其实这个对比过程当中的变量并无彻底控制好,Tomcat 所返回的是 HTML,而 cicada 仅仅返回了 json,固然问题也不止这些。

但仍是能说明 cicada 目前的性能仍是不错的。

总结

本文没有过多讨论 cicada 实现原理,感兴趣的能够看看源码,都比较简单。

在后续的更新中会仔细探讨这块内容。

同时不出意外 cicada 会持续更新,将来也会加入更多实用的功能。

甚至我会在适当的时机将它应用于个人生产项目,也但愿更多朋友能参与进来一块儿把这个「轮子」作的更好。

项目地址:github.com/crossoverJi…

你的点赞与转发是最大的支持。

相关文章
相关标签/搜索