Java+Netty实现的RESTful框架--netty-rest-server-白红宇

Java+Netty实现的RESTful框架--netty-rest-server

阅读量：5947 次

发布时间：2019-06-19

本文共 3315 字，大约阅读时间需要 11 分钟。

在工作中用Netty做了几个服务，感觉Netty做出来的程序性能好，资源占用少，但是实现Http服务比较麻烦，于是就参考Spring MVC的注解基于Netty实现了一个轻量级的RESTful框架。

该框架提供了控制器注解、全局异常控制器、拦截器等功能。

注解名称参考了Spring MVC，编译理解和记忆，主要包括如下注解：

@RestController

@RequestMapping

@GetMapping

@PostMapping

@DeleteMapping

@PutMapping

@PatchMapping

@JsonResponse

@RequestParam

@PathVariable

@RequestBody

@UploadFile

@UrlEncodedForm

@RequestHeader

Controller示例：

//默认为单例，singleton = false表示启用多例。//@RestController(singleton = false)@RestController@RequestMapping("/users")public class UserController {        @GetMapping("")    @JsonResponse    public ResponseEntity
    
      listUser() {        // 查询用户        User user = new User();        user.setId(1);        user.setName("Leo");        user.setAge((short)18);        return ResponseEntity.ok().build(user);    }        @PutMapping("/{id}")    public ResponseEntity
      putMethod(@PathVariable("id") int id, @RequestBody String body) {        // 更新用户        return ResponseEntity.status(HttpStatus.CREATED).build();    }        @DeleteMapping("/{id}")    public ResponseEntity
      deleteMethod(@PathVariable int id) {        // 删除用户        return ResponseEntity.status(HttpStatus.NO_CONTENT).build();    }        @PostMapping("")    public ResponseEntity
      postMethod(@RequestBody String body) {        // 添加用户        JSONObject json = JSONObject.parseObject(body);        User user = new User();        user.setId(json.getIntValue("id"));        user.setName(json.getString("name"));        user.setAge(json.getShortValue("age"));        return ResponseEntity.status(HttpStatus.CREATED).build(user);    }}

拦截器示例：

public final class CorsInterceptor implements Interceptor {    @Override    public boolean preHandle(FullHttpRequest request, HttpResponse response) throws Exception {        // 使用axios发送cookie，这里不能用*，需要使用Web前端地址，如：http://localhost:8080        // response.getHeaders().put("Access-Control-Allow-Origin", "*");        response.getHeaders().put("Access-Control-Allow-Origin", System.getProperty("http.origin"));        response.getHeaders().put("Access-Control-Allow-Methods", "POST, PUT, GET, OPTIONS, DELETE, PATCH");        response.getHeaders().put("Access-Control-Max-Age", "3600");        response.getHeaders().put("Access-Control-Allow-Headers", "Content-Type,X-Token");        response.getHeaders().put("Access-Control-Allow-Credentials", "true");        return true;    }    @Override    public void postHandle(FullHttpRequest request, HttpResponse response) throws Exception {    }    @Override    public void afterCompletion(FullHttpRequest request, HttpResponse response) {    }}

启动服务：

@Test    public void test() {        // 忽略指定url        WebServer.getIgnoreUrls().add("/favicon.ico");                // 全局异常处理        WebServer.setExceptionHandler(new ExceptionController());                // 设置监听端口号        WebServer server = new WebServer(2006);                // 设置Http最大内容长度（默认 为10M）        server.setMaxContentLength(1024 * 1024 * 50);                // 设置Controller所在包        server.setControllerBasePackage("org.leo.web.controller");                // 添加拦截器，按照添加的顺序执行。        // 跨域拦截器        server.addInterceptor(new CorsInterceptor(), "/不用拦截的url");                try {            server.start();        } catch (InterruptedException e) {            e.printStackTrace();        }    }