Connect: примеры (JAVA)

Короткие примеры использования

1. Блокирующий Socket с таймаутом

import java.net.*;
import java.io.*;

public class SocketExample {
  public static void main(String[] args) throws Exception {
    Socket socket = new Socket();
    socket.connect(new InetSocketAddress("example.com", 80), 2000);
    System.out.println("connected: " + socket.isConnected());
    socket.close();
  }
}

connected: true

2. Неблокирующий SocketChannel

import java.net.*;
import java.nio.channels.*;
import java.nio.*;

public class ChannelExample {
  public static void main(String[] args) throws Exception {
    SocketChannel ch = SocketChannel.open();
    ch.configureBlocking(false);
    boolean finished = ch.connect(new InetSocketAddress("93.184.216.34", 80)); // example.com
    if (!finished) {
      while (!ch.finishConnect()) {
        System.out.println("waiting to finish connect...");
        Thread.sleep(100);
      }
    }
    System.out.println("connected: " + ch.isConnected());
    ch.close();
  }
}

waiting to finish connect...
connected: true

3. HttpURLConnection

import java.net.*;
import java.io.*;

public class HttpExample {
  public static void main(String[] args) throws Exception {
    URL url = new URL("http://httpbin.org/get");
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setRequestMethod("GET");
    conn.connect();
    System.out.println(conn.getResponseCode());
    conn.disconnect();
  }
}

200

4. DatagramSocket.connect (ограничение адреса)

import java.net.*;

public class DatagramExample {
  public static void main(String[] args) throws Exception {
    DatagramSocket ds = new DatagramSocket();
    ds.connect(InetAddress.getByName("8.8.8.8"), 53);
    System.out.println("isBound: " + ds.isBound() + ", isConnected: " + ds.isConnected());
    ds.close();
  }
}

isBound: true, isConnected: true

Похожие методы в Java и их особенности

• SocketChannel.connect предпочтительнее при работе с NIO и большом числе одновременных соединений: поддерживает неблокирующий режим и селекторы.
• Socket.connect удобен для простых блокирующих сценариев и короткого кода.
• HttpURLConnection.connect устарев в плане удобства, но всё ещё работает; с Java 11 чаще применяется java.net.http.HttpClient для HTTP/2 и более гибкой работы.
• DatagramSocket.connect не устанавливает канала в сетевом смысле TCP, а ограничивает удалённый адрес для приёма и отправки.

Когда выбирать

• Для асинхронной модели и масштабируемости использовать SocketChannel.
• Для простых клиентских приложений - Socket или высокоуровневые HTTP/DB клиенты.

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

PHP (файловые сокеты и cURL)

// fsockopen
$fp = fsockopen("example.com", 80, $errno, $errstr, 2);
if ($fp) { echo "connected"; fclose($fp); } else { echo "$errstr ($errno)"; }

connected

// cURL для HTTP
$ch = curl_init("http://httpbin.org/get");
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
$out = curl_exec($ch);
curl_close($ch);
echo strlen($out);

1234  // пример длины ответа

JavaScript (браузер/Node.js)

// fetch в браузере
fetch('https://httpbin.org/get').then(r => r.status).then(s => console.log(s));

200

// net.Socket в Node.js
const net = require('net');
const s = net.createConnection({host:'example.com', port:80}, () => console.log('connected'));

connected

Python

import socket
s = socket.create_connection(('example.com', 80), timeout=2)
print(s.getpeername())
s.close()

('93.184.216.34', 80)

C#

using System.Net.Sockets;
var client = new TcpClient();
client.Connect("example.com", 80);
Console.WriteLine(client.Connected);

True

Go

package main
import (
  "fmt"
  "net"
)
func main() {
  conn, _ := net.Dial("tcp", "example.com:80")
  fmt.Println(conn != nil)
  conn.Close()
}

true

Kotlin

import java.net.Socket
fun main() {
  val s = Socket()
  s.connect(java.net.InetSocketAddress("example.com", 80), 2000)
  println(s.isConnected)
  s.close()
}

true

Отличия от Java

• В языках уровня выше для HTTP часто используется специализированный клиент (fetch, requests, cURL), а не низкоуровневые сокеты.
• Node.js и Go ориентированы на неблокирующий/асинхронный ввод-вывод по умолчанию, Java позволяет выбирать между блокирующим и NIO.

Типичные ошибки при использовании connect

1. ConnectException: Connection refused

// пример: локальный порт закрыт
Socket s = new Socket();
s.connect(new InetSocketAddress("127.0.0.1", 65000), 1000);

Exception in thread "main" java.net.ConnectException: Connection refused (Connection refused)

2. SocketTimeoutException при коротком таймауте

Socket s = new Socket();
s.connect(new InetSocketAddress("10.255.255.1", 80), 500);

java.net.SocketTimeoutException: connect timed out

3. UnknownHostException при неправильном DNS

Socket s = new Socket();
s.connect(new InetSocketAddress("nonexistent.example.invalid", 80));

java.net.UnknownHostException: nonexistent.example.invalid

4. Неправильное использование SocketChannel в блокирующем/неблокирующем режимах

SocketChannel ch = SocketChannel.open();
ch.configureBlocking(false);
ch.connect(new InetSocketAddress("example.com", 80));
// если не вызвать finishConnect, операции чтения/записи могут бросать IllegalBlockingModeException

java.nio.channels.NotYetConnectedException или операции не выполняются корректно

5. SecurityException в средах с менеджером безопасности

В контейнерах или приложениях с SecurityManager может возникать отказ при попытке открытия сокета к недопустимому хосту.

Изменения в последних версиях Java

• Java 11 ввёл java.net.http.HttpClient, который является современной заменой для многих задач, ранее решавшихся через HttpURLConnection. Это улучшило поддержку HTTP/2 и асинхронных запросов.
• Обновления безопасности и TLS/HTTPS реализованы в JSSE: более строгие наборы протоколов и шифров в свежих релизах, что может повлиять на успешность SSL-подключений.
• Небольшие улучшения производительности и исправления в реализации NIO и SocketChannel, но сигнатуры методов connect остались стабильными.

Расширенные и редкие сценарии применения

1. Socket с привязкой к локальному адресу (исходящий интерфейс)

import java.net.*;
public class BindLocal {
  public static void main(String[] args) throws Exception {
    Socket s = new Socket();
    s.bind(new InetSocketAddress("192.168.1.100", 0)); // выбор исходящего интерфейса
    s.connect(new InetSocketAddress("example.com", 80), 2000);
    System.out.println(s.getLocalAddress() + ":" + s.getLocalPort());
    s.close();
  }
}

/192.168.1.100:54321

2. Неблокирующее подключение с Selector (SocketChannel)

import java.net.InetSocketAddress;
import java.nio.channels.*;
import java.util.Iterator;

public class SelectorConnect {
  public static void main(String[] args) throws Exception {
    SocketChannel ch = SocketChannel.open();
    ch.configureBlocking(false);
    ch.connect(new InetSocketAddress("93.184.216.34", 80));

    Selector sel = Selector.open();
    ch.register(sel, SelectionKey.OP_CONNECT);

    while (true) {
      sel.select(1000);
      Iterator<SelectionKey> it = sel.selectedKeys().iterator();
      while (it.hasNext()) {
        SelectionKey key = it.next();
        it.remove();
        if (key.isConnectable()) {
          SocketChannel sc = (SocketChannel) key.channel();
          if (sc.finishConnect()) {
            System.out.println("connected via selector");
            sc.close();
            sel.close();
            return;
          }
        }
      }
    }
  }
}

connected via selector

3. TLS через SSLSocket (ручной контроль хендшейка)

import javax.net.ssl.*;
import java.net.*;

public class SSLConnect {
  public static void main(String[] args) throws Exception {
    SSLSocketFactory f = (SSLSocketFactory) SSLSocketFactory.getDefault();
    SSLSocket s = (SSLSocket) f.createSocket();
    s.connect(new InetSocketAddress("www.google.com", 443), 3000);
    s.startHandshake();
    System.out.println("protocol: " + s.getSession().getProtocol());
    s.close();
  }
}

protocol: TLSv1.3

4. HTTP с Java 11 HttpClient (альтернатива HttpURLConnection)

import java.net.http.*;
import java.net.URI;

public class HttpClientExample {
  public static void main(String[] args) throws Exception {
    HttpClient client = HttpClient.newHttpClient();
    HttpRequest req = HttpRequest.newBuilder(URI.create("https://httpbin.org/get")).GET().build();
    HttpResponse<String> resp = client.send(req, HttpResponse.BodyHandlers.ofString());
    System.out.println(resp.statusCode());
    System.out.println(resp.body().substring(0, 80));
  }
}

200
{"args":{},"headers":{...}

5. Повторные попытки с экспоненциальной задержкой

import java.net.*;
public class RetryConnect {
  public static void main(String[] args) {
    int attempts = 0;
    int max = 5;
    while (attempts < max) {
      try (Socket s = new Socket()) {
        s.connect(new InetSocketAddress("example.com", 80), 1000);
        System.out.println("ok");
        break;
      } catch (Exception e) {
        attempts++;
        try { Thread.sleep((long)Math.pow(2, attempts) * 100); } catch (InterruptedException ignored) {}
      }
    }
  }
}

ok

6. Подключение через прокси (HTTP туннель для TLS)

import java.net.*;
import javax.net.ssl.*;

public class ProxyConnect {
  public static void main(String[] args) throws Exception {
    Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress("proxy.example", 3128));
    Socket s = new Socket(proxy);
    s.connect(new InetSocketAddress("target.example", 443));
    SSLSocketFactory sf = (SSLSocketFactory) SSLSocketFactory.getDefault();
    SSLSocket ssl = (SSLSocket) sf.createSocket(s, "target.example", 443, true);
    ssl.startHandshake();
    System.out.println("tunneled and handshake ok");
    ssl.close();
  }
}

tunneled and handshake ok

Пояснения

• В неблокирующем режиме важно вызывать finishConnect() и использовать селектор для масштабируемости.
• При работе с TLS следует явно запускать рукопожатие, чтобы обнаружить проблемы с сертификатами или несовместимостью протоколов.
• При использовании прокси или привязке локального адреса порядок операций и тип сокета влияет на результат.