模拟Tcp连接三次握手,四次挥手
服务端
服务端使用 Nio 搭建Server,也可以使用Socket套接字
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;
?
public class NioSelectorServerCopy {
? ?public static void main(String[] args) throws IOException {
? ? ? ?accept();
? }
? ?public static void accept() throws IOException {
? ? ? ?ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
? ? ? ?serverSocketChannel.bind(new InetSocketAddress(52168));
? ? ? ?serverSocketChannel.configureBlocking(false);
? ? ? ?Selector selector = Selector.open();
? ? ? ?serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
? ? ? ?System.out.println("server start success!");
? ? ? ?while (true){
? ? ? ? ? ?selector.select();
?
? ? ? ? ? ?Set<SelectionKey> selectionKeys = selector.selectedKeys();
? ? ? ? ? ?Iterator<SelectionKey> selectionKeysIterator = selectionKeys.iterator();
?
? ? ? ? ? ?while (selectionKeysIterator.hasNext()) {
? ? ? ? ? ? ? ?SelectionKey selectionKey = selectionKeysIterator.next();
? ? ? ? ? ? ? ?if (selectionKey.isAcceptable()) {
? ? ? ? ? ? ? ? ? ?ServerSocketChannel channel = (ServerSocketChannel) selectionKey.channel();
? ? ? ? ? ? ? ? ? ?SocketChannel accept = channel.accept();
? ? ? ? ? ? ? ? ? ?accept.configureBlocking(false);
? ? ? ? ? ? ? ? ? ?accept.register(selector, SelectionKey.OP_READ);
? ? ? ? ? ? ? }
?
? ? ? ? ? ? ? ?if (selectionKey.isReadable()){
? ? ? ? ? ? ? ? ? ?SocketChannel socketChannel = (SocketChannel) selectionKey.channel();
? ? ? ? ? ? ? ? ? ?ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
? ? ? ? ? ? ? ? ? ?int length = socketChannel.read(byteBuffer);
? ? ? ? ? ? ? ? ? ?if (length > 0) {
? ? ? ? ? ? ? ? ? ? ? ?System.out.println("received data: "+new String(byteBuffer.array()));
? ? ? ? ? ? ? ? ? }else if (length == -1){
? ? ? ? ? ? ? ? ? ? ? ?socketChannel.close();
? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? }
? ? ? ? ? ? ? ?selectionKeysIterator.remove();
? ? ? ? ? }
? ? ? }
? }
}
部署服务端程序
使用另外一台机器或者虚拟机部署
// 编译服务端程序
javac NioSelectorServerCopy.java
// 运行服务端程序
java NioSelectorServerCopy
?
客户端程序
客户端可在Windows使用telnet 连接服务端;控制面板->程序->启用或关闭 Windows 功能->勾选 Telnet 客户端;
开启后,连接客户端程序;
?
wireshark 抓包结果如下:
客户端断开连接后,wireshark 的抓包结果:
|