ZeroMQでCでマルチパートメッセージを受信

Question

私はZeroMQソケットを使用してデータを送信し、マルチパートメッセージを発行するデバイス用のデータ記録システムを作成しています。

私のプログラムは、私はまさにそれが必要として動作Pythonスクリプトを書くために管理しなかったC.

で書かれる必要があります。 これは、次のようになります。

import zmq 
import time 
import numpy as np 

_HEARTBEAT_PREFIX =  b'ray.heartbeat\0' 
_RAW_DATA_PREFIX =  b'ray.rawdata\0' 

context = zmq.Context.instance() 

time.sleep(5) 

socket = context.socket(zmq.SUB) 
socket.setsockopt(zmq.LINGER, 0) 
socket.setsockopt(zmq.SUBSCRIBE, b'') 
time.sleep(5) 
socket.connect("tcp://localhost:50290") 
time.sleep(5) 
go = True 
while go: 

    if socket.poll(1000): 

     zframes = socket.recv_multipart(flags=zmq.NOBLOCK, copy=False) 

     if (zframes[0].buffer.tobytes() == _HEARTBEAT_PREFIX): 
      print ('Heartbeart') 
     elif (zframes[0].buffer.tobytes() == _RAW_DATA_PREFIX): 
      dataToWrite = np.frombuffer(zframes[1].buffer, dtype='i2') 
      print ('Raw data: ') 
      # and so on ... 

この私がCに、このPythonコードをZMQと協力し、ポートにしようとしています初めて本当の挑戦です。私は今、書かれているCのコードが実行されますが、正常に動作しません：

#include "zhelpers.h" 

int main (int argc, char *argv []) 
{ 

    void *context = zmq_ctx_new(); 
    void *subscriber = zmq_socket(context,ZMQ_SUB); 

    int rc = zmq_connect(subscriber,"tcp://localhost:50290"); 
    assert(rc == 0); 
    rc = zmq_setsockopt(subscriber,ZMQ_SUBSCRIBE, "", 0); 
    assert(rc == 0); 

    while (1) 
    { 
    zmq_msg_t message; 
    zmq_msg_init (&message); 
    zmq_msg_recv (&message, subscriber,0);//, ZMQ_NOBLOCK); 
    // Process the message frame 


    int size = zmq_msg_size(&message); 
    char *string = malloc(size + 1); 
    memcpy(string, zmq_msg_data(&message), size); 


    zmq_msg_close (&message); 

    string[size] = 0; 
    printf("Message[%d]: %s\n", size, string); 

    if (!zmq_msg_more (&message)) 
     break;  // Last message frame 
    } 
    return 0; 
} 

ので、このコードは、しかし、入ってくるデータの正確なサイズを提供しますが、データを表示するとき、それはのように読めない文字を示します（シンボルとon）..私は、Pythonでやっているように、それをさらに処理するために入力データを文字列として取得する必要があります。

Answer 1

私は、Pythonのnumpy配列がintの文字列配列に変換されていることを知りました。そして、Cプログラムでは非常に難しい値が解釈されます。私は正しい値を抽出することができた、受信されたデータを操作することにより

：パイソンからnumpyのアレイを受信した場合、これが唯一の問題であることを

#include "zhelpers.h" 

int main (int argc, char *argv []) 
{ 

    int i = 0; 

    void *context = zmq_ctx_new(); 
    void *subscriber = zmq_socket(context,ZMQ_SUB); 

    int rc = zmq_connect(subscriber,"tcp://localhost:50290"); 
    assert(rc == 0); 

    char* filter = "ray."; 

    rc = zmq_setsockopt(subscriber,ZMQ_SUBSCRIBE, filter, sizeof(filter)); 
    assert(rc == 0); 
    int nextFrame = 0; 

    while (1) 
    { 

    zmq_msg_t message; 
    zmq_msg_init (&message); 
    zmq_msg_recv (&message, subscriber,0);//, ZMQ_NOBLOCK); 

    // Process the message frame 

    int size = zmq_msg_size(&message); 
    char *string = malloc(size + 1); 
    memcpy(string, zmq_msg_data(&message), size); 

    if (nextFrame) 
    { 

     zmq_msg_close (&message); 
     printf("Raw data: "); 
     string[size] = 0; 
     //printf("Data: %s\n", string); 
     for (i = 0; i < size; i+=2) 
     { 

     printf("%d ", (int16_t) ((string[i] & 0xff) +((string[i+1] & 0xff)<<8))); 

     } 


    } 
     if (strcmp(string, "ray.rawdata") != 0) 
     { 
     nextFrame = 0; 
     break; 
     } 
     else 
     { 
     nextFrame = 1; 

     zmq_msg_close (&message); 

     string[size] = 0; 
     printf("Prefix: %s\n", string); 

     if (!zmq_msg_more (&message)) 
      break;  // Last message frame 
     } 

    }} 
    return 0; 
} 

注 - であれば心拍ストリングまたは何であるように、問題はありません。