Android面试题之Java网络通信基础知识

2024-06-24 20:15:30 浏览数 (1)

网络通信基础

socket

socket是应用层与TCP/IP协议族通信的中间软件抽象，操作系统把传输层一下的内容都包装了，应用层只需要用socket即可完成网络请求

Tcp是基于流；UDP是基于DatagramPacket数据报；socket可以利用DatagramPacket进行UDP通信

网络请求3部分
  • 连接（客户端和服务端）
  • 读网络数据
  • 写网络数据
BIO、NIO、AIO
  • BIO：阻塞的IO
  • NIO（IO多路复用）：一个线程同时管理多个和客户端的连接，一般应用线程数量限制为1024个（系统限制，总共65535，要除去系统使用）
  • AIO（异步IO）：目前只有Windows上完全实现
BIO网络编程
服务端
代码语言：javascript复制
private static ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*2);
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket();
        serverSocket.bind(new InetSocketAddress(10001));
        System.out.println("start server ....");
        try {
            while (true){
                executorService.execute(new ServerTask(serverSocket.accept()));
            }

        }finally {
            serverSocket.close();
        }
    }

    private static class ServerTask implements Runnable{
        private Socket socket;

        public ServerTask(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            //这样会自动关闭流
            try (ObjectInputStream inputStream = new ObjectInputStream(socket.getInputStream());
                 ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream());) {
                String input = inputStream.readUTF();
                System.out.println("accept input :"  input);
                outputStream.writeUTF("hello "   input);
                outputStream.flush();

            } catch (IOException e) {
                e.printStackTrace();
            }finally {
                if (socket != null) {
                    try {
                        socket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
客户端
代码语言：javascript复制
public static void main(String[] args) throws IOException {
        Socket socket = new Socket();
        InetSocketAddress inetSocketAddress = new InetSocketAddress("127.0.0.1", 10001);
        ObjectOutputStream outputStream = null;
        ObjectInputStream inputStream = null;

        try {
            socket.connect(inetSocketAddress);
            outputStream = new ObjectOutputStream(socket.getOutputStream());
            inputStream = new ObjectInputStream(socket.getInputStream());
            outputStream.writeUTF("hello");
            outputStream.flush();

            System.out.println(inputStream.readUTF());

        } finally {
            if (socket != null) {
                socket.close();
            }
            if (outputStream != null) {
                outputStream.close();
            }
            if (inputStream != null) {
                inputStream.close();
            }
        }
    }
BIO网络编程

Selector、ServerSocketChannel、SocketChannel、Buffer、应用程序

服务端一个线程里面，会有一个Selector，用于接收客户端发来的事件，比如连接、有数产生事件等

ServerSocketChannel：用于处理连接事件，会在Selector里注册OP_ACCEPT事件监听，Selector收到客户端连接事件后会通知ServerSocketChannel；

SocketChannel：用于处理数据读的事件，一个客户端会对应一个SocketChannel；同样它会注册数据读的事件到Selector，有数据发送来了以后，Selector就会通知对应的SocketChannel；

Buffer：用于SocketChannel与服务端应用程序直接的数据操作，有数据时，SocketChannel会写到缓冲区Buffer中，然后应用程序从Buffer中读数据，处理完又写回到Buffer，然后SocketChannel从Buffer中读

有新的客户端连接进来后，会创建新的SocketChannel，进行数据的读写通信

Buffer
Buffer是内存中的一块区域，是一个字节数组，有3个重要变量：Position、limit、capacity；模式的话有读和写2种模式，不能同时进行读和写
  • position：指示当前数据的位置，写模式下，会随着写入数据而移动；当调用flip方法切换到读的模式时，position和limit会发生变化，position会指向0，limit会变成position的值，也就是之前最后写入数据的position
  • capacity：Buffer的容量
Buffer的内存分配：可以在堆上分配，也可以在直接内存上分配

堆上分配：分配速度会快一点，网络通信慢一点，一般业务处理方面多一点

代码语言：javascript复制
ByteBuffer buffer = ByteBuffer.allocate(20000);

直接内存分配：分配速度会慢一点，网络通信会快一点，一般直接读写网络数据用这个

代码语言：javascript复制
ByteBuffer buffer = ByteBuffer.allocateDirect(20000);

把byte数组转换为Buffer

代码语言：javascript复制
ByteBuffer.wrap(bytes)
Buffer的写
  • Channel向Buffer写：用Buffer的read方法，表示从网络读数据写到Buffer
  • 应用程序向Buffer写：用Buffer提供的各种put方法
Buffer的读
  • 从Buffer读数据写到Channel：用Buffer的write方法，表示从Buffer读数据写到channel
  • Buffer从应用程序读：用Buffer的get方法
NIO网络编程
注意点
  • ServerSocketChannel和SocketChannel都要设置为非阻塞，configBolcking(false)
  • selector和ServerSocketChannel初始化的方式都是调用open函数
  • 调用selector.select(1000)表示开启事件监听，每个1秒唤醒一次，但是有事件过来会立刻唤醒处理
  • ServerSocketChannel和SocketChannel通过register函数来向selector注册事件监听
  • register函数可以同时支持多个事件的监听，用位操作符连接：OP_CONNNECT | OP_READ
  • register函数还可以同时注册Buffer，作为第3个参数，这样可以在其他地方，通过SelectionKey的attachment拿到
  • 所有的事件都在SelectionKey里面，包括OP_CONNNECT,OP_READ,OP_WRITE,OP_ACCEPT
  • Buffer在读模式切换到写模式的时候，需要调用flip方法进行模式切换
OP_WRITE和OP_READ事件

我们一般很少使用OP_WRITE事件，因为操作系统在建立socket连接的时候，会为socket创建2个缓冲区（Buffer），一个发送Buffer，一个接收Buffer；当客户端向服务端发送数据的时候，服务端接收缓存接收到数据，就会触发OP_READ事件；这2个缓冲区由操作系统内核管理。

而发送缓存里面只要还有空间可写，哪怕一个字节，就会触发OP_WRITE事件

OP_WRITE使用方式
  • 用SelectionKey的isWritable判断是否有数据
  • Buffer用SelectionKey的attachment来获取
  • 根据Buffer的hasRemaining来判断是否还有数据可写
  • 数据都写完的话要取消写事件的监听，用SelectionKey的interestOps方法
OKhttp中的心跳包

websocket实现，websocket本身定义了跟心跳有关的2个数据帧，实现以后，服务端会自动解析和应答

书籍
  • 《Java网络编程》：网络编程、UDP用socket实现等
  • 《UNIX网络编程》：socket原理等
  • 《Netty实战》：Netty相关的网络开发

想深入网络学习的可以参考读一读，都是经典。

作者介绍

中年程序猿，十年移动端开发老司机，分享一线开发经验和知识，正在探索通过副业渡过中年危机

越努力越幸运，加油

java android 事件 数据 网络通信

0 人点赞