4장. 예
이 장에서는 예제 프로그램을 통해 AMQ C++ 사용을 보여줍니다.
자세한 내용은 AMQ C++ 예제 및 Cryostat Proton C++ 예제 를 참조하십시오.
참고
이 가이드에 제공된 코드는 C++11 기능을 사용합니다. AMQ C++는 C++03과도 호환되지만 코드는 약간의 수정이 필요합니다.
4.1. 메시지 전송
이 클라이언트 프로그램은 < connection-url >을 사용하여 서버에 연결하고, 대상 < address >에 대한 보낸 사람을 생성하고, < message-body >를 포함하는 메시지를 전송하고, 연결을 종료하고 종료합니다.
예: 메시지 전송
#include <proton/connection.hpp>
#include <proton/container.hpp>
#include <proton/message.hpp>
#include <proton/messaging_handler.hpp>
#include <proton/sender.hpp>
#include <proton/target.hpp>
#include <iostream>
#include <string>
struct send_handler : public proton::messaging_handler {
std::string conn_url_ {};
std::string address_ {};
std::string message_body_ {};
void on_container_start(proton::container& cont) override {
cont.connect(conn_url_);
// To connect with a user and password:
//
// proton::connection_options opts {};
// opts.user("<user>");
// opts.password("<password>");
//
// cont.connect(conn_url_, opts);
}
void on_connection_open(proton::connection& conn) override {
conn.open_sender(address_);
}
void on_sender_open(proton::sender& snd) override {
std::cout << "SEND: Opened sender for target address '"
<< snd.target().address() << "'\n";
}
void on_sendable(proton::sender& snd) override {
proton::message msg {message_body_};
snd.send(msg);
std::cout << "SEND: Sent message '" << msg.body() << "'\n";
snd.close();
snd.connection().close();
}
};
int main(int argc, char** argv) {
if (argc != 4) {
std::cerr << "Usage: send <connection-url> <address> <message-body>\n";
return 1;
}
send_handler handler {};
handler.conn_url_ = argv[1];
handler.address_ = argv[2];
handler.message_body_ = argv[3];
proton::container cont {handler};
try {
cont.run();
} catch (const std::exception& e) {
std::cerr << e.what() << "\n";
return 1;
}
return 0;
}
예제 실행
예제 프로그램을 실행하려면 로컬 파일에 복사하여 명령줄에서 컴파일한 후 실행합니다. 자세한 내용은 3장. 시작하기의 내용을 참조하십시오.
$ g++ send.cpp -o send -std=c++11 -lstdc++ -lqpid-proton-cpp $ ./send amqp://localhost queue1 hello
