Nettyノートの3:NettyがSocketプログラミングを実現
6900 ワード
NettyはTcp Socketプログラミングを実現します.
demoは機能クライアントがサービス側にメッセージを送信し、サーバがメッセージを受信した後にクライアントに応答することを実現する.
依存関係の追加:
私はgradleを使ってプロジェクトを構築したのでbuild.gradleは次のとおりです.
サーバコード
サーバ側初期化Initializer
サーバ側カスタムHandler:
クライアント:
クライアント初期化Initializer
クライアントカスタムHandler:
クライアントとサービス・エンド、サービス・エンド・コンソールを起動します.
クライアントコンソール:
プロセス分析:クライアントとサービス側のチャネルが接続を確立すると(channelActiveメソッドをトリガー)、クライアントはサービスに「クライアントとの問題!」を送信します.データ、サーバ側channelRead 0がトリガーされ、クライアントにデータの書き込みを行うchannelRead 0コールバックメソッドが呼び出され、順次往復する.
demoは機能クライアントがサービス側にメッセージを送信し、サーバがメッセージを受信した後にクライアントに応答することを実現する.
依存関係の追加:
io.netty
netty-all
4.1.10.Final
私はgradleを使ってプロジェクトを構築したのでbuild.gradleは次のとおりです.
compile (
'io.netty:netty-all:4.1.10.Final'
)
サーバコード
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 io.netty.handler.logging.LoggingHandler;
public class MyServer {
public static void main(String[] args) throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup wokerGroup = new NioEventLoopGroup();
try{
ServerBootstrap serverBootstrap = new ServerBootstrap();
// handler() bossGroup , childHandler wokerGroup
serverBootstrap.group(bossGroup,wokerGroup).channel(NioServerSocketChannel.class)
.childHandler(new MyServerInitializer());
ChannelFuture channelFuture = serverBootstrap.bind(8899).sync();
channelFuture.channel().closeFuture().sync();
}finally {
bossGroup.shutdownGracefully();
wokerGroup.shutdownGracefully();
}
}
}
サーバ側初期化Initializer
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
import io.netty.handler.codec.LengthFieldPrepender;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
public class MyServerInitializer extends ChannelInitializer{
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE,0,4,0,4));
pipeline.addLast(new LengthFieldPrepender(4));
//
pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));
//
pipeline.addLast(new StringEncoder(CharsetUtil.UTF_8));
//
pipeline.addLast(new MyServerHandler());
}
}
サーバ側カスタムHandler:
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import java.util.UUID;
public class MyServerHandler extends SimpleChannelInboundHandler{
@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
//
System.out.println(ctx.channel().remoteAddress()+", "+msg);
ctx.channel().writeAndFlush("form server: "+ UUID.randomUUID());
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
クライアント:
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
public class MyClient {
public static void main(String[] args) throws Exception{
EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
try{
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class)
.handler(new MyClientInitializer());
ChannelFuture channelFuture = bootstrap.connect("localhost",8899).sync();
channelFuture.channel().closeFuture().sync();
}finally {
eventLoopGroup.shutdownGracefully();
}
}
}
クライアント初期化Initializer
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
import io.netty.handler.codec.LengthFieldPrepender;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
public class MyClientInitializer extends ChannelInitializer {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE,0,4,0,4));
pipeline.addLast(new LengthFieldPrepender(4));
pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));
pipeline.addLast(new StringEncoder(CharsetUtil.UTF_8));
pipeline.addLast(new MyClientHandler());
}
}
クライアントカスタムHandler:
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import java.time.LocalDateTime;
public class MyClientHandler extends SimpleChannelInboundHandler{
@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
//
System.out.println(ctx.channel().remoteAddress());
System.out.println("client output: "+msg);
ctx.writeAndFlush("from client: "+ LocalDateTime.now());
}
/**
* , , , channelRead0 ,
* , channelActive handler channelRead0 ,
* channelRead0, 。
*/
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
ctx.writeAndFlush(" !");
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
クライアントとサービス・エンド、サービス・エンド・コンソールを起動します.
/127.0.0.1:49645, !
/127.0.0.1:49645, from client: 2017-10-09T23:44:42.493
/127.0.0.1:49645, from client: 2017-10-09T23:44:42.495
/127.0.0.1:49645, from client: 2017-10-09T23:44:42.496
...
クライアントコンソール:
localhost/127.0.0.1:8899
client output: form server: ca79614c-351c-4aed-9906-532fb19f8286
localhost/127.0.0.1:8899
client output: form server: c66482ff-503b-41e8-a2b1-0de88e856433
localhost/127.0.0.1:8899
...
プロセス分析:クライアントとサービス側のチャネルが接続を確立すると(channelActiveメソッドをトリガー)、クライアントはサービスに「クライアントとの問題!」を送信します.データ、サーバ側channelRead 0がトリガーされ、クライアントにデータの書き込みを行うchannelRead 0コールバックメソッドが呼び出され、順次往復する.