Boost.Asio c++ 网络编程翻译(20)

简介:
异步服务端
这个图表是相当复杂的;从Boost.Asio出来你能够看到4个箭头指向on_accept。on_read,on_write和on_check_ping。

着也就意味着你永远不知道哪个异步调用是下一个完毕的调用。可是你能够确定的是它是这4个操作中的一个。

如今。我们是异步的了;我们能够继续保持单线程。接受client连接是最简单的部分。例如以下所看到的:
ip::tcp::acceptor acceptor(service, ip::tcp::endpoint(ip::tcp::v4(),
   8001));
   void handle_accept(talk_to_client::ptr client, const error_code & err)
   {
       client->start();
       talk_to_client::ptr new_client = talk_to_client::new_();
       acceptor.async_accept(new_client->sock(),
                             boost::bind(handle_accept,new_client,_1));
   }
   int main(int argc, char* argv[]) {
       talk_to_client::ptr client = talk_to_client::new_();
       acceptor.async_accept(client->sock(),boost::bind(handle_accept,client,_1));
    service.run();
}
上述代码会一直异步地等待一个新的client连接(每一个新的client连接会触发另外一个异步等待操作)。

我们须要监控client list changed事件(一个新client连接或者一个client断开连接),然后当事件发生时通知全部的client。因此,我们须要保存一个client连接的数组,否则。除非你不须要在某一时刻知道全部连接的client,你才不须要这样一个数组。
class talk_to_client; typedef boost::shared_ptr<talk_to_client>
   client_ptr;
   typedef std::vector<client_ptr> array;
   array clients;
connection类的框架例如以下:

class talk_to_client : public boost::enable_shared_from_this<talk_to_

client>

                        , boost::noncopyable {
       talk_to_client() { ... }
   public:
       typedef boost::system::error_code error_code;
       typedef boost::shared_ptr<talk_to_client> ptr;
       void start() {
           started_ = true;
           clients.push_back( shared_from_this());
           last_ping = boost::posix_time::microsec_clock::local_time();
           do_read(); //首先,我们等待客户端连接
       }
       static ptr new_() { ptr new_(new talk_to_client); return new_; }
       void stop() {
           if ( !started_) return;
           started_ = false;
           sock_.close();
           ptr self = shared_from_this();
           array::iterator it = std::find(clients.begin(), clients.end(),
   self);
           clients.erase(it);
           update_clients_changed();
       }
       bool started() const { return started_; }
       ip::tcp::socket & sock() { return sock_;}
       std::string username() const { return username_; }
       void set_clients_changed() { clients_changed_ = true; }
       … 
private:
       ip::tcp::socket sock_;
       enum { max_msg = 1024 };
       char read_buffer_[max_msg];
       char write_buffer_[max_msg];
       bool started_;
       std::string username_;
       deadline_timer timer_;
       boost::posix_time::ptime last_ping;
       bool clients_changed_;

};

我会用talk_to_client或者talk_to_server来调用connection类,从而使你更明确我所说的内容。
如今你须要用到之前的代码了;它和我们在client应用中所用到的是一样的。可是我们还有另外一个stop()方法,这种方法用来从client数组中移除一个client连接。

服务端持续不断地等待异步的read操作:
void on_read(const error_code & err, size_t bytes) {
       if ( err) stop();
       if ( !started() ) return;
       std::string msg(read_buffer_, bytes);
       if ( msg.find("login ") == 0) on_login(msg);
       else if ( msg.find("ping") == 0) on_ping();
       else if ( msg.find("ask_clients") == 0) on_clients();
   }
   void on_login(const std::string & msg) {
       std::istringstream in(msg);
       in >> username_ >> username_;
       do_write("login ok\n");
       update_clients_changed();
   }
   void on_ping() {
       do_write(clients_changed_ ? "ping client_list_changed\n" : "ping
   ok\n");
       clients_changed_ = false;
   }
void on_clients() {
    std::string msg;
for(array::const_iterator b =clients.begin(),e =clients.end(); b
   != e; ++b)
           msg += (*b)->username() + " ";
       do_write("clients " + msg + "\n");

这段代码是简单易懂的;须要注意的一点是:当一个新客户端登录,我们调用update_clients_changed(),这种方法为全部客户端将clients_changed_标志为true。

服务端每收到一个请求就用正确的方式进行回复。例如以下所看到的:
void do_ping() { do_write("ping\n"); }
   void do_ask_clients() { do_write("ask_clients\n"); }
   void on_write(const error_code & err, size_t bytes) { do_read(); }
   void do_read() {
       async_read(sock_, buffer(read_buffer_),
                   MEM_FN2(read_complete,_1,_2), MEM_FN2(on_read,_1,_2));
       post_check_ping();
   }
   void do_write(const std::string & msg) {
       if ( !started() ) return;
       std::copy(msg.begin(), msg.end(), write_buffer_);
       sock_.async_write_some( buffer(write_buffer_, msg.size()),
                               MEM_FN2(on_write,_1,_2));
   }
   size_t read_complete(const boost::system::error_code & err, size_t
   bytes) {
       // ... as before
   }
在每一个write操作的末尾,on_write()方法被调用。这种方法会触发另外一个异步读操作,这种话“等待请求-回复请求”这个循环酒会一直运行,直到client断开连接或者超时。
在每次读操作開始之前,我们异步等待5秒钟来观察client是否超时。假设超时。我们关闭它的连接:
void on_check_ping() {
       ptime now = microsec_clock::local_time();
       if ( (now - last_ping).total_milliseconds() > 5000)
           stop();
       last_ping = boost::posix_time::microsec_clock::local_time();
   }
   void post_check_ping() {
       timer_.expires_from_now(boost::posix_time::millisec(5000));
       timer_.async_wait( MEM_FN(on_check_ping));
   }
这就是整个服务端的实现。你能够执行并让它工作起来!
在代码中,我向你们展示了这一章我们学到的东西,为了更easy理解,我把代码略微精简了下。比方,大部分的控制台输出我都没有展示。虽然在这本书附赠的代码中它们是存在的。

我建议你自己执行这些样例,由于从头到尾读一次代码能加强你对本章展示应用的理解。

总结
我们已经学到了怎么写一些基础的client/服务端应用。

我们已经避免了一些诸如内存泄漏和死锁的低级错误。全部的编码都是框架式的。这样你就能够依据你自己的需求对它们进行扩展。

在接下来的章节中,我们会更加深入地了解使用Boost.Asio进行同步编程和异步编程的不同点。同一时候你会也学会怎样嵌入你自己的异步操作。







本文转自mfrbuaa博客园博客,原文链接:http://www.cnblogs.com/mfrbuaa/p/5306409.html,如需转载请自行联系原作者
相关文章
|
28天前
|
网络协议 C++
C++ Qt开发:QTcpSocket网络通信组件
`QTcpSocket`和`QTcpServer`是Qt中用于实现基于TCP(Transmission Control Protocol)通信的两个关键类。TCP是一种面向连接的协议,它提供可靠的、双向的、面向字节流的通信。这两个类允许Qt应用程序在网络上建立客户端和服务器之间的连接。Qt 是一个跨平台C++图形界面开发库,利用Qt可以快速开发跨平台窗体应用程序,在Qt中我们可以通过拖拽的方式将不同组件放到指定的位置,实现图形化开发极大的方便了开发效率,本章将重点介绍如何运用`QTcpSocket`组件实现基于TCP的网络通信功能。
37 8
C++ Qt开发:QTcpSocket网络通信组件
|
1月前
|
消息中间件 网络协议 C++
C/C++网络编程基础知识超详细讲解第三部分(系统性学习day13)
C/C++网络编程基础知识超详细讲解第三部分(系统性学习day13)
|
2月前
|
网络协议 网络性能优化 C++
C/C++工程师面试题(网络编程篇)
C/C++工程师面试题(网络编程篇)
38 0
|
3天前
|
存储 算法 Linux
【实战项目】网络编程:在Linux环境下基于opencv和socket的人脸识别系统--C++实现
【实战项目】网络编程:在Linux环境下基于opencv和socket的人脸识别系统--C++实现
17 6
|
24天前
|
SQL XML API
Qt C++ 模块 描述列表【从Qt 官网 6.5 版本翻译】
Qt C++ 模块 描述列表【从Qt 官网 6.5 版本翻译】
12 0
|
25天前
|
网络协议 Linux C++
Linux C/C++ 网络编程中地址格式转换(inet_pton和inet_ntop函数)
Linux C/C++ 网络编程中地址格式转换(inet_pton和inet_ntop函数)
21 0
|
27天前
|
存储 网络安全 C++
C++ Qt开发:QUdpSocket网络通信组件
Qt 是一个跨平台C++图形界面开发库,利用Qt可以快速开发跨平台窗体应用程序,在Qt中我们可以通过拖拽的方式将不同组件放到指定的位置,实现图形化开发极大的方便了开发效率,本章将重点介绍如何运用`QUdpSocket`组件实现基于UDP的网络通信功能。与`QTcpSocket`组件功能类似,`QUdpSocket`组件是 Qt 中用于实现用户数据报协议(UDP,User Datagram Protocol)通信的类。UDP 是一种无连接的、不可靠的数据传输协议,它不保证数据包的顺序和可靠性,但具有低延迟和简单的特点。
19 0
C++ Qt开发:QUdpSocket网络通信组件
|
1月前
|
网络协议 C++
C/C++网络编程基础知识超详细讲解第二部分(系统性学习day12)
C/C++网络编程基础知识超详细讲解第二部分(系统性学习day12)
|
1月前
|
存储 网络协议 安全
C/C++网络编程基础知识超详细讲解第一部分(系统性学习day11)
C/C++网络编程基础知识超详细讲解第一部分(系统性学习day11)
|
1月前
|
缓存 网络安全 调度
C++ Qt开发:QNetworkAccessManager网络接口组件
Qt 是一个跨平台C++图形界面开发库,利用Qt可以快速开发跨平台窗体应用程序,在Qt中我们可以通过拖拽的方式将不同组件放到指定的位置,实现图形化开发极大的方便了开发效率,本章将重点介绍如何运用`QNetworkAccessManager`组件实现Web网页访问。QNetworkAccessManager是Qt网络模块中的关键类,用于管理网络访问和请求。作为一个网络请求的调度中心,它为Qt应用程序提供了发送和接收各种类型的网络请求的能力,包括常见的GET、POST、PUT、DELETE等。这个模块的核心功能在于通过处理`QNetworkReply`和`QNetworkRequest`来实现
19 0
C++ Qt开发:QNetworkAccessManager网络接口组件