Клиент xmlrpc PHP и сервер xmlrpc Python 2.5: неполные данные и сброс соединения при ошибке равноправного узла

Question

У меня есть сервер XML RPC, работающий с Python.

Он реализован как экземпляр класса SimpleXMLRPCServer.

from SimpleXMLRPCServer import SimpleXMLRPCServer
from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler

class MyClass:
    def getGeneExtraInfo(self,genome,infoType,elements):
        print 'DEBUG:\ngenome: %s\ninfoType: %s, elements %s' % (genome,infoType,elements)
        return 'A' * 10000

csfServer = MyClass()

server = SimpleXMLRPCServer((serverHost, serverPort), SimpleXMLRPCRequestHandler)
server.register_instance(csfServer) 
server.serve_forever()

У csfServer есть метод def getGeneExtraInfo(self,genome,infoType,elements), которыйвозвращает длинную строку, давайте для простоты рассмотрим, что повторяет 10000 повторений «A».

Я обращаюсь к этому веб-сервису через PHP по следующему коду:

function sendRequest($host, $url, $request, $port = 80) {                                                                                                                                      

  $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  if ($socket === false) {
      echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
      return FALSE;
  }

  $address = gethostbyname($host);
  if (!socket_connect ($socket, $address, $port)) {
      echo socket_strerror(socket_last_error());
      return FALSE;
  }

  $httpQuery = "POST ". $url ." HTTP/1.0\r\n";
  $httpQuery .= "User-Agent: xmlrpc\r\n";
  $httpQuery .= "Host: ". $host ."\r\n";
  $httpQuery .= "Content-Type: text/xml\r\n";
  $httpQuery .= "Content-Length: ". strlen($request) ."\r\n\r\n";
  $httpQuery .= $request ."\r\n";

  if (!socket_send($socket, $httpQuery , strlen($httpQuery), 0)) {
      echo socket_strerror(socket_last_error());
      return FALSE;
  }

  $xmlResponse = "";
  $buff = "";
  while ($bytes = socket_recv($socket, $buff, 1024, MSG_WAITALL) > 0) {
      $xmlResponse .= $buff;
  }

  // Just for debugging
  echo "socket_recv() failed; reason: " . socket_strerror(socket_last_error($socket)) . "\n";

  socket_close($socket);

  return  $xmlResponse;
}

Переменная $request является сборкой:

$xmlrpc_output_options = array( 
                        "output_type" => "xml", 
                        "verbosity" => "no_white_space", 
                        "escaping" => array("markup", "non-ascii", "non-print"), 
                        "version" => "xmlrpc", 
                        "encoding" => "UTF-8");


$xmlRequest = xmlrpc_encode_request('getGeneExtraInfo', array($genome,$infoType,$elements), $xmlrpc_output_options);

(можно увидеть встроенный запрос в следующем коде C и Python)

Клиент и сервер php работают правильно, когда серверработает с python 2.4, но , когда сервер выполняется с python 2.5 или 2.6, иногда (в 50% случаев) данные оказываются неполными и с ошибкой «Сброс соединения по пиру».

Чтобы проверить, связана ли проблема с Python или PHP, я написал два клиента, один на C и другой на Python.Оба используют сокеты и, в основном, как работает код PHP.Содержимое «запроса» было скопировано из вывода PHP, это означает, что ровно запрос для PHP, C и Python.

Код C:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h> 

void error(const char *msg)
{
        perror(msg);
            exit(0);
}

int main(int argc, char *argv[])
{
        int sockfd, n;
        struct sockaddr_in serv_addr;
        struct hostent *server;

        char* hostname=  "wks-13-15";
        int portno = 56572;

        char buffer[1024];

        char request[] = "POST / HTTP/1.0\r\nUser-Agent: xmlrpc\r\nHost: wks-13-15\r\nContent-Type: text/xml\r\nContent-Length: 4479\r\n\r\n<?xml version=\"1.0\" encoding=\"UTF-8\"?><methodCall><methodName>getGeneExtraInfo</methodName><params><param><value><string>hg19</string></value></param><param><value><string>GO</string></value></param><param><value><array><data><value><string>GO:0044428</string></value><value><string>GO:0044422</string></value><value><string>GO:0044425</string></value><value><string>GO:0044424</string></value><value><string>GO:0043412</string></value><value><string>GO:0006464</string></value><value><string>GO:0009889</string></value><value><string>GO:0003824</string></value><value><string>GO:0016020</string></value><value><string>GO:0016021</string></value><value><string>GO:0048522</string></value><value><string>GO:0048523</string></value><value><string>GO:0090304</string></value><value><string>GO:0019538</string></value><value><string>GO:0051171</string></value><value><string>GO:0001882</string></value><value><string>GO:0001883</string></value><value><string>GO:0080090</string></value><value><string>GO:0042221</string></value><value><string>GO:0048869</string></value><value><string>GO:0019222</string></value><value><string>GO:0005488</string></value><value><string>GO:0005886</string></value><value><string>GO:0005524</string></value><value><string>GO:0031090</string></value><value><string>GO:0050896</string></value><value><string>GO:0010556</string></value><value><string>GO:0010468</string></value><value><string>GO:0016740</string></value><value><string>GO:0003677</string></value><value><string>GO:2000112</string></value><value><string>GO:0005622</string></value><value><string>GO:0019219</string></value><value><string>GO:0006139</string></value><value><string>GO:0032502</string></value><value><string>GO:0032501</string></value><value><string>GO:0050794</string></value><value><string>GO:0009058</string></value><value><string>GO:0032991</string></value><value><string>GO:0044249</string></value><value><string>GO:0044260</string></value><value><string>GO:0044267</string></value><value><string>GO:0035639</string></value><value><string>GO:0009987</string></value><value><string>GO:0044464</string></value><value><string>GO:0051252</string></value><value><string>GO:0043170</string></value><value><string>GO:0005634</string></value><value><string>GO:0005737</string></value><value><string>GO:0050789</string></value><value><string>GO:0031326</string></value><value><string>GO:0051716</string></value><value><string>GO:0016787</string></value><value><string>GO:0031323</string></value><value><string>GO:0006810</string></value><value><string>GO:0048856</string></value><value><string>GO:0065007</string></value><value><string>GO:0043227</string></value><value><string>GO:0043167</string></value><value><string>GO:0044459</string></value><value><string>GO:0043169</string></value><value><string>GO:0008150</string></value><value><string>GO:0008152</string></value><value><string>GO:0006355</string></value><value><string>GO:0005575</string></value><value><string>GO:0046914</string></value><value><string>GO:0003674</string></value><value><string>GO:0006807</string></value><value><string>GO:0003676</string></value><value><string>GO:0044446</string></value><value><string>GO:0044444</string></value><value><string>GO:0051234</string></value><value><string>GO:0032555</string></value><value><string>GO:0043228</string></value><value><string>GO:0043229</string></value><value><string>GO:0043226</string></value><value><string>GO:0045449</string></value><value><string>GO:0032559</string></value><value><string>GO:0031224</string></value><value><string>GO:0017076</string></value><value><string>GO:0071842</string></value><value><string>GO:0071841</string></value><value><string>GO:0071840</string></value><value><string>GO:0060255</string></value><value><string>GO:0016043</string></value><value><string>GO:0034641</string></value><value><string>GO:0008270</string></value><value><string>GO:0000166</string></value><value><string>GO:0046872</string></value><value><string>GO:0044237</string></value><value><string>GO:0044238</string></value><value><string>GO:0043234</string></value><value><string>GO:0043231</string></value><value><string>GO:0043232</string></value><value><string>GO:0032553</string></value><value><string>GO:0005515</string></value><value><string>GO:0007165</string></value><value><string>GO:0048519</string></value><value><string>GO:0048518</string></value><value><string>GO:0030554</string></value></data></array></value></param></params></methodCall>";

        fprintf(stderr, "%s\n", request);

        sockfd = socket(AF_INET, SOCK_STREAM, 0);
        if (sockfd < 0) 
            error("ERROR opening socket");
        server = gethostbyname(hostname);

        if (server == NULL) {
            fprintf(stderr,"ERROR, no such host\n");
            exit(0);
        }

        bzero((char *) &serv_addr, sizeof(serv_addr));
        serv_addr.sin_family = AF_INET;
        bcopy((char *)server->h_addr, 
                (char *)&serv_addr.sin_addr.s_addr,
                server->h_length);

        serv_addr.sin_port = htons(portno);

        if (connect(sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0) 
            error("ERROR connecting");

        fprintf(stderr, "%d\n", strlen(request));

        n = write(sockfd,request,strlen(request));
        if (n < 0) 
            error("ERROR writing to socket");

        fprintf(stderr, "%d\n", n);

        bzero(buffer,1024);
        while (read(sockfd,buffer,1023) > 0) {
            printf("%s",buffer);
            bzero(buffer,1024);
        }

        if (n < 0) 
            error("ERROR reading from socket");

        close(sockfd);

        return 0;
}

Код Python:

import socket

request = """POST / HTTP/1.0
User-Agent: xmlrpc
Host: wks-13-15
Content-Type: text/xml
Content-Length: 4479

<?xml version="1.0" encoding="UTF-8"?><methodCall><methodName>getGeneExtraInfo</methodName><params><param><value><string>hg19</string></value></param><param><value><string>GO</string></value></param><param><value><array><data><value><string>GO:0044428</string></value><value><string>GO:0044422</string></value><value><string>GO:0044425</string></value><value><string>GO:0044424</string></value><value><string>GO:0043412</string></value><value><string>GO:0006464</string></value><value><string>GO:0009889</string></value><value><string>GO:0003824</string></value><value><string>GO:0016020</string></value><value><string>GO:0016021</string></value><value><string>GO:0048522</string></value><value><string>GO:0048523</string></value><value><string>GO:0090304</string></value><value><string>GO:0019538</string></value><value><string>GO:0051171</string></value><value><string>GO:0001882</string></value><value><string>GO:0001883</string></value><value><string>GO:0080090</string></value><value><string>GO:0042221</string></value><value><string>GO:0048869</string></value><value><string>GO:0019222</string></value><value><string>GO:0005488</string></value><value><string>GO:0005886</string></value><value><string>GO:0005524</string></value><value><string>GO:0031090</string></value><value><string>GO:0050896</string></value><value><string>GO:0010556</string></value><value><string>GO:0010468</string></value><value><string>GO:0016740</string></value><value><string>GO:0003677</string></value><value><string>GO:2000112</string></value><value><string>GO:0005622</string></value><value><string>GO:0019219</string></value><value><string>GO:0006139</string></value><value><string>GO:0032502</string></value><value><string>GO:0032501</string></value><value><string>GO:0050794</string></value><value><string>GO:0009058</string></value><value><string>GO:0032991</string></value><value><string>GO:0044249</string></value><value><string>GO:0044260</string></value><value><string>GO:0044267</string></value><value><string>GO:0035639</string></value><value><string>GO:0009987</string></value><value><string>GO:0044464</string></value><value><string>GO:0051252</string></value><value><string>GO:0043170</string></value><value><string>GO:0005634</string></value><value><string>GO:0005737</string></value><value><string>GO:0050789</string></value><value><string>GO:0031326</string></value><value><string>GO:0051716</string></value><value><string>GO:0016787</string></value><value><string>GO:0031323</string></value><value><string>GO:0006810</string></value><value><string>GO:0048856</string></value><value><string>GO:0065007</string></value><value><string>GO:0043227</string></value><value><string>GO:0043167</string></value><value><string>GO:0044459</string></value><value><string>GO:0043169</string></value><value><string>GO:0008150</string></value><value><string>GO:0008152</string></value><value><string>GO:0006355</string></value><value><string>GO:0005575</string></value><value><string>GO:0046914</string></value><value><string>GO:0003674</string></value><value><string>GO:0006807</string></value><value><string>GO:0003676</string></value><value><string>GO:0044446</string></value><value><string>GO:0044444</string></value><value><string>GO:0051234</string></value><value><string>GO:0032555</string></value><value><string>GO:0043228</string></value><value><string>GO:0043229</string></value><value><string>GO:0043226</string></value><value><string>GO:0045449</string></value><value><string>GO:0032559</string></value><value><string>GO:0031224</string></value><value><string>GO:0017076</string></value><value><string>GO:0071842</string></value><value><string>GO:0071841</string></value><value><string>GO:0071840</string></value><value><string>GO:0060255</string></value><value><string>GO:0016043</string></value><value><string>GO:0034641</string></value><value><string>GO:0008270</string></value><value><string>GO:0000166</string></value><value><string>GO:0046872</string></value><value><string>GO:0044237</string></value><value><string>GO:0044238</string></value><value><string>GO:0043234</string></value><value><string>GO:0043231</string></value><value><string>GO:0043232</string></value><value><string>GO:0032553</string></value><value><string>GO:0005515</string></value><value><string>GO:0007165</string></value><value><string>GO:0048519</string></value><value><string>GO:0048518</string></value><value><string>GO:0030554</string></value></data></array></value></param></params></methodCall>"""

HOST = "wks-13-15"
PORT = 56572

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.sendall(request)

while 1:
        data = s.recv(1024)
        print data
        if not data: break

s.close()

Обе программы работают и получают полные данные ответа.

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

Мои вопросы: (не стесняйтесь отвечать на любой из них :-))

• Почему программы на C и Python работают, а PHP иногда нет?
• Почему иногда PHP-код работает, а другие нет?
• Почему ссервер работает на Python 2.4, клиентский код PHP работает, а с Python 2.5 и 2.6 - нет?
• Как я могу это решить?Предложения приветствуются.

Answer 1

Я использую класс xml_rpc, я не уверен, с какой версии PHP это началось, но он работает для меня.Он даже закодирует ваш запрос из массива, но если у вас уже есть XML для запроса, я бы сделал это:

PHP

function sendRequest($host, $url, $request, $port = 80) {

//create the context to send to the xmlrpc server
$context = stream_context_create(array('http' => array(
    'method' => "POST",
    'header' => "Content-Type: text/xml\r\nUser-Agent: PHPRPC/1.0\r\n",
    'content' => $request
)));

//i am not sure how to get the url, normally something like http://server/api/xml
$server = "http://$host:$port"; //?

//store the response
$file = file_get_contents($server, false, $context);
//decode the response to xml
$return xmlrpc_decode($file);
}