TCP传输初始化配置

1、初始化服务端TCP连接监听

2、初始化客户端发起连接操作

3、服务端Socket链接处理

客户端与服务器交互

1、客户端发送简单的字节

2、服务端接受客户端发送数据

3、服务器回送消息、客户端识别回送消息

// 设置读取超时时间为2秒
socket.setSoTimeout(2000);

// 是否复用未完全关闭的Socket地址，对于指定bind操作后的套接字有效不设置这关闭后两秒就不能用了
socket.setReuseAddress(true);

// 是否开启Nagle算法每一份新的数据发送都要等待前面的数据回送回来之后
socket.setTcpNoDelay(true);

// 是否需要在长时无数据响应时发送确认数据（类似心跳包），时间大约为2小时
socket.setKeepAlive(true);

        // 对于close关闭操作行为进行怎样的处理；默认为false，0
        // false、0：默认情况，关闭时立即返回，底层系统接管输出流，将缓冲区内的数据发送完成
        // true、0：关闭时立即返回，缓冲区数据抛弃，直接发送RST结束命令到对方，并无需经过2MSL等待
        // true、200：关闭时最长阻塞200毫秒，随后按第二情况处理
        socket.setSoLinger(true, 20);

// 是否让紧急数据内敛，默认false；紧急数据通过 socket.sendUrgentData(1);发送
socket.setOOBInline(true);

        // 设置接收发送缓冲器大小
        socket.setReceiveBufferSize(64 * 1024 * 1024);
        socket.setSendBufferSize(64 * 1024 * 1024);

// 设置性能参数：短链接，延迟，带宽的相对重要性
socket.setPerformancePreferences(1, 1, 0);

private static final int PORT = 20000;

public static void main(String[] args) throws IOException {
ServerSocket server = createServerSocket();

initServerSocket(server);

// 绑定到本地端口上 50 是允许等待的连接队列
server.bind(new InetSocketAddress(Inet4Address.getLocalHost(), PORT), 50);

System.out.println("服务器准备就绪～");
System.out.println("服务器信息：" + server.getInetAddress() + " P:" + server.getLocalPort());

        // 等待客户端连接
        for (; ; ) {
            // 得到客户端
            Socket client = server.accept();
            // 客户端构建异步线程
            ClientHandler clientHandler = new ClientHandler(client);
            // 启动线程
            clientHandler.start();
        }

}

    private static ServerSocket createServerSocket() throws IOException {
        // 创建基础的ServerSocket
        ServerSocket serverSocket = new ServerSocket();

// 绑定到本地端口20000上，并且设置当前可允许等待链接的队列为50个
//serverSocket = new ServerSocket(PORT);

// 等效于上面的方案，队列设置为50个
//serverSocket = new ServerSocket(PORT, 50);

// 与上面等同
// serverSocket = new ServerSocket(PORT, 50, Inet4Address.getLocalHost());

return serverSocket;
}

    private static void initServerSocket(ServerSocket serverSocket) throws IOException {
        // 是否复用未完全关闭的地址端口
        serverSocket.setReuseAddress(true);

// 等效Socket#setReceiveBufferSize
serverSocket.setReceiveBufferSize(64 * 1024 * 1024);

// 设置serverSocket#accept超时时间
// serverSocket.setSoTimeout(2000);

        // 设置性能参数：短链接，延迟，带宽的相对重要性
        serverSocket.setPerformancePreferences(1, 1, 1);
    }

    /**
     * 客户端消息处理
     */
    private static class ClientHandler extends Thread {
        private Socket socket;

        ClientHandler(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            super.run();
            System.out.println("新客户端连接：" + socket.getInetAddress() +
                    " P:" + socket.getPort());

            try {
                // 得到套接字流
                OutputStream outputStream = socket.getOutputStream();
                InputStream inputStream = socket.getInputStream();

                byte[] buffer = new byte[256];
                int readCount = inputStream.read(buffer);
                ByteBuffer byteBuffer = ByteBuffer.wrap(buffer, 0, readCount);

// byte
byte be = byteBuffer.get();

// char
char c = byteBuffer.getChar();

// int
int i = byteBuffer.getInt();

// bool
boolean b = byteBuffer.get() == 1;

// Long
long l = byteBuffer.getLong();

// float
float f = byteBuffer.getFloat();

// double
double d = byteBuffer.getDouble();

                // String
                int pos = byteBuffer.position();
                String str = new String(buffer, pos, readCount - pos - 1);

                System.out.println("收到数量：" + readCount + " 数据："
                        + be + "\n"
                        + c + "\n"
                        + i + "\n"
                        + b + "\n"
                        + l + "\n"
                        + f + "\n"
                        + d + "\n"
                        + str + "\n");

                outputStream.write(buffer, 0, readCount);
                outputStream.close();
                inputStream.close();

            } catch (Exception e) {
                System.out.println("连接异常断开");
            } finally {
                // 连接关闭
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

System.out.println("客户端已退出：" + socket.getInetAddress() +
" P:" + socket.getPort());

}
}
}

TCP传输初始化配置

猜你喜欢