Comment garantir la connexion TCP actuelle pour le contrôleur programmable ESPased

Lors de la conception de l'architecture du système logiciel du contrôleur programmable simple, j'ai les principales considérations suivantes :
(1) besoin de prendre en charge le serveur TCP ainsi que le client TCP multiplexé simultanément, le serveur TCP a trois cas de connexion, le navigateur télécharge la page Web intégrée et la communication après cela, pour la connexion de communication du logiciel tiers, pour la connexion du protocole Modbus-TCP ;
Le client TCP est utilisé pour se connecter au serveur TCP sur le serveur cloud afin de réaliser un accès à distance. Compte tenu de la situation des ressources de l'ESP8266, la concurrence est conçue selon la spécification selon laquelle le serveur TCP prend en charge quatre connexions client TCP tandis qu'un client TCP se connecte au serveur cloud ;
(2) Il est nécessaire de contrôler le flux de communication de données TCP/IP jusqu'à 5 voies et d'allouer suffisamment de tranches de temps pour la planification des tâches liées à l'API afin de garantir une planification fiable des fonctions de l'API et une réponse en temps réel ;
3) Les tâches principales sont la tâche LWIP et la tâche principale, la priorité de la tâche LWIP est inférieure à celle de la tâche principale, tout en garantissant que la tâche principale n'a pas de tâche longue ou bloquante. , et la tâche principale est planifiée en 10 ms, et elle entre activement dans l'état de blocage après l'exécution de la tâche principale, libérant le CPU pour planifier d'autres tâches ;
En les combinant, j'ai conçu l'architecture logicielle à proximité ;
Lorsque le serveur TCP ou le client TCP reçoit des données, la tâche de LWIP exécute la fonction de rappel pour la réception des données ;
Dans la fonction de rappel, le programme stocke simplement les données reçues dans le tampon de réception, mais ne traite pas les données ;
Il existe cinq tampons de réception, chacun utilisé pour cinq connexions simultanées ; lorsqu'ils sont déposés dans ce tampon, le déballage des paquets TCP et la situation des paquets persistants sont traités en même temps, les données du protocole HTTP sont décompressées jusqu'à la fin des caractères rnrn ;
Lorsque de nouvelles données sont reçues, la tâche LWIP réveille la tâche principale pour les traiter en signalant Sémaphore.
Chaque fois que la tâche principale détecte l'état de ces 5 tampons, et si des données sont reçues, elle traite les données pertinentes et génère une réponse à l'expéditeur ;
Afin de garantir que les 5 connexions ont la même chance d'être traitées, la tâche principale se relaye pour prioriser l'état de ces 5 caches.
Par exemple, si le planificateur détermine d'abord le cache pour la connexion 0, le planificateur suivant détermine le cache pour la connexion 1.
Cela peut être réalisé avec un simple code ;

court signé http_get_recvs(U32 *msg, U32 *addr, U16 *port){
U8i;
signé courte res = -1;
pour (i = 0; i {

    if(tcpclient_curquery_client >= TCPSERVER_CLIENT_NUM){
        tcpclient_curquery_client = 0;
    }
    if(tcpclient_info[tcpclient_curquery_client].used == TRUE){
        if(tcpclient_info[tcpclient_curquery_client].received){
            *msg = (U32)tcpclient_info[tcpclient_curquery_client].recvbuff;
            *addr = tcpclient_info[tcpclient_curquery_client].ipaddr;
            *port = tcpclient_info[tcpclient_curquery_client].port;
            res = (signed short)tcpclient_curquery_client;
            break;
        }
    }
    tcpclient_curquery_client++;
}
return(res);

}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!