Spec-Zone.ru › Ruby 2.6

класс Net::HTTP

Родитель:
Протокол

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

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

Разработан для тесного взаимодействия с URI. URI::HTTP#host, URI::HTTP#port и URI::HTTP#request_uri разработаны для работы с Net::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

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

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

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

Для всех объектов запросов Net::HTTP и сокращённых методов запросов вы можете указать либо String для пути запроса, либо 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?

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

Каждый объект Net::HTTPResponse принадлежит классу для своего кода ответа.

Например, все ответы 2XX являются экземплярами подкласса Net::HTTPSuccess, ответ 3XX является экземпляром подкласса Net::HTTPRedirection, а ответ 200 — экземпляром класса Net::HTTPOK. Для получения подробной информации о классах ответов см. раздел «Классы ответов 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 можно выполнить, используя класс запроса Net::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 используйте Net::HTTPHeader#set_form:

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

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

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

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

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 включён для подключения HTTP с помощью 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 = 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
}

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

Сжатие

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

Сжатие можно отключить с помощью заголовка Accept-Encoding: identity.

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

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

  • Net::HTTPRequest

    • Net::HTTP::Get

    • Net::HTTP::Head

    • Net::HTTP::Post

    • Net::HTTP::Patch

    • Net::HTTP::Put

    • Net::HTTP::Proppatch

    • Net::HTTP::Lock

    • Net::HTTP::Unlock

    • Net::HTTP::Options

    • Net::HTTP::Propfind

    • Net::HTTP::Delete

    • Net::HTTP::Move

    • Net::HTTP::Copy

    • Net::HTTP::Mkcol

    • Net::HTTP::Trace

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

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

HTTPUnknownResponse

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

HTTPInformation

1xx

HTTPContinue

100

HTTPSwitchProtocol

101

HTTPSuccess

2xx

HTTPOK

200

HTTPCreated

201

HTTPAccepted

202

HTTPNonAuthoritativeInformation

203

HTTPNoContent

204

HTTPResetContent

205

HTTPPartialContent

206

HTTPMultiStatus

207

HTTPIMUsed

226

HTTPRedirection

3xx

HTTPMultipleChoices

300

HTTPMovedPermanently

301

HTTPFound

302

HTTPSeeOther

303

HTTPNotModified

304

HTTPUseProxy

305

HTTPTemporaryRedirect

307

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

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

HTTPInsufficientStorage

507

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]

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

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

ca_path[RW]

Устанавливает путь к каталогу сертификатов доверенных центров сертификации, содержащему сертификаты в формате 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.

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 для проверки сертификации сервера.

verify_depth[RW]

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

verify_mode[RW]

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

Допустимы OpenSSL::SSL::VERIFY_NONE или OpenSSL::SSL::VERIFY_PEER.

END_OF_DOCUMENT_MARKER
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 1053
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 539
def HTTP.default_port
  http_default_port()
end

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

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

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

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

или:

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

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

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

или:

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

Отправляет запрос GET на целевой ресурс и возвращает ответ HTTP в виде объекта Net::HTTPResponse. Цель может быть указана как (uri), или как (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
http_default_port() Показать исходный код
# File lib/net/http.rb, line 544
def HTTP.http_default_port
  80
end

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

https_default_port() Показать исходный код
# File lib/net/http.rb, line 549
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 632
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 660
def initialize(address, port = nil)
  @address = address
  @port    = (port || HTTP.default_port)
  @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 499
def HTTP.post(url, data, header = nil)
  start(url.hostname, url.port,
        :use_ssl => url.scheme == 'https' ) {|http|
    http.post(url, data, header)
  }
end

Отправляет данные на указанный объект 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 524
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-формы на указанный объект URI. Данные формы должны быть предоставлены в виде отображения Hash от String к String. Пример:

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

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

Пример:

require 'net/http'
require 'uri'

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

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

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 587
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)

  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 устанавливает следующие значения с помощью своего аксессора. Ключи — ca_file, ca_path, cert, cert_store, ciphers, 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 404
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 410
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 783
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 1338
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 1326
def delete(path, initheader = {'Depth' => 'Infinity'})
  request(Delete.new(path, initheader))
end

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

finish() Показать исходный код
# File lib/net/http.rb, line 1022
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 1226
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 1248
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 694
def inspect
  "#<#{self.class} #{@address}:#{@port} open=#{started?}>"
end
lock(path, body, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1302
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 755
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 1344
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 1332
def move(path, initheader = nil)
  request(Move.new(path, initheader))
end

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

options(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1314
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 1286
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 899
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 1280
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
}

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

post2(path, data, initheader = nil)
Псевдоним для: request_post
END_OF_DOCUMENT_MARKER
propfind(path, body = nil, initheader = {'Depth' => '0'}) Показать исходный код
# File lib/net/http.rb, line 1320
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 1296
def proppatch(path, body, initheader = nil)
  request(Proppatch.new(path, initheader), body)
end

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

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

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

proxy_address() Показать исходный код
# File lib/net/http.rb, line 1114
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 1100
def proxy_from_env?
  @proxy_from_env
end

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

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

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

proxy_port() Показать исходный код
# File lib/net/http.rb, line 1123
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 1139
def proxy_user
  if ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE && @proxy_from_env
    proxy_uri&.user
  else
    @proxy_user
  end
end

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

proxyaddr()
Псевдоним для: proxy_address
proxyport()
Псевдоним для: proxy_port
read_timeout=(sec) Показать исходный код
# File lib/net/http.rb, line 766
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 1468
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 1379
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 1393
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 1423
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 1447
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 707
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 915
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 795
def started?
  @started
end

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

Также алиасируется как: active?
trace(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1350
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 1308
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 812
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 804
def use_ssl?
  @use_ssl
end

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

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

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

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

D(msg) Показать исходный код
# File lib/net/http.rb, line 1636
def D(msg)
  return unless @debug_output
  @debug_output << msg
  @debug_output << "\n"
end
addr_port() Показать исходный код
# File lib/net/http.rb, line 1629
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 1546
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 935
def connect
  if proxy? then
    conn_address = proxy_address
    conn_port    = proxy_port
  else
    conn_address = address
    conn_port    = port
  end

  D "opening connection to #{conn_address}:#{conn_port}..."
  s = Timeout.timeout(@open_timeout, Net::OpenTimeout) {
    begin
      TCPSocket.open(conn_address, conn_port, @local_host, @local_port)
    rescue => e
      raise e, "Failed to open TCP connection to " +
        "#{conn_address}:#{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 #{@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) and
        value = instance_variable_get(ivname)
        ssl_parameters[SSL_ATTRIBUTES[i]] = value if value
      end
    end
    @ssl_context = OpenSSL::SSL::SSLContext.new
    @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_address}:#{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
      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)
  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 1027
def do_finish
  @started = false
  @socket.close if @socket
  @socket = nil
end
do_start() Показать исходный код
# File lib/net/http.rb, line 929
def do_start
  connect
  @started = true
end
edit_path(path) Показать исходный код
# File lib/net/http.rb, line 1171
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 1569
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 1586
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 1016
def on_connect
end
send_entity(path, data, initheader, dest, type, &block) Показать исходный код
# File lib/net/http.rb, line 1491
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 1610
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 1595
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 1502
def transport_request(req)
  count = 0
  begin
    begin_transport req
    res = catch(:response) {
      req.exec @socket, @curr_http_version, edit_path(req.path)
      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,
         # 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

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

Spec-Zone.ru

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