1

Freeswitch（VOIPソフトウェアスイッチ）のzmqモジュールに接続するために、phpバインディングでzeromqを使用しています。

短い: 私はイベントを失っています。Long: Freeswitch の zmq モジュールは、パブリッシャーとして c++ で実装されています。私のPHPコードは次のとおりです。

<?php
  $context = new ZMQContext();

  echo "connect to freeswitch zmq module...";
  $sub = new ZMQSocket($context, ZMQ::SOCKET_SUB);
  $sub->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE,"");
  $sub->connect("tcp://192.168.20.73:5556");
  $hwm = $sub->getSockOpt(ZMQ::SOCKOPT_HWM);
  echo "ok.hwm: $hwm\n";

  echo "looping\n";
  while(1) {
  $data = $sub->recv();
  $d = json_decode($sub->recv(),TRUE);
  $event = $d["Event-Name"];
  $date = $d["Event-Date-Local"];
  $ts = $d["Event-Date-Timestamp"];
  $msgnr = $d["ZMQ-Msg-Cnt"];
  echo "PHP: $date msg# $msgnr $ts received $event\n";
}
?>

ZMQ-Msg-Cnt は、freeswitch の zmq モジュールに組み込んだシーケンス番号です。2 つおきのメッセージが失われていることがわかります。tcpdump は、メッセージが zmq によって受信されたことを示しています。

PHP コードを C に変換したところ、すべてのメッセージを受信できるようになりました。子：

#include "zhelpers.h"
#include "cJSON.h"

int main (void)
{
    void *context = zmq_init (1);

    void *subscriber = zmq_socket (context, ZMQ_SUB);
    zmq_connect (subscriber, "tcp://192.168.20.73:5556");
    zmq_setsockopt (subscriber, ZMQ_SUBSCRIBE, "", 0);

    while (1) {
        char *string = s_recv (subscriber);

        cJSON *root = cJSON_Parse(string);
        int msgcnt = cJSON_GetObjectItem(root,"ZMQ-Msg-Cnt")->valueint;

        printf("C: %s msg# %s %s received %s\n",
            cJSON_GetObjectItem(root,"Event-Date-Local")->valuestring,
            cJSON_GetObjectItem(root,"ZMQ-Msg-Cnt")->valuestring,
            cJSON_GetObjectItem(root,"Event-Date-Timestamp")->valuestring,
            cJSON_GetObjectItem(root,"Event-Name")->valuestring
        );
        cJSON_Delete(root);
        free (string);
    }

zmq_close (subscriber);
zmq_term (context);
return 0;
}

PHPコードに問題はありますか? PHP のトリック/必須/ヒントはありますか?

前もって感謝します、ジェラルド・ウェーバー

4

1 に答える 1

1

You are calling the recv function twice, thus it is loading one message, skipping any processing on it, then loading the second one:

$data = $sub->recv();
// This is your first message, called in a blocking mode

$d = json_decode($sub->recv(),TRUE);
// and here's your second one, called in a non-blocking mode

Change these two lines to just one:

$d = json_decode($sub->recv());
于 2012-01-13T15:26:50.320 に答える