这期内容当中小编将会给大家带来有关如何在springboot中整合netty,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
1. 新建一个springboot项目,在pom文件中添加netty依赖:
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>5.0.0.Alpha1</version> </dependency>
2.新建netty服务
其实可以复制上一篇文章的netty的三个服务类,做一些稍微的修改就行了;这里为了方便演示,且修都是改好了的,就直接贴出来了;
DiscardServer类:
@Component public class DiscardServer { @Resource private ChildChannelHandler childChannelHandler; public void run(int port) throws Exception { EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); System.out.println("准备运行端口:" + port); try { ServerBootstrap bootstrap = new ServerBootstrap(); bootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 128) .childHandler(childChannelHandler); //绑定端口,同步等待成功 ChannelFuture f = bootstrap.bind(port).sync(); //等待服务监听端口关闭 f.channel().closeFuture().sync(); } finally { //退出,释放线程资源 workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } } }
ChildChannelHandler类
@Component public class ChildChannelHandler extends ChannelInitializer<SocketChannel> { @Resource private DiscardServerHandler discardServerHandler; public void initChannel(SocketChannel socketChannel) throws Exception { socketChannel.pipeline().addLast(discardServerHandler); } }
3.DiscardServerHandler类
特别注意DiscardServerHandler类上需要加@Sharable注解,如果不加的话会报错;
@Component @Sharable public class DiscardServerHandler extends ChannelHandlerAdapter { @Resource private BaseService baseService; @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { try { ByteBuf in = (ByteBuf) msg; System.out.println("传输内容是"); System.out.println(in.toString(CharsetUtil.UTF_8)); //这里调用service服务 baseService.test(); } finally { ReferenceCountUtil.release(msg); } } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { // 出现异常就关闭 cause.printStackTrace(); ctx.close(); } }
3.netty调用所需的服务类
1.BaseService接口
public interface BaseService { /** * 测试接口 */ void test(); }
2.接口实现类BaseServiceImpl:
@Service public class BaseServiceImpl implements BaseService { @Override public void test() { System.out.println("调用service服务"); } }
4 springboot启动类
由于main方法是静态方法,netty服务启动类不是静态类,在main方法里面需要用new的方式启动;
也可以将netty服务启动类改为静态类,然后调用其他非静态的类时就得用new方法来构造其他类了;
我也百度到了几篇文章说实现CommandLineRunner接口,所以我用了springboot启动类实现CommandLineRunner接口的run方法,然后在run方法里启动netty服务
@SpringBootApplication public class DemoApplication implements CommandLineRunner { @Resource private DiscardServer discardServer; public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } @Override public void run(String... args) throws Exception { discardServer.run(8080); } }
5.测试
写一个能发送数据的socket就可以了;
发送的数据为:
public static void main(String[] args){ try { Socket socket=new Socket("localhost",8080); OutputStream outputStream = socket.getOutputStream(); PrintWriter printWriter=new PrintWriter(outputStream); printWriter.write("$tmb00035ET3318/08/22 11:5804029.94,027.25,20.00,20.00$"); printWriter.flush(); socket.shutdownOutput(); socket.close(); } catch (IOException e) { e.printStackTrace(); } }
我的测试结果:
传输内容是 $tmb00035ET3318/08/22 11:5804029.94,027.25,20.00,20.00$ aaaaa
到这里,netty与springboot的整合就完成了;
我在整合过程中遇到的问题
我使用springboot结合netty的流程
springboot启动类中启动netty启动类(DiscardServer),netty启动类(DiscardServer)再调用初始化channel类(ChildChannelHandler),然后初始化channel类再调用(DiscardServerHandler)类;然后DiscardServerHandler类再调用service服务;如下示例图:
问题:
springboot启动类我并没有实现CommandLineRunner接口,直接在main方法通过new的方式启动netty服务
我实现了CommandLineRunner接口,但是我在run方法中用的new的方式启动的netty服务或者我在run方法使用注入的方式启动netty,但是在其他某个地方调用另一个类使用了new的方式;
DiscardServerHandler类上为标记@Sharable类,会报错误;
以上总结起来的问题就是我在springboot整合netty的过程中有其中一处的调用其他类时使用的方式是new构造的,这样虽然springboot能启动,netty也能启动,但是netty服务中使用new构造的那个类中无法依赖注入,会报空指针异常;
举个栗子:在图中的过程中,我在ChildChannelHandler类中通过new的方式调用DiscardServerHandler类,其他的过程都是使用注入的方式调用,就会出现上边的问题;
在遇到空指针的时候,我把spring托管的bean打印了出来,所有的类都在spring的托管中,但是就是无法注入,我也一直没有明白怎么回事,最后用了一个极端的方法,就是在调用服务时,获取spring的上下文,然后再根据名字来获取bean,你谷歌或百度:非托管类调用spring托管类,就能找到很多文章了;虽然用这个方式能解决上述的问题,但总是不好的;
最后的解决办法:所以类之间的调用都使用spring的依赖注入,别用new的方式来调用或者静态方法的方式调用
上述就是小编为大家分享的如何在springboot中整合netty了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。