Spec-Zone.ru › Ruby 2.7

класс Net::HTTP

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

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

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

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

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

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

Все примеры предполагают загрузку библиотеки Net::HTTP с помощью:

require 'net/http'

Это также потребует библиотеки 'uri', поэтому ее не нужно подключать отдельно.

Методы Net::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».

Для всех объектов запросов 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?

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

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

Например, все ответы 2XX являются экземплярами подкласса HTTPSuccess, ответ 3XX — экземпляром подкласса HTTPRedirection, а ответ 200 — экземпляром класса HTTPSuccess. Подробнее о классах ответов см. раздел «Классы ответов 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-запрос можно выполнить, используя класс запроса HTTPPost. В этом примере создается 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, можно создать аналогичным образом, используя соответствующий класс запроса (HTTPPut).

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

Следующий пример выполняет условный 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 включён для соединения 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 для использования HTTPS требовалось подключение 'net/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.

  • HTTPRequest

    • HTTPGet

    • HTTPHead

    • HTTPPost

    • HTTPPatch

    • HTTPPut

    • HTTPProppatch

    • HTTPLock

    • HTTPUnlock

    • HTTPOptions

    • HTTPPropfind

    • HTTPDelete

    • HTTPMove

    • HTTPCopy

    • HTTPMkcol

    • HTTPTrace

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

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

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]

Устанавливает путь к файлу сертификата 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.

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]

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

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 1066
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 633
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 661
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 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

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

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

Этот метод также выполняет аутентификацию Basic, если 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 1089
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)
  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, 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 796
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 1351
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 1339
def delete(path, initheader = {'Depth' => 'Infinity'})
  request(Delete.new(path, initheader))
end

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

finish() Показать исходный код
# File lib/net/http.rb, line 1035
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 1239
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 1261
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 696
def inspect
  "#<#{self.class} #{@address}:#{@port} open=#{started?}>"
end
ipaddr() Показать исходный код
# File lib/net/http.rb, line 733
def ipaddr
  started? ?  @socket.io.peeraddr[3] : @ipaddr
end

IP-адрес для подключения/используемый для подключения

ipaddr=(addr) Показать исходный код
# File lib/net/http.rb, line 738
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 1315
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 768
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 1357
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 1345
def move(path, initheader = nil)
  request(Move.new(path, initheader))
end

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

options(path, initheader = nil) Показать исходный код
# File lib/net/http.rb, line 1327
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 1299
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 912
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 1293
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 1333
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 1309
def proppatch(path, body, initheader = nil)
  request(Proppatch.new(path, initheader), body)
end

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

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

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

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

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

proxy_pass() Показать исходный код
# File lib/net/http.rb, line 1161
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 1136
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 1152
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 779
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 1481
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 1392
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 1406
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 1436
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 1460
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 709
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 928
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 808
def started?
  @started
end

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

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

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

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

Установка значения атрибута write_timeout.

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

D(msg) Показать исходный код
# File lib/net/http.rb, line 1655
def D(msg)
  return unless @debug_output
  @debug_output << msg
  @debug_output << "\n"
end
addr_port() Показать исходный код
# File lib/net/http.rb, line 1648
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 1565
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 948
def connect
  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}..."
  s = Timeout.timeout(@open_timeout, Net::OpenTimeout) {
    begin
      TCPSocket.open(conn_addr, conn_port, @local_host, @local_port)
    rescue => e
      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) 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_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
      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 1040
def do_finish
  @started = false
  @socket.close if @socket
  @socket = nil
end
do_start() Показать исходный код
# File lib/net/http.rb, line 942
def do_start
  connect
  @started = true
end
edit_path(path) Показать исходный код
# File lib/net/http.rb, line 1184
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 1588
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 1605
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 1029
def on_connect
end
send_entity(path, data, initheader, dest, type, &block) Показать исходный код
# File lib/net/http.rb, line 1504
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 1629
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 1614
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 1515
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

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