2015-06-04 43 views
3

我学习zeromq并具有以下的测试代码:zmq_socket()是给分段错误

void *context = (void *)zmq_ctx_new(); 

if (context == NULL) { 
    printf("context is null\n"); 
} else { 
    printf("context was created successfully\n"); 
} 

printf("connecting to the 0mq server\n"); 
void *responder = zmq_socket (context, ZMQ_REQ); 

printf("got socket\n"); 

if (responder == NULL) { 
    printf("responder is null\n"); 
} else { 
    printf("responder was created successfully\n"); 
} 

当我运行的代码,它崩溃时zmq_socket()被调用。下面是输出:

开始连接到 0mq服务器分段故障已成功创建0mq服务器环境(核心转储)

我不知道为什么zmq_socket()失败。我试图在Makefile中链接系列的开头移动zmq库。它仍然失败。

任何帮助将不胜感激。

+0

我的第一个语句:无效的情况下=(无效)zmq_ctx_new();实际上,void * context =(void *)zmq_ctx_new();不知道为什么它没有把*放在那里。无论如何..只是想澄清它 – Kavita

+0

你的调试器说segfault发生在哪里? – Peter

+0

为什么在第一个声明中演员?在C里投这里是没有必要的。如果编译器抱怨没有它,你可能会找到你的问题的原因。 – alk

回答

0

变化

void context = (void)zmq_ctx_new(); 

void *context = (void *)zmq_ctx_new(); 

而且,我想你的代码,无效的情况下=(无效)zmq_ctx_new()会导致编译错误。

这是我的代码,可以在我的OSX上工作。

gcc -o cli client.c -lzmq 
gcc -o srv server.c -lzmq 

client.c:

#include <zmq.h> 
#include <string.h> 
#include <stdio.h> 
#include <unistd.h> 

int main (void) 
{ 
    printf ("Connecting to hello world server…\n"); 
    void *context = (void *)zmq_ctx_new(); 
    void *requester = zmq_socket (context, ZMQ_REQ); 
    zmq_connect (requester, "tcp://localhost:5555"); 

    int request_nbr; 
    for (request_nbr = 0; request_nbr != 10; request_nbr++) { 
     char buffer [10]; 
     char snd[] = "hello"; 
     printf ("Sending Hello %d…\n", request_nbr); 
     zmq_send (requester, snd, sizeof(snd), 0); 
     zmq_recv (requester, buffer, 10, 0); 
     printf ("Received World %d\n", request_nbr); 
    } 
    zmq_close (requester); 
    zmq_ctx_destroy (context); 
    return 0; 
} 

server.c:

#include <zmq.h> 
#include <stdio.h> 
#include <unistd.h> 
#include <string.h> 
#include <assert.h> 

int main (void) 
{ 
    // Socket to talk to clients 
    void *context = zmq_ctx_new(); 
    void *responder = zmq_socket (context, ZMQ_REP); 
    int rc = zmq_bind (responder, "tcp://*:5555"); 
    assert (rc == 0); 

    while (1) { 
     int nrecv; 
     char buffer [10]; 
     nrecv = zmq_recv (responder, buffer, 10, 0); 
     printf ("[%d] Received %s\n", nrecv, buffer); 
     sleep (1);   // Do some 'work' 
     zmq_send (responder, "World", 5, 0); 
    } 
    return 0; 
} 
+0

感谢您的反馈。这就是我的代码的方式。出于某种原因,我的明星不在这里展示。我的代码就是你所建议的。 – Kavita

+0

奇怪的是,如果我调用zmq_socket(&context,ZMQ_REQ),那么分段错误不会发生,但创建的套接字为NULL。我知道,将地址传递给上下文是一个错误的电话。但是,它告诉我,问题可能不是代码。我不知道 – Kavita

+0

@Kavita,zmq_socket(&context,ZMQ_REQ)是不正确的,zmq_socket(context,ZMQ_REQ)是正确的。上下文是zmq_ctx_new()返回的指针,不能将指针的地址传递给zmq_socket。只需将指针本身传入zmq_socket即可。 – finesse