简介
一直很喜欢 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();
}