Gutty 0.14.9 发布，基于 Guice 和 Netty 的网络服务框架
一直很喜欢 Netty 和 Guice，简单好用，一直想自己动手来整合他们。 Gutty 大概用了一个月的时间来做，参考 Spring 中一些习惯， 通过扫描包完成路由，依赖，长链接配置， 或是自动给 Controller 传递值。 也预置了 模板，Redis 和 Mybatis 的便捷接入， 可以按 URI 来添加多个 Filter,后面还会继续的完善和添加便捷的功能。 功能列表和完成状况 短连接 * [√] Guice 和 Netty 整合 * [√] 启动时扫描包，为 @Controller 和 @Socket 的类配置路由 * [√] 自动绑定扫描到的 @Service 的类(普通的绑定 和 按名称绑定) * [√] @Post @Get @Delete @Put 的 httpMethod 支持 * [√] 通过 @Product 识别返回值是 Json 还是 模板，或是 Protobuf 或是 Binary * [√] 控制类下的方法参数传入，支持 @CookieParm @QueryParam @PathParam @FormParam * [√] Controller 识别 和输出 Json 请求 * [√] Controller 识别 Protobuf 请求 * [√] 可以通过 @FileParam 来上传文件 * [√] 支持模板，预置 Freemarker 和 Thymeleaf 的接入 * [√] 支持 @RequestAttribute，可以用来提供 Session 功能 * [√] 适配 uri 的 Filter 支持 Websocket * [√] 整合 Websocket，通过 @Socket 指定类接收长连接数据 * [√] Websocket 的路由通过类的 @Path 完成配置 * [√] 支持 @Open @Close @Message @TextMessage @BinaryMessage @Ping @Pong 完成不同数据包的传递 * [√] 长连接 WebsocketFrame 的值可自动传入到你的 socket handler * [√] 添加 protobuf， json 的自动编码，解码到变量 * [√] 适配 uri 的 Filter 支持 * [ ] 长连接的参数还需要补充和完善 包引入 <dependency> <groupId>com.doopp</groupId> <artifactId>gutty</artifactId> <version>0.14.9</version> </dependency> compile 'com.doopp:gutty:0.14.9' 启动 Gutty public static void main(String[] args) { new Gutty().loadProperties(args) // 加载配置文件 // 设定扫描的包路径 .setBasePackages("com.doopp.gutty.test") // Json 支持 .setMessageConverter(JacksonMessageConverter.class) // 模板支持 .setViewResolver(FreemarkerViewResolver.class) // 添加 Filter .addFilter("/api", ApiFilter.class) // 配置数据库，需要引入 guice-mybatis 包 .setMyBatis(HikariCPProvider.class, "com.doopp.gutty.test.dao", PageInterceptor.class) // 配置多个 redis .addModules( new RedisModule() { @Override protected void initialize() { bindJedisPoolConfigProvider(JedisPoolConfigProvider.class); bindSerializableHelper(JdkSerializableHelper.class); } @Singleton @Provides @Named("userRedis") public ShardedJedisHelper userRedis(JedisPoolConfig jedisPoolConfig, SerializableHelper serializableHelper, @Named("redis.user.servers") String userServers) { return new ShardedJedisHelper(userServers, jedisPoolConfig, serializableHelper); } @Singleton @Provides public ShardedJedisHelper testRedis(JedisPoolConfig jedisPoolConfig, SerializableHelper serializableHelper, @Named("redis.test.servers") String userServers) { return new ShardedJedisHelper(userServers, jedisPoolConfig, serializableHelper); } } ) // 完成 injector 配置后，执行里面的代码，多用于任务的执行 .addInjectorConsumer(injector->{ ScheduledExecutorService newScheduledThreadPool = Executors.newScheduledThreadPool(8); newScheduledThreadPool.scheduleWithFixedDelay(injector.getInstance(AgarTask.class), 1000, 16, TimeUnit.MILLISECONDS); }) .start(); } Controller 类 @Path("/api") @Controller public class HelloController { private static final Logger logger = LoggerFactory.getLogger(HelloController.class); @Inject private HelloService helloService; @Inject private UserDao userDao; @Inject @Named("userRedis") private ShardedJedisHelper userRedis; @GET @Path("/redis/read") @Produces("application/json") public User readRedis() { User user = userRedis.get("user_redis".getBytes(), User.class); return user; } @GET @Path("/redis/write") @Produces("application/json") public User writeRedis() { User user = new User(); user.setId(System.currentTimeMillis()); userRedis.set("user_redis".getBytes(), user); return user; } @GET @Path("/template") public String template(ModelMap modelMap) { modelMap.addAttribute("hello", "hello freemarker !"); return "hello.template"; } @GET @Path("/hello") @Produces("application/json") public String hello(@CookieParam("user") String user) { return helloService.hello(); } @GET @Path("/users") @Produces("application/json") public List<User> users(@RequestAttribute("hello") String hello) { System.out.println(hello); return userDao.selectAll(); } @GET @Path("/hello/{id}/{name}") public String hello3(@PathParam("id") Integer id, @PathParam("name") String name) { logger.info("id {}", id); logger.info("name {}", name); return helloService.hello(); } @POST @Path("/hello") @Produces("application/json") public User hello2(@FormParam("liu") String liu) { logger.info("liu {}", liu); User user = new User(); user.setNickName(liu); return user; } @POST @Path("/json") @Produces("application/json") public User hello2(User user) { logger.info("user {}", user); return user; } @POST @Path("/upload") @Produces("application/json") public String upload(@FileParam(value = "file", path = "d:/tmp") File uploadFile) { logger.info("file {}", uploadFile); return "hello"; } } Service 类 // HelloService.java public interface HelloService { String hello(); } // HelloServiceImpl.java @Service public class HelloServiceImpl implements HelloService { @Override public String hello() { return "hello kunlun !"; } } Websocket 类 @Socket @Path("/ws/game") public class HelloSocket { private static final Logger logger = LoggerFactory.getLogger(HelloSocket.class); @Open public void onConnect(Channel channel) { channel.writeAndFlush(new TextWebSocketFrame("you connected")); } @TextMessage public void onTextMessage(Channel channel) { channel.writeAndFlush(new TextWebSocketFrame("hello")); } @TextMessage public void onJsonMessage(@JsonFrame User user) { logger.info("user {}", user.getNickName()); } @BinaryMessage public void onBinaryMessage(BinaryWebSocketFrame binaryWebSocketFrame) { logger.info("binaryFrame {}", binaryWebSocketFrame.content()); } @BinaryMessage public void onProtobufMessage(@ProtobufFrame User user) { logger.info("user {}", user); } //@Message //public void onMessage(WebSocketFrame webSocketFrame) { // logger.info("onMessage : {}", webSocketFrame.getClass()); //} @Ping public void onPing() { } @Pong public void onPong() { } @Close public void onClose() { } }
