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

posts - 6,  comments - 61,  trackbacks - 0

This tutorial program shows how to combine the two asynchronous servers that we have just written, into a single server application.

本例示范了我們如何將已經實現的兩種異步服務整合為一個服務器應用程序。

The main() function

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

We will begin by creating a server object to accept a TCP client connection.

 我們首先創建一個用于接收TCP客戶端連接的服務器對象。


   tcp_server server1(io_service);

We also need a server object to accept a UDP client request.

我們也需要一個用于接收UDP客戶端請求的服務器對象。


udp_server server2(io_service);

We have created two lots of work for the boost::asio::io_service object to do.

這樣我們就已經創建兩個需要完成很多工作的服務器,而這些工作都由boost::asio::io_service對象完成


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

  
return 0;
}
The tcp_connection and tcp_server classes

TCP連接和TCP服務器類

The following two classes are taken from Daytime.3 .

下面的兩個類實例來自例子Daytime.3。


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()));
  }

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

  
void handle_write()
  {
  }

  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_;
};
The udp_server class

UDP服務器類

Similarly, this next class is taken from the previous tutorial step .

同樣,下面的這個類實例也是來自以前的示例程序。


class udp_server
{
public:
  udp_server(boost::asio::io_service
& io_service)
    : socket_(io_service, udp::endpoint(udp::v4(), 
13))
  {
    start_receive();
  }

private:
  
void start_receive()
  {
    socket_.async_receive_from(
        boost::asio::buffer(recv_buffer_), remote_endpoint_,
        boost::bind(
&udp_server::handle_receive, this,
          boost::asio::placeholders::error));
  }

  
void handle_receive(const boost::system::error_code& error)
  {
    
if (!error || error == boost::asio::error::message_size)
    {
      boost::shared_ptr
<std::string> message(
          
new std::string(make_daytime_string()));

      socket_.async_send_to(boost::asio::buffer(
*message), remote_endpoint_,
          boost::bind(
&udp_server::handle_send, this, message));

      start_receive();
    }
  }

  
void handle_send(boost::shared_ptr<std::string> /*message*/)
  {
  }

  udp::socket socket_;
  udp::endpoint remote_endpoint_;
  boost::array
<char1> recv_buffer_;
};

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/array.hpp>
#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;
using boost::asio::ip::udp;

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()));
  }

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

  
void handle_write()
  {
  }

  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_;
};

class udp_server
{
public:
  udp_server(boost::asio::io_service
& io_service)
    : socket_(io_service, udp::endpoint(udp::v4(), 
13))
  {
    start_receive();
  }

private:
  
void start_receive()
  {
    socket_.async_receive_from(
        boost::asio::buffer(recv_buffer_), remote_endpoint_,
        boost::bind(
&udp_server::handle_receive, this,
          boost::asio::placeholders::error));
  }

  
void handle_receive(const boost::system::error_code& error)
  {
    
if (!error || error == boost::asio::error::message_size)
    {
      boost::shared_ptr
<std::string> message(
          
new std::string(make_daytime_string()));

      socket_.async_send_to(boost::asio::buffer(
*message), remote_endpoint_,
          boost::bind(
&udp_server::handle_send, this, message));

      start_receive();
    }
  }

  
void handle_send(boost::shared_ptr<std::string> /*message*/)
  {
  }

  udp::socket socket_;
  udp::endpoint remote_endpoint_;
  boost::array
<char1> recv_buffer_;
};

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

  
return 0;
}
posted on 2008-04-21 09:24 王曉軒 閱讀(4185) 評論(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>
            亚洲福利av| 亚洲成在人线av| 午夜精品成人在线| 亚洲无吗在线| 国产欧美高清| 久久躁日日躁aaaaxxxx| 久久综合五月天婷婷伊人| 亚洲国产一区二区三区高清| 亚洲激情视频网| 欧美日韩精品在线观看| 欧美永久精品| 老巨人导航500精品| 一区二区三区产品免费精品久久75| 99精品国产福利在线观看免费 | 欧美精品在线观看播放| 亚洲婷婷免费| 久久精品二区三区| 99精品免费视频| 午夜精品一区二区三区在线| 亚洲福利国产| 一本色道久久88综合日韩精品| 国产精品yjizz| 日韩视频―中文字幕| 日韩午夜高潮| 国产欧美日韩精品丝袜高跟鞋| 久久激情中文| 欧美mv日韩mv国产网站app| 亚洲麻豆av| 亚洲免费在线视频| 亚洲国产婷婷香蕉久久久久久| 日韩一级精品| 欧美日韩视频一区二区三区| 亚洲影音一区| 午夜日韩在线| 在线欧美日韩| 99re热这里只有精品视频| 国产欧美日韩精品在线| 久久久噜噜噜久久中文字免| 免费在线观看成人av| 亚洲一级电影| 久久深夜福利免费观看| 亚洲色无码播放| 久久久久国产一区二区三区| 99热这里只有成人精品国产| 亚洲欧美成人在线| 亚洲国产影院| 欧美在线观看网站| 一区二区三区福利| 久久精品一区二区三区不卡牛牛| 亚洲日本欧美| 久久九九有精品国产23| 亚洲视频在线免费观看| 久久亚洲春色中文字幕| 亚洲欧美视频在线观看视频| 麻豆免费精品视频| 欧美中文字幕第一页| 欧美日韩色综合| 欧美激情精品久久久久久久变态| 国产精品一区二区在线观看| 亚洲国产欧美久久| 激情六月婷婷综合| 日韩亚洲欧美中文三级| 激情懂色av一区av二区av| 日韩亚洲视频| 国产一区二区三区在线免费观看| 9l视频自拍蝌蚪9l视频成人| 国产日韩av一区二区| 亚洲视频一区二区免费在线观看| 亚洲人成高清| 欧美成年网站| 欧美国产先锋| 亚洲第一天堂av| 久久av一区二区三区| 制服丝袜激情欧洲亚洲| 免费日本视频一区| 欧美激情免费在线| 亚洲国产高清aⅴ视频| 久久久精品视频成人| 久久蜜臀精品av| 国内自拍视频一区二区三区| 欧美一区二区三区在线视频 | 国产欧美精品日韩| 亚洲一区二区三区四区视频| 午夜欧美大片免费观看| 国产精品久久久久永久免费观看| 亚洲视频网站在线观看| 午夜精品成人在线| 国产亚洲人成网站在线观看| 欧美一区二区久久久| 久久不射中文字幕| 在线成人av.com| 欧美成年人视频| 亚洲免费av网站| 性欧美video另类hd性玩具| 欧美电影资源| 久久综合久色欧美综合狠狠| 国产日韩欧美日韩大片| 性8sex亚洲区入口| 久久只精品国产| 日韩视频中文| 国产精品草草| 久色成人在线| 亚洲综合色视频| 欧美成人亚洲成人日韩成人| 一本色道久久综合狠狠躁篇的优点| 欧美婷婷六月丁香综合色| 亚洲男女自偷自拍图片另类| 免费视频一区二区三区在线观看| 国产在线不卡| 欧美日韩三区| 欧美一区日韩一区| 亚洲经典视频在线观看| 欧美一区二区三区四区高清| 国产专区一区| 欧美制服第一页| 欧美福利视频| 亚洲欧美日韩中文在线制服| 国产一区视频网站| 欧美日韩国产一区精品一区| 亚洲欧美日本国产有色| 亚洲大胆女人| 久久成人免费网| 亚洲精品在线免费观看视频| 国产麻豆午夜三级精品| 欧美激情1区2区| 欧美一区二区三区男人的天堂| 亚洲国产美女| 久久免费黄色| 亚洲欧美影院| 在线精品福利| 伊人久久大香线| 国产精品一区一区| 欧美日本三区| 欧美1区3d| 久久精品成人| 亚洲欧美日韩视频二区| 日韩亚洲欧美一区| 亚洲激情成人在线| 欧美成人一品| 久久影院午夜片一区| 亚洲一区二区黄色| 亚洲视频综合在线| av成人免费在线| 亚洲精品视频免费观看| 国内精品免费午夜毛片| 国产精品日韩精品欧美精品| 欧美日韩精品系列| 欧美精品日韩一本| 欧美国产高清| 欧美国产精品中文字幕| 蜜臀久久久99精品久久久久久| 欧美专区亚洲专区| 欧美在线视频免费| 久久香蕉精品| 免费黄网站欧美| 久久青草福利网站| 久久综合网色—综合色88| 久久久久一区二区三区| 久久久九九九九| 久久久国产亚洲精品| 久久久久久久久久久久久久一区 | 欧美成人精品在线| 欧美国产日韩亚洲一区| 欧美激情视频一区二区三区免费 | 亚洲国产女人aaa毛片在线| 1024亚洲| 在线观看一区二区视频| 国产日韩欧美制服另类| 国产一级一区二区| 激情文学一区| 亚洲精品在线视频| 中国av一区| 欧美在线观看网站| 午夜亚洲一区| 久久se精品一区二区| 久久深夜福利免费观看| 欧美大片在线看| 日韩视频免费看| 亚洲一区二区免费在线| 久久精品最新地址| 欧美成人tv| 国产精品美女久久久久aⅴ国产馆| 国产老肥熟一区二区三区| 黑丝一区二区| 一区二区三区在线看| 国产精品一区在线观看你懂的| 国产欧美日韩视频一区二区| 激情视频一区| 亚洲一区二区四区| 久久精品日产第一区二区三区| 欧美国产免费| 亚洲亚洲精品在线观看 | 午夜在线精品偷拍| 欧美成人精品1314www| 免费中文字幕日韩欧美| 亚洲国产日韩欧美综合久久| 夜夜狂射影院欧美极品| 久久爱www.| 国产精品第13页| 亚洲黄色性网站|