1. 問題
其中，C 建立tcp連線和http請求是用一個類別實現的，過程都是異步的，其中有一個回呼函數on_read()會得到伺服器的回應訊息，並進行加工處理。
C 拿到js的json請求之後，便開始進行網路工作。
問題是：
a. 不知道回應訊息何時返回，無法像同步那樣等待回應。
b. 在js的主執行緒之外不能使用v8的api，也就是說無法在on_read()回呼函數中直接向js傳回回應訊息
2.程式碼
class TCP_CLIENT : public IConnectionHandler
{
bool isdone;
public:
TCP_CLIENT(const char* host, int port, const char* data, Isolate *isolate, const FunctionCallbackInfo<Value> args)
{
this->host_ = host;
this->port_ = port;
this->request_data_ = data;
isolate_ = isolate;
}
~TCP_CLIENT()
{
std::cout << "~tcp_client" << std::endl;
}
/*callback handler implement回调接口实现*/
//建立连接的回调
void on_established(IBaseConnection* conn) override_final
{
std::cout << "Connect Successful" << std::endl;
this->send_request(conn);
}
。。。。。。。。。
//服务器响应得到数据的回调
int on_read(int err, int bytes_transfered, IBaseConnection* conn, SharedBufferPtr buffer) override_final
{
if (err == 0 && bytes_transfered)
{
std::cout << "In read, thread id is ----" << GetCurrentThreadId() << std::endl;
buffer->erase(bytes_transfered);
if (conn->is_established())
{
conn->stop();
}
}
return 0;
}
//发送数据的回调
void on_write(int err, int bytes_transferred, IBaseConnection* conn, SharedBufferPtr buffer) override_final
{
if (err == 0 && bytes_transferred > 0)
{
std::cout << "Send Request Successful------>" << buffer->length() << std::endl;
buffer->erase(bytes_transferred);
}
else {}
}
private:
const char* host_;
int port_;
const char* request_data_;
http::ParserPtr response_parser_;
Isolate *isolate_;
};
const char* ToCString(const v8::String::Utf8Value& value)
{
return *value ? *value : "<string conversion failed>";
}
void entry(const FunctionCallbackInfo<Value>& args)
{
std::cout << "In entry, process id is ----" << GetCurrentProcessId() << std::endl;
std::cout << "In entry, thread id is ----" << GetCurrentThreadId() << std::endl;
//启动一个线程执行tcp连接
global_http_transfer_context_pool.run();
Isolate* isolate = args.GetIsolate();
if (args.Length() != 2)
{
isolate->ThrowException(Exception::TypeError(v8::String::NewFromUtf8(isolate, "参数数量必须为二")));
return;
}
if (!args[0]->IsString() || !args[1]->IsNumber())
{
isolate->ThrowException(Exception::TypeError(
v8::String::NewFromUtf8(isolate, "参数类型错误")
));
}
v8::String::Utf8Value str_temp(args[0]);
const char* data = ToCString(str_temp);
TCP_CLIENT* tcp_client;
if (args[1]->NumberValue() == 1)
{
tcp_client = new TCP_CLIENT(cms_host, cms_port, data, isolate, args);
tcp_client->perform(1);
}
else
{
tcp_client = new TCP_CLIENT(liteapp_host, liteapp_port, data, isolate, args);
tcp_client->perform(0);
}
}
void Init(Local<Object> exports)
{
NODE_SET_METHOD(exports, "http_request", entry);
}
NODE_MODULE(NODE_GYP_MODULE_NAME, Init)嘗試的方法：
a. 在主執行緒中設定while循環等待，子執行緒在on_read()向js傳回資料之後，設定標誌表示結束，這樣能夠正確結束，但是C 的非同步請求就變成了一個同步，沒有意義。
b. 在網路上看到的libuv方法，但是仍然會出現libuv的工作函數無法得到C 非同步回應訊息的問題，主要就是非同步訊息與C 向node返回，線程之間如何處理的問題。
相關文章：
NodeJS與Mysql的互動範例程式碼_javascript技巧
相關影片：