netty tcp服务器,云主机和物理机,挂机vps 512,vps搭建cdn,百度VPS

🗣 Wd提问: netty tcp服务器

🤖 Ai回答:
Netty 是一个高性能、异步事件驱动的网络应用框架，广泛用于构建 TCP/UDP 服务器和客户端。下面是一个使用 Netty 编写的简单 TCP 服务器示例，适用于 Java 开发环境。

1、添加 Maven 依赖

如果你使用的是 Maven 项目，请在 `pom.xml` 中添加 Netty 依赖：

xml
<dependency
<groupIdio.netty</groupId
<artifactIdnetty-all</artifactId
<version4.1.92.Final</version
</dependency

注意：请根据你的项目需求选择合适的 Netty 版本。

2、创建 TCP 服务器代码

java
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
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;

public class NettyTcpServer {

private final int port;

public NettyTcpServer(int port) {
this.port = port;
}

public void start() throws Exception {
// 配置 boss 和 worker 线程组
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();

try {
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
// 添加编解码器（字符串处理）
ch.pipeline().addLast(
new StringDecoder(),
new StringEncoder(),
new MyServerHandler()
);
}
})
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);

// 绑定端口并启动服务
ChannelFuture future = bootstrap.bind(port).sync();
System.out.println(TCP 服务器启动，监听端口： + port);
future.channel().closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}

public static void main(String[] args) throws Exception {
int port = 8080;
new NettyTcpServer(port).start();
}
}

3、自定义处理器（Handler）

java
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class MyServerHandler extends SimpleChannelInboundHandler<String {

@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
System.out.println(收到消息： + msg);
// 回复客户端
ctx.writeAndFlush(服务器收到： + msg + \n);
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println(客户端连接： + ctx.channel().remoteAddress());
}

@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
System.out.println(客户端断开： + ctx.channel().remoteAddress());
}
}

4、运行说明

启动该程序后，服务器会在 `8080` 端口监听。
可以使用 telnet 或编写客户端程序测试：
bash
telnet localhost 8080

输入任意文本，服务器会回显。

特点说明

异步非阻塞：基于 NIO 实现，支持高并发。
可扩展性强：可通过 Pipeline 添加更多 Handler（如 JSON 解析、SSL 加密等）。
易于维护：职责分离清晰，适合复杂业务场景。

如需实现更复杂的协议（如二进制、自定义帧格式），可以替换 `StringDecoder` 和 `StringEncoder` 为其他编解码器，例如 `LengthFieldBasedFrameDecoder` 等。

如有具体需求（如心跳机制、长连接管理、多线程处理等），可进一步扩展。

Ai作答

📣 商家广告：