C/C++编程：http_client分析

た入场券 2022-09-04 05:53 371阅读 0赞

# 版本1：创建一个客户端 #

//
    // Created by oceanstar on 2021/8/11.
    //
    
    #ifndef OCEANSTAR_HTTP_HTTP_CLIENT_H
    #define OCEANSTAR_HTTP_HTTP_CLIENT_H
    
    #include <stream/socket_stream.h>
    #include <protocol/HTTP_HDR_REQ.h>
    
    namespace oceanstar{
        
        /**
         * 该类的用处：
         *   当 HTTP 客户端向服务器请求数据时
         */
        class http_client: public noncopyable{
        
        public:
            /**
    	 * 缺省的构造函数，使用此构造函数创建的 HTTP 客户端对象，需要显示地
    	 * 调用 http_client::open 来打开数据流
    	 */
            http_client(void)
                    : stream_(NULL)
                    , hdr_req_(NULL)
                    , req_(NULL)
                    , disconnected_(true){
        
            }
            /**
             * 根据已经连接成功的连接流对象创建 HTTP 客户端对象，但需要注意的是，
             * 当该 http_client 对象销毁时，传入的 client 流对象并不会被销毁，需
             * 要应用自己销毁，否则会造成资源泄露
             * @param is_request {bool} 是请求端还是响应端的客户端流
             *  read_body(string&, bool, int*)
             */
            http_client(socket_stream* client)
                    : stream_(client)
                    , hdr_req_(NULL)
                    , req_(NULL)
                    , disconnected_(false){
        
            }
    
            /**
             * 连接远程 HTTP 服务器
             * @param addr {const char*} 服务器地址，格式：IP|PORT 或 DOMAIN|PORT
             * @param conn_timeout {int} 连接超时时间(秒)
             * @param rw_timeout {int} 读写超时时间(秒)
             * @return {bool} 连接是否成功
             */
            bool open(const char* addr, int conn_timeout = 60, int rw_timeout = 60){
        
                if(stream_){
        
                    delete stream_;
                    stream_ = NULL;
                    disconnected_ = true;
                }
    
                socket_stream* stream = new socket_stream();
                if (!stream->open(addr, conn_timeout, rw_timeout)) {
        
                    delete stream;
                    disconnected_ = true;
                    return false;
                }
                disconnected_ = false;
                stream_       = stream;
                return true;
            }
    
        private:
            bool disconnected_;         // 网络连接是否已经关闭
            socket_stream* stream_;     // HTTP 数据流
            HTTP_HDR_REQ* hdr_req_;     // HTTP 头请求对象
            struct HTTP_REQ* req_;      // HTTP 请求对象
        };
    }
    
    
    #endif //OCEANSTAR_HTTP_HTTP_CLIENT_H