Function websocket_run

android/samples/websocket/websocket/src/main/cpp/websocket.cpp:259–324

};

bool websocket_run(const char* addr, void (*callback)(void*, void*, const char*),
		void* env, void* obj)
{
	int  conn_timeout = 5, rw_timeout = 5;
	acl::string host("www.test.com");
	std::vector<acl::string> name_servers;
	bool debug = false;

	// 定义 AIO 事件引擎
	acl::aio_handle handle(acl::ENGINE_KERNEL);

	//////////////////////////////////////////////////////////////////////

	if (name_servers.empty()) {
		name_servers.push_back("8.8.8.8:53");
	}

	for (std::vector<acl::string>::const_iterator cit = name_servers.begin();
		cit != name_servers.end(); ++cit) {

		// 设置 DNS 域名服务器地址
		handle.set_dns((*cit).c_str(), 5);
	}


	// 开始异步连接远程 WEB 服务器
	websocket_client* conn = new websocket_client(handle, host, callback, env, obj);
	if (!conn->open(addr, conn_timeout, rw_timeout)) {
		log_info("connect %s error\r\n", addr);

		delete conn;
		return false;
	}

	(*conn).enable_debug(debug);		// 是否启用调试方式
	conn->unzip_body(true);			// 针对 HTTP 自动解压

	// 设置 HTTP 请求头，也可将此过程放在 conn->on_connect() 里
	acl::http_header& head = conn->request_header();
	head.set_url("/path?name1&name2")
		.add_param("name3", "")
		.add_param("n1", "v1")
		.add_param("n2", "v2")
		.add_param("n3", "")
		.set_content_length(0)
		.set_host(host)
		.accept_gzip(true)
		.set_keep_alive(true);

	acl::string buf;
	head.build_request(buf);
	log_info("---------------request header-----------------\r\n");
	log_info("[%s]\r\n", buf.c_str());

	// 开始 AIO 事件循环过程
	while (true) {
		// 如果返回 false 则表示不再继续，需要退出
		if (!handle.check()) {