Daytime.1 - A synchronous TCP daytime client

다음 내용에 기반함

http://www.boost.org/doc/libs/1_57_0/doc/html/boost_asio/tutorial/tutdaytime1.html

Introduction to Sockets

The tutorial programs in this section show how to use asio to develop simple client and server programs. These tutorial programs are based around the daytimeprotocol, which supports both TCP and UDP.

The first three tutorial programs implement the daytime protocol using TCP.

이번 튜토리얼에서는 TCP 클라이언트를 만드는데 어떻게 이용 할 수 있을지 소개한다.

먼저 필요한 헤더파일들을 include 하는 것으로 시작한다.

#include <iostream>
#include <boost/array.hpp>
#include <boost/asio.hpp>

이 응용프로그램은 daytime 서비스에 접근하는것이며, 따라서 유저가 서버를 특정할 필요가 있다.

using boost::asio::ip::tcp;

int main(int argc, char* argv[])
{
  try
  {
    if (argc != 2)
    {
      std::cerr << "Usage: client <host>" << std::endl;
      return 1;
    }

asio 를 이용하는 모든 프로그램들은 적어도 하나이상의 io_service 객체를 필요로한다. 

    boost::asio::io_service io_service;

파라미터에 지정된 서버 이름을 TCP endpoint 로 변환할 필요가 있는데, 이는 ip::tcp::resolver 객체를 통한다.

  tcp::resolver resolver(io_service);

resolver 는 쿼리 객체를 받아 이를 endpoint 의 리스트로 변환한다. 쿼리이름을 서버이름을 이용하여 생성할 것이며, 이 서비스의 이름은 "daytime" 이다.

리스트는  ip::tcp::resolver::iterator 타입으로 리턴된다. (ip::tcp::resolver::iterator 의 기본 생성자를 통해 생성된 객체는 end iterator 로 사용 될 수 있다)

   tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);

이제 소켓을 생성하고 연결할 차례다. 

얻어진 리스트는 IPv4 와 IPv6 를 모두 포함할 수도 있으므로 동작하는 것을 찾기 위해 각각의 주소들에 대해 시도해야한다. 

이런 사용이, 클라이언트 프로그램이 특정 IP 주소체계와 독립적으로 프로그램을 구성할 수 있게 해준다. 

boost::asio::connect() 함수는 자동적으로 이를 수행해준다.

    tcp::socket socket(io_service);
    boost::asio::connect(socket, endpoint_iterator);

이제 연결이 수립되었다. daytime 서비스의 응답만을 기다리면 된다.

boost::array 를 전달받은 데이터를 저장하는데 사용하도록 하자. boost::asio::buffer() 함수는 자동적으로 배열의 사이즈를 결정해주어 버퍼 오버런이 발생하지 않게 도와준다. boost::array 대신에, char[] 나 std::vector 도 사용할 수 있다.

 for (;;)
    {
      boost::array<char, 128> buf;
      boost::system::error_code error;

      size_t len = socket.read_some(boost::asio::buffer(buf), error);

서버가 연결을 종료했을때, ip::tcp::socket::read_some 함수는 boost::asio::error::eof 에러와 함께 종료될 것이며, 이때 루프를 빠져나가면 된다.

if (error == boost::asio::error::eof)
        break; // Connection closed cleanly by peer.
      else if (error)
        throw boost::system::system_error(error); // Some other error.

      std::cout.write(buf.data(), len);
    }

마지막으로, thrown 된 예외를 처리하면 된다. 

full source code

#include <iostream> #include "boost/asio.hpp" #include "boost/array.hpp" namespace nolleh { namespace intro_socket { using boost::asio::ip::tcp; void client_run(std::string name){ try { boost::asio::io_service io_service; tcp::resolver resolver(io_service); tcp::resolver::iterator endpoint_iterator = resolver.resolve( boost::asio::ip::tcp::resolver::query("127.0.0.1", name)); tcp::socket socket(io_service); boost::asio::connect(socket, endpoint_iterator); io_service.run(); for (;;) { boost::array<char, 128> buf; boost::system::error_code error; size_t len = socket.read_some(boost::asio::buffer(buf), error); if (error == boost::asio::error::eof) break; else if (error) throw boost::system::system_error(error); // Some other error. std::cout.write(buf.data(), len); } } catch (const std::exception& e) { std::cerr << e.what() << std::endl; } } } }

main 

#include "006.TCPClient.hpp" int main() { nolleh::intro_socket::client_run("daytime"); return 0; }

실행결과