在cmake工程中使用ZeroMQ

ZeroMQ官網

linux平台

一、安裝libzmq

        1、下載代碼：git clone https://github.com/zeromq/libzmq.git

        2、切換到最新的tag，目前是v4.3.3：git checkout v4.3.3

        3、配置：

1. cd libzmq
2. ./autogen.sh
3. ./configure --prefix=/home/xxx/libzmq/_install

        4、編譯並安裝：make -j4 && sudo make install

在配置時根據需求更改安裝目錄，如果是安裝在linux平台上可以直接安裝到/usr

 若是交叉編譯到ARM-LINUX上，要在Makefile中修改編譯工具鏈，並安裝到自己指定的目錄下

只需要安裝libzmq就可以使用ZeroMQ的通信功能了，但是由於libzmq本身是用C寫的，為了方便C++用戶，官方有做了一個針對C++的接口封裝，方便C++用戶使用C++類和對象進行編程。可以下載和編譯cppzmq或在zmqpp庫。

二、安裝zmqpp

       因為zmqpp是對libzmq接口的高層次的封裝，是c++接口中最好用的一個，所以選擇了zmqpp庫

       1、下載代碼：git clone https://github.com/zeromq/zmqpp.git

        2、切換到最新的tag，目前是v4.2.0：git checkout v4.2.0

        3、編譯並安裝：make -j4 && sudo make install

同樣需要安裝到指定目錄或在交叉編譯，在Makefile中指定

 

三、在cmake工程中使用zmqpp

 1. 在third_party添加zmqpp相關頭文件

 

 2. 在lib目錄下添加靜態庫zmq, zmqpp

 

 3. 在cmakelists中添加配置

...
include_directories(net lib)

link_libraries(
    ${CMAKE_CURRENT_SOURCE_DIR}/lib/libzmq.a
    ${CMAKE_CURRENT_SOURCE_DIR}/lib/libzmqpp.a
    pthread )

add_executable(server server.cpp)

add_executable(client client.cpp)

target_link_libraries(server pthread  zmqpp zmq)
...

4. 在源碼中添加頭文件

#include "third_party/zmqpp/zmqpp.hpp"
#include <string>
#include <iostream>
#include <chrono>
#include <thread>

using namespace std;

int main(int argc, char *argv[]) {
  const string endpoint = "tcp://*:5555";

  // initialize the 0MQ context
  zmqpp::context context;

  // generate a pull socket
  zmqpp::socket_type type = zmqpp::socket_type::reply;
  zmqpp::socket socket (context, type);

  // bind to the socket
  socket.bind(endpoint);
  while (1) {
    // receive the message
    zmqpp::message message;
    // decompose the message 
    socket.receive(message);
    string text;
    message >> text;

    //Do some 'work'
    std::this_thread::sleep_for(std::chrono::seconds(1));
    cout << "Received Hello" << endl;
    socket.send("World");
  }

}

#include "third_party/zmqpp/zmqpp.hpp"
#include <string>
#include <iostream>

using namespace std;

int main(int argc, char *argv[]) {
  const string endpoint = "tcp://localhost:5555";

  // initialize the 0MQ context
  zmqpp::context context;

  // generate a push socket
  zmqpp::socket_type type = zmqpp::socket_type::req;
  zmqpp::socket socket (context, type);

  // open the connection
  cout << "Connecting to hello world server…" << endl;
  socket.connect(endpoint);
  int request_nbr;
  for (request_nbr = 0; request_nbr != 10; request_nbr++) {
    // send a message
    cout << "Sending Hello " << request_nbr <<"…" << endl;
    zmqpp::message message;
    // compose a message from a string and a number
    message << "Hello";
    socket.send(message);
    string buffer;
    socket.receive(buffer);
    
    cout << "Received World " << request_nbr << endl;
  }
}

5. 測試

參考：

跟我一起學習ZeroMQ（3）：安裝libzmq和zmqpp（接下來基於zmqpp實現多種zmq通訊模式）

ZeroMQ推薦博客：

  烏合之眾  /  ZeroMQ-Guide-Zh

 

https://blog.csdn.net/lianshaohua