класс 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 и сокращенных методов запросов можно передать строку пути запроса или объект 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. См. RFC 2616 раздел 9.3 для получения дополнительной информации.
uri = URI('http://example.com/cached_response')
file = File.stat 'cached_response'
req = Net::HTTP::Get.new(uri)
req['If-Modified-Since'] = file.mtime.rfc2822
res = Net::HTTP.start(uri.hostname, uri.port) {|http|
http.request(req)
}
open 'cached_response', 'w' do |io|
io.write res.body
end if res.is_a?(Net::HTTPSuccess)
Базовая аутентификация
Базовая аутентификация выполняется в соответствии с [RFC2617](www.ietf.org/rfc/rfc2617.txt).
uri = URI('http://example.com/index.html?key=value')
req = Net::HTTP::Get.new(uri)
req.basic_auth 'user', 'pass'
res = Net::HTTP.start(uri.hostname, uri.port) {|http|
http.request(req)
}
puts res.body
Потоковая передача тел ответов
По умолчанию Net::HTTP считывает весь ответ в память. Если вы работаете с большими файлами или хотите реализовать индикатор прогресса, вы можете вместо этого передавать тело непосредственно в IO.
uri = URI('http://example.com/large_file')
Net::HTTP.start(uri.host, uri.port) do |http|
request = Net::HTTP::Get.new uri
http.request request do |response|
open 'large_file', 'w' do |io|
response.read_body do |chunk|
io.write chunk
end
end
end
end
HTTPS
HTTPS включён для соединения 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 с 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.
Классы ответов 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
Атрибуты
Адрес прокси-сервера. Если Net::HTTP не использует прокси, значение nil.
Пароль пользователя для доступа к прокси. Если Net::HTTP не использует прокси, значение nil.
Номер порта прокси-сервера. Если Net::HTTP не использует прокси, значение nil.
Имя пользователя для доступа к прокси. Если Net::HTTP не использует прокси, значение nil.
Имя хоста DNS или IP-адрес для подключения.
Устанавливает путь к файлу сертификатов CA в формате PEM.
Файл может содержать несколько сертификатов CA.
Устанавливает путь к каталогу сертификатов CA, содержащему сертификаты в формате PEM.
Устанавливает объект OpenSSL::X509::Certificate в качестве клиентского сертификата. (Этот метод появился в расширении Майкла Рокоса OpenSSL).
Устанавливает X509::Store для проверки сертификата удалённого узла.
Устанавливает доступные шифры. См. OpenSSL::SSL::SSLContext#ciphers=
Секунды ожидания ответа 100 Continue. Если объект HTTP не получает ответ в течение этого времени, он отправляет тело запроса. Значение по умолчанию — nil.
Устанавливает дополнительные сертификаты X509, которые будут добавлены в цепочку сертификатов. См. OpenSSL::SSL::SSLContext#extra_chain_cert=
Устанавливает объект OpenSSL::PKey::RSA или OpenSSL::PKey::DSA. (Этот метод появился в расширении Майкла Рокоса OpenSSL).
Локальный хост, используемый для установления соединения.
Локальный порт, используемый для установления соединения.
Устанавливает максимальную версию SSL. См. OpenSSL::SSL::SSLContext#max_version=
Устанавливает минимальную версию SSL. См. OpenSSL::SSL::SSLContext#min_version=
Количество секунд ожидания открытия соединения. Может быть использовано любое число, включая дробные значения. Если объект HTTP не может открыть соединение в течение этого времени, он генерирует исключение Net::OpenTimeout. Значение по умолчанию — 60 секунд.
Номер порта для подключения.
Количество секунд ожидания одного блока для чтения (через один вызов read(2)). Может быть использовано любое число, включая дробные значения. Если объект HTTP не может прочитать данные в течение этого времени, он генерирует исключение Net::ReadTimeout. Значение по умолчанию — 60 секунд.
Устанавливает время ожидания SSL в секундах.
Устанавливает версию SSL. См. OpenSSL::SSL::SSLContext#ssl_version=
Устанавливает обратный вызов для проверки сертификации сервера.
Устанавливает максимальную глубину проверки цепочки сертификатов.
Устанавливает проверку, является ли сертифицикат сервера действительным для указанного имени хоста. См. OpenSSL::SSL::SSLContext#verify_hostname=
Устанавливает флаги для проверки сертификации сервера в начале сеанса SSL/TLS.
Допустимы значения OpenSSL::SSL::VERIFY_NONE или OpenSSL::SSL::VERIFY_PEER.
Количество секунд ожидания записи одного блока (через один вызов write(2)). Можно использовать любое число, включая числа с плавающей точкой для дробных секунд. Если объект HTTP не может записать данные за это время, он поднимает исключение Net::WriteTimeout. Значение по умолчанию — 60 секунд. Исключение Net::WriteTimeout не генерируется в Windows.
Общедоступные методы класса
# File lib/net/http.rb, line 1095
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.
# File lib/net/http.rb, line 554 def HTTP.default_port http_default_port() end
Порт по умолчанию для запросов HTTP; по умолчанию 80.
# File lib/net/http.rb, line 466 def HTTP.get(uri_or_host, path_or_headers = nil, port = nil) get_response(uri_or_host, path_or_headers, port).body end
Отправляет запрос GET на целевой ресурс и возвращает ответ HTTP в виде строки. Цель может быть указана как (uri, headers), или как (host, path, port = 80); например:
print Net::HTTP.get(URI('http://www.example.com/index.html'))
или:
print Net::HTTP.get('www.example.com', '/index.html')
также можно указать заголовки запроса:
Net::HTTP.get(URI('http://www.example.com/index.html'), { 'Accept' => 'text/html' })
# File lib/net/http.rb, line 602
def HTTP.start(address, *arg, &block) # :yield: +http+
arg.pop if opt = Hash.try_convert(arg[-1])
port, p_addr, p_port, p_user, p_pass = *arg
p_addr = :ENV if arg.size < 2
port = https_default_port if !port && opt && opt[:use_ssl]
http = new(address, port, p_addr, p_port, p_user, p_pass)
http.ipaddr = opt[:ipaddr] if opt && opt[:ipaddr]
if opt
if opt[:use_ssl]
opt = {verify_mode: OpenSSL::SSL::VERIFY_PEER}.update(opt)
end
http.methods.grep(/\A(\w+)=\z/) do |meth|
key = $1.to_sym
opt.key?(key) or next
http.__send__(meth, opt[key])
end
end
http.start(&block)
end Создаёт новый объект Net::HTTP, а затем дополнительно открывает TCP-соединение и HTTP сеанс.
Аргументы следующие:
- address
-
имя хоста или IP-адрес сервера
- port
-
порт сервера
- p_addr
-
адрес прокси-сервера
- p_port
-
порт прокси-сервера
- p_user
-
пользователь прокси-сервера
- p_pass
-
пароль прокси-сервера
- opt
-
необязательный хэш
opt устанавливает следующие значения с помощью своего аксессора. Ключи: ipaddr, ca_file, ca_path, cert, cert_store, ciphers, keep_alive_timeout, close_on_empty_response, key, open_timeout, read_timeout, write_timeout, ssl_timeout, ssl_version, use_ssl, verify_callback, verify_depth и verify_mode. Если вы установите :use_ssl в true, вы можете использовать https, а значение по умолчанию для verify_mode будет установлено как OpenSSL::SSL::VERIFY_PEER.
Если задан необязательный блок, созданный объект Net::HTTP передаётся ему, и закрывается при завершении блока. В этом случае возвращаемое значение этого метода — возвращаемое значение блока. Если блок не задан, возвращаемое значение этого метода — созданный объект Net::HTTP, и вызывающий метод отвечает за его закрытие по завершении с помощью метода finish().
# File lib/net/http.rb, line 405 def HTTP.version_1_2 true end
Включает функции net/http 1.2 (Ruby 1.8). По умолчанию включено в Ruby 1.8 и более поздних версиях.
# File lib/net/http.rb, line 411 def HTTP.version_1_2? true end
Возвращает true, если net/http находится в режиме версии 1.2. По умолчанию — true.
Методы экземпляра публичного использования
# File lib/net/http.rb, line 811 def continue_timeout=(sec) @socket.continue_timeout = sec if @socket @continue_timeout = sec end
Устанавливает значение атрибута continue_timeout.
# File lib/net/http.rb, line 1380 def copy(path, initheader = nil) request(Copy.new(path, initheader)) end
Отправляет запрос COPY на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1368
def delete(path, initheader = {'Depth' => 'Infinity'})
request(Delete.new(path, initheader))
end Отправляет запрос DELETE на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1064 def finish raise IOError, 'HTTP session not yet started' unless started? do_finish end
Завершает сеанс HTTP-соединения и закрывает TCP-соединение. Возбуждает исключение IOError, если сеанс не был начат.
# File lib/net/http.rb, line 1268
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
}
# File lib/net/http.rb, line 1290 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']
# File lib/net/http.rb, line 711
def inspect
"#<#{self.class} #{@address}:#{@port} open=#{started?}>"
end # File lib/net/http.rb, line 748 def ipaddr started? ? @socket.io.peeraddr[3] : @ipaddr end
IP-адрес для подключения.
# File lib/net/http.rb, line 753 def ipaddr=(addr) raise IOError, "ipaddr value changed, but session already started" if started? @ipaddr = addr end
Установить IP-адрес для подключения.
# File lib/net/http.rb, line 1344 def lock(path, body, initheader = nil) request(Lock.new(path, initheader), body) end
Отправляет запрос LOCK на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 783
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.
# File lib/net/http.rb, line 1386 def mkcol(path, body = nil, initheader = nil) request(Mkcol.new(path, initheader), body) end
Отправляет запрос MKCOL на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1374 def move(path, initheader = nil) request(Move.new(path, initheader)) end
Отправляет запрос MOVE на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1356 def options(path, initheader = nil) request(Options.new(path, initheader)) end
Отправляет запрос OPTIONS на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1328 def patch(path, data, initheader = nil, dest = nil, &block) # :yield: +body_segment+ send_entity(path, data, initheader, dest, Patch, &block) end
Отправляет запрос PATCH на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 939
def peer_cert
if not use_ssl? or not @socket
return nil
end
@socket.io.peer_cert
end Возвращает сертификаты X.509, представленные сервером.
# File lib/net/http.rb, line 1322 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».
# File lib/net/http.rb, line 1362
def propfind(path, body = nil, initheader = {'Depth' => '0'})
request(Propfind.new(path, initheader), body)
end Отправляет запрос PROPFIND на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1338 def proppatch(path, body, initheader = nil) request(Proppatch.new(path, initheader), body) end
Отправляет запрос PROPPATCH на path и получает ответ в виде объекта HTTPResponse.
# File lib/net/http.rb, line 1137 def proxy? !!(@proxy_from_env ? proxy_uri : @proxy_address) end
Истина, если запросы для этого соединения будут проксироваться
# File lib/net/http.rb, line 1156
def proxy_address
if @proxy_from_env then
proxy_uri&.hostname
else
@proxy_address
end
end Адрес прокси-сервера, если он настроен.
# File lib/net/http.rb, line 1142 def proxy_from_env? @proxy_from_env end
Истина, если прокси для этого соединения определяется из среды
# File lib/net/http.rb, line 1190
def proxy_pass
if ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE && @proxy_from_env
proxy_uri&.password
else
@proxy_pass
end
end Пароль прокси-сервера, если он настроен.
# File lib/net/http.rb, line 1165
def proxy_port
if @proxy_from_env then
proxy_uri&.port
else
@proxy_port
end
end Порт прокси-сервера, если он настроен.
# File lib/net/http.rb, line 1181
def proxy_user
if ENVIRONMENT_VARIABLE_IS_MULTIUSER_SAFE && @proxy_from_env
proxy_uri&.user
else
@proxy_user
end
end Имя пользователя прокси-сервера, если он настроен.
# File lib/net/http.rb, line 794 def read_timeout=(sec) @socket.read_timeout = sec if @socket @read_timeout = sec end
Установка значения атрибута read_timeout.
# File lib/net/http.rb, line 1510
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::*.
# File lib/net/http.rb, line 1421 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
}
# File lib/net/http.rb, line 1435 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']
# File lib/net/http.rb, line 1465 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
}
# File lib/net/http.rb, line 1489 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
# File lib/net/http.rb, line 724 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 { .... } # File lib/net/http.rb, line 955
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.
# File lib/net/http.rb, line 823 def started? @started end
Возвращает true, если HTTP сеанс был начат.
# File lib/net/http.rb, line 1392 def trace(path, initheader = nil) request(Trace.new(path, initheader)) end
Отправляет запрос TRACE на path и получает ответ как объект HTTPResponse.
# File lib/net/http.rb, line 1350 def unlock(path, body, initheader = nil) request(Unlock.new(path, initheader), body) end
Отправляет запрос UNLOCK на path и получает ответ как объект HTTPResponse.
# File lib/net/http.rb, line 840
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.
# File lib/net/http.rb, line 832 def use_ssl? @use_ssl end
Возвращает true, если с HTTP используется SSL/TLS.
# File lib/net/http.rb, line 800 def write_timeout=(sec) @socket.write_timeout = sec if @socket @write_timeout = sec end
Установка атрибута write_timeout.
Приватные методы экземпляров
# File lib/net/http.rb, line 1684 def D(msg) return unless @debug_output @debug_output << msg @debug_output << "\n" end
# File lib/net/http.rb, line 1677
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
# File lib/net/http.rb, line 1594
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
Ruby Core © 1993–2020 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.