Boost.Asio c++ 网络编程翻译（30）［完结］

//  对于Windows
   HANDLE h = CreateFile("err.txt", GENERIC_WRITE, 0, 0, CREATE_ALWAYS,
   FILE_ATTRIBUTE_NORMAL , 0);
   SetStdHandle(STD_ERROR_HANDLE, h);
   // 对于Unix
   int err_file = open("err.txt", O_WRONLY);
   dup2(err_file, STDERR_FILENO);

0. #include <boost/asio.hpp>
      #include <boost/asio/ssl.hpp>
      using namespace boost::asio;
      io_service service;
   

      int main(int argc, char* argv[]) {

   typedef ssl::stream<ip::tcp::socket> ssl_socket;
   

   ssl::context ctx(ssl::context::sslv23);
   ctx.set_default_verify_paths();
   

   // 打开一个到指定主机的SSL socket
   

   io_service service;
   ssl_socket sock(service, ctx);

   ip::tcp::resolver resolver(service);
   std::string host = "www.yahoo.com";
   ip::tcp::resolver::query query(host, "https");
   connect(sock.lowest_layer(), resolver.resolve(query));
   // SSL 握手
   sock.set_verify_mode(ssl::verify_none);
   sock.set_verify_callback(ssl::rfc2818_verification(host));
   sock.handshake(ssl_socket::client);
   

          std::string req = "GET /index.html HTTP/1.0\r\nHost: "
              + host + "\r\nAccept: */*\r\nConnection: close\r\n\r\n";
   

          write(sock, buffer(req.c_str(), req.length()));
          char buff[512];
          boost::system::error_code ec;
          while ( !ec) {
   

              int bytes = read(sock, buffer(buff), ec);
   

              std::cout << std::string(buff, bytes);
          }
   

   } 

HANDLE file = ::CreateFile("readme.txt", GENERIC_READ, 0, 0,
       OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, 0);

   windows::stream_handle h(service, file);
   streambuf buf;
   int bytes = read_until(h, buf, ‘\n‘);
   std::istream in(&buf);

   std::string line;
   std::getline(in, line);
   std::cout << line << std::endl;

HANDLE file = ::CreateFile("readme.txt", GENERIC_READ, 0, 0,
       OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, 0);

   windows::random_access_handle h(service, file);
   char buf[50];
   int bytes = read_at(h, 1000, buffer( buf));
   std::string msg(buf, bytes);

   std::cout << msg << std::endl;

void on_wait_complete(boost::system::error_code err) {}
   ...
   HANDLE evt = ::CreateEvent(0, true, true, 0);
   windows::object_handle h(service, evt);

   // 同步等待
   h.wait();
   // 异步等待
   h.async_wait(on_wait_complete);

local::stream_protocol::endpoint ep("/tmp/my_cool_app");
   local::stream_protocol::socket sock(service);
   sock.connect(ep);

::unlink("/tmp/my_cool_app");
   local::stream_protocol::endpoint ep("/tmp/my_cool_app");
   local::stream_protocol::acceptor acceptor(service, ep);
   local::stream_protocol::socket sock(service);
   acceptor.accept(sock);

// 基于连接
   local::stream_protocol::socket s1(service);
   local::stream_protocol::socket s2(service);
   local::connect_pair(s1, s2);
   // 数据报
   local::datagram_protocol::socket s1(service);
   local::datagram_protocol::socket s2(service);
   local::connect_pair(s1, s2);

size_t read_up_to_enter(error_code err, size_t bytes) { ... }
   posix::stream_descriptor in(service, ::dup(STDIN_FILENO));
   posix::stream_descriptor out(service, ::dup(STDOUT_FILENO));
   char buff[512];

   int bytes = read(in, buffer(buff), read_up_to_enter);
   write(out, buffer(buff, bytes));

service.notify_fork(io_service::fork_prepare);
   if (fork() == 0) {

       // 孩子
       service.notify_fork(io_service::fork_child);
       ...

   } else {
       // 父亲

       service.notify_fork(io_service::fork_parent);

... }