前言
前面写到了springboot整合netty,只是使用netty将数据处理了,还没有存入数据库,现在就把mybatis加进去吧;刚好最近也有一位读者问到了这个问题;
正文
首先引入pom依赖
1 |
|
配置
配置文件配置:
1 |
|
记住springboot的启动类上要扫描mapper接口包
springboot中启动netty
其实springboot中启动netty的方式有很多种,前一篇netty文章中我通过实现CommandLineRunner
接口来启动netty服务,后面写了一篇springbean生命周期,发现springboot
可以用配置bean的方式启动netty服务,在启动方法上添加@PostConstruct
注解,代码如下:
NettyStart
类
1 |
|
其中的serverHandler
是通过依赖注入的方式注入的,这是为了后面serverHandler
类中可以直接依赖注入;
ServerHandler
类:
1 |
|
这个类加了@Component
和@Sharable
注解,前一个不用解释了,后一个个人觉得:这个类被spring托管了,那么这个类就是单例,相当于这个类是共享的,所以得加@Sharable
注解,关于该注解,可以参考这篇文章:https://blog.csdn.net/supper10090/article/details/78431948
这里我注入了UserService
类,这里是操作数据库的方法
UserService
类
1 |
|
UserServiceImpl
类
1 |
|
实体类
1 |
|
set,get方法省略
mapper接口
1 |
|
mapper的xml文件就补贴上来了;
输出结果
1 |
|
我的mapper中只是查询数据库操作,并没有写如数据,如果要写入,修改mapper就行了;
总结
在很多关于netty的项目或博客中都是通过new的方式添加pipeline
的,而我这里用了注入的方式;我是因为我所做的这个项目是单机版的,相当于就是所有的功能都在一个项目里面,而且单个功能操作数据库的频率比较高,而且我做的这个项目处理不了高并发,并发高了就会gg;所以我所写的这些文章都是从项目上所学来的;
如果通过new的方式添加pipeline
,那么在处理数据的方法中可以通过一个类实现ApplicationContextAware
接口来获取spring上下文;然后在调用bean,操作数据库;下面是参考链接:
在非spring管理的类中,使用spring管理的类
- springboot启动netty的方式有很多:一种是实现
CommandLineRunner
接口;一种是配置bean,指定初始化方法;还有其他的
参考文章:https://crossoverjie.top/2018/05/24/netty/Netty(1)TCP-Heartbeat/