{"id":253291,"date":"2015-03-18T09:19:01","date_gmt":"2015-03-18T05:19:01","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=253291"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=253291","title":{"rendered":"RabbitMQ tutorials \u043d\u0430 C++"},"content":{"rendered":"

\t\t\t\u041d\u0430 \u0441\u0430\u0439\u0442\u0435 rabbitmq.com<\/a> \u0432 \u0440\u0430\u0437\u0434\u0435\u043b\u0435 tutorials<\/a> \u043f\u0440\u0438\u0432\u0435\u0434\u0435\u043d\u044b \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u043d\u0430 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u0445 \u044f\u0437\u044b\u043a\u0430\u0445, \u043d\u043e \u0441\u0440\u0435\u0434\u0438 \u043d\u0438\u0445 \u043d\u0435\u0442 C++. \u041f\u043e\u0434 \u043a\u0430\u0442\u043e\u043c \u0441\u043e\u0431\u0440\u0430\u043d\u044b \u0441\u0441\u044b\u043b\u043a\u0438 \u043d\u0430 \u043f\u0435\u0440\u0435\u0432\u0435\u0434\u0435\u043d\u043d\u044b\u0435 \u0440\u0443\u043a\u043e\u0432\u043e\u0434\u0441\u0442\u0432\u0430, \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u044b \u0438 \u043a\u043e\u0434 \u043f\u043e\u0434 \u0441\u043f\u043e\u0439\u043b\u0435\u0440\u043e\u043c.
<\/a>
\u041a\u043e\u043c\u0443 \u0443\u0434\u043e\u0431\u043d\u0435\u0435 \u043f\u0440\u043e\u0441\u043c\u0430\u0442\u0440\u0438\u0432\u0430\u0442\u044c \u043a\u043e\u0434 \u0438\u0437 \u043f\u043e\u0434 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u0430 GitHub, \u043c\u043e\u0436\u043d\u043e \u0441\u0440\u0430\u0437\u0443 \u043f\u0435\u0440\u0435\u0439\u0442\u0438 \u0432 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439<\/a>.<\/p>\n

\u0414\u0430\u043d\u043d\u044b\u0439 \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044e \u043a\u043b\u0438\u0435\u043d\u0442\u0430 AMQP-CPP<\/a> \u0438 POCO C++<\/a> \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u0441\u043e\u043a\u0435\u0442\u043e\u043c.<\/p>\n

\u00abRabbitMQ tutorial 1 \u2014 Hello World\u00bb<\/a><\/p>\n

receive.cpp<\/b><\/p>\n
\n
#include <iostream> #include "SimplePocoHandler.h"  int main(void) {     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareQueue("hello");     channel.consume("hello", AMQP::noack).onReceived(             [](const AMQP::Message &message,                        uint64_t deliveryTag,                        bool redelivered)             {                  std::cout <<" [x] Received "<<message.message() << std::endl;             });      std::cout << " [*] Waiting for messages. To exit press CTRL-C\\n";     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
send.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h"  int main(void) {     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");     AMQP::Channel channel(&connection);      channel.onReady([&]()     {         if(handler.connected())         {             channel.publish("", "hello", "Hello World!");             std::cout << " [x] Sent 'Hello World!'" << std::endl;             handler.quit();         }     });      handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  \u00abRabbitMQ tutorial 2 \u2014 \u041e\u0447\u0435\u0440\u0435\u0434\u044c \u0437\u0430\u0434\u0430\u0447\u00bb<\/a><\/p>\n
worker.cpp<\/b><\/p>\n
\n
#include <iostream> #include <algorithm> #include <thread> #include <chrono>  #include "SimplePocoHandler.h"  int main(void) {     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareQueue("task_queue", AMQP::durable);     channel.consume("task_queue", AMQP::noack).onReceived(             [&channel](const AMQP::Message &message,                        uint64_t deliveryTag,                        bool redelivered)             {                 const auto body = message.message();                 std::cout<<" [x] Received "<<body<<std::endl;                  size_t count = 0;                 std::for_each(body.cbegin(), body.cend(), [&](const char& ch)                         {                             if(ch =='.')                             {                                 ++count;                             }                         });                 std::this_thread::sleep_for (std::chrono::seconds(count));                  std::cout<<" [x] Done"<<std::endl;                 channel.ack(deliveryTag);             });      channel.setQos(1);     std::cout << " [*] Waiting for messages. To exit press CTRL-C\\n";     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
new_task.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h" #include "tools.h"  int main(int argc, const char* argv[]) {     const std::string msg =             argc > 1 ? join(&argv[1], &argv[argc], " ") : "Hello World!";      SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");     AMQP::Channel channel(&connection);      auto callback =             [&](const std::string &name, int msgcount, int consumercount)             {                 channel.publish("", "task_queue", msg);                 std::cout<<" [x] Sent '"<<msg<<"'\\n";                 handler.quit();             };      channel.declareQueue("task_queue", AMQP::durable).onSuccess(callback);     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  \u00abRabbitMQ tutorial 3 \u2014 \u041f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u044f\/\u041f\u043e\u0434\u043f\u0438\u0441\u043a\u0430\u00bb<\/a><\/p>\n
receive_logs.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h"  int main(void) {     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     auto receiveMessageCallback = [](const AMQP::Message &message,             uint64_t deliveryTag,             bool redelivered)     {          std::cout <<" [x] "<<message.message() << std::endl;     };      auto callback =             [&](const std::string &name, int msgcount, int consumercount)             {                 channel.bindQueue("logs", name,"");                 channel.consume(name, AMQP::noack).onReceived(receiveMessageCallback);             };      channel.declareExchange("logs", AMQP::fanout).onSuccess([&]()     {         channel.declareQueue(AMQP::exclusive).onSuccess(callback);      });      std::cout << " [*] Waiting for messages. To exit press CTRL-C\\n";     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
emit_log.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h" #include "tools.h"  int main(int argc, const char* argv[]) {     const std::string msg =             argc > 1 ? join(&argv[1], &argv[argc], " ") : "info: Hello World!";      SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareExchange("logs", AMQP::fanout).onSuccess([&]()     {         channel.publish("logs", "", msg);         std::cout << " [x] Sent "<<msg<< std::endl;         handler.quit();     });      handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  \u00abRabbitMQ tutorial 4 \u2014 \u0420\u043e\u0443\u0442\u0438\u043d\u0433\u00bb<\/a><\/p>\n
receive_logs_direct.cpp<\/b><\/p>\n
\n
#include <iostream> #include <algorithm>  #include "SimplePocoHandler.h"  int main(int argc, const char* argv[]) {     if(argc==1)     {         std::cout<<"Usage: "<<argv[0]<<" [info] [warning] [error]"<<std::endl;         return 1;     }     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);      channel.declareExchange("direct_logs", AMQP::direct);      auto receiveMessageCallback =             [](const AMQP::Message &message,                uint64_t deliveryTag,                bool redelivered)             {                 std::cout <<" [x] "                           <<message.routingKey()                           <<":"                           <<message.message()                           << std::endl;             };      auto callback = [&](const std::string &name,             int msgcount,             int consumercount)     {         std::for_each(&argv[1],                 &argv[argc],                 [&](const char* severity)                 {                     channel.bindQueue("direct_logs","", severity);                     channel.consume(name, AMQP::noack).onReceived(receiveMessageCallback);                 });      };     channel.declareQueue(AMQP::exclusive).onSuccess(callback);      std::cout << " [*] Waiting for messages. To exit press CTRL-C\\n";     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
emit_log_direct.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h" #include "tools.h"  int main(int argc, const char* argv[]) {     const std::string severity = argc > 2 ? argv[1] : "info";     const std::string msg =             argc > 2 ? join(&argv[2], &argv[argc], " ") : "Hello World!";      SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareExchange("direct_logs", AMQP::direct).onSuccess([&]()     {         channel.publish("direct_logs", severity, msg);         std::cout << " [x] Sent "<<severity<<":"<<msg<< std::endl;         handler.quit();     });      handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  \u00abRabbitMQ tutorial 5 \u2014 \u0422\u0435\u043c\u0430\u0442\u0438\u043a\u0438\u00bb<\/a><\/p>\n
receive_logs_topic.cpp<\/b><\/p>\n
\n
#include <iostream> #include <algorithm>  #include "SimplePocoHandler.h"  int main(int argc, const char* argv[]) {     if(argc==1)     {         std::cout<<"Usage: "<<argv[0]<<" [binding_key]..."<<std::endl;         return 1;     }     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);      channel.declareExchange("topic_logs", AMQP::topic);      auto receiveMessageCallback =             [](const AMQP::Message &message,                uint64_t deliveryTag,                bool redelivered)             {                 std::cout <<" [x] "                           <<message.routingKey()                           <<":"                           <<message.message()                           << std::endl;             };      auto callback = [&](const std::string &name,             int msgcount,             int consumercount)     {         std::for_each(&argv[1],                 &argv[argc],                 [&](const char* bindingKeys)                 {                     std::cout<<bindingKeys<<std::endl;                     channel.bindQueue("topic_logs",name, bindingKeys);                     channel.consume(name, AMQP::noack).onReceived(receiveMessageCallback);                 });      };     channel.declareQueue(AMQP::exclusive).onSuccess(callback);      std::cout << " [*] Waiting for messages. To exit press CTRL-C\\n";     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
emit_log_topic.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "SimplePocoHandler.h" #include "tools.h"  int main(int argc, const char* argv[]) {     const std::string msg =             argc > 1 ? join(&argv[2], &argv[argc], " ") : "Hello World!";     const std::string routing_key = argc > 1 ? argv[1] : "anonymous.info";      SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareExchange("topic_logs", AMQP::topic).onSuccess([&]()     {         channel.publish("topic_logs", routing_key, msg);         std::cout << " [x] Sent "<<routing_key<<":"<<msg<< std::endl;         handler.quit();     });      handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  \u00abRabbitMQ tutorial 6 \u2014 \u0423\u0434\u0430\u043b\u0435\u043d\u043d\u044b\u0439 \u0432\u044b\u0437\u043e\u0432 \u043f\u0440\u043e\u0446\u0435\u0434\u0443\u0440\u00bb<\/a><\/p>\n
rpc_server.cpp<\/b><\/p>\n
\n
#include <iostream> #include <algorithm> #include <thread> #include <chrono>  #include "SimplePocoHandler.h"  int fib(int n) {     switch (n)     {     case 0:         return 0;     case 1:         return 1;     default:         return fib(n - 1) + fib(n - 2);     } }  int main(void) {     SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     channel.declareQueue("rpc_queue");     channel.consume("").onReceived([&channel](const AMQP::Message &message,             uint64_t deliveryTag,             bool redelivered)     {         const auto body = message.message();         std::cout<<" [.] fib("<<body<<")"<<std::endl;          AMQP::Envelope env(std::to_string(fib(std::stoi(body))));         env.setCorrelationID(message.correlationID());          channel.publish("", message.replyTo(), env);         channel.ack(deliveryTag);     });      channel.setQos(1);     std::cout << " [x] Awaiting RPC requests" << std::endl;     handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
  <\/p>\n
rpc_client.cpp<\/b><\/p>\n
\n
#include <iostream>  #include "tools.h" #include "SimplePocoHandler.h"  int main(int argc, const char* argv[]) {     const std::string correlation(uuid());      SimplePocoHandler handler("localhost", 5672);      AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "\/");      AMQP::Channel channel(&connection);     auto callback = [&](const std::string &name,             int msgcount,             int consumercount)     {         AMQP::Envelope env("30");         env.setCorrelationID(correlation);         env.setReplyTo(name);         channel.publish("","rpc_queue",env);         std::cout<<" [x] Requesting fib(30)"<<std::endl;      };     channel.declareQueue(AMQP::exclusive).onSuccess(callback);      auto receiveCallback = [&](const AMQP::Message &message,             uint64_t deliveryTag,             bool redelivered)     {         if(message.correlationID() != correlation)             return;          std::cout<<" [.] Got "<<message.message()<<std::endl;         handler.quit();     };      channel.consume("", AMQP::noack).onReceived(receiveCallback);      handler.loop();     return 0; } <\/code><\/pre>\n
  <\/div>\n<\/div>\n
<\/div>\n
 \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438  http:\/\/habrahabr.ru\/post\/253317\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
 \t\t\t\u041d\u0430 \u0441\u0430\u0439\u0442\u0435 rabbitmq.com<\/a> \u0432 \u0440\u0430\u0437\u0434\u0435\u043b\u0435 tutorials<\/a> \u043f\u0440\u0438\u0432\u0435\u0434\u0435\u043d\u044b \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u043d\u0430 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u0445 \u044f\u0437\u044b\u043a\u0430\u0445, \u043d\u043e \u0441\u0440\u0435\u0434\u0438 \u043d\u0438\u0445 \u043d\u0435\u0442 C++. \u041f\u043e\u0434 \u043a\u0430\u0442\u043e\u043c \u0441\u043e\u0431\u0440\u0430\u043d\u044b \u0441\u0441\u044b\u043b\u043a\u0438 \u043d\u0430 \u043f\u0435\u0440\u0435\u0432\u0435\u0434\u0435\u043d\u043d\u044b\u0435 \u0440\u0443\u043a\u043e\u0432\u043e\u0434\u0441\u0442\u0432\u0430, \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u044b \u0438 \u043a\u043e\u0434 \u043f\u043e\u0434 \u0441\u043f\u043e\u0439\u043b\u0435\u0440\u043e\u043c.  <\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-253291","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/253291","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=253291"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/253291\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=253291"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=253291"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=253291"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}