Gutty —— 基于 Google Guice 和 Netty 的网络框架
简介 一直很喜欢 Netty 和 Guice ,简单好用, 网上有不少整合的例子,但是这些例子也多是基于 Netty 或 Guice 特性的,缺少值的自动传入和路由注解等功能,这是我最爱的。 之前将 Spring 出的 Reactor-Netty 和 Guice 整合了一遍,因为他已经处理好了路由,还有长连接, 只用把参数自动传入,整合起来省事不少, 但是 Reactor 那个写法确实不习惯,有些方法也不熟悉,用起来常常绕晕自己。 最近有点时间,撸起袖子开始整,半个多月,完成下列的基本功能 功能列表和完成状况 短连接 * [√] Guice 和 Netty 整合 * [√] 可自定义添加 Guice 的 Model * [√] 在类上加注解(@Service @Controller @Socket)自动扫描完成依赖注入 * [√] 通过 @Path 完成路由的配置,类和方法上的取值会自动连接 * [√] 识别请求的 @Post @Get @Delete @Put 的 httpMethod * [√] 通过 @Product 识别返回值是 Json 还是 模板,或是 Protobuf 或是 Binary * [√] Controller 自动注入 HttpRequest HttpResponse Post 和 Get 参数 * [√] Controller 识别 和输出 Json 请求 * [√] Controller 识别 Protobuf 请求 * [√] 文件上传 @FileParam * [√] 增加模板,自带 Freemarker 和 Thymeleaf * [√] Session RequestAttribute * [√] filter 支持 Websocket * [√] 整合 Websocket,通过 @Socket 指定类接收长连接数据 * [√] Websocket 的路由通过类的 @Path 完成配置 * [√] 通过方法上的注解 @Open @Close @Message @TextMessage @BinaryMessage @Ping @Pong 完成不同数据包的传递 * [√] 长连接 WebsocketFrame 的值可自动传入到你的 socket handler * [√] protobuf , json 的自动编码,解码到变量 * [ ] 长连接的参数还需要补充和完善 * [√] filter 支持 引入 <dependency> <groupId>com.doopp</groupId> <artifactId>gutty</artifactId> <version>0.14.8</version> </dependency> compile 'com.doopp:gutty:0.14.8' 启动 Gutty // 驱动 Gutty public static void main(String[] args) { new Gutty().loadProperties(args) .setBasePackages("com.doopp.gutty.auth") .setMessageConverter(JacksonMessageConverter.class) .setViewResolver(FreemarkerViewResolver.class) .addFilter("/api", ApiFilter.class) .addMyBatisModule(HikariCPProvider.class, "com.doopp.gutty.auth.dao", PageInterceptor.class) .addModules(new RedisModule() { @Singleton @Provides public ShardedJedisHelper userRedis(JedisPoolConfig jedisPoolConfig, @Named("redis.user.servers") String userServers) { return new ShardedJedisHelper(userServers, jedisPoolConfig); } }) .addInjectorConsumer(injector->{ ScheduledExecutorService newScheduledThreadPool = Executors.newScheduledThreadPool(8); newScheduledThreadPool.scheduleWithFixedDelay(injector.getInstance(AgarTask.class), 1000, 16, TimeUnit.MILLISECONDS); }) .start(); }