当前位置：首页 > article >正文

Netty来创建一个TCP服务器，分包上传语音文件的处理

article 2025/1/25 3:48:14

创建一个TCP服务器。

我们以在Spring Boot项目中集成Netty来创建一个TCP服务器为例，使用Netty创建一个TCP服务器是常见且可靠的，特别是在需要高性能、低延迟的网络通信时。

添加依赖

在pom.xml文件中添加Netty的依赖：

<dependencies>
    <dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.1.68.Final</version>
    </dependency>
</dependencies>

创建Netty服务器配置类

创建一个配置类来启动Netty服务器。

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
 
@Configuration
public class NettyServerConfig {
   
 
    private final int port = 8080;
    private EventLoopGroup bossGroup;
    private EventLoopGroup workerGroup;
    private ChannelFuture channelFuture;
 
    @PostConstruct
    public void start() throws Exception {
   
        bossGroup = new NioEventLoopGroup(1);
        workerGroup = new NioEventLoopGroup();
        try {
   
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
   
                    @Override
                    public void initChannel(SocketChannel ch) throws Exception {
   
                        ch.pipeline().addLast(new StringDecoder());
                        ch.pipeline().addLast(new StringEncoder());
                        ch.pipeline().addLast(new SessionIdHandler());
                        ch.pipeline().addLast(new NettyServerHandler());
                        ch.pipeline().addLast(new NettyServerHandler());
                    }
                })
                .option(ChannelOption.SO_BACKLOG, 128)
                .childOption(ChannelOption.SO_KEEPALIVE, true);
 
            channelFuture = b.bind(port).sync();
            System.out.println("Netty server started on port " + port);
        } finally {
   
            if (channelFuture != null && channelFuture.isSuccess()) {
   
                channelFuture.channel().closeFuture().sync();
            }
        }
    }
 
    @PreDestroy
    public void stop() throws Exception {
   
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}