- 安装zeromq
$ wget http://www.zeromq.org/local--files/area:download/zeromq-2.0.6.tar.gz
$ tar -xzf zeromq-2.0.6.tar.gz
$ cd zeromq-2.0.6
$ ./configure --prefix=/home/app/zeromq
$ make
$ sudo make install
// 重建so文件链接
$ sudo ln -s /home/app/zeromq/lib/libzmq.so.0.0.0 /usr/lib/libzmq.so.0
$ sudo ln -s /home/app/zeromq/lib/libzmq.so.0.0.0 /usr/lib/libzmq.so
- 测试zeromq
// client.c
#include
#include
#include
#include "/home/app/zeromq/include/zmq.h"
int main ()
{
int rc;
void *ctx, *s;
zmq_msg_t query, resultset;
const char *query_string, *resultset_string = "OK";
/* Initialise 0MQ context, requesting a single application thread
and a single I/O thread */
ctx = zmq_init (1, 1, 0);
assert (ctx);
/* Create a ZMQ_REP socket to receive requests and send replies */
s = zmq_socket (ctx, ZMQ_REP);
assert (s);
/* Bind to the TCP transport and port 5555 on the 'lo' interface */
rc = zmq_bind (s, "tcp://lo:5555");
assert (rc == 0);
while (1) {
/* Allocate an empty message to receive a query into */
rc = zmq_msg_init (&query);
assert (rc == 0);
/* Receive a message, blocks until one is available */
rc = zmq_recv (s, &query, 0);
assert (rc == 0);
/* Process the query */
query_string = (const char *)zmq_msg_data (&query);
printf ("Received query: '%s'\n", query_string);
zmq_msg_close (&query);
/* Allocate a response message and fill in an example response */
rc = zmq_msg_init_size (&resultset, strlen (resultset_string) + 1);
assert (rc == 0);
memcpy (zmq_msg_data (&resultset),
resultset_string, strlen (resultset_string) + 1);
/* Send back our canned response */
rc = zmq_send (s, &resultset, 0);
assert (rc == 0);
zmq_msg_close (&resultset);
}
}
// server.cpp
#include
#include "/home/app/zeromq/include/zmq.hpp"
int main ()
{
try {
// Initialise 0MQ context with one application and one I/O thread
zmq::context_t ctx (1, 1);
// Create a ZMQ_REQ socket to send requests and receive replies
zmq::socket_t s (ctx, ZMQ_REQ);
// Connect it to port 5555 on localhost using the TCP transport
s.connect ("tcp://localhost:5555");
// Construct an example zmq::message_t with our query
const char *query_string = "SELECT * FROM mytable";
zmq::message_t query (strlen (query_string) + 1);
memcpy (query.data (), query_string, strlen (query_string) + 1);
// Send the query
s.send (query);
// Receive and display the result
zmq::message_t resultset;
s.recv (&resultset);
const char *resultset_string = (const char *)resultset.data ();
printf ("Received response: '%s'\n", resultset_string);
}
catch (std::exception &e) {
// 0MQ throws standard exceptions just like any other C++ API
printf ("An error occurred: %s\n", e.what());
return 1;
}
return 0;
}
// 编译
$ gcc `pkg-config --libs --cflags /home/app/zeromq/lib/pkgconfig/libzmq.pc` -o server server.c
$ g++ `pkg-config --libs --cflags /home/app/zeromq/lib/pkgconfig/libzmq.pc` -o client client.cpp
注意：将so链接到usr/lib下 测试程序才运行成功！
- 安装java扩展不成功
configure.in:3: error: Autoconf version 2.61 or higher is required
$ autoreconf --version
autoreconf (GNU Autoconf) 2.59
没有时间细弄了 下次有时间再试吧 准备看下 activemq去
