Форум dkLab и Denwer

Дмитрий Кóтеров

Дмитрий Кóтеров

В текущей бета-версии библиотеки есть проблема с чрезмерном расходованием CPU из-за busy wait.
В ближайшее время будет фикс, который эту проблему решит. К сожалению, не все так просто в curl_multi...

WingedFox

По сему, имеет смысл пользоваться WS-Addressing =)
Правда тут возникает проблема с синхронизацией, потому как спека предполагает, что запрашиваемый сервер будет пинать коллбэк на запрашивающем.

Дмитрий Кóтеров

Busy wait я, кстати, уже починил. На днях выложу.

WS-Addressing, насколько я понимаю, не совсем про это. Dklab_SoapClient позволяет распараллеливать загрузку разных кусков страницы, синхронизируясь в конце для вывода самой страницы. А WS-Addressing, если не ошибаюсь, это способ асинхронного ПОЛУЧЕНИЯ сообщений, а не асинхронной отправки с последующей синхронизацией.

WingedFox

WS-Addressing это просто техника для снижения нагрузки на железо за счёт минимизации времени жизни соединений.
Например, если время работы удалённой системы может достигать десятков минут, логичным выходом будет отправить туда запрос и закрыть соединение. Удалённая система в определённый момент проснётся, и отдаст нам данные используя наш коллбэк сервис.

Ровно ту же схему удобно использовать и в случае необходимости получения данных от большого числа удалённых систем. Чаще всего все эти данные не являются уникальными для каждого запроса, в результате чего можно реализовать примерно такую схему работы:
1) Кеш данных
2) Кеш запросов
3) Набор клиентов для отправки запросов
4) Набор коллбэков
5) Синхронизационный тред, проще всего завязанный на семафоры (обычно с неким таймаутом), или некий кеш запросов

Если же данные уникальны, из схемы просто выкидывается кеш данных (1).

Как оно работает:
1) отправляются запросы с сохранением их ID в неком расшаренном кеше (напр. в том же memcached)
2) состояние кеша запросов опрашивается с неким интервалом, до истечения таймаута или получения всех ответов
3) коллбэк сервис при получении ответа обновляет инфу в
а) кеше запросов
б) в кеше данных
4) по окончании (2) заполняем все блоки данных свежими (или не очень, или не заполняем) данными

Такая организация немного сложнее нежели работа с асинхронными запросами, но имеет большое преимущество - кардинальное снижение нагрузки на железо за счёт
1) создания только одного синхронизационного треда, независимо от количества опрашиваемых сервисов
2) отсутствия необходимости в сохранении открытого канала к удалённому сервису

Дмитрий Кóтеров писал(а):

асинхронного ПОЛУЧЕНИЯ сообщений, а не асинхронной отправки с последующей синхронизацией

Ну, вопрос "последующей синхронизации" это просто вопрос о терминах. Оба варианта распараллеливают работу, другое дело что они этим занимаются на разных уровнях:
1) асинхронные запросы - на уровне исполняемого кода
2) ws-addressing - на уровне транспорта

PS: Мы как раз сейчас реализуем именно такую схему (правда в рамках axis2/java) на базе ws-addressing, поскольку затраты на установление "обратного" соединения ниже, нежели на создание большой кучи параллельных тредов. =)
PPS: к PHP можно попробовать прикрутить axis2/C, который и реализует всякие радости вида ws-addressing, ws-policy и иже с ними.

Дмитрий Кóтеров

version 0.92:
- Fixed bug with busy wait. CPU is now used efficiently.
- Added $result->waitForConnect() method useful when you need to create a number of asynchronous requests and continue the main process execution while these requests are guaranteed begun their processings.

Дмитрий Кóтеров

Теперь разработка ведется в GIT, а не в SVN:
http://github.com/DmitryKoterov/dklab_soapclient/tree/master

prologic

Здравствуйте,

У меня такая проблема. В WSDL mode всегда возвращается такой результат: SOAP response is empty.
Если не-WSDL mode, то всегда возвращается такой результат: Unable to handle request without a valid action parameter. Please supply a valid soap action.

При этом если работать со стандартной SOAP библиотекой PHP, то всё работает.

Помогите пожалуйста разобраться в чём проболема.

Код (php):

скопировать код в буфер обмена

<pre><?
error_reporting(E_ALL);
ini_set('display_errors', "1");
ini_set('log_errors', "1");

define('REMOTE_SERVICE_REQUEST_TIMEOUT', 5);
ini_set('default_socket_timeout', REMOTE_SERVICE_REQUEST_TIMEOUT);

require_once('lib/Dklab/SoapClient.php');

try
{
$client = new Dklab_SoapClient('https://polise.if.lv/PartnerWS/OCTA/PArtner/PremiumCalculator.asmx?wsdl', array(
// 'location' => 'https://polise.if.lv/PartnerWS/OCTA/PArtner/PremiumCalculator.asmx',
// 'uri' => 'urn:myschema',
'timeout' => REMOTE_SERVICE_REQUEST_TIMEOUT
));

$parameters = array(
'VehicleRegNr' => 'AA12345',
'VehicleRegCertNr' => 'AE12312312',
);

$cost = $client->GetVehiclePremium($parameters);

echo 'cost: ';
print_r($cost);
echo '<br />';
}
catch (Exception $e)
{
echo 'Exception: '.$e->getMessage();
}
?>
</pre>

WSDL mode:

Код (any language):

скопировать код в буфер обмена

Array
(
[url] => https://polise.if.lv/PartnerWS/OCTA/PArtner/PremiumCalculator.asmx
[content_type] =>
[http_code] => 415
[header_size] => 198
[request_size] => 517
[filetime] => -1
[ssl_verify_result] => 0
[redirect_count] => 0
[total_time] => 0.11403
[namelookup_time] => 0.000285
[connect_time] => 0.01853
[pretransfer_time] => 0.094567
[size_upload] => 348
[size_download] => 0
[speed_download] => 0
[speed_upload] => 3051
[download_content_length] => -1
[upload_content_length] => -1
[starttransfer_time] => 0.114002
[redirect_time] => 0
[request_header] => POST /PartnerWS/OCTA/PArtner/PremiumCalculator.asmx HTTP/1.1
Host: polise.if.lv
Accept: */*
Content-Type: application/soap+xml; charset=utf-8
Content-Length: 348

[result] => 0
[result_timeout] =>
[body] =>
[headers] => HTTP/1.1 415 Unsupported Media Type
Date: Wed, 31 Mar 2010 10:21:53 GMT
Server: Microsoft-IIS/6.0
X-Powered-By: ASP.NET
X-AspNet-Version: 2.0.50727
Cache-Control: private
Content-Length: 0
)
Exception: SOAP response is empty

Non-WSDL mode:

Код (any language):

скопировать код в буфер обмена

Array
(
[url] => https://polise.if.lv/PartnerWS/OCTA/PArtner/PremiumCalculator.asmx
[content_type] => text/xml; charset=utf-8
[http_code] => 500
[header_size] => 238
[request_size] => 923
[filetime] => -1
[ssl_verify_result] => 0
[redirect_count] => 0
[total_time] => 0.117329
[namelookup_time] => 0.000248
[connect_time] => 0.019593
[pretransfer_time] => 0.097132
[size_upload] => 754
[size_download] => 435
[speed_download] => 3707
[speed_upload] => 6426
[download_content_length] => 435
[upload_content_length] => -1
[starttransfer_time] => 0.117302
[redirect_time] => 0
[request_header] => POST /PartnerWS/OCTA/PArtner/PremiumCalculator.asmx HTTP/1.1
Host: polise.if.lv
Accept: */*
Content-Type: application/soap+xml; charset=utf-8
Content-Length: 754

[result] => 0
[result_timeout] =>
[body] => soap:ClientUnable to handle request without a valid action parameter. Please supply a valid soap action.
[headers] => HTTP/1.1 500 Internal Server Error
Date: Wed, 31 Mar 2010 10:20:19 GMT
Server: Microsoft-IIS/6.0
X-Powered-By: ASP.NET
X-AspNet-Version: 2.0.50727
Cache-Control: private
Content-Type: text/xml; charset=utf-8
Content-Length: 435
)
Exception: Unable to handle request without a valid action parameter. Please supply a valid soap action.

P.S. И ещё вопрос можно ли с помощью Dklab_SoapClient авторизоваться на soap серврере c помощью SSL сертификата (.pem)?
В стандартной SOAP библиотеке это можно было сделать так:
$client = new SoapClient("https://www.baltaonline.lv/Veseris/Policy/18.asmx?wsdl", array('local_cert' => 'mycert.pem'));

sergiosi

Код (php):	скопировать код в буфер обмена
$client = new Dklab_SoapClient('http://10.1.1.2/?wsdl', array('timeout' => 3)); $result = $client->GetModelsList($aParams);

Выдает SOAP response is empty, хотя код

Код (php):	скопировать код в буфер обмена
$client = new SoapClient('http://10.1.1.2/?wsdl', array('timeout' => 3)); $result = $client->GetModelsList($aParams);

выдает правильный результат