UDP Hole Punching - P2P

BeefyX · 19. Juni 2012, 22:32

Hallooo Leute..
Nach lange suchen bei Google und jeder Menge Wikipedia blieb ich doch stecken, bei meinem Problem...
Ich habe einen UDP Server ("Master Server"), der immer Port 8000 hat (beispiel).
Master Server ist einfach mal der hier: 200.200.100.100:8000
Dann habe ich Client A (LAN: 192.168.2.117:5123 WAN: 217.232.200.100:13337) und
Client B (LAN: 192.168.1.143:7851 WAN: 142.85.33.123:9412).
Per Packets von beiden Clienten hat mein Master Server nun die LAN und WAN daten gesammelt.
Der Master Server sendet nun die Daten von Client A zu Client B. Und zu Client A sendet er die von Client B.
Nun dürften beide eigentlich miteinander kommunizieren? (Man beachte: [bei mir jedenfalls] ist der LAN Port immer wie der WAN Port).

Also so in etwa ist das dann:

192.168.2.117:5123 -> 217.232.200.100:13337 -> 200.200.100.100:8000
192.168.1.143:7851 -> 142.85.33.123:9412 -> 200.200.100.100:8000
200.200.100.100:8000 sagt 217.232.200.100:13337 soll auf 142.85.33.123:9412 verbinden.
200.200.100.100:8000 sagt 142.85.33.123:9412 soll auf 217.232.200.100:13337 verbinden.

Also siehts so aus:

192.168.2.117:5123 -> 217.232.200.100:13337 -> 142.85.33.123:9412 -> 192.168.1.143:7851

Und wieso geht das bei mir nicht?
Oder habe ich das mit dem Hole Punching / P2P nicht wirklich verstanden?
Soweit ich weiss wird (wenn ich iwo hin connecte) ein lokaler port bei mir temporär geöffnet: Also z.b. 9412, 7851, 5123 oder 13337 (LAN und WAN Port? Weiss ich nicht genau...).

Könnte mir das bitte jemand besser erklären als bei Wikipedia?
Oder mir was nützliches geben?
Ich bin schon am verzweifeln!

Edit by nikeee13:
Da es sich hier wohl um eine PHP-Frage handelt: Topic verschoben.
Außerdem: Die Farbe Rot ist den Moderatoren vorbehalten.

joscha999 · 19. Juni 2012, 22:36

Nun dürften beide eigentlich miteinander kommunizieren?

nope ohne die ports/ den port auf zu haben funzt das nicht so einfach

hab ich auch schon oft versucht

Gelöschter Benutzer · 19. Juni 2012, 22:52

derp, doch klar. du musst den selben socket nutzen den du auch zum ermitteln des ports genutzt hast. der client darf afaik auch keine antwort kriegen, allerdings hat sone connection auch nen timeout, meist ne minute oderso. es gibt auch router die bei jeder connection nen neuen random port oeffnen, da funktionieet das ganze nicht

edit: zeig uns doch mal dein code

BeefyX · 20. Juni 2012, 13:07

Naja es geht hier um ein Server für ein Spiel... Nur für mich, was privates.

udpserver.php

Spoiler anzeigen

PHP-Quellcode

<?php
include("functions.php");
$strServerIp = '0.0.0.0';
$intServerPort = 5350;
WriteLine("Server", "Server starting ".$strServerIp.":".$intServerPort." ...");
include("data.php");
include("data/mysql.php");
$objMysql = new MysqlClass($arrMysqlData['host'], $arrMysqlData['user'], $arrMysqlData['password'], $arrMysqlData['database']);
WriteLine("MySQL", "Successfully connected to ".$objMysql->getHost()." as '".$objMysql->getUser()."'");
$objServer = stream_socket_server("udp://".$strServerIp.":".$intServerPort, $errno, $errstr, STREAM_SERVER_BIND);
$arrIpData = array();
if($objServer)
{
WriteLine("Server", "Server running on ".$strServerIp.":".$intServerPort." !");
while(true)
{
$strReceived = stream_socket_recvfrom($objServer, 1024, 0, $objPeer);
$strAnalyzedPacket = analyzePacket($strReceived, $objPeer);
stream_socket_sendto($objServer, $strAnalyzedPacket, 0, $objPeer);
}
}
else
{
WriteLine("Server", "Could not start UDP Server on '".$strServerIp.":".$intServerPort);
WriteLine("Server", "Error #".$errno);
WriteLine("Server", $errstr);
}
function analyzePacket($strInput, $strFrom)
{
global $arrIpData;
global $objMysql;
global $objServer;
$arrChars = array();
for($intIndex = 0; $intIndex < strlen($strInput); $intIndex ++)
{
$arrChars[] = ord($strInput[$intIndex]);
}
$arrOutput = array();
//if(isset($strFrom) && isset($strInput) && isValidAddress($strFrom) == true && strlen($strInput > 4))
if(true)
{
if($arrChars[0] == 0x10 && $arrChars[1] == 0x1 && $arrChars[2] == 0x1)
{
$arrOutput = array(0x10, 0x1, 0x1, 0x0, 0x14, 0xE6, 0x0, 0x0, 0x0, 0x0);
$arrOutput[] = $arrChars[count($arrChars) - 4];
$arrOutput[] = $arrChars[count($arrChars) - 3];
$arrOutput[] = $arrChars[count($arrChars) - 2];
$arrOutput[] = $arrChars[count($arrChars) - 1];
$intUserId = bytesToDecimal(array($arrChars[count($arrChars) - 1], $arrChars[count($arrChars) - 2], $arrChars[count($arrChars) - 3], $arrChars[count($arrChars) - 4]));
$arrIpData[$strFrom] = array();
$arrIpData[$strFrom]['id'] = $intUserId;
}
elseif($arrChars[0] == 0x10 && $arrChars[1] == 0x10 && $arrChars[2] == 0x0 && $arrChars[14] == 0x21)
{
/*$arrOutput = array(0x10, 0x10, 0x0, 0x0, 0x0, 0x4,
0xFF, 0xFF, 0xFF, 0xFF, 0x0, 0x0, 0x0, 0x0, 0x21,
0x0, 0x0, 0x41, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0,
0x0, 0x0, 0x0, 0x1, 0x11, 0x13, 0x11, 0xDF, 0x21,
0xA1, 0x15, 0xBE, 0x1B, 0x11, 0x11, 0x11, 0x11,
0x11, 0x11, 0x11, 0x11, 0x1, 0x11, 0x13, 0x11,
0xF9, 0xEA, 0x1B, 0xC0, 0xBE, 0x1B, 0x19, 0x19,
0x19, 0x19, 0x19, 0x19, 0x19, 0x19, 0x11);*/
if(!isset($arrIpData[$strFrom]) || !is_array($arrIpData[$strFrom])) //packet is not authed
{
WriteLine("Server", "Cross Packet from ".$strFrom);
return;
}
$arrKeys = array(0x25, 0x10, 0x2525, 0x1010); //server key, client key
// REMOTE STUFF
$arrAddress = explode(":", $strFrom);
$strRemoteIP = $arrAddress[0];
$intRemotePort = $arrAddress[1];
$arrRemoteIP = explode(".", $strRemoteIP);
$arrRemotePort = splitInt($intRemotePort);
$arrIpData[$strFrom]['remoteip'] = $strRemoteIP;
array_reverse($arrRemotePort); //fasten make good crap
$intRemotePort = bytesToDecimal($arrRemotePort);
$arrIpData[$strFrom]['remoteport'] = $intRemotePort;
// LOCAL STUFF
$arrLocalIP = array($arrChars[34], $arrChars[35], $arrChars[36], $arrChars[37]);
$arrLocalIP[0] = XorFix($arrLocalIP[0], $arrKeys[1]);
$arrLocalIP[1] = XorFix($arrLocalIP[1], $arrKeys[1]);
$arrLocalIP[2] = XorFix($arrLocalIP[2], $arrKeys[1]);
$arrLocalIP[3] = XorFix($arrLocalIP[3], $arrKeys[1]);
array_reverse($arrLocalIP);
$strLocalIP = implode(".", $arrLocalIP);
$arrLocalPort = array($arrChars[32], $arrChars[33]);
$arrLocalPort[0] = XorFix($arrLocalPort[0], $arrKeys[1]);
$arrLocalPort[1] = XorFix($arrLocalPort[1], $arrKeys[1]);
//array_reverse($arrLocalPort);
$intLocalPort = bytesToDecimal($arrLocalPort);
$arrIpData[$strFrom]['localip'] = $strLocalIP;
$arrIpData[$strFrom]['localport'] = $intLocalPort;
array_reverse($arrRemoteIP);
$intRemoteDecimal = bytesToDecimal($arrRemoteIP);
$intLocalDecimal = bytesToDecimal($arrLocalIP);
WriteLine("UDP", "Setting network for #".$arrIpData[$strFrom]['id']." [".$strFrom."] to [".$intRemoteDecimal.":".$intRemotePort." ; ".$intLocalDecimal.":".$intLocalPort." (".$strLocalIP.":".$intLocalPort.")]");
$objMysql->query("UPDATE `peer` SET `remoteip` = '".$arrIpData[$strFrom]['remoteip']."', `remoteport` = '".$arrIpData[$strFrom]['remoteport']."', `localip` = '".$arrIpData[$strFrom]['localip']."', `localport` = '".$arrIpData[$strFrom]['localport']."', `c_remoteip`='".$intRemoteDecimal."', `c_localip`='".$intLocalDecimal."' WHERE `peer`.`userid` = '".$arrIpData[$strFrom]['id']."';");
// MAKE GOOD STUFF OUT OF IT (REMOTE)
$arrRemoteIP[0] = XorFix($arrRemoteIP[0], $arrKeys[0]);
$arrRemoteIP[1] = XorFix($arrRemoteIP[1], $arrKeys[0]);
$arrRemoteIP[2] = XorFix($arrRemoteIP[2], $arrKeys[0]);
$arrRemoteIP[3] = XorFix($arrRemoteIP[3], $arrKeys[0]);
$arrRemotePort[0] = XorFix($arrRemotePort[0], $arrKeys[0]);
$arrRemotePort[1] = XorFix($arrRemotePort[1], $arrKeys[0]);
// MAKE GOOD STUFF OUT OF IT (LOCAL)
$arrLocalIP[0] = XorFix($arrLocalIP[0], $arrKeys[0]);
$arrLocalIP[1] = XorFix($arrLocalIP[1], $arrKeys[0]);
$arrLocalIP[2] = XorFix($arrLocalIP[2], $arrKeys[0]);
$arrLocalIP[3] = XorFix($arrLocalIP[3], $arrKeys[0]);
array_reverse($arrLocalIP);
$arrLocalPort[0] = XorFix($arrLocalPort[0], $arrKeys[0]);
$arrLocalPort[1] = XorFix($arrLocalPort[1], $arrKeys[0]);
array_reverse($arrLocalPort);
$arrOutput = array(0x10, 0x10, 0x00, 0x00, $arrChars[4], $arrChars[5],
0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00, 0x21,
0x0, 0x0, 0x41, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0,
0x0, 0x0, 0x0, 0x35, 0x25, 0x27, 0x25, $arrRemotePort[0], $arrRemotePort[1],
$arrRemoteIP[0], $arrRemoteIP[1], $arrRemoteIP[2], $arrRemoteIP[3],
0x25, 0x25, 0x25, 0x25, 0x25, 0x25, 0x25, 0x25, 0x35,
0x25, 0x27, 0x25, $arrLocalPort[0], $arrLocalPort[1],
$arrLocalIP[3], $arrLocalIP[2], $arrLocalIP[1], $arrLocalIP[0],
0x2D, 0x2D, 0x2D, 0x2D, 0x2D, 0x2D, 0x2D, 0x2D, 0x25);
/*
0xDF 0x21 -> 0xF6 0x3A
0xF9 0xEA -> 0xCD 0x74
0xA1 0x15 0xBE 0x1B -> 0x3F 0x62 0x20 0x85
0xCD 0x74 -> 0xEA 0x19
OLD
$arrOutput = array(0x10, 0x10, 0x0, 0x0, 0x2, 0x3B,
0xFF, 0xFF, 0xFF, 0xFF, 0x0, 0x0, 0x0, 0x0, 0x21,
0x0, 0x0, 0x41, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0,
0x0, 0x0, 0x0, 0x1, 0x11, 0x13, 0x11, 0x1F, 0x19,
0xC8, 0xF9, 0x53, 0x96, 0x11, 0x11, 0x11, 0x11,
0x11, 0x11, 0x11, 0x11, 0x1, 0x11, 0x13, 0x11,
0x1F, 0x19, 0x1A, 0x7, 0x30, 0x3D, 0x19, 0x19,
0x19, 0x19, 0x19, 0x19, 0x19, 0x19, 0x11);
*/
}
elseif($arrChars[0] == 0x10 && $arrChars[1] == 0x10 && $arrChars[2] == 0x0 && $arrChars[14] == 0x31)
{
foreach($arrIpData as $strKey => $strValue)
{
//stream_socket_sendto($objServer, arrToString($arrChars), 0, $strKey);
}
}
else
{
WriteLine("UDP", "Uknown packet: ".hexString($strInput));
}
}
else
{
WriteLine("UDP", "Invalid UDP Packet from ".$strFrom."!");
}
return arrToString($arrOutput);
}
function arrToString($arrInput)
{
$strOutput = '';
for($intIndex = 0; $intIndex < count($arrInput); $intIndex ++)
{
$strOutput .= chr($arrInput[$intIndex]);
}
return $strOutput;
}
function splitInt($intInput)
{
$strBinary = decbin($intInput);
if(strlen($strBinary) < 16)
{
for($intIndex = strlen($strBinary); $intIndex < 16; $intIndex ++)
{
$strBinary = "0" . $strBinary;
}
}
$intByteA = $strBinary[0].$strBinary[1].$strBinary[2].$strBinary[3].$strBinary[4].$strBinary[5].$strBinary[6].$strBinary[7];
$intByteB = $strBinary[8].$strBinary[9].$strBinary[10].$strBinary[11].$strBinary[12].$strBinary[13].$strBinary[14].$strBinary[15];
return array(bindec($intByteA), bindec($intByteB));
}
function hexString($strInput)
{
$strFinalHex = '';
for($intIndex = 0; $intIndex < strlen($strInput); $intIndex ++)
{
$strFinalHex .= dechex(ord($strInput[$intIndex])). " ";
}
return $strFinalHex;
}
function isValidAddress($strAddress)
{
$arrAddress = explode(":", $strAddress);
if(count($arrAddress) != 2)
{
return false;
}
$strIP = $arrAddress[0];
$intPort = $arrAddress[1];
if(is_numeric($intPort) && $intPort > 0 && $intPort < 65536)
{
$arrIP = explode(".", $strIp);
if(count($arrIp) == 4 && is_numeric($arrIP[0]) && is_numeric($arrIP[1]) && is_numeric($arrIP[2]) && is_numeric($arrIP[3]))
{
return true;
}
}
else
{
return false;
}
}
function ip2ulong($arrIpAddress)
{
return $arrIpAddress[0] << 24 + $arrIpAddress[1] << 16 + $arrIpAddress[2] << 8 + $arrIpAddress[3];
}
?>

network/game/29952_playerlist.php

Spoiler anzeigen

PHP-Quellcode

<?php
class gSvPlayerlist extends Packet
{
public function __construct($arrPlayers, $objRoom, $objSelf = NULL)
{
global $GameOperationcodes;
parent::__construct(Crypter::PACKETTYPE_Game(), $GameOperationcodes['SvPlayersInRoom']);
$this->addBlock(count($arrPlayers)); // + 24);
$objMarlon = NULL;
foreach($arrPlayers as $objHandler)
{
$objPlayer = $objHandler->getUser();
$objPlayer->refreshIpData();
$this->addBlock($objPlayer->getUserId());
$this->addBlock($objPlayer->getSessionId());
$this->addBlock($objRoom->getPlayerSlot($objHandler));
$this->addBlock($objPlayer->getReadyState());
$this->addBlock($objRoom->getTeam($objHandler));
$this->addBlock(0);
$this->addBlock(0);
$this->addBlock(0);
$this->addBlock(1000);
$this->addBlock($objPlayer->getNickname());
$this->addBlock(-1); //clan id?
$this->addBlock(-1); //clan member?
$this->addBlock(-1); //wtf
$this->addBlock($objPlayer->getUserId() + 1);
$this->addBlock($objPlayer->getUserId());
$this->addBlock($objPlayer->getUniqId());
$this->addBlock($objPlayer->getPremium());
$this->addBlock(0);
$this->addBlock(-1);
$this->addBlock($objPlayer->getKills());
$this->addBlock($objPlayer->getDeaths());
$this->addBlock(1000);
$this->addBlock($objPlayer->getExp());
$this->addBlock(-1);
$this->addBlock(-1);
if($objHandler == $objRoom->getMaster())
{
$this->addBlock("ÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿÿ");
}
else
{
$this->addBlock(1);
}
$this->addBlock($objPlayer->getIpData('remote'));
$this->addBlock($objPlayer->getIpData('remotep'));
$this->addBlock($objPlayer->getIpData('local'));
$this->addBlock($objPlayer->getIpData('localp'));
$this->addBlock(0);
}
echo $this->getPacket()."\n";
/* global $objMysql;
for($intIndex = 8; $intIndex < 32; $intIndex ++)
{
$objPlayer = $objMarlon->getUser();
$this->addBlock($objPlayer->getUserId() + 1);
$this->addBlock($objPlayer->getSessionId() + 1);
$this->addBlock($intIndex);
$this->addBlock($objPlayer->getReadyState());
$this->addBlock(1);
$this->addBlock(0);
$this->addBlock(0);
$this->addBlock(0);
$this->addBlock(1000);
$this->addBlock($objPlayer->getNickname()."-TestFucker".$intIndex);
$this->addBlock(-1);
$this->addBlock(-1);
$this->addBlock(-1);
$this->addBlock(0);
$this->addBlock(19);
$this->addBlock(910);
$this->addBlock($objPlayer->getPremium());
$this->addBlock(0);
$this->addBlock(-1);
$this->addBlock($objPlayer->getKills());
$this->addBlock($objPlayer->getDeaths());
$this->addBlock(551513);
$this->addBlock($objPlayer->getExp());
$this->addBlock(-1);
$this->addBlock(-1);
$this->addBlock(1); //can be yyyyyy too...
$this->addBlock($objPlayer->getIpData('remote'));
$objQuery = $objMysql->query("SELECT `port` FROM `marlon` WHERE `id`='".$intIndex."'");
$objRow = mysql_fetch_array($objQuery);
$this->addBlock($objRow['port']);
$this->addBlock($objPlayer->getIpData('local'));
$this->addBlock($objRow['port']);
$this->addBlock(0);
}
WriteLine("Game", $this->getPacket()); */
}
}
?>

Edit by nikeee13:
Bei langen Codeausschnitten bitte den Expander-Tag verwenden!
Expander hinzugefügt.

UDP Hole Punching - P2P

UDP Hole Punching - P2P

PHP-Quellcode

PHP-Quellcode

Benutzer online 1

Ähnliche Themen

1 Benutzer hat hier geschrieben