Semnalizarea este str\u00e2ns legat\u0103 de implementarea noastr\u0103 a socket-urilor, descris\u0103 \u00een sec\u021biunea urm\u0103toare.<\/li>\n<\/ul>\n\nLista serverelor din joc \u0219i pe pagina principal\u0103<\/i><\/p>\nImplementarea socket-urilor<\/h1>\n
\nDorim s\u0103 cre\u0103m un API c\u00e2t mai apropiat de socket-urile Posix UDP, pentru a minimiza num\u0103rul de modific\u0103ri necesare.<\/p>\n
De asemenea, dorim s\u0103 implement\u0103m minimul necesar pentru un schimb de date simplu prin re\u021bea.<\/p>\n
De exemplu, nu avem nevoie de rutare real\u0103: toate nodurile se afl\u0103 \u00eentr-o \u201eLAN virtual\u0103\u201d, legat\u0103 de o instan\u021b\u0103 specific\u0103 a bazei de date Firebase.<\/p>\n
Prin urmare, nu avem nevoie de adrese IP unice: pentru identificarea unic\u0103 a nodurilor, este suficient s\u0103 folosim valori unice ale cheilor Firebase (similar cu numele de domenii), iar fiecare nod \u00ee\u0219i aloc\u0103 local \u201efalsuri\u201d IP pentru fiecare cheie care trebuie convertit\u0103. Acest lucru ne scute\u0219te complet de necesitatea aloc\u0103rii globale a adreselor IP, ceea ce este o sarcin\u0103 non-trivial\u0103.<\/p>\n
Iat\u0103 API-ul minim pe care trebuie s\u0103-l implement\u0103m:<\/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\nAPI-ul este simplu \u0219i seam\u0103n\u0103 cu API-ul socket-urilor Posix, dar are c\u00e2teva diferen\u021be importante: \u00eenregistrarea callback-urilor, alocarea IP-urilor locale \u0219i conexiune \u201elene\u0219\u0103\u201d<\/strong>.<\/p>\n\u00cenregistrarea callback-urilor<\/h2>\n \nChiar dac\u0103 programul ini\u021bial folose\u0219te intrare\/ie\u0219ire non-blocant\u0103, pentru a rula \u00een browserul web, codul trebuie refactorizat.<\/p>\n
Motivul este c\u0103 ciclul de evenimente din browser este ascuns de program (fie c\u0103 este vorba de JavaScript sau WebAssembly).<\/p>\n
\u00centr-un mediu nativ, putem scrie cod \u00een acest mod<\/p>\n
while(running) {\n select(...); \/\/ a\u0219teapt\u0103 evenimente I\/O\n while(true) {\n int r = readfrom(...); \/\/ \u00eencearc\u0103 s\u0103 citeasc\u0103\n if (r < 0 && errno == EWOULDBLOCK) \/\/ nu mai sunt date disponibile\n break;\n ...\n }\n ...\n}<\/code><\/pre>\n\nDac\u0103 ciclul de evenimente este ascuns pentru noi, atunci trebuie s\u0103-l transform\u0103m \u00eentr-un mod similar:<\/p>\n
auto cb = []() { \/\/ acest lucru va fi apelat c\u00e2nd sunt disponibile date noi\n while(true) {\n int r = readfrom(...); \/\/ \u00eencearc\u0103 s\u0103 citeasc\u0103\n if (r < 0 && errno == EWOULDBLOCK) \/\/ nu mai sunt date disponibile\n break;\n ...\n }\n ...\n};\nrecvCallback(cb); \/\/ \u00eenregistreaz\u0103 callback-ul<\/code><\/pre>\n<\/p>\n
Scopul IP-urilor locale<\/h2>\n \nIdentificatorii nodurilor din \u201ere\u021beaua\u201d noastr\u0103 nu sunt adrese IP, ci chei Firebase (acestea sunt \u0219iruri care arat\u0103 a\u0219a: -LmEC50PYZLCiCP-vqde<\/code> ).<\/p>\nAcest lucru este convenabil, deoarece nu avem nevoie de un mecanism pentru a aloca IP-uri \u0219i a verifica unicitatea lor (precum \u0219i de gestionarea lor dup\u0103 deconectarea clientului), dar este adesea necesar s\u0103 identific\u0103m perechile printr-o valoare numeric\u0103.<\/p>\n
Exact pentru aceasta sunt folosite func\u021biile resolve<\/code> \u0219i reverseResolve<\/code>: aplica\u021bia ob\u021bine \u00een vreun fel valoarea \u0219irului cheii (prin introducerea utilizatorului sau prin serverul maestru) \u0219i poate transforma aceasta \u00een adres\u0103 IP pentru utilizare intern\u0103. Restul API-ului de asemenea, pentru simplificare, prime\u0219te \u00een locul \u0219irului aceast\u0103 valoare.<\/p>\nAceasta este similar cu o c\u0103utare DNS, doar c\u0103 se efectueaz\u0103 local pe client.<\/p>\n
Adic\u0103, adresele IP nu pot fi comune pentru diferi\u021bi clien\u021bi, iar dac\u0103 este nevoie de un identificator global, acesta va fi generat printr-o alt\u0103 metod\u0103.<\/p>\n
Conexiune lene\u0219\u0103<\/h2>\n \nUDP nu necesit\u0103 o conexiune, dar, a\u0219a cum am v\u0103zut, \u00eenainte de a \u00eencepe transferul de date \u00eentre dou\u0103 perechi, WebRTC necesit\u0103 un proces lung de conectare.<\/p>\n
Dac\u0103 dorim s\u0103 asigur\u0103m acela\u0219i nivel de abstractizare, (sendto<\/code>\/recvfrom<\/code> cu perechi arbitrare f\u0103r\u0103 conectare prealabil\u0103), atunci trebuie s\u0103 realiz\u0103m o conectare \u201elene\u0219\u0103\u201d (\u00eent\u00e2rziat\u0103) \u00een cadrul API-ului.<\/p>\nIat\u0103 ce se \u00eent\u00e2mpl\u0103 \u00een mod obi\u0219nuit \u00een timpul schimbului de date \u00eentre \u201eserver\u201d \u0219i \u201eclient\u201d \u00een cazul utiliz\u0103rii UDP, \u0219i ce ar trebui s\u0103 fac\u0103 biblioteca noastr\u0103:<\/p>\n
\nServerul apeleaz\u0103 bind()<\/code>, pentru a informa sistemul de operare c\u0103 dore\u0219te s\u0103 primeasc\u0103 pachete pe portul specificat.<\/li>\n<\/ul>\n\n\u00cen schimb, vom publica un port deschis \u00een Firebase sub cheia serverului \u0219i vom asculta evenimente \u00een subarborele s\u0103u.<\/p>\n
\nServerul apeleaz\u0103 recvfrom()<\/code>, primind \u00een acel port pachete de la orice gazd\u0103.<\/li>\n<\/ul>\n\n\u00cen cazul nostru, trebuie s\u0103 verific\u0103m coada de intrare a pachetelor trimise pe acel port.<\/p>\n
Fiecare port are propria coad\u0103, iar noi ad\u0103ug\u0103m la cap\u0103tul datagramei WebRTC porturile surs\u0103 \u0219i destina\u021bie, pentru a \u0219ti \u00een ce coad\u0103 s\u0103 redirec\u021bion\u0103m un pachet nou la sosire.<\/p>\n
Apelul este non-blocant, a\u0219a c\u0103, dac\u0103 nu exist\u0103 pachete, doar return\u0103m -1 \u0219i set\u0103m errno=EWOULDBLOCK<\/code>.<\/p>\n\nClientul ob\u021bine prin metode externe IP-ul \u0219i portul serverului \u0219i apeleaz\u0103 sendto()<\/code>. De asemenea, se efectueaz\u0103 un apel intern, astfel \u00eenc\u00e2t urm\u0103torul bind()<\/code>va primi un r\u0103spuns f\u0103r\u0103 a efectua explicit bind. recvfrom()<\/code> va primi un r\u0103spuns f\u0103r\u0103 a efectua explicit bind.<\/li>\n<\/ul>\n\n\u00cen cazul nostru, clientul prime\u0219te extern un cheie de tip string \u0219i folose\u0219te func\u021bia resolve()<\/code> pentru a ob\u021bine adresa IP.<\/p>\n\u00cen acest stadiu, \u00eencepem \u00abstr\u00e2ngerea de m\u00e2n\u0103\u00bb WebRTC, dac\u0103 cei doi peer-uri nu sunt \u00eenc\u0103 conecta\u021bi unul la cel\u0103lalt. Conexiunile la porturi diferite ale aceluia\u0219i peer folosesc aceea\u0219i DataChannel WebRTC.<\/p>\n
De asemenea, efectuam indirect bind()<\/code>, pentru ca serverul s\u0103 poat\u0103 restabili conexiunea \u00een urm\u0103torul sendto()<\/code> \u00een cazul \u00een care acesta s-a \u00eenchis din diverse motive.<\/p>\nServerul este notificat de conectarea clientului atunci c\u00e2nd clientul \u00ee\u0219i scrie oferta SDP sub informa\u021bia portului serverului \u00een Firebase, iar serverul r\u0103spunde tot acolo cu un r\u0103spuns.<\/p>\n
\nSchema prezentat\u0103 mai jos arat\u0103 un exemplu de mi\u0219care a mesajelor pentru schema de socket \u0219i transmiterea primei mesaje de la client la server:<\/p>\n
Schema complet\u0103 a etapei de conectare \u00eentre client \u0219i server.<\/i><\/p>\nConcluzie<\/h1>\n
\nDac\u0103 a\u021bi citit p\u00e2n\u0103 la cap\u0103t, probabil c\u0103 sunte\u021bi curios s\u0103 vede\u021bi teoria \u00een ac\u021biune. Pute\u021bi juca jocul pe teeworlds.leaningtech.com<\/a><\/noindex>, da, \u00eencerca\u021bi!<\/p>\n