A jelz\u00e9s szorosan \u00f6sszef\u00fcgg a k\u00f6vetkez\u0151 r\u00e9szben bemutatott socket megval\u00f3s\u00edt\u00e1sunkkal.<\/li>\n<\/ul>\n\n![\"\u00c1tkonvert\u00e1ljuk](\"\/wp-content\/uploads\/2019\/09\/5e30bc22643f8baecf850053bf69e130.jpg\")
\nA j\u00e1t\u00e9kbeli \u00e9s a f\u0151oldalon l\u00e9v\u0151 szerverek list\u00e1ja<\/i><\/p>\nSocket megval\u00f3s\u00edt\u00e1s<\/h1>\n
\nEgy olyan API-t szeretn\u00e9nk l\u00e9trehozni, amely a lehet\u0151 legk\u00f6zelebb \u00e1ll a Posix UDP Sockets-hoz, hogy minimaliz\u00e1ljuk a sz\u00fcks\u00e9ges v\u00e1ltoztat\u00e1sok sz\u00e1m\u00e1t.<\/p>\n
A legsz\u00fcks\u00e9gesebb minim\u00e1lis funkci\u00f3kat szeretn\u00e9nk megval\u00f3s\u00edtani a legegyszer\u0171bb h\u00e1l\u00f3zati adatcser\u00e9hez.<\/p>\n
P\u00e9ld\u00e1ul nincs sz\u00fcks\u00e9g\u00fcnk val\u00f3di \u00fatv\u00e1laszt\u00e1sra: minden peer egy virtu\u00e1lis \"LAN\"-ban tal\u00e1lhat\u00f3, amely egy adott Firebase adatb\u00e1zishoz kapcsol\u00f3dik.<\/p>\n
Ennek megfelel\u0151en nincs sz\u00fcks\u00e9g\u00fcnk egyedi IP-c\u00edmekre: a peer-ek egyedi azonos\u00edt\u00e1s\u00e1hoz elegend\u0151, ha a Firebase egyedi kulcs\u00e9rt\u00e9keit haszn\u00e1ljuk (haszn\u00e1lhat\u00f3 domainnevek szerint), \u00e9s minden peer helyben \"\u00e1l\" IP-c\u00edmeket rendel a megfelel\u0151 kulcshoz, amelyet le kell ford\u00edtani. Ez teljesen megsz\u00fcnteti a glob\u00e1lis IP-c\u00edmek kioszt\u00e1s\u00e1nak sz\u00fcks\u00e9gess\u00e9g\u00e9t, ami nem trivi\u00e1lis feladat.<\/p>\n
Itt van a minim\u00e1lis API, amelyet meg kell val\u00f3s\u00edtanunk:<\/p>\n
\/\/ Create and destroy a socket\nint socket();\nint close(int fd);\n\/\/ Bind a socket to a port, and publish it on Firebase\nint bind(int fd, AddrInfo* addr);\n\/\/ Send a packet. This lazily create a WebRTC connection to the \n\/\/ peer when necessary\nint sendto(int fd, uint8_t* buf, int len, const AddrInfo* addr);\n\/\/ Receive the packets destined to this socket\nint recvfrom(int fd, uint8_t* buf, int len, AddrInfo* addr);\n\/\/ Be notified when new packets arrived\nint recvCallback(Callback cb);\n\/\/ Obtain a local ip address for this peer key\nuint32_t resolve(client::String* key);\n\/\/ Get the peer key for this ip\nString* reverseResolve(uint32_t addr);\n\/\/ Get the local peer key\nString* local_key();\n\/\/ Initialize the library with the given Firebase database and \n\/\/ WebRTc connection options\nvoid init(client::FirebaseConfig* fb, client::RTCConfiguration* ice);<\/code><\/pre>\n\nAz API egyszer\u0171 \u00e9s hasonl\u00edt a Posix Sockets API-hoz, de van n\u00e9h\u00e1ny fontos elt\u00e9r\u00e9se: visszah\u00edv\u00e1sok regisztr\u00e1l\u00e1sa, helyi IP-k kioszt\u00e1sa \u00e9s \"lusta\" csatlakoztat\u00e1s<\/strong>.<\/p>\nVisszah\u00edv\u00e1sok regisztr\u00e1l\u00e1sa<\/h2>\n
\nM\u00e9g ha az alapprogram nem blokkol\u00f3 bemeneti-kimenetet haszn\u00e1l is, a webb\u00f6ng\u00e9sz\u0151ben val\u00f3 futtat\u00e1shoz a k\u00f3dot refaktor\u00e1lni kell.<\/p>\n
Ennek az az oka, hogy az esem\u00e9nyciklus a b\u00f6ng\u00e9sz\u0151ben rejtve van a program el\u0151l (legyen sz\u00f3 JavaScript-r\u0151l vagy WebAssembly-r\u0151l).<\/p>\n
Nat\u00edv k\u00f6rnyezetben ilyen m\u00f3don \u00edrhatunk k\u00f3dot<\/p>\n
while(running) {\n select(...); \/\/ v\u00e1rakoz\u00e1s I\/O esem\u00e9nyekre\n while(true) {\n int r = readfrom(...); \/\/ pr\u00f3b\u00e1lkoz\u00e1s az olvas\u00e1ssal\n if (r < 0 && errno == EWOULDBLOCK) \/\/ nincs t\u00f6bb el\u00e9rhet\u0151 adat\n break;\n ...\n }\n ...\n}<\/code><\/pre>\n\nHa az esem\u00e9nyciklus rejtve van el\u0151tt\u00fcnk, akkor azt ilyesmiv\u00e9 kell alak\u00edtanunk:<\/p>\n
auto cb = []() { \/\/ ezt h\u00edvj\u00e1k meg, amikor \u00faj adatok \u00e9rhet\u0151k el\n while(true) {\n int r = readfrom(...); \/\/ pr\u00f3b\u00e1lkoz\u00e1s az olvas\u00e1ssal\n if (r < 0 && errno == EWOULDBLOCK) \/\/ nincs t\u00f6bb el\u00e9rhet\u0151 adat\n break;\n ...\n }\n ...\n};\nrecvCallback(cb); \/\/ a visszah\u00edv\u00e1s regisztr\u00e1l\u00e1sa<\/code><\/pre>\n<\/p>\n
Helyi IP-k feladata<\/h2>\n
\nA csom\u00f3pontok az \u00abh\u00e1l\u00f3zatunkban\u00bb nem IP-c\u00edmek, hanem Firebase kulcsok (ezek olyan karakterl\u00e1ncok, amelyek \u00edgy n\u00e9znek ki: -LmEC50PYZLCiCP-vqde<\/code> ).<\/p>\nEz k\u00e9nyelmes, mert nincs sz\u00fcks\u00e9g\u00fcnk IP-k kioszt\u00e1s\u00e1nak mechanizmus\u00e1ra \u00e9s azok egyedis\u00e9g\u00e9nek ellen\u0151rz\u00e9s\u00e9re (valamint azok elt\u00e1vol\u00edt\u00e1s\u00e1ra az \u00fcgyf\u00e9l lekapcsol\u00e1sa ut\u00e1n), de gyakran sz\u00fcks\u00e9ges a peer-ek azonos\u00edt\u00e1sa numerikus \u00e9rt\u00e9k alapj\u00e1n.<\/p>\n
Ez\u00e9rt haszn\u00e1ljuk a k\u00f6vetkez\u0151 funkci\u00f3kat resolve<\/code> \u00e9s reverseResolve<\/code>: az alkalmaz\u00e1s valamilyen m\u00f3don megszerzi a kulcs string \u00e9rt\u00e9k\u00e9t (felhaszn\u00e1l\u00f3i bevitel vagy mesterszerver \u00fatj\u00e1n), \u00e9s \u00e1t tudja alak\u00edtani IP-c\u00edmm\u00e9 a bels\u0151 haszn\u00e1lat \u00e9rdek\u00e9ben. Az API t\u00f6bbi r\u00e9sze is egyszer\u0171s\u00e9g kedv\u00e9\u00e9rt ezt az \u00e9rt\u00e9ket kapja \u00fajra, nem string form\u00e1j\u00e1ban.<\/p>\nEz hasonl\u00edt a DNS keres\u00e9sre, csak a kliensn\u00e9l helyben t\u00f6rt\u00e9nik.<\/p>\n
Teh\u00e1t az IP-c\u00edmek nem lehetnek k\u00f6z\u00f6sek k\u00fcl\u00f6nb\u00f6z\u0151 kliensek k\u00f6z\u00f6tt, \u00e9s ha valamilyen glob\u00e1lis azonos\u00edt\u00f3ra van sz\u00fcks\u00e9g, azt m\u00e1s m\u00f3don kell gener\u00e1lni.<\/p>\n
Lusta kapcsolat<\/h2>\n
\nAz UDP-nek nincs sz\u00fcks\u00e9ge kapcsolatra, de mint l\u00e1ttuk, miel\u0151tt adatokat elkezden\u00e9nk \u00e1tadni k\u00e9t peer k\u00f6z\u00f6tt, a WebRTC hossz\u00fa kapcsolati folyamatot ig\u00e9nyel.<\/p>\n
Ha ugyanazt az absztrakci\u00f3s szintet szeretn\u00e9nk biztos\u00edtani, (sendto<\/code>\/recvfrom<\/code> tetsz\u0151leges peerekkel el\u0151zetes kapcsol\u00f3d\u00e1s n\u00e9lk\u00fcl), akkor a bels\u0151 API-ban \u00ablusta\u00bb (k\u00e9sleltetett) kapcsolatot kell l\u00e9trehoznunk.<\/p>\nItt van, mi t\u00f6rt\u00e9nik az adatcser\u00e9n\u00e9l a \u00abszerver\u00bb \u00e9s a \u00abkliensek\u00bb k\u00f6z\u00f6tt UDP haszn\u00e1latakor, \u00e9s mit kell megval\u00f3s\u00edtania a k\u00f6nyvt\u00e1runknak:<\/p>\n
\n- A szerver megh\u00edvja
bind()<\/code>, hogy \u00e9rtes\u00edtse az oper\u00e1ci\u00f3s rendszert, hogy csomagokat szeretne fogadni a megadott porton.<\/li>\n<\/ul>\n\nEhelyett a Firebase-en k\u00f6zz\u00e9tesz\u00fcnk egy nyitott portot a szerver kulcsak\u00e9nt, \u00e9s figyelj\u00fck az esem\u00e9nyeket annak a lefel\u00e9 mutat\u00f3 \u00e1gain.<\/p>\n
\n- A szerver megh\u00edvja
recvfrom()<\/code>, fogadva a portj\u00e1ra \u00e9rkez\u0151 csomagokat b\u00e1rmely hostb\u00f3l.<\/li>\n<\/ul>\n\nA mi eset\u00fcnkben ellen\u0151rizn\u00fcnk kell a bej\u00f6v\u0151 csomagok sor\u00e1t, amelyeket erre a portra k\u00fcldtek.<\/p>\n
Minden port saj\u00e1t sorral rendelkezik, \u00e9s a WebRTC datagramjak\u00e9nt hozz\u00e1adjuk a forr\u00e1st \u00e9s a c\u00e9lportot, hogy tudjuk, hov\u00e1 ir\u00e1ny\u00edtsuk az \u00e9rkez\u0151 \u00faj csomagot.<\/p>\n
A h\u00edv\u00e1s nem blokkol\u00f3, \u00edgy ha nincsenek csomagok, egyszer\u0171en -1-et adunk vissza, \u00e9s be\u00e1ll\u00edtjuk errno=EWOULDBLOCK<\/code>.<\/p>\n\n- Az \u00fcgyf\u00e9l valamilyen k\u00fcls\u0151 m\u00f3don megszerzi a szerver IP-c\u00edm\u00e9t \u00e9s portj\u00e1t, \u00e9s megh\u00edvja
sendto()<\/code>. Ezenk\u00edv\u00fcl bels\u0151 h\u00edv\u00e1s is zajlik, \u00edgy a k\u00f6vetkez\u0151 bind()<\/code>v\u00e1laszt fog kapni a bind explicite v\u00e9grehajt\u00e1sa n\u00e9lk\u00fcl. recvfrom()<\/code> v\u00e1lasz fog j\u00f6nni an\u00e9lk\u00fcl, hogy a bind kifejezett v\u00e9grehajt\u00e1sa t\u00f6rt\u00e9nne.<\/li>\n<\/ul>\n\nEbben az esetben a kliens k\u00fcls\u0151leg egy karakterl\u00e1nc kulcsot kap, \u00e9s haszn\u00e1lja a funkci\u00f3t resolve()<\/code> az IP-c\u00edm megszerz\u00e9s\u00e9hez.<\/p>\nEbben a szakaszban elkezdj\u00fck a WebRTC \u201ek\u00e9zfog\u00e1s\u00e1t\u201d, ha a k\u00e9t peer m\u00e9g nem csatlakozott egym\u00e1shoz. K\u00fcl\u00f6nb\u00f6z\u0151 portok csatlakoz\u00e1sa egy peeren ugyanazt a WebRTC DataChannel-t haszn\u00e1lja.<\/p>\n
Tov\u00e1bb\u00e1 k\u00f6zvetett bind()<\/code>, hogy a szerver a k\u00f6vetkez\u0151 alkalommal helyre tudja \u00e1ll\u00edtani a kapcsolatot, sendto()<\/code> ha valamilyen okb\u00f3l megszakad.<\/p>\nA szerver \u00e9rtes\u00edt\u00e9st kap a kliens csatlakoz\u00e1s\u00e1r\u00f3l, amikor a kliens r\u00f6gz\u00edti SDP aj\u00e1nlat\u00e1t a szerver portinform\u00e1ci\u00f3j\u00e1val a Firebase-en, \u00e9s a szerver ott is v\u00e1laszol az aj\u00e1nlatra.<\/p>\n
\nAz al\u00e1bbi \u00e1br\u00e1n a socket s\u00e9ma \u00fczeneteinek \u00e1raml\u00e1s\u00e1t \u00e9s az els\u0151 \u00fczenet kliensr\u0151l a szerverre val\u00f3 tov\u00e1bb\u00edt\u00e1s\u00e1t l\u00e1thatjuk:<\/p>\n
![\"\u00c1tkonvert\u00e1ljuk](\"\/wp-content\/uploads\/2019\/09\/7dc48e816c09e33daf28c307cad0c258.jpg\")
\nA kliens \u00e9s a szerver k\u00f6z\u00f6tti csatlakoz\u00e1si szakasz teljes s\u00e9m\u00e1ja<\/i><\/p>\nZ\u00e1r\u00e1s<\/h1>\n
\nHa v\u00e9gigolvastad, val\u00f3sz\u00edn\u0171leg \u00e9rdekelne, hogy a gyakorlatban is l\u00e1sd a te\u00f3ri\u00e1t. J\u00e1tszhatsz a