如何在springboot中整合netty
这期内容当中小编将会给大家带来有关如何在springboot中整合netty，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
创新互联自2013年创立以来，是专业互联网技术服务公司，拥有项目成都做网站、成都网站设计网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元灵寿做网站,已为上家服务,为灵寿各地企业和个人服务,联系电话:13518219792
1. 新建一个springboot项目，在pom文件中添加netty依赖：
io.netty netty-all 5.0.0.Alpha1
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{ @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了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
分享文章：如何在springboot中整合netty
本文路径：http://6mz.cn/article/iisdje.html