La signalisation est \u00e9troitement li\u00e9e \u00e0 notre impl\u00e9mentation des sockets, d\u00e9crite dans la section suivante.<\/li>\n<\/ul>\n\nListe des serveurs dans le jeu et sur la page d'accueil<\/i><\/p>\nImpl\u00e9mentation des sockets<\/h1>\n
\nNous souhaitons cr\u00e9er une API aussi proche que possible des sockets UDP Posix, afin de minimiser le nombre de modifications n\u00e9cessaires.<\/p>\n
De plus, nous voulons impl\u00e9menter le strict minimum requis pour un \u00e9change de donn\u00e9es basique sur le r\u00e9seau.<\/p>\n
Par exemple, nous n'avons pas besoin de v\u00e9ritable routage : tous les pairs se trouvent dans un \"LAN virtuel\" connect\u00e9 \u00e0 une instance sp\u00e9cifique de la base de donn\u00e9es Firebase.<\/p>\n
Par cons\u00e9quent, nous n'avons pas besoin d'adresses IP uniques : pour identifier les pairs de mani\u00e8re unique, il suffit d'utiliser des valeurs cl\u00e9s uniques de Firebase (similaire aux noms de domaine), et chaque pair attribue localement des adresses IP \"fausses\" \u00e0 chaque cl\u00e9 devant \u00eatre convertie. Cela nous lib\u00e8re compl\u00e8tement de la n\u00e9cessit\u00e9 d'allouer des adresses IP globales, ce qui constitue une t\u00e2che non triviale.<\/p>\n
Voici l'API minimale que nous devons impl\u00e9menter :<\/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\nL'API est simple et ressemble \u00e0 l'API des sockets Posix, mais avec quelques diff\u00e9rences importantes : enregistrement des rappels, attribution d'IP locales et connexion \"paresseuse\"<\/strong>.<\/p>\nEnregistrement des rappels<\/h2>\n \nM\u00eame si le programme d'origine utilise des entr\u00e9es\/sorties non bloquantes, le code doit \u00eatre r\u00e9factoris\u00e9 pour fonctionner dans un navigateur web.<\/p>\n
La raison en est que la boucle d'\u00e9v\u00e9nements dans le navigateur est cach\u00e9e du programme (qu'il s'agisse de JavaScript ou de WebAssembly).<\/p>\n
Dans un environnement natif, nous pouvons \u00e9crire du code de cette mani\u00e8re<\/p>\n
while(running) {\n select(...); \/\/ attendre les \u00e9v\u00e9nements I\/O\n while(true) {\n int r = readfrom(...); \/\/ essayer de lire\n if (r < 0 && errno == EWOULDBLOCK) \/\/ plus de donn\u00e9es disponibles\n break;\n ...\n }\n ...\n}<\/code><\/pre>\n\nSi la boucle d'\u00e9v\u00e9nements est cach\u00e9e pour nous, nous devons la transformer en quelque chose comme :<\/p>\n
auto cb = []() { \/\/ ceci sera appel\u00e9 lorsque de nouvelles donn\u00e9es sont disponibles\n while(true) {\n int r = readfrom(...); \/\/ essayer de lire\n if (r < 0 && errno == EWOULDBLOCK) \/\/ plus de donn\u00e9es disponibles\n break;\n ...\n }\n ...\n};\nsrecvCallback(cb); \/\/ enregistrer le rappel<\/code><\/pre>\n<\/p>\n
Destinataires des IP locaux<\/h2>\n \nLes identifiants des n\u0153uds dans notre \u00ab r\u00e9seau \u00bb ne sont pas des adresses IP, mais des cl\u00e9s Firebase (ce sont des cha\u00eenes qui ressemblent \u00e0 \u00e7a : -LmEC50PYZLCiCP-vqde<\/code> ).<\/p>\nC'est pratique, car nous n'avons pas besoin d'un m\u00e9canisme pour attribuer des IP et v\u00e9rifier leur unicit\u00e9 (ni de les r\u00e9cup\u00e9rer apr\u00e8s la d\u00e9connexion du client), mais il est souvent n\u00e9cessaire d'identifier les pairs par une valeur num\u00e9rique.<\/p>\n
C'est pr\u00e9cis\u00e9ment pour cela que nous utilisons les fonctions resolve<\/code> et reverseResolve<\/code>: l'application obtient d'une mani\u00e8re ou d'une autre la valeur de cha\u00eene de la cl\u00e9 (soit par saisie utilisateur, soit via un serveur ma\u00eetre), et peut la convertir en adresse IP pour une utilisation interne. Le reste de l'API re\u00e7oit \u00e9galement cette valeur au lieu de la cha\u00eene pour simplifier les choses.<\/p>\nC'est similaire \u00e0 une recherche DNS, mais cela se fait localement sur le client.<\/p>\n
C'est-\u00e0-dire que les adresses IP ne peuvent pas \u00eatre partag\u00e9es entre diff\u00e9rents clients, et si un identifiant global est n\u00e9cessaire, il devra \u00eatre g\u00e9n\u00e9r\u00e9 d'une autre mani\u00e8re.<\/p>\n
Connexion paresseuse<\/h2>\n \nLe UDP n'a pas besoin de connexion, mais, comme nous l'avons vu, avant de commencer \u00e0 transf\u00e9rer des donn\u00e9es entre deux pairs, WebRTC n\u00e9cessite un processus de connexion long.<\/p>\n
Si nous voulons garantir le m\u00eame niveau d'abstraction, (sendto<\/code>\/recvfrom<\/code> avec des pairs arbitraires sans connexion pr\u00e9alable), nous devons effectuer une connexion \u00ab paresseuse \u00bb (diff\u00e9r\u00e9e) au sein de l'API.<\/p>\nVoici ce qui se passe lors de l'\u00e9change normal de donn\u00e9es entre un \u00ab serveur \u00bb et un \u00ab client \u00bb dans le cas de l'utilisation du UDP, et ce que notre biblioth\u00e8que doit faire :<\/p>\n
\nLe serveur appelle bind()<\/code>, pour indiquer au syst\u00e8me d'exploitation qu'il souhaite recevoir des paquets sur le port sp\u00e9cifi\u00e9.<\/li>\n<\/ul>\n\nAu lieu de cela, nous publions un port ouvert dans Firebase sous la cl\u00e9 du serveur et nous \u00e9coutons les \u00e9v\u00e9nements dans son sous-arbre.<\/p>\n
\nLe serveur appelle recvfrom()<\/code>, acceptant sur ce port des paquets provenant de n'importe quel h\u00f4te.<\/li>\n<\/ul>\n\nDans notre cas, nous devons v\u00e9rifier la file d'attente des paquets entrants envoy\u00e9s \u00e0 ce port.<\/p>\n
Chaque port a sa propre file d'attente, et nous ajoutons au d\u00e9but des datagrammes WebRTC les ports source et destination, afin de savoir dans quelle file d'attente rediriger lors de l'arriv\u00e9e d'un nouveau paquet.<\/p>\n
L'appel est non-bloquant, donc si aucun paquet n'est pr\u00e9sent, nous retournons simplement -1 et d\u00e9finissons errno=EWOULDBLOCK<\/code>.<\/p>\n\nLe client obtient par des moyens externes l'IP et le port du serveur, et appelle sendto()<\/code>. Cette action entra\u00eene \u00e9galement un appel interne, donc le suivant bind()<\/code>. recvfrom()<\/code> obtiendra une r\u00e9ponse sans ex\u00e9cution explicite du bind.<\/li>\n<\/ul>\n\nDans notre cas, le client obtient une cl\u00e9 de cha\u00eene de mani\u00e8re externe et utilise la fonction resolve()<\/code> pour obtenir l'adresse IP.<\/p>\n\u00c0 ce stade, nous commen\u00e7ons le \u00ab handshake \u00bb WebRTC, si deux pairs ne sont pas encore connect\u00e9s entre eux. Les connexions \u00e0 diff\u00e9rents ports d'un m\u00eame pair utilisent le m\u00eame DataChannel WebRTC.<\/p>\n
Nous effectuons \u00e9galement une op\u00e9ration indirecte bind()<\/code>, pour que le serveur puisse restaurer la connexion lors du prochain sendto()<\/code> au cas o\u00f9 elle se serait ferm\u00e9e pour une raison quelconque.<\/p>\nLe serveur est inform\u00e9 de la connexion du client lorsque le client enregistre son offre SDP sous les informations du port du serveur dans Firebase, et le serveur r\u00e9pond \u00e9galement avec sa r\u00e9ponse.<\/p>\n
\nLe sch\u00e9ma ci-dessous montre un exemple de transmission des messages pour le sch\u00e9ma de sockets et l'envoi du premier message du client au serveur :<\/p>\n
Le sch\u00e9ma complet de l'\u00e9tape de connexion entre le client et le serveur<\/i><\/p>\nConclusion<\/h1>\n
\nSi vous \u00eates arriv\u00e9 jusqu'ici, vous devez probablement \u00eatre int\u00e9ress\u00e9 \u00e0 voir la th\u00e9orie en action. Vous pouvez jouer \u00e0 teeworlds.leaningtech.com<\/a><\/noindex>, essayez-le !<\/p>\n