Spec-Zone.ru › Ruby 3.1

класс Net::HTTP

Родитель:
Protocol

API клиента HTTP для Ruby.

Предоставляет богатую библиотеку, которая может быть использована для создания пользовательских агентов. Подробнее о HTTP см. [RFC2616](www.ietf.org/rfc/rfc2616.txt).

Разработан для тесного взаимодействия с объектами URI. атрибут host, атрибут port и метод request_uri предназначены для работы с HTTP.

Если вам нужно выполнить только несколько запросов GET, попробуйте OpenURI.

Простые примеры

Все примеры предполагают, что вы загрузили Net::HTTP с:

require 'net/http'

Это также потребует 'uri', поэтому вам не нужно загружать его отдельно.

Методы Net::HTTP в следующем разделе не сохраняют соединения. Они не рекомендуются, если вы выполняете много запросов HTTP.

GET

Net::HTTP.get('example.com', '/index.html') # => String

GET с помощью URI

uri = URI('http://example.com/index.html?count=10')
Net::HTTP.get(uri) # => String

GET с динамическими параметрами

uri = URI('http://example.com/index.html')
params = { :limit => 10, :page => 3 }
uri.query = URI.encode_www_form(params)

res = Net::HTTP.get_response(uri)
puts res.body if res.is_a?(Net::HTTPSuccess)

POST

uri = URI('http://www.example.com/search.cgi')
res = Net::HTTP.post_form(uri, 'q' => 'ruby', 'max' => '50')
puts res.body

POST с несколькими значениями

uri = URI('http://www.example.com/search.cgi')
res = Net::HTTP.post_form(uri, 'q' => ['ruby', 'perl'], 'max' => '50')
puts res.body

Как использовать Net::HTTP

Следующий пример кода может быть использован в качестве основы пользовательского агента, который может выполнять различные типы запросов с использованием постоянных соединений.

uri = URI('http://example.com/some_path?query=string')

Net::HTTP.start(uri.host, uri.port) do |http|
  request = Net::HTTP::Get.new uri

  response = http.request request # Net::HTTPResponse object
end

start немедленно создаёт соединение с сервером HTTP, которое остается открытым на протяжении всего блока. Соединение останется открытым для нескольких запросов в блоке, если сервер указывает, что поддерживает постоянные соединения.

Если вы хотите повторно использовать соединение между несколькими запросами HTTP без автоматического закрытия, вы можете использовать new, а затем вручную вызвать start и finish.

Типы запросов, которые поддерживает Net::HTTP, перечислены ниже в разделе «Классы запросов HTTP».

Для всех объектов запроса Net::HTTP и сокращенных методов запроса вы можете передать либо строку пути запроса, либо объект URI, из которого Net::HTTP извлечет путь запроса.

Данные ответа

uri = URI('http://example.com/index.html')
res = Net::HTTP.get_response(uri)

# Headers
res['Set-Cookie']            # => String
res.get_fields('set-cookie') # => Array
res.to_hash['set-cookie']    # => Array
puts "Headers: #{res.to_hash.inspect}"

# Status
puts res.code       # => '200'
puts res.message    # => 'OK'
puts res.class.name # => 'HTTPOK'

# Body
puts res.body if res.response_body_permitted?

Следование перенаправлению

Каждый объект HTTP::Response принадлежит классу, соответствующему его коду ответа.

Например, все ответы 2XX являются экземплярами подкласса HTTP::Success, ответ 3XX — экземпляром подкласса HTTP::Redirection, а ответ 200 — экземпляром класса HTTP::OK. Подробнее о классах ответов см. раздел «Классы ответов HTTP» ниже.

Используя оператор case, вы можете правильно обработать различные типы ответов:

def fetch(uri_str, limit = 10)
  # You should choose a better exception.
  raise ArgumentError, 'too many HTTP redirects' if limit == 0

  response = Net::HTTP.get_response(URI(uri_str))

  case response
  when Net::HTTPSuccess then
    response
  when Net::HTTPRedirection then
    location = response['location']
    warn "redirected to #{location}"
    fetch(location, limit - 1)
  else
    response.value
  end
end

print fetch('http://www.ruby-lang.org')

POST

POST можно выполнить, используя класс запроса HTTP::Post. В этом примере создаётся тело POST в формате URL.

uri = URI('http://www.example.com/todo.cgi')
req = Net::HTTP::Post.new(uri)
req.set_form_data('from' => '2005-01-01', 'to' => '2005-03-31')

res = Net::HTTP.start(uri.hostname, uri.port) do |http|
  http.request(req)
end

case res
when Net::HTTPSuccess, Net::HTTPRedirection
  # OK
else
  res.value
end

Для отправки данных в формате multipart/form-data используйте set_form:

req = Net::HTTP::Post.new(uri)
req.set_form([['upload', File.open('foo.bar')]], 'multipart/form-data')

Другие запросы, которые могут содержать тело, такие как PUT, можно создать аналогичным образом, используя соответствующий класс запроса (HTTP::Put).

Установка заголовков

Следующий пример выполняет условный GET-запрос, используя заголовок If-Modified-Since. Если файл не был изменён с момента указанного во временном заголовке, будет возвращен ответ Not Modified. Дополнительные сведения см. в RFC 2616, раздел 9.3.

uri = URI('http://example.com/cached_response')
file = File.stat 'cached_response'

req = Net::HTTP::Get.new(uri)
req['If-Modified-Since'] = file.mtime.rfc2822

res = Net::HTTP.start(uri.hostname, uri.port) {|http|
  http.request(req)
}

open 'cached_response', 'w' do |io|
  io.write res.body
end if res.is_a?(Net::HTTPSuccess)

Базовая аутентификация

Базовая аутентификация выполняется в соответствии с [RFC2617](www.ietf.org/rfc/rfc2617.txt).

uri = URI('http://example.com/index.html?key=value')

req = Net::HTTP::Get.new(uri)
req.basic_auth 'user', 'pass'

res = Net::HTTP.start(uri.hostname, uri.port) {|http|
  http.request(req)
}
puts res.body

Потоковая передача тел ответов

По умолчанию Net::HTTP считывает весь ответ в память. Если вы работаете с большими файлами или хотите реализовать индикатор прогресса, вы можете вместо этого передать тело непосредственно в объект IO.

uri = URI('http://example.com/large_file')

Net::HTTP.start(uri.host, uri.port) do |http|
  request = Net::HTTP::Get.new uri

  http.request request do |response|
    open 'large_file', 'w' do |io|
      response.read_body do |chunk|
        io.write chunk
      end
    end
  end
end

HTTPS

HTTPS включён для соединения Net::HTTP с помощью use_ssl.

uri = URI('https://secure.example.com/some_path?query=string')

Net::HTTP.start(uri.host, uri.port, :use_ssl => true) do |http|
  request = Net::HTTP::Get.new uri
  response = http.request request # Net::HTTPResponse object
end

Или, если вам просто нужно выполнить GET-запрос, вы можете передать объект URI с URL HTTPS. Net::HTTP автоматически включает проверку TLS, если у объекта URI есть схема ‘https’.

uri = URI('https://example.com/')
Net::HTTP.get(uri) # => String

В предыдущих версиях Ruby вам нужно было загрузить ‘net/https’, чтобы использовать HTTPS. Это больше не требуется.

Прокси

Net::HTTP автоматически создаст прокси из переменной среды http_proxy, если она присутствует. Чтобы отключить использование http_proxy, передайте nil в качестве адреса прокси.

Вы также можете создать настраиваемый прокси:

proxy_addr = 'your.proxy.host'
proxy_port = 8080

Net::HTTP.new('example.com', nil, proxy_addr, proxy_port).start { |http|
  # always proxy via your.proxy.addr:8080
}

См. new для получения дополнительных сведений и примеров прокси, которые требуют имени пользователя и пароля.

Сжатие

Net::HTTP автоматически добавляет Accept-Encoding для сжатия тел ответов и автоматически распаковывает ответы gzip и deflate, если не был отправлен заголовок Range.

Сжатие можно отключить, добавив заголовок Accept-Encoding: identity.

Классы запросов HTTP

Вот иерархия классов запросов HTTP.

  • HTTP::Request

    • HTTP::Get

    • HTTP::Head

    • HTTP::Post

    • HTTP::Patch

    • HTTP::Put

    • HTTP::Proppatch

    • HTTP::Lock

    • HTTP::Unlock

    • HTTP::Options

    • HTTP::Propfind

    • HTTP::Delete

    • HTTP::Move

    • HTTP::Copy

    • HTTP::Mkcol

    • HTTP::Trace

Классы ответов HTTP

Вот иерархия классов ответов HTTP. Все классы определены в модуле Net и являются подклассами HTTP::Response.

HTTPUnknownResponse

Для необработанных расширений HTTP

HTTPInformation

1xx

HTTPContinue

100

HTTPSwitchProtocol

101

HTTPProcessing

102

HTTPEarlyHints

103

HTTPSuccess

2xx

HTTPOK

200

HTTPCreated

201

HTTPAccepted

202

HTTPNonAuthoritativeInformation

203

HTTPNoContent

204

HTTPResetContent

205

HTTPPartialContent

206

HTTPMultiStatus

207

HTTPAlreadyReported

208

HTTPIMUsed

226

HTTPRedirection

3xx

HTTPMultipleChoices

300

HTTPMovedPermanently

301

HTTPFound

302

HTTPSeeOther

303

HTTPNotModified

304

HTTPUseProxy

305

HTTPTemporaryRedirect

307

HTTPPermanentRedirect

308

HTTPClientError

4xx

HTTPBadRequest

400

HTTPUnauthorized

401

HTTPPaymentRequired

402

HTTPForbidden

403

HTTPNotFound

404

HTTPMethodNotAllowed

405

HTTPNotAcceptable

406

HTTPProxyAuthenticationRequired

407

HTTPRequestTimeOut

408

HTTPConflict

409

HTTPGone

410

HTTPLengthRequired

411

HTTPPreconditionFailed

412

HTTPRequestEntityTooLarge

413

HTTPRequestURITooLong

414

HTTPUnsupportedMediaType

415

HTTPRequestedRangeNotSatisfiable

416

HTTPExpectationFailed

417

HTTPMisdirectedRequest

421

HTTPUnprocessableEntity

422

HTTPLocked

423

HTTPFailedDependency

424

HTTPUpgradeRequired

426

HTTPPreconditionRequired

428

HTTPTooManyRequests

429

HTTPRequestHeaderFieldsTooLarge

431

HTTPUnavailableForLegalReasons

451

HTTPServerError

5xx

HTTPInternalServerError

500

HTTPNotImplemented

501

HTTPBadGateway

502

HTTPServiceUnavailable

503

HTTPGatewayTimeOut

504

HTTPVersionNotSupported

505

HTTPVariantAlsoNegotiates

506

HTTPInsufficientStorage

507

HTTPLoopDetected

508

HTTPNotExtended

510

HTTPNetworkAuthenticationRequired

511

Также существует исключение Net::HTTPBadResponse, которое генерируется при возникновении ошибки протокола.

Константы

ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE
SSL_ATTRIBUTES
SSL_IVNAMES
STATUS_CODES

Атрибуты

proxy_address[R]

Адрес хоста прокси. Если Net::HTTP не использует прокси, nil.

proxy_pass[R]

Пароль пользователя для доступа к прокси. Если Net::HTTP не использует прокси, nil.

proxy_port[R]

Порт хоста прокси. Если Net::HTTP не использует прокси, nil.

proxy_user[R]

Имя пользователя для доступа к прокси. Если Net::HTTP не использует прокси, nil.

address[R]

Имя хоста DNS или IP-адрес для подключения.

ca_file[RW]

Устанавливает путь к файлу сертификатов CA в формате PEM.

Файл может содержать несколько сертификатов CA.

ca_path[RW]

Устанавливает путь к каталогу сертификатов CA, содержащему сертификаты в формате PEM.

cert[RW]

Устанавливает объект OpenSSL::X509::Certificate в качестве клиентского сертификата. (Этот метод появился в расширении Михала Рокоса OpenSSL).

cert_store[RW]

Устанавливает X509::Store для проверки сертификата узла.

ciphers[RW]

Устанавливает доступные шифры. См. OpenSSL::SSL::SSLContext#ciphers=

close_on_empty_response[RW]
continue_timeout[R]

Секунды ожидания ответа 100 Continue. Если объект HTTP не получает ответа в течение этого времени, он отправляет тело запроса. Значение по умолчанию — nil.

extra_chain_cert[RW]

Устанавливает дополнительные сертификаты X509, которые нужно добавить в цепочку сертификатов. См. OpenSSL::SSL::SSLContext#extra_chain_cert=

keep_alive_timeout[RW]

Секунды повторного использования соединения предыдущего запроса. Если время простоя меньше этого значения Keep-Alive Timeout, Net::HTTP повторно использует TCP/IP сокет, используемый предыдущей коммуникацией. Значение по умолчанию — 2 секунды.

key[RW]

Устанавливает объект OpenSSL::PKey::RSA или OpenSSL::PKey::DSA. (Этот метод появился в расширении Михала Рокоса OpenSSL).

local_host[RW]

Локальный хост, используемый для установления соединения.

local_port[RW]

Локальный порт, используемый для установления соединения.

max_retries[R]
max_version[RW]

Устанавливает максимальную версию SSL. См. OpenSSL::SSL::SSLContext#max_version=

min_version[RW]

Устанавливает минимальную версию SSL. См. OpenSSL::SSL::SSLContext#min_version=

open_timeout[RW]

Количество секунд ожидания открытия соединения. Можно использовать любое число, включая числа с плавающей запятой для дробных секунд. Если объект HTTP не может открыть соединение в течение этого времени, он генерирует исключение Net::OpenTimeout. Значение по умолчанию — 60 секунд.

port[R]

Номер порта для подключения.

proxy_address[W]
proxy_from_env[W]
proxy_pass[W]
proxy_port[W]
proxy_user[W]
read_timeout[R]

Количество секунд ожидания одного блока для чтения (через вызов read(2)). Можно использовать любое число, включая числа с плавающей запятой для дробных секунд. Если объект HTTP не может прочитать данные в течение этого времени, он генерирует исключение Net::ReadTimeout. Значение по умолчанию — 60 секунд.

ssl_timeout[RW]

Устанавливает время ожидания SSL в секундах.

ssl_version[RW]

Устанавливает версию SSL. См. OpenSSL::SSL::SSLContext#ssl_version=

verify_callback[RW]

Устанавливает обратный вызов для проверки сертификата сервера.

verify_depth[RW]

Устанавливает максимальную глубину проверки цепочки сертификатов.

END_OF_DOCUMENT_MARKER
verify_hostname[RW]

Устанавливает проверку того, соответствует ли сертифицированный сертификат имени хоста. См. OpenSSL::SSL::SSLContext#verify_hostname=

verify_mode[RW]

Устанавливает флаги для проверки сертификации сервера в начале сессии SSL/TLS.

Допустимы значения OpenSSL::SSL::VERIFY_NONE или OpenSSL::SSL::VERIFY_PEER.

write_timeout[R]

Количество секунд ожидания записи одного блока (через вызов write(2)). Можно использовать любое число, включая числа с плавающей точкой для дробных секунд. Если объект HTTP не может записать данные в течение этого времени, он генерирует исключение Net::WriteTimeout. Значение по умолчанию составляет 60 секунд. Net::WriteTimeout не генерируется в Windows.

Методы публичного класса

Proxy(p_addr = :ENV, p_port = nil, p_user = nil, p_pass = nil) Показать исходный код
# File lib/net/http.rb, line 1106
def HTTP.Proxy(p_addr = :ENV, p_port = nil, p_user = nil, p_pass = nil)
  return self unless p_addr

  Class.new(self) {
    @is_proxy_class = true

    if p_addr == :ENV then
      @proxy_from_env = true
      @proxy_address = nil
      @proxy_port    = nil
    else
      @proxy_from_env = false
      @proxy_address = p_addr
      @proxy_port    = p_port || default_port
    end

    @proxy_user = p_user
    @proxy_pass = p_pass
  }
end

Создаёт класс прокси HTTP, который ведёт себя как Net::HTTP, но выполняет все запросы через указанный прокси.

Этот класс устарел. Вы можете передать эти параметры непосредственно в Net::HTTP.new. Подробности аргументов см. в Net::HTTP.new.

default_port() Показать исходный код
# File lib/net/http.rb, line 560
def HTTP.default_port
  http_default_port()
end

Порт по умолчанию для запросов HTTP; по умолчанию 80.

get(uri_or_host, path_or_headers = nil, port = nil) Показать исходный код
# File lib/net/http.rb, line 473
def HTTP.get(uri_or_host, path_or_headers = nil, port = nil)
  get_response(uri_or_host, path_or_headers, port).body
end

Отправляет GET-запрос на целевой ресурс и возвращает ответ HTTP в виде строки. Целевой ресурс можно указать как (uri, headers) или как (host, path, port = 80); например:

print Net::HTTP.get(URI('http://www.example.com/index.html'))

или:

print Net::HTTP.get('www.example.com', '/index.html')

также можно указать заголовки запроса:

Net::HTTP.get(URI('http://www.example.com/index.html'), { 'Accept' => 'text/html' })
get_print(uri_or_host, path_or_headers = nil, port = nil) Показать исходный код
# File lib/net/http.rb, line 450
def HTTP.get_print(uri_or_host, path_or_headers = nil, port = nil)
  get_response(uri_or_host, path_or_headers, port) {|res|
    res.read_body do |chunk|
      $stdout.print chunk
    end
  }
  nil
end

Получает текст тела от целевого ресурса и выводит его в $stdout. Целевой ресурс можно указать как (uri, headers) или как (host, path, port = 80); например:

Net::HTTP.get_print URI('http://www.example.com/index.html')

или:

Net::HTTP.get_print 'www.example.com', '/index.html'

также можно указать заголовки запроса:

Net::HTTP.get_print URI('http://www.example.com/index.html'), { 'Accept' => 'text/html' }
get_response(uri_or_host, path_or_headers = nil, port = nil, &block) Показать исходный код
# File lib/net/http.rb, line 493
def HTTP.get_response(uri_or_host, path_or_headers = nil, port = nil, &block)
  if path_or_headers && !path_or_headers.is_a?(Hash)
    host = uri_or_host
    path = path_or_headers
    new(host, port || HTTP.default_port).start {|http|
      return http.request_get(path, &block)
    }
  else
    uri = uri_or_host
    headers = path_or_headers
    start(uri.hostname, uri.port,
          :use_ssl => uri.scheme == 'https') {|http|
      return http.request_get(uri, headers, &block)
    }
  end
end

Отправляет GET-запрос на целевой ресурс и возвращает ответ HTTP как объект Net::HTTPResponse. Целевой ресурс можно указать как (uri, headers) или как (host, path, port = 80); например:

res = Net::HTTP.get_response(URI('http://www.example.com/index.html'))
print res.body

или:

res = Net::HTTP.get_response('www.example.com', '/index.html')
print res.body

также можно указать заголовки запроса:

Net::HTTP.get_response(URI('http://www.example.com/index.html'), { 'Accept' => 'text/html' })
http_default_port() Показать исходный код
# File lib/net/http.rb, line 565
def HTTP.http_default_port
  80
end

Порт по умолчанию для запросов HTTP; по умолчанию 80.

https_default_port() Показать исходный код
# File lib/net/http.rb, line 570
def HTTP.https_default_port
  443
end

Порт по умолчанию для запросов HTTPS; по умолчанию 443.

is_version_1_2?()
Псевдоним для: version_1_2?
new(address, port = nil, p_addr = :ENV, p_port = nil, p_user = nil, p_pass = nil, p_no_proxy = nil) Показать исходный код
# File lib/net/http.rb, line 654
def HTTP.new(address, port = nil, p_addr = :ENV, p_port = nil, p_user = nil, p_pass = nil, p_no_proxy = nil)
  http = super address, port

  if proxy_class? then # from Net::HTTP::Proxy()
    http.proxy_from_env = @proxy_from_env
    http.proxy_address  = @proxy_address
    http.proxy_port     = @proxy_port
    http.proxy_user     = @proxy_user
    http.proxy_pass     = @proxy_pass
  elsif p_addr == :ENV then
    http.proxy_from_env = true
  else
    if p_addr && p_no_proxy && !URI::Generic.use_proxy?(p_addr, p_addr, p_port, p_no_proxy)
      p_addr = nil
      p_port = nil
    end
    http.proxy_address = p_addr
    http.proxy_port    = p_port || default_port
    http.proxy_user    = p_user
    http.proxy_pass    = p_pass
  end

  http
end

Создаёт новый объект Net::HTTP без открытия TCP-соединения или сессии HTTP.

address должен быть именем хоста DNS или IP-адресом, а port — портом работы сервера. Если port не указан, используется порт по умолчанию для HTTP или HTTPS.

Если ни один из аргументов p_ не указан, адрес и порт прокси берутся из переменной окружения http_proxy (или её аналога в верхнем регистре), если она присутствует. При необходимости аутентификации на прокси вы должны указать её вручную. Подробности обнаружения прокси из окружения см. в URI::Generic#find_proxy. Чтобы отключить обнаружение прокси, установите p_addr в nil.

Если вы подключаетесь к пользовательскому прокси, p_addr указывает имя хоста DNS или IP-адрес хоста прокси, p_port — используемый порт для доступа к прокси, p_user и p_pass — имя пользователя и пароль, если требуется авторизация для использования прокси, а p_no_proxy — хосты, которые не используют прокси.

Вызывает метод суперкласса
Также известен как: newobj
new(address, port = nil) Показать исходный код
# File lib/net/http.rb, line 682
def initialize(address, port = nil)
  @address = address
  @port    = (port || HTTP.default_port)
  @ipaddr = nil
  @local_host = nil
  @local_port = nil
  @curr_http_version = HTTPVersion
  @keep_alive_timeout = 2
  @last_communicated = nil
  @close_on_empty_response = false
  @socket  = nil
  @started = false
  @open_timeout = 60
  @read_timeout = 60
  @write_timeout = 60
  @continue_timeout = nil
  @max_retries = 1
  @debug_output = nil

  @proxy_from_env = false
  @proxy_uri      = nil
  @proxy_address  = nil
  @proxy_port     = nil
  @proxy_user     = nil
  @proxy_pass     = nil

  @use_ssl = false
  @ssl_context = nil
  @ssl_session = nil
  @sspi_enabled = false
  SSL_IVNAMES.each do |ivname|
    instance_variable_set ivname, nil
  end
end

Создаёт новый объект Net::HTTP для указанного адреса сервера без открытия TCP-соединения или инициализации сессии HTTP. address должен быть именем хоста DNS или IP-адресом.

newobj(address, port = nil, p_addr = :ENV, p_port = nil, p_user = nil, p_pass = nil, p_no_proxy = nil)
Псевдоним для: new
post(url, data, header = nil) Показать исходный код
# File lib/net/http.rb, line 521
def HTTP.post(url, data, header = nil)
  start(url.hostname, url.port,
        :use_ssl => url.scheme == 'https' ) {|http|
    http.post(url, data, header)
  }
end

Отправляет данные POST на указанный объект URI.

Пример:

require 'net/http'
require 'uri'

Net::HTTP.post URI('http://www.example.com/api/search'),
               { "q" => "ruby", "max" => "50" }.to_json,
               "Content-Type" => "application/json"
post_form(url, params) Показать исходный код
# File lib/net/http.rb, line 545
def HTTP.post_form(url, params)
  req = Post.new(url)
  req.form_data = params
  req.basic_auth url.user, url.password if url.user
  start(url.hostname, url.port,
        :use_ssl => url.scheme == 'https' ) {|http|
    http.request(req)
  }
end

Отправляет данные HTML-формы POST на указанный объект URI. Данные формы должны быть представлены как отображение Hash из String в String. Пример:

{ "cmd" => "search", "q" => "ruby", "max" => "50" }

Этот метод также выполняет базовые аутентификации, если и только если существует url.user. Но пользовательская информация для аутентификации устарела (RFC3986). Поэтому эта функция будет удалена.

Пример:

require 'net/http'

Net::HTTP.post_form URI('http://www.example.com/search.cgi'),
                    { "q" => "ruby", "max" => "50" }
proxy_class?() Показать исходный код
# File lib/net/http.rb, line 1129
def proxy_class?
  defined?(@is_proxy_class) ? @is_proxy_class : false
end

Возвращает true, если self — класс, созданный методом HTTP::Proxy.

END_OF_DOCUMENT_MARKER
start(address, port, p_addr, p_port, p_user, p_pass, &block) Показать исходный код
start(address, port=nil, p_addr=:ENV, p_port=nil, p_user=nil, p_pass=nil, opt, &block)
# File lib/net/http.rb, line 608
def HTTP.start(address, *arg, &block) # :yield: +http+
  arg.pop if opt = Hash.try_convert(arg[-1])
  port, p_addr, p_port, p_user, p_pass = *arg
  p_addr = :ENV if arg.size < 2
  port = https_default_port if !port && opt && opt[:use_ssl]
  http = new(address, port, p_addr, p_port, p_user, p_pass)
  http.ipaddr = opt[:ipaddr] if opt && opt[:ipaddr]

  if opt
    if opt[:use_ssl]
      opt = {verify_mode: OpenSSL::SSL::VERIFY_PEER}.update(opt)
    end
    http.methods.grep(/\A(\w+)=\z/) do |meth|
      key = $1.to_sym
      opt.key?(key) or next
      http.__send__(meth, opt[key])
    end
  end

  http.start(&block)
end

Создаёт новый объект Net::HTTP, затем дополнительно открывает TCP-соединение и HTTP-сеанс.

Аргументы следующие:

address

имя хоста или IP-адрес сервера

port

порт сервера

p_addr

адрес прокси-сервера

p_port

порт прокси-сервера

p_user

пользователь прокси-сервера

p_pass

пароль прокси-сервера

opt

опциональный хэш

opt устанавливает следующие значения с помощью своего доступа. Ключи — ipaddr, ca_file, ca_path, cert, cert_store, ciphers, keep_alive_timeout, close_on_empty_response, key, open_timeout, read_timeout, write_timeout, ssl_timeout, ssl_version, use_ssl, verify_callback, verify_depth и verify_mode. Если вы установите :use_ssl как true, вы можете использовать https, а значение по умолчанию для verify_mode будет установлено как OpenSSL::SSL::VERIFY_PEER.

Если задан необязательный блок, новый созданный объект Net::HTTP передаётся ему и закрывается, когда блок завершается. В этом случае возвращаемое значение этого метода — возвращаемое значение блока. Если блок не задан, возвращаемое значение этого метода — сам вновь созданный объект Net::HTTP, и вызывающий метод отвечает за его закрытие по завершении с помощью метода finish().

version_1_2() Показать исходный код
# File lib/net/http.rb, line 412
def HTTP.version_1_2
  true
end

Включает возможности net/http 1.2 (Ruby 1.8). По умолчанию включено в Ruby 1.8 и более поздних версиях.

version_1_2?() Показать исходный код
# File lib/net/http.rb, line 418
def HTTP.version_1_2?
  true
end

Возвращает true, если net/http находится в режиме версии 1.2. По умолчанию — true.

Также алиасировано как: is_version_1_2?

Методы публичного экземпляра

active?()
Псевдоним для: started?
continue_timeout=(sec) Показать исходный код
# File lib/net/http.rb, line 817
def continue_timeout=(sec)
  @socket.continue_timeout = sec if @socket
  @continue_timeout = sec
end

Устанавливает значение атрибута continue_timeout.

copy(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1398
def copy(path, initheader = nil)
  request(Copy.new(path, initheader))
end

Отправляет запрос COPY на path и получает ответ в виде объекта HTTPResponse.

delete(path, initheader = {'Depth' => 'Infinity'}) Показать исходный код
# File lib/net/http.rb, line 1386
def delete(path, initheader = {'Depth' => 'Infinity'})
  request(Delete.new(path, initheader))
end

Отправляет запрос DELETE на path и получает ответ в виде объекта HTTPResponse.

finish() Показать исходный код
# File lib/net/http.rb, line 1075
def finish
  raise IOError, 'HTTP session not yet started' unless started?
  do_finish
end

Завершает сеанс HTTP и закрывает TCP-соединение. Вызывает IOError, если сеанс не был начат.

get(path, initheader = nil, dest = nil) { |body_segment| ... } Показать исходный код
# File lib/net/http.rb, line 1286
def get(path, initheader = nil, dest = nil, &block) # :yield: +body_segment+
  res = nil
  request(Get.new(path, initheader)) {|r|
    r.read_body dest, &block
    res = r
  }
  res
end

Извлекает данные с path на подключённом хосте, который может быть абсолютным путём String или URI для извлечения пути.

initheader должно быть Hash типа { ‘Accept’ => ‘/’, … }, по умолчанию это пустой массив. Если у initheader нет ключа ‘accept-encoding’, используется значение «gzip;q=1.0,deflate;q=0.6,identity;q=0.3», чтобы gzip-сжатие использовалось вместо deflate-сжатия, которое используется вместо отсутствия сжатия. Ruby не имеет библиотек для поддержки сжатия (Lempel-Ziv), поэтому оно не поддерживается. Цель этого — по умолчанию уменьшить пропускную способность. Если эта функция настраивает сжатие, она также выполняет разархивирование, удаляя заголовок, чтобы избежать путаницы. В противном случае она оставляет тело как есть.

Этот метод возвращает объект Net::HTTPResponse.

Если вызов сделан с блоком, он передаёт каждый фрагмент тела сущности по очереди как строку по мере чтения из сокета. Обратите внимание, что в этом случае возвращаемый объект ответа не будет содержать тело (смысловое).

Аргумент dest устарел. Он всё ещё работает, но вы не должны его использовать.

Этот метод никогда не вызывает исключение.

response = http.get('/index.html')

# using block
File.open('result.txt', 'w') {|f|
  http.get('/~foo/') do |str|
    f.write str
  end
}
get2(path, initheader = nil)
Псевдоним для: request_get
head(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1308
def head(path, initheader = nil)
  request(Head.new(path, initheader))
end

Получает только заголовок с path на подключённом хосте. header — это Hash типа { ‘Accept’ => ‘/’, … }.

Этот метод возвращает объект Net::HTTPResponse.

Этот метод никогда не вызывает исключение.

response = nil
Net::HTTP.start('some.www.server', 80) {|http|
  response = http.head('/index.html')
}
p response['content-type']
head2(path, initheader = nil, &block)
Псевдоним для: request_head
inspect() Показать исходный код
# File lib/net/http.rb, line 717
def inspect
  "#<#{self.class} #{@address}:#{@port} open=#{started?}>"
end
ipaddr() Показать исходный код
# File lib/net/http.rb, line 754
def ipaddr
  started? ?  @socket.io.peeraddr[3] : @ipaddr
end

IP-адрес для подключения.

ipaddr=(addr) Показать исходный код
# File lib/net/http.rb, line 759
def ipaddr=(addr)
  raise IOError, "ipaddr value changed, but session already started" if started?
  @ipaddr = addr
end

Устанавливает IP-адрес для подключения.

lock(path, body, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1362
def lock(path, body, initheader = nil)
  request(Lock.new(path, initheader), body)
end

Отправляет запрос LOCK на path и получает ответ в виде объекта HTTPResponse.

max_retries=(retries) Показать исходный код
# File lib/net/http.rb, line 789
def max_retries=(retries)
  retries = retries.to_int
  if retries < 0
    raise ArgumentError, 'max_retries should be non-negative integer number'
  end
  @max_retries = retries
end

Максимальное количество попыток повторной отправки идемпотентного запроса в случае Net::ReadTimeout, IOError, EOFError, Errno::ECONNRESET, Errno::ECONNABORTED, Errno::EPIPE, OpenSSL::SSL::SSLError, Timeout::Error. Должно быть неотрицательным целым числом. Ноль означает отсутствие повторных попыток. Значение по умолчанию — 1.

mkcol(path, body = nil, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1404
def mkcol(path, body = nil, initheader = nil)
  request(Mkcol.new(path, initheader), body)
end

Отправляет запрос MKCOL на path и получает ответ в виде объекта HTTPResponse.

move(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1392
def move(path, initheader = nil)
  request(Move.new(path, initheader))
end

Отправляет запрос MOVE на path и получает ответ в виде объекта HTTPResponse.

options(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1374
def options(path, initheader = nil)
  request(Options.new(path, initheader))
end

Отправляет запрос OPTIONS на path и получает ответ в виде объекта HTTPResponse.

patch(path, data, initheader = nil, dest = nil) { |body_segment| ... } Показать исходный код
# File lib/net/http.rb, line 1346
def patch(path, data, initheader = nil, dest = nil, &block) # :yield: +body_segment+
  send_entity(path, data, initheader, dest, Patch, &block)
end

Отправляет запрос PATCH на path и получает ответ в виде объекта HTTPResponse.

peer_cert() Показать исходный код
# File lib/net/http.rb, line 945
def peer_cert
  if not use_ssl? or not @socket
    return nil
  end
  @socket.io.peer_cert
end

Возвращает представленные сервером сертификаты X.509.

post(path, data, initheader = nil, dest = nil) { |body_segment| ... } Показать исходный код
# File lib/net/http.rb, line 1340
def post(path, data, initheader = nil, dest = nil, &block) # :yield: +body_segment+
  send_entity(path, data, initheader, dest, Post, &block)
end

Отправляет data (должно быть String) на path. header должно быть Hash типа { ‘Accept’ => ‘/’, … }.

Этот метод возвращает объект Net::HTTPResponse.

Если вызывается с блоком, то по очереди передаёт каждый фрагмент тела ответа как строку по мере его считывания из сокета. Обратите внимание, что в этом случае возвращаемый объект ответа не будет содержать (осмысленного) тела.

Аргумент dest устарел. Он всё ещё работает, но его использовать не следует.

Этот метод никогда не вызывает исключений.

response = http.post('/cgi-bin/search.rb', 'query=foo')

# using block
File.open('result.txt', 'w') {|f|
  http.post('/cgi-bin/search.rb', 'query=foo') do |str|
    f.write str
  end
}

Вы должны установить заголовок Content-Type: для POST. Если заголовок Content-Type не задан, этот метод использует «application/x-www-form-urlencoded» по умолчанию.

post2(path, data, initheader = nil)
Псевдоним для: request_post
propfind(path, body = nil, initheader = {'Depth' => '0'}) Показать исходный код
# File lib/net/http.rb, line 1380
def propfind(path, body = nil, initheader = {'Depth' => '0'})
  request(Propfind.new(path, initheader), body)
end

Отправляет запрос PROPFIND на path и получает ответ, как объект HTTPResponse.

proppatch(path, body, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1356
def proppatch(path, body, initheader = nil)
  request(Proppatch.new(path, initheader), body)
end

Отправляет запрос PROPPATCH на path и получает ответ, как объект HTTPResponse.

proxy?() Показать исходный код
# File lib/net/http.rb, line 1148
def proxy?
  !!(@proxy_from_env ? proxy_uri : @proxy_address)
end

Истина, если запросы для этого подключения будут проксироваться

proxy_address() Показать исходный код
# File lib/net/http.rb, line 1167
def proxy_address
  if @proxy_from_env then
    proxy_uri&.hostname
  else
    @proxy_address
  end
end

Адрес сервера прокси, если он настроен.

Также алиасируется как: proxyaddr
proxy_from_env?() Показать исходный код
# File lib/net/http.rb, line 1153
def proxy_from_env?
  @proxy_from_env
end

Истина, если прокси для этого соединения определяется из среды

proxy_pass() Показать исходный код
# File lib/net/http.rb, line 1202
def proxy_pass
  if ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE && @proxy_from_env
    pass = proxy_uri&.password
    unescape(pass) if pass
  else
    @proxy_pass
  end
end

Пароль сервера прокси, если он настроен.

proxy_port() Показать исходный код
# File lib/net/http.rb, line 1176
def proxy_port
  if @proxy_from_env then
    proxy_uri&.port
  else
    @proxy_port
  end
end

Порт сервера прокси, если он настроен.

Также алиасируется как: proxyport
proxy_user() Показать исходный код
# File lib/net/http.rb, line 1192
def proxy_user
  if ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE && @proxy_from_env
    user = proxy_uri&.user
    unescape(user) if user
  else
    @proxy_user
  end
end

Имя пользователя сервера прокси, если он настроен.

proxyaddr()
Псевдоним для: proxy_address
proxyport()
Псевдоним для: proxy_port
read_timeout=(sec) Показать исходный код
# File lib/net/http.rb, line 800
def read_timeout=(sec)
  @socket.read_timeout = sec if @socket
  @read_timeout = sec
end

Установка атрибута read_timeout.

request(req, body = nil) { |response| ... } Показать исходный код
# File lib/net/http.rb, line 1528
def request(req, body = nil, &block)  # :yield: +response+
  unless started?
    start {
      req['connection'] ||= 'close'
      return request(req, body, &block)
    }
  end
  if proxy_user()
    req.proxy_basic_auth proxy_user(), proxy_pass() unless use_ssl?
  end
  req.set_body_internal body
  res = transport_request(req, &block)
  if sspi_auth?(res)
    sspi_auth(req)
    res = transport_request(req, &block)
  end
  res
end

Отправляет объект HTTPRequest req на сервер HTTP.

Если req это запрос Net::HTTP::Post или Net::HTTP::Put содержащий данные, данные также отправляются. Предоставление данных для запроса Net::HTTP::Head или Net::HTTP::Get приводит к ошибке ArgumentError.

Возвращает объект HTTPResponse.

При вызове с блоком, передаёт объект HTTPResponse в блок. Тело ответа ещё не было прочитано; блок может обработать его с помощью HTTPResponse#read_body, если необходимо.

Этот метод никогда не генерирует исключения Net::*.

request_get(path, initheader = nil) { |response| ... } Показать исходный код
# File lib/net/http.rb, line 1439
def request_get(path, initheader = nil, &block) # :yield: +response+
  request(Get.new(path, initheader), &block)
end

Отправляет запрос GET на path. Возвращает ответ в виде объекта Net::HTTPResponse.

При вызове с блоком, передаёт объект HTTPResponse в блок. Тело ответа ещё не было прочитано; блок может обработать его с помощью HTTPResponse#read_body, если необходимо.

Возвращает ответ.

Этот метод никогда не генерирует исключения Net::*.

response = http.request_get('/index.html')
# The entity body is already read in this case.
p response['content-type']
puts response.body

# Using a block
http.request_get('/index.html') {|response|
  p response['content-type']
  response.read_body do |str|   # read body now
    print str
  end
}
Также алиасируется как: get2
request_head(path, initheader = nil, &block) Показать исходный код
# File lib/net/http.rb, line 1453
def request_head(path, initheader = nil, &block)
  request(Head.new(path, initheader), &block)
end

Отправляет запрос HEAD на path и возвращает ответ как объект Net::HTTPResponse.

Возвращает ответ.

Этот метод никогда не генерирует исключения Net::*.

response = http.request_head('/index.html')
p response['content-type']
Также алиасируется как: head2
request_post(path, data, initheader = nil) { |response| ... } Показать исходный код
# File lib/net/http.rb, line 1483
def request_post(path, data, initheader = nil, &block) # :yield: +response+
  request Post.new(path, initheader), data, &block
end

Отправляет запрос POST на path.

Возвращает ответ в виде объекта Net::HTTPResponse.

При вызове с блоком, блок получает объект HTTPResponse. Тело ответа ещё не было прочитано; блок может обработать его с помощью HTTPResponse#read_body, если необходимо.

Возвращает ответ.

Этот метод никогда не генерирует исключения Net::*.

# example
response = http.request_post('/cgi-bin/nice.rb', 'datadatadata...')
p response.status
puts response.body          # body is already read in this case

# using block
http.request_post('/cgi-bin/nice.rb', 'datadatadata...') {|response|
  p response.status
  p response['content-type']
  response.read_body do |str|   # read body now
    print str
  end
}
Также алиасируется как: post2
send_request(name, path, data = nil, header = nil) Показать исходный код
# File lib/net/http.rb, line 1507
def send_request(name, path, data = nil, header = nil)
  has_response_body = name != 'HEAD'
  r = HTTPGenericRequest.new(name,(data ? true : false),has_response_body,path,header)
  request r, data
end

Отправляет запрос HTTP на сервер HTTP. Также отправляет строку DATA, если data задана.

Возвращает объект Net::HTTPResponse.

Этот метод никогда не генерирует исключения Net::*.

response = http.send_request('GET', '/index.html')
puts response.body
set_debug_output(output) Показать исходный код
# File lib/net/http.rb, line 730
def set_debug_output(output)
  warn 'Net::HTTP#set_debug_output called after HTTP started', uplevel: 1 if started?
  @debug_output = output
end

ПРЕДУПРЕЖДЕНИЕ Этот метод создаёт серьёзную уязвимость безопасности. Никогда не используйте этот метод в коде производства.

Устанавливает поток вывода для отладки.

http = Net::HTTP.new(hostname)
http.set_debug_output $stderr
http.start { .... }
start() { |http| ... } Показать исходный код
# File lib/net/http.rb, line 961
def start  # :yield: http
  raise IOError, 'HTTP session already opened' if @started
  if block_given?
    begin
      do_start
      return yield(self)
    ensure
      do_finish
    end
  end
  do_start
  self
end

Открывает TCP-соединение и HTTP сеанс.

Когда этот метод вызывается с блоком, он передаёт объект Net::HTTP в блок и закрывает TCP-соединение и HTTP сеанс после выполнения блока.

При вызове с блоком возвращает значение, возвращаемое блоком; в противном случае возвращает self.

started?() Показать исходный код
# File lib/net/http.rb, line 829
def started?
  @started
end

Возвращает true, если HTTP сеанс был начат.

Также алиасируется как: active?
trace(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1410
def trace(path, initheader = nil)
  request(Trace.new(path, initheader))
end

Отправляет запрос TRACE на path и получает ответ в виде объекта HTTPResponse.

unlock(path, body, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1368
def unlock(path, body, initheader = nil)
  request(Unlock.new(path, initheader), body)
end

Отправляет запрос UNLOCK на path и получает ответ в виде объекта HTTPResponse.

use_ssl=(flag) Показать исходный код
# File lib/net/http.rb, line 846
def use_ssl=(flag)
  flag = flag ? true : false
  if started? and @use_ssl != flag
    raise IOError, "use_ssl value changed, but session already started"
  end
  @use_ssl = flag
end

Включает/выключает SSL. Этот флаг должен быть установлен до начала сеанса. Если вы измените значение use_ssl после начала сеанса, объект Net::HTTP вызывает исключение IOError.

use_ssl?() Показать исходный код
# File lib/net/http.rb, line 838
def use_ssl?
  @use_ssl
end

Возвращает true, если SSL/TLS используется с HTTP.

write_timeout=(sec) Показать исходный код
# File lib/net/http.rb, line 806
def write_timeout=(sec)
  @socket.write_timeout = sec if @socket
  @write_timeout = sec
end

Сеттер для атрибута write_timeout.

Приватные методы экземпляра

D(msg) Показать исходный код
# File lib/net/http.rb, line 1702
def D(msg)
  return unless @debug_output
  @debug_output << msg
  @debug_output << "\n"
end
addr_port() Показать исходный код
# File lib/net/http.rb, line 1695
def addr_port
  addr = address
  addr = "[#{addr}]" if addr.include?(":")
  default_port = use_ssl? ? HTTP.https_default_port : HTTP.http_default_port
  default_port == port ? addr : "#{addr}:#{port}"
end

utils

begin_transport(req) Показать исходный код
# File lib/net/http.rb, line 1612
def begin_transport(req)
  if @socket.closed?
    connect
  elsif @last_communicated
    if @last_communicated + @keep_alive_timeout < Process.clock_gettime(Process::CLOCK_MONOTONIC)
      D 'Conn close because of keep_alive_timeout'
      @socket.close
      connect
    elsif @socket.io.to_io.wait_readable(0) && @socket.eof?
      D "Conn close because of EOF"
      @socket.close
      connect
    end
  end

  if not req.response_body_permitted? and @close_on_empty_response
    req['connection'] ||= 'close'
  end

  req.update_uri address, port, use_ssl?
  req['host'] ||= addr_port()
end
connect() Показать исходный код
# File lib/net/http.rb, line 981
def connect
  if use_ssl?
    # reference early to load OpenSSL before connecting,
    # as OpenSSL may take time to load.
    @ssl_context = OpenSSL::SSL::SSLContext.new
  end

  if proxy? then
    conn_addr = proxy_address
    conn_port = proxy_port
  else
    conn_addr = conn_address
    conn_port = port
  end

  D "opening connection to #{conn_addr}:#{conn_port}..."
  begin
    s = Socket.tcp conn_addr, conn_port, @local_host, @local_port, connect_timeout: @open_timeout
  rescue => e
    e = Net::OpenTimeout.new(e) if e.is_a?(Errno::ETIMEDOUT) #for compatibility with previous versions
    raise e, "Failed to open TCP connection to " +
      "#{conn_addr}:#{conn_port} (#{e.message})"
  end
  s.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1)
  D "opened"
  if use_ssl?
    if proxy?
      plain_sock = BufferedIO.new(s, read_timeout: @read_timeout,
                                  write_timeout: @write_timeout,
                                  continue_timeout: @continue_timeout,
                                  debug_output: @debug_output)
      buf = "CONNECT #{conn_address}:#{@port} HTTP/#{HTTPVersion}\r\n"
      buf << "Host: #{@address}:#{@port}\r\n"
      if proxy_user
        credential = ["#{proxy_user}:#{proxy_pass}"].pack('m0')
        buf << "Proxy-Authorization: Basic #{credential}\r\n"
      end
      buf << "\r\n"
      plain_sock.write(buf)
      HTTPResponse.read_new(plain_sock).value
      # assuming nothing left in buffers after successful CONNECT response
    end

    ssl_parameters = Hash.new
    iv_list = instance_variables
    SSL_IVNAMES.each_with_index do |ivname, i|
      if iv_list.include?(ivname)
        value = instance_variable_get(ivname)
        unless value.nil?
          ssl_parameters[SSL_ATTRIBUTES[i]] = value
        end
      end
    end
    @ssl_context.set_params(ssl_parameters)
    @ssl_context.session_cache_mode =
      OpenSSL::SSL::SSLContext::SESSION_CACHE_CLIENT |
      OpenSSL::SSL::SSLContext::SESSION_CACHE_NO_INTERNAL_STORE
    @ssl_context.session_new_cb = proc {|sock, sess| @ssl_session = sess }
    D "starting SSL for #{conn_addr}:#{conn_port}..."
    s = OpenSSL::SSL::SSLSocket.new(s, @ssl_context)
    s.sync_close = true
    # Server Name Indication (SNI) RFC 3546
    s.hostname = @address if s.respond_to? :hostname=
    if @ssl_session and
       Process.clock_gettime(Process::CLOCK_REALTIME) < @ssl_session.time.to_f + @ssl_session.timeout
      s.session = @ssl_session
    end
    ssl_socket_connect(s, @open_timeout)
    if (@ssl_context.verify_mode != OpenSSL::SSL::VERIFY_NONE) && @ssl_context.verify_hostname
      s.post_connection_check(@address)
    end
    D "SSL established, protocol: #{s.ssl_version}, cipher: #{s.cipher[0]}"
  end
  @socket = BufferedIO.new(s, read_timeout: @read_timeout,
                           write_timeout: @write_timeout,
                           continue_timeout: @continue_timeout,
                           debug_output: @debug_output)
  @last_communicated = nil
  on_connect
rescue => exception
  if s
    D "Conn close because of connect error #{exception}"
    s.close
  end
  raise
end
do_finish() Показать исходный код
# File lib/net/http.rb, line 1080
def do_finish
  @started = false
  @socket.close if @socket
  @socket = nil
end
do_start() Показать исходный код
# File lib/net/http.rb, line 975
def do_start
  connect
  @started = true
end
edit_path(path) Показать исходный код
# File lib/net/http.rb, line 1231
def edit_path(path)
  if proxy?
    if path.start_with?("ftp://") || use_ssl?
      path
    else
      "http://#{addr_port}#{path}"
    end
  else
    path
  end
end
end_transport(req, res) Показать исходный код
# File lib/net/http.rb, line 1635
def end_transport(req, res)
  @curr_http_version = res.http_version
  @last_communicated = nil
  if @socket.closed?
    D 'Conn socket closed'
  elsif not res.body and @close_on_empty_response
    D 'Conn close'
    @socket.close
  elsif keep_alive?(req, res)
    D 'Conn keep-alive'
    @last_communicated = Process.clock_gettime(Process::CLOCK_MONOTONIC)
  else
    D 'Conn close'
    @socket.close
  end
end
keep_alive?(req, res) Показать исходный код
# File lib/net/http.rb, line 1652
def keep_alive?(req, res)
  return false if req.connection_close?
  if @curr_http_version <= '1.0'
    res.connection_keep_alive?
  else   # HTTP/1.1 or later
    not res.connection_close?
  end
end
on_connect() Показать исходный код
# File lib/net/http.rb, line 1069
def on_connect
end
send_entity(path, data, initheader, dest, type, &block) Показать исходный код
# File lib/net/http.rb, line 1551
def send_entity(path, data, initheader, dest, type, &block)
  res = nil
  request(type.new(path, initheader), data) {|r|
    r.read_body dest, &block
    res = r
  }
  res
end

Выполняет запрос, использующий представление, и возвращает его тело.

sspi_auth(req) Показать исходный код
# File lib/net/http.rb, line 1676
def sspi_auth(req)
  n = Win32::SSPI::NegotiateAuth.new
  req["Proxy-Authorization"] = "Negotiate #{n.get_initial_token}"
  # Some versions of ISA will close the connection if this isn't present.
  req["Connection"] = "Keep-Alive"
  req["Proxy-Connection"] = "Keep-Alive"
  res = transport_request(req)
  authphrase = res["Proxy-Authenticate"]  or return res
  req["Proxy-Authorization"] = "Negotiate #{n.complete_authentication(authphrase)}"
rescue => err
  raise HTTPAuthenticationError.new('HTTP authentication failed', err)
end
sspi_auth?(res) Показать исходный код
# File lib/net/http.rb, line 1661
def sspi_auth?(res)
  return false unless @sspi_enabled
  if res.kind_of?(HTTPProxyAuthenticationRequired) and
      proxy? and res["Proxy-Authenticate"].include?("Negotiate")
    begin
      require 'win32/sspi'
      true
    rescue LoadError
      false
    end
  else
    false
  end
end
transport_request(req) { |res| ... } Показать исходный код
# File lib/net/http.rb, line 1562
def transport_request(req)
  count = 0
  begin
    begin_transport req
    res = catch(:response) {
      begin
        req.exec @socket, @curr_http_version, edit_path(req.path)
      rescue Errno::EPIPE
        # Failure when writing full request, but we can probably
        # still read the received response.
      end

      begin
        res = HTTPResponse.read_new(@socket)
        res.decode_content = req.decode_content
      end while res.kind_of?(HTTPInformation)

      res.uri = req.uri

      res
    }
    res.reading_body(@socket, req.response_body_permitted?) {
      yield res if block_given?
    }
  rescue Net::OpenTimeout
    raise
  rescue Net::ReadTimeout, IOError, EOFError,
         Errno::ECONNRESET, Errno::ECONNABORTED, Errno::EPIPE, Errno::ETIMEDOUT,
         # avoid a dependency on OpenSSL
         defined?(OpenSSL::SSL) ? OpenSSL::SSL::SSLError : IOError,
         Timeout::Error => exception
    if count < max_retries && IDEMPOTENT_METHODS_.include?(req.method)
      count += 1
      @socket.close if @socket
      D "Conn close because of error #{exception}, and retry"
      retry
    end
    D "Conn close because of error #{exception}"
    @socket.close if @socket
    raise
  end

  end_transport req, res
  res
rescue => exception
  D "Conn close because of error #{exception}"
  @socket.close if @socket
  raise exception
end
unescape(value) Показать исходный код
# File lib/net/http.rb, line 1216
def unescape(value)
  require 'cgi/util'
  CGI.unescape(value)
end

Ruby Core © 1993–2022 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API