【发布时间】:2014-04-25 04:36:40
【问题描述】:
是否有任何已知的可用作库的 AMQP 代理实现?有大量的客户端,但我发现的代理实现都希望作为独立进程运行。
我正在考虑编写一些东西,其中每个节点既是代理又是客户端。不能选择独立的代理/外部流程。
最好使用 C/C++ 或 Haskell 或任何提供可链接的类 C 接口的东西。
如果没有,是否有任何推荐的 AMQP 替代方案符合要求?
【问题讨论】:
是否有任何已知的可用作库的 AMQP 代理实现?有大量的客户端,但我发现的代理实现都希望作为独立进程运行。
我正在考虑编写一些东西,其中每个节点既是代理又是客户端。不能选择独立的代理/外部流程。
最好使用 C/C++ 或 Haskell 或任何提供可链接的类 C 接口的东西。
如果没有,是否有任何推荐的 AMQP 替代方案符合要求?
【问题讨论】:
这里是client and server example 手册。
以及来自示例仓库的简要实现:
// Hello World server
#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) {
char buffer [10];
zmq_recv (responder, buffer, 10, 0);
printf ("Received Hello\n");
sleep (1); // Do some 'work'
zmq_send (responder, "World", 5, 0);
}
return 0;
}
// Hello World client
#include <zmq.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
int main (void)
{
printf ("Connecting to hello world server...\n");
void *context = 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];
printf ("Sending Hello %d...\n", request_nbr);
zmq_send (requester, "Hello", 5, 0);
zmq_recv (requester, buffer, 10, 0);
printf ("Received World %d\n", request_nbr);
}
zmq_close (requester);
zmq_ctx_destroy (context);
return 0;
}
【讨论】:
在四处询问后,我被指出 Nanomsg 由 Martin Sústrik 完成,与 ZMQ 相同的家伙。虽然它并不能完全提供我所追求的保证,但似乎从 ZMQ 对 nanomsg 所做的架构更改使得手动实现和执行保证变得更加容易。 我会更深入地研究它,但到目前为止它看起来很有希望。
【讨论】: