Phenquestions
Comunicare inter-proces POSIX (IPC)
IPC este utilizat pentru extensii în timp real. Aceste cozi de mesaje fac parte din Linux. Aceste apeluri sunt utilizate ca standard acum, dar ar putea face parte din versiunile contemporane. Aceste apeluri sunt ușor de implementat cu o interfață mult mai curată.
Cozi de mesaje POSIX în Linux
Cozile de mesaje V dintr-un sistem Linux sunt identificate folosind chei care sunt obținute folosind ftok apeluri. Aceste cozi de mesaje POSIX folosesc de obicei șiruri de nume. În sistemele Linux, cozile POSIX sunt numite șiruri. Aceste șiruri sunt considerate a începe cu / și apoi au alte caractere. Procesele care urmează și cunosc numele numelui cozii cu drepturi adecvate pot trimite sau primi mesaje către și din coadă. Acest lucru va ajuta la realizarea unor funcționalități importante.
Ce sunt apelurile de coadă de mesaje POSIX?
Cozile de mesaje POSIX trebuie să facă legătura cu orice bibliotecă care iese real. Următoarele sunt câteva apeluri utilizate:
librt folosește opțiunea de compilare -lrtNumele apelurilor încep cu mq_prefix
Detaliile apelurilor la coadă sunt discutate mai jos:
>> mq_open, mq_close
Această funcție este utilizată pentru a deschide o coadă POSIX.
Mq_open este o funcție care este utilizată pentru a apela numele cozii. Următorul parametru este un steag utilizat pentru a primi mesajele. O_WRONLY este utilizat pentru a trimite mesaje, iar O_RDWR este utilizat pentru a trimite și primi operațiuni în coadă. Utilizatorii pot utiliza semnalizatorul O_NONBLOCK pentru a specifica coada la modul de non-blocare și mq_send și mq_rece pentru a trimite și primi date într-o coadă.
Sintaxă
Sintaxa pentru apelul de coadă de mai sus este afișată mai jos:
/ * folosit pentru a deschide fișierele * /
#include
/ * pentru a determina un fișier pe baza căii * /
#include
/ * pentru a include descrierile cozii de mesaje * /
mqd_t mq_open (const caracter * name, int oflag);
/ * pentru a deschide și accesa coada * /
mqd_t mq_open (const caracter * nume, int oflag, mode_t mode,
struct mq_attribute * atribut);
Mq_Flags: Poate fi O sau non-bloc
Mq_MaxMsg: Numărul maxim de mesaje care pot fi introduse în coadă
Mq_Msgsize: Numărul maxim de octeți dintr-un mesaj
Mq_CurMsgs: Mesaje trimise în prezent într-o coadă
mq_închide apeluri: Pentru a închide toți descriptorii cozii.
mq_notificați
Este un apel utilizat pentru a înregistra și anula înregistrarea notificării de sosire atunci când un mesaj intră într-o coadă goală.
Sintaxă
#include/ * pentru a include toate descrierile cozii de mesaje din cod * /
int mq_notify (mqd_t mqdes, const struct sigevent * sevp);
/ * pentru a anunța sosirea mesajului într-o coadă * /
mq_unlink
Este folosit pentru a elimina coada care are nume_codă.
Sintaxă
int mq_unlink (const char * nume_codă);/ * Pentru a elimina coada care are numele ca nume_coadă * /
mq_getattr, mq_setattr
Această funcție are o structură de atribute:
struct mq_attr este folosit ca o coadă de mesaje pentru descriptori.
mq_setattr este utilizat pentru setarea atributelor într-o coadă.
Sintaxă
#includeint mq_getattribute (mqd_t mqdes, struct mq_attribute * atribut);
int mq_setattribute (mqd_t mqdes, const struct mq_attribute * newattribute,
struct mq_attribute * oldattr);
Exemplu: Comunicare client-server prin POSIX
Următorul este un exemplu de comunicare client-server prin cozi de mesaje POSIX. În exemplu, vom avea un fișier client și un fișier server.
Vom avea două fișiere: primul fișier (server) este Server.c, iar celălalt fișier (client) este client.c.
Cod server
Imaginea afișată mai jos arată codul pe care l-am folosit pentru comunicarea client-server. În primul rând, am apelat la câteva biblioteci pentru a defini șirurile, variabilele și funcțiile. Apoi, am definit fcntl funcția și numele serverului de coadă. După aceea, am definit numele cozii serverului, urmat de dimensiunea mesajului și dimensiunea bufferului, pentru a defini dimensiunea mesajelor care să se potrivească bufferului nostru la un moment dat. Apoi, am sunat și am descris cozile, apoi am generat următoarele jetoane pentru a vedea răspunsul clientului odată ce acesta a fost trimis clientului. În cele din urmă, confirmarea a fost finalizată prin imprimarea mesajului de la capătul serverului. În secțiunea următoare, veți vedea steagurile discutate în secțiunea anterioară.
Am inițializat toate steagurile, inclusiv mq_flags, mq_maxmsgs, etc. pentru a continua cu stocarea cererilor. Apoi, am aplicat condiția pe numele serverului și am stocat mesajele în bufferul de coadă. După aceasta, în momentul stocării, ne-am asigurat că cozile respectă o regulă de prioritate bazată pe primul venit. La sfârșit, codul afișează un mesaj de eșec dacă există erori primite de la capătul clientului. În cele din urmă, am ieșit de pe server pentru a trimite solicitarea către client.
Salvați serverul.fișier c
Cod client
Vom discuta acum al doilea dosar. Imaginea afișată mai jos este codul pe care l-am folosit pentru comunicarea client-server. Codul a început prin apelarea bibliotecilor standard și definirea antetelor variabile. Apoi, am definit șirurile și toate tipurile de date. După aceea, am declarat antetul cozii pentru a defini numele cozii serverului. Apoi, am definit cozile de permisiuni și dimensiunea mesajului în coadă, împreună cu dimensiunea bufferului de mesaje (dimensiunea maximă care ar putea intra în coadă).
Vom descrie cozile și vom crea un nou client pentru a primi mesajele trimise de la sfârșitul serverului. Apoi, vom apela steagurile și le vom inițializa și vom apela funcția de finalizare client. Va ieși din funcție în cazul unei erori. Valoarea este stocată în buffer și un răspuns la cerere este trimis la server. În cazul unui răspuns, serverul va furniza apoi simbolul, care este tipărit odată ce capătul clientului a introdus intrarea. În caz de eroare, acesta va returna valorile erorii, i.e., clientul nu a putut trimite un mesaj către server. După aceea, vom părăsi clientul.
Salvați clientul.fișier c
Executarea fișierelor
Folosim un gcc compilator pentru a executa fișierele. Pentru a rula fișierul final al serverului, tastați comanda anexată în fereastra terminalului:
serverul $ sudo gcc.c -lrt
Apoi, tastați următoarele:
$ ./A.afară
Ieșirea va apărea după cum urmează:
Trecând la răspunsul clientului, tastați următoarele:
$ sudo gcc client.c -lrt
Apoi executați următoarele:
$ ./A.afară
Ieșirea va apărea după cum urmează:
Concluzie
În acest articol, ați învățat cum să trimiteți cozile de mesaje POSIX cu programare C, precum și câteva dintre funcțiile sale. Apoi, ați văzut câteva exemple ale acestui proces mai detaliat.
