Skip to content

N
netty-demo

Kwan的解忧杂货铺@新空间代码工作室 / netty-demo

通知 2
Star 0
Fork 0
N
netty-demo
提交 61ef5640 编写于 作者: Kwan的解忧杂货铺@新空间代码工作室's avatar Kwan的解忧杂货铺@新空间代码工作室 🐭
浏览文件
操作

fix:接受关闭之后的处理

上级 d4a59a72
隐藏空白更改
内联 并排
Showing with 243 addition and 1 deletion
src/main/java/com/kwan/shuyu/heima/netty_04_netty/c11_Scanner/TestEventLoop_02_client.java
浏览文件 @ 61ef5640
......@@ -46,7 +46,7 @@ public class TestEventLoop_02_client {
while (true) {
final String line = scanner.nextLine();
if ("q".equals(line)) {
channel.close();
channel.close();//close是异步操作
break;
}
channel.writeAndFlush(line);
......
src/main/java/com/kwan/shuyu/heima/netty_04_netty/c12_closesync/TestEventLoop_01_server.java 0 → 100644
浏览文件 @ 61ef5640
package com.kwan.shuyu.heima.netty_04_netty.c12_closesync;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import lombok.extern.slf4j.Slf4j;
import java.nio.charset.Charset;
/**
* 服务端3个Handler
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2023/4/23 10:51
*/
@Slf4j
public class TestEventLoop_01_server {
public static void main(String[] args) {
//普通任务
final EventLoopGroup group = new DefaultEventLoopGroup();
new ServerBootstrap()
//boss 只负责ServerSocketChannel 上 accept 事件 worker只负责socketChannel上的读写
.group(new NioEventLoopGroup(), new NioEventLoopGroup(2))
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<NioSocketChannel>() {
@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
//支持链式调用
ch.pipeline().addLast("handler1", new ChannelInboundHandlerAdapter() {
// ByteBuf
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf buf = (ByteBuf) msg;
log.info("我是handler1,{}", buf.toString(Charset.defaultCharset()));
ctx.fireChannelRead(msg);
}
}).addLast(group, "handler2", new ChannelInboundHandlerAdapter() {
// handler2 是一个普通任务,第一个参数是EventExecutorGroup,指定group执行
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf buf = (ByteBuf) msg;
log.info("我是handler1,{}", buf.toString(Charset.defaultCharset()));
}
});
//添加解码器
ch.pipeline().addLast("handler0", new StringDecoder());
}
})
.bind(8080);
}
}
\ No newline at end of file
src/main/java/com/kwan/shuyu/heima/netty_04_netty/c12_closesync/TestEventLoop_02_client.java 0 → 100644
浏览文件 @ 61ef5640
package com.kwan.shuyu.heima.netty_04_netty.c12_closesync;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import lombok.extern.slf4j.Slf4j;
import java.net.InetSocketAddress;
import java.util.Scanner;
/**
* 客户端添加Scanner输入
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2023/4/23 16:43
*/
@Slf4j
public class TestEventLoop_02_client {
public static void main(String[] args) throws InterruptedException {
//1.启动类
final ChannelFuture channelFuture = new Bootstrap()
// 2.添加 EventLoop
.group(new NioEventLoopGroup())
//3.选择客户端channel实现
.channel(NioSocketChannel.class)
// 4.添加处理器4
.handler(new ChannelInitializer<NioSocketChannel>() {
@Override //在连接建立后被调用
protected void initChannel(NioSocketChannel ch) throws Exception {
ch.pipeline().addLast(new LoggingHandler(LogLevel.INFO));
ch.pipeline().addLast(new StringEncoder());
}
})
//连接到服务器
.connect(new InetSocketAddress("localhost", 8080));
Channel channel = channelFuture.sync().channel();
new Thread(() -> {
final Scanner scanner = new Scanner(System.in);
while (true) {
final String line = scanner.nextLine();
if ("q".equals(line)) {
channel.close();//close是异步操作,需要处理之后的操作
break;
}
channel.writeAndFlush(line);
}
}, "input").start();
//获取 ClosedFuture 对象，1.异步处理关闭 2.同步处理
ChannelFuture closeFuture = channel.closeFuture();
System.out.println("waiting close.….");
closeFuture.sync();//同步处理关闭
log.debug("处理关闭之后的操作");
}
}
\ No newline at end of file
src/main/java/com/kwan/shuyu/heima/netty_04_netty/c13_closefeature/TestEventLoop_01_server.java 0 → 100644
浏览文件 @ 61ef5640
package com.kwan.shuyu.heima.netty_04_netty.c13_closefeature;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import lombok.extern.slf4j.Slf4j;
import java.nio.charset.Charset;
/**
* 服务端3个Handler
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2023/4/23 10:51
*/
@Slf4j
public class TestEventLoop_01_server {
public static void main(String[] args) {
//普通任务
final EventLoopGroup group = new DefaultEventLoopGroup();
new ServerBootstrap()
//boss 只负责ServerSocketChannel 上 accept 事件 worker只负责socketChannel上的读写
.group(new NioEventLoopGroup(), new NioEventLoopGroup(2))
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<NioSocketChannel>() {
@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
//支持链式调用
ch.pipeline().addLast("handler1", new ChannelInboundHandlerAdapter() {
// ByteBuf
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf buf = (ByteBuf) msg;
log.info("我是handler1,{}", buf.toString(Charset.defaultCharset()));
ctx.fireChannelRead(msg);
}
}).addLast(group, "handler2", new ChannelInboundHandlerAdapter() {
// handler2 是一个普通任务,第一个参数是EventExecutorGroup,指定group执行
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf buf = (ByteBuf) msg;
log.info("我是handler1,{}", buf.toString(Charset.defaultCharset()));
}
});
//添加解码器
ch.pipeline().addLast("handler0", new StringDecoder());
}
})
.bind(8080);
}
}
\ No newline at end of file
src/main/java/com/kwan/shuyu/heima/netty_04_netty/c13_closefeature/TestEventLoop_02_client.java 0 → 100644
浏览文件 @ 61ef5640
package com.kwan.shuyu.heima.netty_04_netty.c13_closefeature;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import lombok.extern.slf4j.Slf4j;
import java.net.InetSocketAddress;
import java.util.Scanner;
/**
* 客户端添加Scanner输入
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2023/4/23 16:43
*/
@Slf4j
public class TestEventLoop_02_client {
public static void main(String[] args) throws InterruptedException {
//1.启动类
final ChannelFuture channelFuture = new Bootstrap()
// 2.添加 EventLoop
.group(new NioEventLoopGroup())
//3.选择客户端channel实现
.channel(NioSocketChannel.class)
// 4.添加处理器4
.handler(new ChannelInitializer<NioSocketChannel>() {
@Override //在连接建立后被调用
protected void initChannel(NioSocketChannel ch) throws Exception {
ch.pipeline().addLast(new LoggingHandler(LogLevel.INFO));
ch.pipeline().addLast(new StringEncoder());
}
})
//连接到服务器
.connect(new InetSocketAddress("localhost", 8080));
Channel channel = channelFuture.sync().channel();
new Thread(() -> {
final Scanner scanner = new Scanner(System.in);
while (true) {
final String line = scanner.nextLine();
if ("q".equals(line)) {
channel.close();//close是异步操作,需要处理之后的操作
break;
}
channel.writeAndFlush(line);
}
}, "input").start();
//获取 ClosedFuture 对象，1.异步处理关闭 2.同步处理
ChannelFuture closeFuture = channel.closeFuture();
System.out.println("waiting close.….");
//异步处理关闭之后的操作
closeFuture.addListener(
new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture channelFuture) throws Exception {
log.debug("处理关闭之后的操作");
}
}
);
}
}
\ No newline at end of file
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或