SocketChannel.open: примеры (JAVA)

Короткие примеры применения

1) Простое блокирующее подключение и HTTP-запрос

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class SimpleClient {
    public static void main(String[] args) throws Exception {
        SocketChannel sc = SocketChannel.open(new InetSocketAddress("example.com", 80));
        String req = "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n";
        sc.write(ByteBuffer.wrap(req.getBytes()));
        ByteBuffer buf = ByteBuffer.allocate(1024);
        while (sc.read(buf) > 0) {
            buf.flip();
            System.out.print(new String(buf.array(), 0, buf.limit()));
            buf.clear();
        }
        sc.close();
    }
}

HTTP/1.1 200 OK
... (заголовки и часть тела сайта example.com)

2) Неблокирующее подключение с опросом finishConnect()

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class NonBlockingConnect {
    public static void main(String[] args) throws Exception {
        SocketChannel sc = SocketChannel.open();
        sc.configureBlocking(false);
        sc.connect(new InetSocketAddress("example.com", 80));
        while (!sc.finishConnect()) {
            // ожидание завершения подключения
            System.out.println("Ожидание подключения...");
            Thread.sleep(100);
        }
        System.out.println("Подключено");
        sc.close();
    }
}

Ожидание подключения...
Ожидание подключения...
Подключено

3) Открытие без подключения и поздняя установка соединения

import java.net.InetSocketAddress;
import java.nio.channels.SocketChannel;

SocketChannel ch = SocketChannel.open();
ch.bind(new InetSocketAddress(0)); // привязка к свободному локальному порту
ch.connect(new InetSocketAddress("127.0.0.1", 9000));
// затем работать с ch

(в случае успешного соединения - канал в состоянии connected)

Похожие Java API и их особенности

• java.net.Socket - классический сокет. Удобен для простых блокирующих сценариев, имеет более простой API, но не интегрируется с Selector.
• AsynchronousSocketChannel - асинхронный канал из NIO.2. Подходит для масштабируемых асинхронных приложений с коллбэками или CompletableFuture, освобождает от работы с Selector.
• ServerSocketChannel - для серверной стороны, прослушивающий канал. Приём входящих подключений через accept().
• DatagramChannel - для UDP. Используется при работе без установления соединения.

Выбор зависит от требований: требуется ли неблокирующее мультиплексирование (SocketChannel + Selector), простота блокирующего кода (Socket) или асинхронная модель (AsynchronousSocketChannel).

Аналоги в других языках и краткие отличия

PHP

// stream_socket_client
$fp = stream_socket_client("tcp://example.com:80", $errno, $errstr, 5);
fwrite($fp, "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n");
echo stream_get_contents($fp);
fclose($fp);

HTTP/1.1 200 OK
... (ответ)

Node.js (JavaScript)

const net = require('net');
const client = net.createConnection({ host: 'example.com', port: 80 }, () => {
  client.write('GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n');
});
client.on('data', data => console.log(data.toString()));
client.on('end', () => console.log('end'));

HTTP/1.1 200 OK
... (ответ)

Python

import socket
s = socket.create_connection(('example.com', 80), timeout=5)
s.sendall(b'GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n')
print(s.recv(1024))
s.close()

b'HTTP/1.1 200 OK\r\n...'

C#

using System.Net.Sockets;
var client = new TcpClient();
client.Connect("example.com", 80);
var stream = client.GetStream();
// запись и чтение

(ответ сервера)

Go

package main
import (
  "fmt"
  "net"
)
func main(){
  conn, _ := net.Dial("tcp", "example.com:80")
  fmt.Fprintln(conn, "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n")
  buf := make([]byte, 1024)
  n, _ := conn.Read(buf)
  fmt.Println(string(buf[:n]))
}

HTTP/1.1 200 OK
... (ответ)

Краткие различия: в Java SocketChannel даётся тесная интеграция с Selector и возможность работы с ByteBuffer. Во многих языках есть как блокирующие, так и неблокирующие/асинхронные API. Для низкоуровневой работы с буферами и мультиплексированием SocketChannel предоставляет гибкость, близкую к системным вызовам.

Типичные ошибки и их проявления

• ConnectException: Connection refused - при попытке подключения к неслушающему порту.
• UnresolvedAddressException - передан неразрешённый адрес (например, ошибка в hostname).
• AlreadyConnectedException - попытка вызвать connect на уже подключённом канале (в блокирующем режиме).
• NoConnectionPendingException - вызов finishConnect при отсутствии ожидающего соединения в неблокирующем режиме.
• IllegalBlockingModeException - некоторые операции ожидают определённого режима канала.
• ClosedChannelException - попытка работы с уже закрытым каналом.

Пример 1: ConnectException при отсутствии сервера

import java.net.InetSocketAddress;
import java.nio.channels.SocketChannel;

public class ErrExample {
    public static void main(String[] args) throws Exception {
        SocketChannel sc = SocketChannel.open(new InetSocketAddress("127.0.0.1", 65000));
        // если по 127.0.0.1:65000 ничего не слушает - будет исключение
    }
}

Exception in thread "main" java.net.ConnectException: Connection refused: no further information
    at ...

Пример 2: AlreadyConnectedException

SocketChannel sc = SocketChannel.open(new InetSocketAddress("example.com", 80));
sc.connect(new InetSocketAddress("example.com", 80));

java.nio.channels.AlreadyConnectedException

Пример 3: NoConnectionPendingException при неправомерном вызове finishConnect()

SocketChannel sc = SocketChannel.open();
sc.configureBlocking(true);
sc.finishConnect();

java.nio.channels.NoConnectionPendingException

Изменения и эволюция API

Основные изменения в области сокет-каналов за последние релизы Java носят эволюционный характер. Ключевые моменты:

• Введение NIO.2 (Java 7) привело к расширению возможностей через интерфейсы NetworkChannel и работу с опциями сокета (setOption, getOption), а также появлению AsynchronousSocketChannel.
• Постепенное улучшение поддержки стандартизованных SocketOption, таких как TCP_NODELAY, SO_REUSEADDR, SO_KEEPALIVE.
• В новых версиях JVM производительность и интеграция с сетевым стеком оптимизировались, но сигнатура SocketChannel.open осталась стабильной.

Изменения, влияющие на код: использование setOption вместо прямых манипуляций через Socket для некоторых параметров, а также появление альтернативной асинхронной модели.

Продвинутые и редкие варианты использования

1) Использование Selector для масштабируемого клиента с обработкой OP_CONNECT и OP_READ/OP_WRITE

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Selector;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import java.util.Iterator;

public class SelectorClient {
    public static void main(String[] args) throws Exception {
        Selector sel = Selector.open();
        SocketChannel sc = SocketChannel.open();
        sc.configureBlocking(false);
        sc.connect(new InetSocketAddress("example.com", 80));
        sc.register(sel, SelectionKey.OP_CONNECT);

        while (true) {
            sel.select(500);
            Iterator it = sel.selectedKeys().iterator();
            while (it.hasNext()) {
                SelectionKey key = it.next();
                it.remove();
                SocketChannel ch = (SocketChannel) key.channel();
                if (key.isConnectable()) {
                    if (ch.finishConnect()) {
                        ch.register(sel, SelectionKey.OP_WRITE);
                    }
                } else if (key.isWritable()) {
                    ch.write(ByteBuffer.wrap("GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n".getBytes()));
                    ch.register(sel, SelectionKey.OP_READ);
                } else if (key.isReadable()) {
                    ByteBuffer b = ByteBuffer.allocate(2048);
                    int r = ch.read(b);
                    if (r > 0) {
                        b.flip();
                        System.out.print(new String(b.array(), 0, b.limit()));
                    } else if (r < 0) {
                        ch.close();
                        return;
                    }
                }
            }
        }
    }
}

(полный HTTP-ответ от сервера example.com)

2) Отправка файла через FileChannel.transferTo в сокетный канал (эффективная передача данных)

import java.io.RandomAccessFile;
import java.net.InetSocketAddress;
import java.nio.channels.FileChannel;
import java.nio.channels.SocketChannel;

public class SendFile {
    public static void main(String[] args) throws Exception {
        try (RandomAccessFile raf = new RandomAccessFile("bigfile.bin", "r");
             FileChannel fc = raf.getChannel();
             SocketChannel sc = SocketChannel.open(new InetSocketAddress("127.0.0.1", 9000))) {
            long pos = 0;
            long size = fc.size();
            while (pos < size) {
                long sent = fc.transferTo(pos, size - pos, sc);
                if (sent <= 0) break;
                pos += sent;
            }
        }
    }
}

(файл отправлен, данные на стороне сервера приняты)

3) Использование SSLEngine вместе с SocketChannel для TLS без готового SSLSocket

// Упрощённый псевдокод, демонстрирующий идею
// Настройка SSLEngine, создание SocketChannel, обмен байтами через ByteBuffer
// В реальном коде требуется обработка wrap/unwrap и хранение состояния SSLEngine

TLS handshake completed
(в результате установлено защищённое соединение)

4) Комбинация неблокирующего режима и таймаутов: попытка подключиться с контролируемым ожиданием

SocketChannel ch = SocketChannel.open();
ch.configureBlocking(false);
ch.connect(new InetSocketAddress(host, port));
long start = System.currentTimeMillis();
long timeout = 3000; // мс
while (!ch.finishConnect()) {
    if (System.currentTimeMillis() - start > timeout) {
        ch.close();
        throw new java.net.SocketTimeoutException("connect timed out");
    }
    Thread.sleep(50);
}

(в случае таймаута будет выброшено SocketTimeoutException)

Комментарий: сочетание неблокирующего режима и селектора/finishConnect даёт контроль над временем ожидания без использования сторонних библиотек. Использование SSLEngine обеспечивает гибкость при реализации TLS поверх NIO, но требует тщательной обработки состояний и буферов.