java中Socket设置超时时间的两种方式

下面我将为您讲解Java中Socket设置超时时间的两种方式。

方式一：使用setSoTimeout()方法设置超时时间

在Java中，Socket提供了一个setSoTimeout()方法，该方法可用于设置Socket的超时时间。具体步骤如下：

1. 建立Socket连接
2. 获取Socket的输入流和输出流
3. 使用setSoTimeout()方法设置超时时间，单位为毫秒
4. 在读取或写入数据时，使用try-catch块捕捉超时异常

示例代码如下：

import java.io.IOException;
import java.net.Socket;
import java.net.SocketTimeoutException;

public class SocketDemo {
    public static void main(String[] args) {
        try {
            //建立Socket连接
            Socket socket = new Socket("127.0.0.1", 8080);
            //设置超时时间为2秒
            socket.setSoTimeout(2000);
            //获取输入输出流
            InputStream inputStream = socket.getInputStream();
            OutputStream outputStream = socket.getOutputStream();
            //写入数据
            outputStream.write("hello server".getBytes());
            //读取数据
            byte[] buffer = new byte[1024];
            int len = inputStream.read(buffer);
            String response = new String(buffer, 0, len);
            System.out.println(response);
            //关闭连接
            socket.close();
        } catch (SocketTimeoutException e) {
            System.out.println("读取数据超时");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

方式二：使用SelectableChannel和Selector设置超时时间

除了使用Socket的setSoTimeout()方法以外，Java还提供了另一种方式来设置Socket的超时时间，即使用SelectableChannel和Selector。具体步骤如下：

1. 建立Socket连接
2. 创建Selector对象
3. 将SelectableChannel注册到Selector中，并设置感兴趣的事件
4. 执行select()方法，等待事件触发
5. 在事件触发时，进行读/写操作

示例代码如下：

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.SocketChannel;

public class SocketDemo {
    public static void main(String[] args) {
        try {
            //建立Socket连接
            SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 8080));
            socketChannel.configureBlocking(false);
            //创建Selector对象
            Selector selector = Selector.open();
            //将SelectableChannel注册到Selector中，并设置感兴趣的事件
            socketChannel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE);
            //执行select()方法，等待事件触发
            selector.select(2000);
            //获取SelectionKey集合，判断是否有事件触发
            if (!selector.selectedKeys().isEmpty()) {
                //在事件触发时，进行读/写操作
                SelectionKey key = selector.selectedKeys().iterator().next();
                if (key.isReadable()) {
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    int len = socketChannel.read(buffer);
                    String response = new String(buffer.array(), 0, len);
                    System.out.println(response);
                } else if (key.isWritable()) {
                    ByteBuffer buffer = ByteBuffer.wrap("hello server".getBytes());
                    socketChannel.write(buffer);
                }
            }
            //关闭连接
            socketChannel.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

以上就是介绍Java中Socket设置超时时间的两种方式的完整攻略，希望能对您有所帮助。