青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

posts - 6,  comments - 61,  trackbacks - 0

Daytime.1 - A synchronous TCP daytime client

一個同步的TCP daytime客戶端 

 

This tutorial program shows how to use asio to implement a client application with TCP.

We start by including the necessary header files.

 本示例程序顯示如何使用Asio來實現一個TCP客戶端程序。

讓我們從添加必需的頭文件開始。


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

The purpose of this application is to access a daytime service, so we need the user to specify the server.

這個應用程序的目的是訪問一個daytime服務器,因此我們需要用戶去指定服務器。(如time-nw.nist.gov,用IP亦可)


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

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

All programs that use asio need to have at least one boost::asio::io_service object.

所有使用asio的程序都至少需要一個boost::asio::io_service對象


    boost::asio::io_service io_service;

We need to turn the server name that was specified as a parameter to the application, into a TCP endpoint. To do this we use an boost::asio::ip::tcp::resolver object.

 我們需要把服務器的名稱轉化為TCP的節點,而該名稱是通過應用程序的參數指定的。我們使用boost::asio::ip::tcp::resolver 對象來完成。


    tcp::resolver resolver(io_service);

A resolver takes a query object and turns it into a list of endpoints. We construct a query using the name of the server, specified in argv[1], and the name of the service, in this case "daytime".

一個resolver對象獲得一個query對象,并將其轉換為節點列表.我們通過argv[1]中的服務器名稱服務名,在這里是daytime,構造一個query  

 


   tcp::resolver::query query(argv[1], "daytime");

The list of endpoints is returned using an iterator of type boost::asio::ip::tcp::resolver::iterator. A default constructed boost::asio::ip::tcp::resolver::iterator object is used as the end iterator.

節點列表用 boost::asio::ip::tcp::resolver::iterator 類型的迭代器返回。返回的iterator將采用boost::asio::ip::tcp::resolver::iterator的默認構造函數來構造。


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

Now we create and connect the socket. The list of endpoints obtained above may contain both IPv4 and IPv6 endpoints, so we need to try each of them until we find one that works. This keeps the client program independent of a specific IP version.

現在我們建立一個socket并連接之,由于獲得的節點既有IPv4也有IPv6的。所以,我們需要依次嘗試訪問它們直到找到一個可以正常工作的。這樣做可使得我們的程序獨立于特定的IP版本。


    tcp::socket socket(io_service);
    boost::system::error_code error 
= boost::asio::error::host_not_found;
    
while (error && endpoint_iterator != end)
    {
      socket.close();
      socket.connect(
*endpoint_iterator++, error);
    }
    
if (error)
      
throw boost::system::system_error(error);

The connection is open. All we need to do now is read the response from the daytime service.

We use a boost::array to hold the received data. The boost::asio::buffer() function automatically determines the size of the array to help prevent buffer overruns. Instead of a boost::array, we could have used a char [] or std::vector.

連接打開后,現在我們需要做的就是讀取daytime服務器的響應。

我們使用boost::array 來存放接收到的數據。boost::asio::buffer()函數會自動確定array的長度來防止緩沖區溢出。我們也可以使用 char [] 或 std::vector來代替boost::array。


    for (;;)
    {
      boost::array
<char128> buf;
      boost::system::error_code error;

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

When the server closes the connection, the boost::asio::ip::tcp::socket::read_some() function will exit with the boost::asio::error::eof error, which is how we know to exit the loop.

當服務器關閉連接時,boost::asio::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);
    }

Finally, handle any exceptions that may have been thrown.

最后,處理所有可能拋出的異常


  }
  
catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

See the full source listing

完整代碼:

//
// client.cpp
// ~~~~~~~~~~
//
// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

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

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

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

    boost::asio::io_service io_service;

    tcp::resolver resolver(io_service);
    tcp::resolver::query query(argv[
1], "daytime");
    tcp::resolver::iterator endpoint_iterator 
= resolver.resolve(query);
    tcp::resolver::iterator end;

    tcp::socket socket(io_service);
    boost::system::error_code error 
= boost::asio::error::host_not_found;
    
while (error && endpoint_iterator != end)
    {
      socket.close();
      socket.connect(
*endpoint_iterator++, error);
    }
    
if (error)
      
throw boost::system::system_error(error);

    
for (;;)
    {
      boost::array
<char128> buf;
      boost::system::error_code error;

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

      
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);
    }
  }
  
catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

  
return 0;
}

Daytime.2 - A synchronous TCP daytime server

一個同步的TCP daytime服務器

This tutorial program shows how to use asio to implement a server application with TCP.

 本示例示范如何使用Asio來實現一個TCP服務器程序。


#include <ctime>
#include 
<iostream>
#include 
<string>
#include 
<boost/asio.hpp>

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

We define the function make_daytime_string() to create the string to be sent back to the client. This function will be reused in all of our daytime server applications.

我們先定義一個make_daytime_string()來產生需要發送給客戶端的字符串.這個函數會在我們所有的daytime服務器上被使用。


std::string make_daytime_string()
{
  
using namespace std; // For time_t, time and ctime;
  time_t now = time(0);
  
return ctime(&now);
}

int main()
{
  
try
  {
    boost::asio::io_service io_service;

A boost::asio::ip::tcp::acceptor object needs to be created to listen for new connections. It is initialised to listen on TCP port 13, for IP version 4.

新建一個asio::ip::tcp::acceptor對象來監聽新的連接。該對象應遵守IPv4協議,監聽TCP端口13

   

 

tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 13));

 

This is an iterative server, which means that it will handle one connection at a time. Create a socket that will represent the connection to the client, and then wait for a connection.

這是一個iterative server,也就是說同一時間只能處理一個連接。建立一個表示與客戶端的連接的socket, 然后等待客戶端的連接。


    for (;;)
    {
      tcp::socket socket(io_service);
      acceptor.accept(socket);

A client is accessing our service. Determine the current time and transfer this information to the client.

當客戶端訪問服務器時,獲取當前時間,并傳送給客戶端。

      std::string message = make_daytime_string();

      boost::system::error_code ignored_error;
      boost::asio::write(socket, boost::asio::buffer(message),
          boost::asio::transfer_all(), ignored_error);
    }
  }

Finally, handle any exceptions.

最后,

處理異常。


  catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

  
return 0;
}

See the full source listing

全部源碼:

//
// server.cpp
// ~~~~~~~~~~
//
// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

#include 
<ctime>
#include 
<iostream>
#include 
<string>
#include 
<boost/asio.hpp>

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

std::
string make_daytime_string()
{
  
using namespace std; // For time_t, time and ctime;
  time_t now = time(0);
  
return ctime(&now);
}

int main()
{
  
try
  {
    boost::asio::io_service io_service;

    tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 
13));

    
for (;;)
    {
      tcp::socket socket(io_service);
      acceptor.accept(socket);

      std::
string message = make_daytime_string();

      boost::system::error_code ignored_error;
      boost::asio::write(socket, boost::asio::buffer(message),
          boost::asio::transfer_all(), ignored_error);
    }
  }
  
catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

  
return 0;
}

The main() function

主函數


int main()
{
  
try
  {

We need to create a server object to accept incoming client connections. The boost::asio::io_service object provides I/O services, such as sockets, that the server object will use.

我們需要創建一個服務器對象,用來接受客戶端的連接。boost::asio::io_service對象提供了像sockets這樣的I/O服務,這些服務都是服務器對象將要使用的。


    boost::asio::io_service io_service;
    tcp_server server(io_service);

Run the boost::asio::io_service object so that it will perform asynchronous operations on your behalf.

運行boost::asio::io_service 對象,它將執行你想要的異步操作。


    io_service.run();
  }
  
catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

  
return 0;
}
The tcp_server class

TCP服務器類


class tcp_server
{
public:

The constructor initialises an acceptor to listen on TCP port 13.

構造函數初始化一個用于監聽TCP 端口13的接收器。


  tcp_server(boost::asio::io_service& io_service)
    : acceptor_(io_service, tcp::endpoint(tcp::v4(), 
13))
  {
    start_accept();
  }

private:

The function start_accept() creates a socket and initiates an asynchronous accept operation to wait for a new connection.

函數start_accept()創建一個socket ,同時啟動一個異步接收操作去等待一個新的連接。


  void start_accept()
  {
    tcp_connection::pointer new_connection 
=
      tcp_connection::create(acceptor_.io_service());

    acceptor_.async_accept(new_connection
->socket(),
        boost::bind(
&tcp_server::handle_accept, this, new_connection,
          boost::asio::placeholders::error));
  }

The function handle_accept() is called when the asynchronous accept operation initiated by start_accept() finishes. It services the client request, and then calls start_accept() to initiate the next accept operation.

start_accept()啟動的異步接收操作完成后,handle_accept()函數將被調用。它響應客戶端的請求,然后調用start_accept()函數去啟動另一個接收操作。


  void handle_accept(tcp_connection::pointer new_connection,
      
const boost::system::error_code& error)
  {
    
if (!error)
    {
      new_connection
->start();
      start_accept();
    }
  }
The tcp_connection class

TCP連接類

We will use shared_ptr and enable_shared_from_this because we want to keep the tcp_connection object alive as long as there is an operation that refers to it.

我們希望只要還有一個操作涉及tcp_connection對象,該對象就是有效的。因此我們使用shared_ptrenable_shared_from_this


class tcp_connection
  : 
public boost::enable_shared_from_this<tcp_connection>
{
public:
  typedef boost::shared_ptr
<tcp_connection> pointer;

  
static pointer create(boost::asio::io_service& io_service)
  {
    
return pointer(new tcp_connection(io_service));
  }

  tcp::socket
& socket()
  {
    
return socket_;
  }

In the function start(), we call boost::asio::async_write() to serve the data to the client. Note that we are using boost::asio::async_write(), rather than boost::asio::ip::tcp::socket::async_write_some(), to ensure that the entire block of data is sent.

start()函數中,我們調用boost::asio::async_write()為客戶端處理數據。注意:為了確保數據被整塊發送,我們使用的是boost::asio::async_write(),而不是boost::asio::ip::tcp::socket::async_write_some()。


  void start()
  {

The data to be sent is stored in the class member message_ as we need to keep the data valid until the asynchronous operation is complete.

要發送的數據保存在類成員變量message_ 中,在異步操作完成前我們需要保證數據的有效性。

 

 

    message_ = make_daytime_string();

 

When initiating the asynchronous operation, and if using boost::bind(), you must specify only the arguments that match the handler's parameter list. In this program, both of the argument placeholders (boost::asio::placeholders::error and boost::asio::placeholders::bytes_transferred) could potentially have been removed, since they are not being used in handle_write().

當啟動一個異步操作時,如果使用boost::bind(),你只需要指定一個符合句柄參數列表簽名的參數。在本例中,任何一個參數占位符(boost::asio::placeholders::error 和boost::asio::placeholders::bytes_transferred)皆可被隱式地移除,因為操作write()并沒有使用它們。


    boost::asio::async_write(socket_, boost::asio::buffer(message_),
        boost::bind(
&tcp_connection::handle_write, shared_from_this(),
          boost::asio::placeholders::error,
          boost::asio::placeholders::bytes_transferred));

Any further actions for this client connection are now the responsibility of handle_write().

任何對客戶端連接的下一步操作都由handle_write()函數負責處理

 


  }

private:
  tcp_connection(boost::asio::io_service
& io_service)
    : socket_(io_service)
  {
  }

  
void handle_write(const boost::system::error_code& /*error*/,
      size_t 
/*bytes_transferred*/)
  {
  }

  tcp::socket socket_;
  std::
string message_;
};
Removing unused handler parameters

移除無用的操作參數

You may have noticed that the error, and bytes_transferred parameters are not used in the body of the handle_write() function. If parameters are not needed, it is possible to remove them from the function so that it looks like:

你可能已經注意到了:error和bytes_transferred 參數并沒有在 handle_write() 函數體內被應用。因此,如果參數并不是必須的,我們可以移除它們,如下所示:


  void handle_write()
  {
  }

The boost::asio::async_write() call used to initiate the call can then be changed to just:

用來發起呼叫的boost::asio::async_write()函數通常可以被改寫成下面這樣:


  boost::asio::async_write(socket_, boost::asio::buffer(message_),
      boost::bind(
&tcp_connection::handle_write, shared_from_this()));

See the full source listing

全部源碼:

//
// server.cpp
// ~~~~~~~~~~
//
// Copyright (c) 2003-2008 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

#include 
<ctime>
#include 
<iostream>
#include 
<string>
#include 
<boost/bind.hpp>
#include 
<boost/shared_ptr.hpp>
#include 
<boost/enable_shared_from_this.hpp>
#include 
<boost/asio.hpp>

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

std::
string make_daytime_string()
{
  
using namespace std; // For time_t, time and ctime;
  time_t now = time(0);
  
return ctime(&now);
}

class tcp_connection
  : 
public boost::enable_shared_from_this<tcp_connection>
{
public:
  typedef boost::shared_ptr
<tcp_connection> pointer;

  
static pointer create(boost::asio::io_service& io_service)
  {
    
return pointer(new tcp_connection(io_service));
  }

  tcp::socket
& socket()
  {
    
return socket_;
  }

  
void start()
  {
    message_ 
= make_daytime_string();

    boost::asio::async_write(socket_, boost::asio::buffer(message_),
        boost::bind(
&tcp_connection::handle_write, shared_from_this(),
          boost::asio::placeholders::error,
          boost::asio::placeholders::bytes_transferred));
  }

private:
  tcp_connection(boost::asio::io_service
& io_service)
    : socket_(io_service)
  {
  }

  
void handle_write(const boost::system::error_code& /*error*/,
      size_t 
/*bytes_transferred*/)
  {
  }

  tcp::socket socket_;
  std::
string message_;
};

class tcp_server
{
public:
  tcp_server(boost::asio::io_service
& io_service)
    : acceptor_(io_service, tcp::endpoint(tcp::v4(), 
13))
  {
    start_accept();
  }

private:
  
void start_accept()
  {
    tcp_connection::pointer new_connection 
=
      tcp_connection::create(acceptor_.io_service());

    acceptor_.async_accept(new_connection
->socket(),
        boost::bind(
&tcp_server::handle_accept, this, new_connection,
          boost::asio::placeholders::error));
  }

  
void handle_accept(tcp_connection::pointer new_connection,
      
const boost::system::error_code& error)
  {
    
if (!error)
    {
      new_connection
->start();
      start_accept();
    }
  }

  tcp::acceptor acceptor_;
};

int main()
{
  
try
  {
    boost::asio::io_service io_service;
    tcp_server server(io_service);
    io_service.run();
  }
  
catch (std::exception& e)
  {
    std::cerr 
<< e.what() << std::endl;
  }

  
return 0;
}

 

 

posted on 2008-04-20 01:27 王曉軒 閱讀(4256) 評論(7)  編輯 收藏 引用 所屬分類: C\C++
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            午夜精品视频一区| 欧美激情一区二区三区高清视频| 亚洲激情在线观看| 午夜在线观看免费一区| 中文在线不卡| 欧美激情按摩在线| 欧美本精品男人aⅴ天堂| 国产精品中文在线| 一区二区三区 在线观看视| 亚洲人成毛片在线播放| 久久久精品国产免费观看同学| 亚洲欧美另类在线| 欧美亚洲第一页| 亚洲精品视频在线看| 亚洲国产精品视频一区| 久久国内精品视频| 久久全国免费视频| 国产亚洲精品aa| 欧美与黑人午夜性猛交久久久| 欧美一区二区三区免费视| 国产精品美女久久福利网站| 亚洲图色在线| 亚洲性av在线| 国产精品久久看| 一本一道久久综合狠狠老精东影业 | 亚洲欧美日韩久久精品| 国产精品国产三级国产普通话三级 | 久久夜色精品国产| 极品尤物av久久免费看| 久久精品99| 免费人成精品欧美精品| 极品尤物av久久免费看| 美乳少妇欧美精品| 亚洲欧洲日韩女同| 亚洲视频免费在线观看| 国产精品色在线| 久久av红桃一区二区小说| 美女露胸一区二区三区| 亚洲精品久久久久| 欧美午夜不卡| 欧美一区午夜精品| 欧美国产精品久久| 亚洲性色视频| 国产一区二三区| 欧美不卡高清| 这里只有精品丝袜| 久久久久久成人| 亚洲老板91色精品久久| 国产精品视频自拍| 久久亚洲捆绑美女| 宅男噜噜噜66一区二区66| 久久精彩免费视频| 亚洲人永久免费| 国产精品日韩精品欧美在线| 久久精品人人做人人综合| 91久久国产综合久久91精品网站| 一区二区三区.www| 国内外成人免费视频| 欧美精品久久久久久久久老牛影院 | 亚洲国产一区二区三区青草影视 | 久久久av网站| 国产精品美女黄网| 夜夜嗨av一区二区三区| 亚洲理论在线观看| 午夜精品久久久久久99热软件| 欧美aⅴ99久久黑人专区| 巨胸喷奶水www久久久免费动漫| 黄色av一区| 久久综合伊人77777| 欧美大片免费| 亚洲乱码精品一二三四区日韩在线| 欧美mv日韩mv国产网站| 最近中文字幕mv在线一区二区三区四区| 狠狠综合久久| 免费人成网站在线观看欧美高清| 欧美大片免费观看| 夜夜爽www精品| 国产精品高潮在线| 欧美一区二区视频在线观看| 久久青草福利网站| 亚洲国产欧美在线| 欧美日韩在线一二三| 午夜精品久久久久影视| 久久香蕉国产线看观看网| 在线观看日韩精品| 欧美日韩ab片| 亚洲欧美激情一区| 欧美国产日韩一区| 亚洲永久免费精品| 激情久久影院| 欧美日韩亚洲一区三区| 欧美亚洲综合另类| 亚洲国产日韩美| 午夜视频在线观看一区二区| 精品不卡一区| 欧美视频日韩视频在线观看| 香蕉久久精品日日躁夜夜躁| 欧美韩日视频| 欧美在线观看一区二区| 亚洲精品一区二区三区99| 欧美午夜电影在线观看| 久久久久久久久久久成人| 一区二区三区高清视频在线观看| 久久高清一区| 亚洲视频在线观看一区| 伊人久久久大香线蕉综合直播| 欧美日韩久久久久久| 久久亚洲午夜电影| 亚洲在线播放电影| 亚洲精品免费网站| 老司机精品视频一区二区三区| 亚洲天堂成人在线视频| 亚洲激情精品| 国产综合一区二区| 国产精品理论片| 欧美精品日韩一区| 久久偷窥视频| 久久福利资源站| 亚洲男人的天堂在线aⅴ视频| 91久久精品国产91久久| 久久久一本精品99久久精品66| 亚洲主播在线| 亚洲深夜福利在线| 日韩视频不卡中文| 在线播放日韩| 韩日视频一区| 国产欧美va欧美va香蕉在| 欧美日韩一卡| 欧美日韩视频免费播放| 欧美高清在线一区二区| 老司机免费视频一区二区三区| 亚洲欧美日韩在线| 亚洲一区免费网站| 亚洲一区二区黄色| 亚洲男人的天堂在线观看 | 久久九九免费视频| 美女精品国产| 久久久午夜电影| 久久久久亚洲综合| 久久gogo国模啪啪人体图| 欧美在线免费观看视频| 欧美在线观看视频一区二区| 欧美亚洲在线| 久久不见久久见免费视频1| 香蕉尹人综合在线观看| 欧美一级专区免费大片| 欧美自拍偷拍| 久久久999| 欧美成人精品不卡视频在线观看| 老**午夜毛片一区二区三区| 欧美不卡福利| 欧美日韩国语| 国产精品卡一卡二| 韩日成人av| 亚洲精品视频在线| 亚洲视频一区二区免费在线观看| 亚洲免费网站| 久久久久国产精品麻豆ai换脸| 美女图片一区二区| 亚洲国产日韩欧美在线图片| 亚洲精品1区2区| 一本综合精品| 欧美在线精品一区| 美女精品在线观看| 欧美日韩八区| 国产美女精品人人做人人爽| 一区国产精品| 亚洲区免费影片| 亚洲一区亚洲| 免费不卡在线视频| 999亚洲国产精| 久久精品道一区二区三区| 欧美激情一二区| 国产精品专区第二| 亚洲日韩第九十九页| 亚洲在线视频免费观看| 欧美在线网址| 亚洲欧洲日韩在线| 欧美有码视频| 欧美视频在线播放| 在线播放精品| 性色av一区二区三区红粉影视| 欧美电影美腿模特1979在线看| 一本久久综合亚洲鲁鲁五月天| 久久精品人人爽| 欧美视频在线视频| 亚洲国产精品黑人久久久| 午夜精品久久一牛影视| 欧美激情中文字幕一区二区| 亚洲中午字幕| 欧美激情综合| 激情久久久久久久| 亚洲免费影视| 亚洲人成毛片在线播放| 欧美中文在线字幕| 国产精品久久影院| 亚洲视频在线观看三级| 91久久在线视频| 麻豆精品在线视频| 激情亚洲网站|