我試圖在C++客戶端和node.js服務器之間進行通信。我可以將數據發送到服務器,但我無法將任何消息發送回客戶端。我對socket.emit的簡單理解是,它應該通過在基本的Windows消息循環中的FD_READ消息上調用recv()來發送可檢索的消息。我可能會錯過那裏。Node.js到C++客戶端:沒有接收來自socket.emit的消息
下面是相關的客戶端代碼:
s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (s == INVALID_SOCKET)
{
MessageBox(hwnd, TEXT("3"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
return 0;
}
long hostname = inet_addr("192.168.1.70");
target.sin_family = AF_INET;
target.sin_port = htons(server_port_num);
target.sin_addr.s_addr = hostname;
if (connect(s, (SOCKADDR *)&target, sizeof(target)) == SOCKET_ERROR)
{
MessageBox(hwnd, TEXT("999"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
return 0;
}
WSAAsyncSelect(s, hwnd, CUST_MSG, FD_READ | FD_CONNECT | FD_CLOSE);
我發送數據,其接收和輸出在服務器控制檯上:
int nret = send(s, buffer, strlen(buffer), 0);
然後我嘗試將一些數據發送回在同一臺服務器事件接收數據:
this.socket.on('data', function (buffer) {
try {
logger.warn(buffer + "\n");
socket.emit('message', 'psst, wanna buy some macaroni?');
//that.messageHandler(that, buffer);
} catch (err) {
logger.warn('Protocol ' + err + ' ' + that.socket.remoteAddress);
that.dispose();
}
});
我有一個消息循環,但它不檢測亂七八糟從socket.emit()發送的年齡:
MSG msg;
while (GetMessage(&msg, NULL, 0, 0) > 0)
{
if (numBytes > 0) {
wchar_t buffer[256];
wsprintfW(buffer, L"%d", numBytes);
MessageBox(hwnd, buffer, TEXT(""), MB_OK | MB_ICONEXCLAMATION);
}
TranslateMessage(&msg);
DispatchMessage(&msg);
}
//MESSAGE LOOP FUNCTION:
LRESULT CALLBACK WndProc(HWND hwnd, UINT message, WPARAM wParam, LPARAM lParam)
{
switch (message) //handle the messages
{
case CUST_MSG: //Is a message being sent?
{
switch (lParam) //If so, which one is it?
{
case FD_ACCEPT:
MessageBox(hwnd, TEXT("accept"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
accept(wParam, NULL, NULL);
break;
case FD_CONNECT:
MessageBox(hwnd, TEXT("connect"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
break;
case FD_READ:
char buffer[80];
int byte_num;
memset(buffer, 0, sizeof(buffer));
byte_num = recv(wParam, buffer, sizeof(buffer) - 1, 0);
MessageBox(hwnd, TEXT("READING"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
numBytes += byte_num;
break;
case FD_CLOSE:
//MessageBox(hwnd, TEXT("close"), TEXT(""), MB_OK | MB_ICONEXCLAMATION);
break;
}
}
當我改變該程序的位和從客戶端將數據發送到所述客戶端相同的循環正確地檢測的消息。我嘗試過繞過bind(),listen(),recv(),但我無法使用節點獲取FD_READ消息。我嘗試過在同一臺計算機上運行的客戶端和服務器,以及同一本地網絡上的不同計算機。