飞扬轻狂's blog

- 安装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去