acl/lib_acl_cpp/samples/http_client/main.cpp

#include <stdio.h>
#include <stdlib.h>

#include "lib_acl.h"
#include "lib_protocol.h"  // http Э<><D0AD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
#include "acl_cpp/lib_acl.hpp"

class http_request : public acl::http_service_request
{
public:
	http_request(const char* domain, unsigned short port,
		acl::aio_handle* handle)
	: acl::http_service_request(domain, port)
	, handle_(handle)
	{
		read_length_ = 0;
	}

	~http_request(void)
	{
		printf("notify aio handle to stop!\r\n");
		// ֪ͨ<CDA8>첽<EFBFBD>¼<EFBFBD><C2BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȫ<EFBFBD>˳<EFBFBD>
		handle_->stop();
	}
protected:
	//////////////////////////////////////////////////////////////////////////
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӿ<EFBFBD>

	virtual const acl::string* get_body()
	{
		return (NULL);
	}

	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> HTTP <20><>Ӧͷʱ<CDB7>Ļص<C4BB><D8B5>ӿ<EFBFBD>
	virtual void on_hdr(const char* addr, const HTTP_HDR_RES* hdr)
	{
		printf(">>server addr: %s, http reply status: %d\n",
			addr, hdr->reply_status);
		http_hdr_print(&hdr->hdr, "http reply hdr");
		content_length_ = hdr->hdr.content_length;
		if (content_length_ > 0)
		{
			if (out_.open_write("test.exe") == false)
				printf("create file error(%s)\n",
					acl_last_serror());
		}
		time(&begin_);
	}

	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> HTTP <20><>Ӧ<EFBFBD><D3A6>ʱ<EFBFBD>Ļص<C4BB><D8B5><EFBFBD><EFBFBD><EFBFBD>
	virtual void on_body(const char* data, size_t dlen)
	{
		if (data == NULL && dlen == 0)
		{
#ifdef WIN32
			printf("\n>> http reply body over, total: %I64d, %I64d\n",
				content_length_, read_length_);
#else
			printf("\n>> http reply body over, total: %lld, %lld\n",
				content_length_, read_length_);
#endif
			// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƕ<EFBFBD>̬<EFBFBD><CCAC><EFBFBD><EFBFBD><EFBFBD>ģ<EFBFBD><C4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ҫ<EFBFBD>ڴ˴<DAB4><CBB4>ͷ<EFBFBD>
			time_t end = time(NULL);
			printf(">>spent %d seconds\n", (int)(end - begin_));

			return;
		}
		read_length_ += dlen;
		http_off_t n =  (read_length_ * 100) / content_length_;
#ifdef WIN32
		printf("%s(%d): n=%I64d%%\r", __FUNCTION__, __LINE__, n);
#else
		printf("%s(%d): n=%lld%%\r", __FUNCTION__, __LINE__, n);
#endif

		if (out_.opened())
			out_.write(data, dlen);
	}

	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ӧʧ<D3A6><CAA7>ʱ<EFBFBD>Ļص<C4BB><D8B5><EFBFBD><EFBFBD><EFBFBD>
	virtual void on_error(acl::http_status_t errnum)
	{
		printf(">> error: %d\n", (int) errnum);

		// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƕ<EFBFBD>̬<EFBFBD><CCAC><EFBFBD><EFBFBD><EFBFBD>ģ<EFBFBD><C4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ҫ<EFBFBD>ڴ˴<DAB4><CBB4>ͷ<EFBFBD>
	}

	virtual void destroy()
	{
		delete this;
	}

private:
	acl::ofstream out_;
	acl::aio_handle* handle_;
	http_off_t  read_length_;
	http_off_t  content_length_;
	time_t begin_;
};

int main()
{
#ifdef WIN32
	acl::acl_cpp_init();
#endif
	acl::atomic_long n;
	n++;
	printf("n=%lld\r\n", n.value());
	getchar();

	acl::aio_handle handle(acl::ENGINE_SELECT);
	acl::http_service* service = new acl::http_service();

	// ʹ<><CAB9>Ϣ<EFBFBD><CFA2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> 127.0.0.1 <20>ĵ<EFBFBD>ַ
	if (service->open(&handle) == false)
	{
		printf(">>open message service error!\n");
		printf(">>enter any key to quit\n");
		getchar();
		return (1);
	}


	// <20><><EFBFBD><EFBFBD> HTTP <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
	acl::string domain;
	domain = "www.hexun.com";
	//domain = "192.168.1.229";
	//domain = "www.renwou.net";
	http_request* req = new http_request(domain.c_str(), 80, &handle);
	req->set_url("/index.html");
	//req->set_url("/download/banmau_install.exe");
	req->set_host(domain);
	req->set_keep_alive(false);
	req->set_method(acl::HTTP_METHOD_GET);
	req->add_cookie("x-cookie-name", "cookie-value");
	//req->set_redirect(1); // <20><><EFBFBD><EFBFBD><EFBFBD>Զ<EFBFBD><D4B6>ض<EFBFBD><D8B6><EFBFBD><EFBFBD>Ĵ<EFBFBD><C4B4><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>

	// ֪ͨ<CDA8>첽<EFBFBD><ECB2BD>Ϣ<EFBFBD><CFA2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> HTTP <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>

	//////////////////////////////////////////////////////////////////////////
	//acl::string buf;
	//req->build_request(buf);
	//printf("-----------------------------------------------\n");
	//printf("%s", buf.c_str());
	//printf("-----------------------------------------------\n");
	//////////////////////////////////////////////////////////////////////////

	service->do_request(req);

	while (true)
	{
		if (handle.check() == false)
		{
			printf(">>quit aio process\n");
			break;
		}
	}

	printf("delete http service now\r\n");
	delete service;

	printf("delete delay aio stream\r\n");
	handle.check();

	printf(">>enter any key to exist\n");
	getchar();
	return (0);
}