我试图在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消息。我尝试过在同一台计算机上运行的客户端和服务器,以及同一本地网络上的不同计算机。