我正在为一款游戏开发非常简单的大厅系统。每个客户端会定期通过UDP广播两个数据包,以便最初发现其他客户端并传输用户信息、准备状态等。该游戏正在同时开发适用于Windows和Linux(32位和64位)。
在Windows端,我已经完美地实现了大厅系统。当我在一个Windows机器上进入大厅时,其他机器上也会弹出此人的信息。同样地,准备状态检查和断开连接也可以立即检测到。换句话说,它正常工作。
现在问题来了:Linux。网络代码基本相同,只是需要进行一些必要的平台特定更改。我首先尝试了Windows<->Linux,使用Wireshark,我发现Linux方确实正在广播数据包并从Windows接收数据包,但游戏却没有捕获数据包。我发现了我的select语句中的一个错误(套接字而不是套接字+1),但是修复它没有帮助。Windows方正在广播数据包,但根本无法从Linux方接收数据包!
然后我尝试了Linux<->Linux,但是发现即使两台机器都在广播和接收数据包(再次通过Wireshark确认),两台机器上的游戏也不能“看到”数据包。
我很确定这不是防火墙问题(关闭所有防火墙进行测试,然后再次打开防火墙,但两个平台都没有任何变化),而且网络连接似乎没问题(可以手动ping每个主机)。我还检查了端口是否可用(它们是可用的)。
以下是广播数据包的代码:
为什么当我可以看到数据包到达时,
在Windows端,我已经完美地实现了大厅系统。当我在一个Windows机器上进入大厅时,其他机器上也会弹出此人的信息。同样地,准备状态检查和断开连接也可以立即检测到。换句话说,它正常工作。
现在问题来了:Linux。网络代码基本相同,只是需要进行一些必要的平台特定更改。我首先尝试了Windows<->Linux,使用Wireshark,我发现Linux方确实正在广播数据包并从Windows接收数据包,但游戏却没有捕获数据包。我发现了我的select语句中的一个错误(套接字而不是套接字+1),但是修复它没有帮助。Windows方正在广播数据包,但根本无法从Linux方接收数据包!
然后我尝试了Linux<->Linux,但是发现即使两台机器都在广播和接收数据包(再次通过Wireshark确认),两台机器上的游戏也不能“看到”数据包。
我很确定这不是防火墙问题(关闭所有防火墙进行测试,然后再次打开防火墙,但两个平台都没有任何变化),而且网络连接似乎没问题(可以手动ping每个主机)。我还检查了端口是否可用(它们是可用的)。
以下是广播数据包的代码:
void NetworkLinux::BroadcastMessage(const std::string &msg,
const char prefix)
{
string data(prefix + msg);
if (sendto(linuxSocket, data.c_str(), static_cast<int>(data.length()), 0,
reinterpret_cast<sockaddr*>(&broadcastAddr), sizeof(broadcastAddr)) == -1)
{
Display_PError("sendto");
}
}
接收数据包的代码:
const Message NetworkLinux::ReceiveMessage()
{
char buffer[recvBufferLength];
fill(buffer, buffer + recvBufferLength, 0);
sockaddr_in sender;
int senderLen = sizeof(sender);
fd_set read_fds;
FD_ZERO(&read_fds);
FD_SET(linuxSocket, &read_fds);
timeval time;
time.tv_sec = 0;
time.tv_usec = 16667; // microseconds, so this is ~1/60 sec
int selectResult = select(linuxSocket + 1, &read_fds,
nullptr, nullptr, &time);
if (selectResult == -1)
{
Display_PError("select");
}
else if (selectResult > 0) // 0 means it timed-out
{
int receivedBytes = recvfrom(linuxSocket, buffer,
recvBufferLength, 0, reinterpret_cast<sockaddr*>(&sender),
reinterpret_cast<socklen_t*>(&senderLen));
if (receivedBytes == -1)
{
Display_PError("recvfrom");
}
else if (receivedBytes > 0)
{
Message msg;
msg.prefix = buffer[0];
msg.msg = string(buffer + 1, buffer + receivedBytes);
msg.address = sender.sin_addr;
return msg;
}
}
Message m;
m.prefix = 'N';
return m;
}
为什么当我可以看到数据包到达时,
select()
函数返回0?此外,为什么它能在Windows<->Windows的情况下工作,但不能在Linux<->Linux或Linux<->Windows的情况下工作?
编辑:这里是socket创建/设置代码,如请求所示。计算出的示例IP地址/广播地址为:192.168.1.3/192.168.1.255、192.168.1.5/192.168.1.255,与Windows侧生成和使用的相匹配。
bool NetworkLinux::StartUp()
{
// zero addr structures
memset(&machineAddr, 0, sizeof machineAddr);
memset(&broadcastAddr, 0, sizeof broadcastAddr);
// get this machine's IP and store it
machineAddr.sin_family = AF_INET;
machineAddr.sin_port = htons(portNumber);
inet_pton(AF_INET, GetIP().c_str(), &(machineAddr.sin_addr));
// get the netmask and calculate/store the correct broadcast address
broadcastAddr.sin_family = AF_INET;
broadcastAddr.sin_port = htons(portNumber);
GetNetMask();
broadcastAddr.sin_addr.s_addr = machineAddr.sin_addr.s_addr | ~netmask;
char bufIP[INET_ADDRSTRLEN], bufBroadcast[INET_ADDRSTRLEN];
inet_ntop(AF_INET, &machineAddr.sin_addr, bufIP, INET_ADDRSTRLEN);
inet_ntop(AF_INET, &broadcastAddr.sin_addr, bufBroadcast,
INET_ADDRSTRLEN);
Log("IP is: " + string(bufIP) + "\nBroadcast address is: "
+ string(bufBroadcast));
// create socket
linuxSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
if (linuxSocket == -1)
{
Display_PError("socket");
return false;
}
Log("Socket created.");
// switch to broadcast mode
int broadcast = 1;
if (setsockopt(linuxSocket, SOL_SOCKET, SO_BROADCAST, &broadcast,
sizeof broadcast) == -1)
{
Display_PError("setsockopt");
close(linuxSocket);
return false;
}
Log("Socket switched to broadcast mode.");
// bind it (this simplifies things by making sure everyone is using the same port)
if (bind(linuxSocket, reinterpret_cast<sockaddr*>(&machineAddr),
sizeof(machineAddr)) == -1)
{
Display_PError("bind");
close(linuxSocket);
return false;
}
Log("Socket bound.");
return true;
}