Gutty 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
Gutty 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
Gutty 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」 !
Gutty 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」「最积极运营项目」 !
Gutty 获得 2020 年度 OSC 中国开源项目评选「最积极运营项目」 !
授权协议 Apache
开发语言 Java 查看源码 »
操作系统 Linux
软件类型 开源软件
所属分类 程序开发网络工具包
开源组织
地区 国产
投 递 者 前_端
适用人群 未知
收录时间 2021-02-13

软件简介

简介

一直很喜欢轻量 IOC 框架 Guice ,希望能将其和 netty 整合起来
网上有不少整合的例子,但没有整合成扫描包后,自动完成路由和模块配置,这是最好用的功能
之前将 Reactor-Netty 和 Guice 整合了一遍, 但是 Reactor 那个写法确实不习惯,有些方法也不熟悉,用起来常常绕晕自己
最近有点时间,撸起袖子开始整,用半个多月,完成框架主要功能,只需要基本的设定就能支持 MVC 和 websocket 服务
已包含常用的 Jackson , Gson, Freemark, Thymeleof 和 Jedis 助手类,支持按 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 支持
* [√] @Socket 通过配置 subprotocol 来支持 Sec-WebSocket-Protocol

  包引入

<dependency>
    <groupId>com.doopp</groupId>
    <artifactId>gutty</artifactId>
    <version>0.14.10</version>
</dependency>

 

compile 'com.doopp:gutty:0.14.10'

启动 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(subprotocol = "Auth-Token") // 支持 Sec-WebSocket-Protocol
@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() {
    }
}

 

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (4)

加载中
用过vert.x+guice 还行 习惯了spring感觉没spring方便
03/11 11:34
回复
举报
前_端软件作者
是的,spring 更方便,想用什么都有
03/12 01:08
回复
举报
这个到底能干啥,增强netty,还是替代netty?比netty有啥好处
02/20 09:20
回复
举报
前_端软件作者
netty 还是那个 netty , 通过 guice 增加了依赖注入 ,扫描 @Controller@Service 还有 @Socket 类自动完成 mvc 路由和 websocket 路由 , 简单的例子,可见 https://www.oschina.net/news/132409/gutty-0-14-10-released
03/11 10:27
回复
举报
更多评论
03/09 12:34

Gutty 0.14.10 发布, 增加支持 Sec-WebSocket-Protocol

一直很喜欢 Netty 和 Guice,简单好用,一直想自己动手来整合他们。 Gutty 大概用了一个月的时间来做,参考 Spring 中一些习惯, 通过扫描包完成路由,依赖,长链接配置, 或是自动给 Controller 传递值。 也预置了 模板,Redis 和 Mybatis 的便捷接入, 可以按 URI 来添加多个 Filter, 后面还会继续的完善和添加便捷的功能。 功能列表和完成状况 短连接 * [√] Guice 和 Netty 整合 * [√] 启动时扫描包,为 @Control...

0
4
02/13 12:22

Gutty 0.14.9 发布,基于 Guice 和 Netty 的网络服务框架

一直很喜欢 Netty 和 Guice,简单好用,一直想自己动手来整合他们。 Gutty 大概用了一个月的时间来做,参考 Spring 中一些习惯, 通过扫描包完成路由,依赖,长链接配置, 或是自动给 Controller 传递值。 也预置了 模板,Redis 和 Mybatis 的便捷接入, 可以按 URI 来添加多个 Filter, 后面还会继续的完善和添加便捷的功能。 功能列表和完成状况 短连接 * [√] Guice 和 Netty 整合 * [√] 启动时扫描包,为 @Control...

1
14
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表了博客
2018/03/01 07:16

西奥妮·帕帕斯《天天数学》

译者序 你想知道古今中外数学发展的概况吗?你想知道那些伟大人物怎样看待数学的吗?你想知道数学与其它科学的密切关系吗?你想知道数学在科学研究和社会生活中广泛的应用吗?你想寻找一些趣味题目挑战自己思维的灵活性与独创性吗?……翻阅西奥尼·帕帕斯的《天天数学》,让这本书伴你一年轻松而快乐的时光吧!我相信,你们一定不会失望的,你一定会有许多的收获。 西奥尼·帕帕斯撰写了十余部数学科普著作,如《理性的音乐》、...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
4 评论
23 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部