下面是一个简单的Spring Boot整合Netty的例子，实现了一个基础的服务器端。
首先，添加Netty和Spring Boot的起步依赖到你的pom.xml文件中：
<dependencies>
<!-- Spring Boot相关依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- Netty依赖 -->
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.69.Final</version> <!-- 使用的Netty版本 -->
</dependency>
</dependencies>然后，创建一个Netty服务器的配置类：
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class NettyServerConfig {
@Value("${netty.port}")
private int port;
@Bean(destroyMethod="shutdownGracefully")
public EventLoopGroup bossGroup() {
return new NioEventLoopGroup();
}
@Bean(destroyMethod="shutdownGracefully")
public EventLoopGroup workerGroup() {
return new NioEventLoopGroup();
}
@Bean
public ServerBootstrap serverBootstrap(EventLoopGroup bossGroup, EventLoopGroup workerGroup) {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new NettyServerInitializer()); // 自定义初始化处理器
return b;
}
@Bean
public ChannelFuture channelFuture(ServerBootstrap serverBootstrap) {
ChannelFuture f = serverBootstrap.bind(port).sync();
return f;
}
}创建一个Netty的初始化处理器：
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
public class NettyServerInitializer extends ChannelInitializer<SocketChannel> {
@Override
public void initChannel(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("encoder", new StringEncoder());
pipeline.addLas