C Academy · Lekcja

Kolejki komunikatów

Strukturyzowane komunikaty

Kolejki komunikatów to bezpłatna lekcja C Academy na CoddyKit. To lekcja 3 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej C Academy, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs C Academy zawiera 4 lekcji w sumie.

Komunikacja strukturalna

Kolejka komunikatów pozwala procesom wymieniać odrębne komunikaty zamiast surowego strumienia bajtów. Jądro zachowuje granice komunikatów, więc każde wysłanie odpowiada dokładnie jednemu odebraniu.

Komunikaty a strumienie

Potoki dostarczają strumień bajtów, w którym granice komunikatów zacierają się. Kolejki komunikatów dostarczają całe jednostki:

Każde send wysyła jeden komunikat
Każde receive zwraca jeden komunikat
Komunikatom można nadawać priorytety

Kolejki POSIX a System V

Istnieją dwa interfejsy API:

POSIX: mq_open, mq_send, mq_receive, nazwy zaczynają się od ukośnika
System V: msgget, msgsnd, msgrcv, rozwiązanie oparte na kluczach i komunikatach z typami

POSIX to prostszy i nowocześniejszy wybór.

Otwieranie kolejki

mq_open tworzy nazwaną kolejkę lub otwiera istniejącą i zwraca deskryptor. Można przekazać atrybuty, takie jak maksymalna liczba komunikatów i ich rozmiar.

#include <mqueue.h>
#include <fcntl.h>

mqd_t open_queue(const char *name) {
    return mq_open(name, O_CREAT | O_RDWR, 0644, NULL);
    /* name like "/myqueue"; NULL uses default attributes */
}

Atrybuty kolejki

struct mq_attr określa mq_maxmsg (pojemność) i mq_msgsize (maksymalną liczbę bajtów komunikatu). Bufor odbiorcy musi mieć co najmniej rozmiar mq_msgsize.

#include <mqueue.h>

void set_attr(struct mq_attr *a) {
    a->mq_flags = 0;
    a->mq_maxmsg = 10;     /* up to 10 queued messages */
    a->mq_msgsize = 256;   /* each at most 256 bytes */
    a->mq_curmsgs = 0;
}

Wysyłanie komunikatu

mq_send umieszcza komunikat w kolejce wraz z priorytetem. Komunikaty o wyższym priorytecie są dostarczane jako pierwsze.

#include <mqueue.h>
#include <string.h>

int post(mqd_t q, const char *text) {
    return mq_send(q, text, strlen(text) + 1, 5); /* priority 5 */
}

Odbieranie komunikatu

mq_receive zwraca komunikat o najwyższym priorytecie. Bufor musi mieć co najmniej rozmiar mq_msgsize, w przeciwnym razie wywołanie zakończy się błędem EMSGSIZE.

#include <mqueue.h>
#include <stdio.h>

void get(mqd_t q, size_t msgsize) {
    char buf[256];
    unsigned prio;
    ssize_t n = mq_receive(q, buf, msgsize, &prio);
    if (n >= 0) printf("got (prio %u): %s\n", prio, buf);
}

Priorytety określają kolejność dostarczania

W przeciwieństwie do potoku FIFO kolejka komunikatów dostarcza je najpierw według priorytetu, a następnie według kolejności nadejścia w ramach tego samego priorytetu. Dzięki temu pilne komunikaty mogą wyprzedzić pozostałe.

Blokowanie a tryb nieblokujący

Domyślnie mq_send blokuje się, gdy kolejka jest pełna, a mq_receive blokuje się, gdy jest pusta. Otwarcie kolejki z użyciem O_NONBLOCK sprawia, że zamiast czekać, funkcje zwracają EAGAIN.

Operacje z limitem czasu

mq_timedsend i mq_timedreceive przyjmują bezwzględny termin zakończenia. Jeśli operacja nie może zakończyć się na czas, kończy się błędem ETIMEDOUT. Pozwala to uniknąć oczekiwania w nieskończoność.

Sprzątanie

Deskryptor należy zamknąć za pomocą mq_close, a nazwaną kolejkę usunąć z systemu za pomocą mq_unlink, aby nie pozostała po zakończeniu pracy wszystkich użytkowników.

#include <mqueue.h>

void cleanup(mqd_t q, const char *name) {
    mq_close(q);
    mq_unlink(name); /* remove the named queue */
}

Szybkie sprawdzenie

Sprawdź swoją wiedzę na temat kolejek komunikatów.

Podsumowanie

Dowiedziano się, jak używać kolejek komunikatów POSIX.

Wymiana odrębnych komunikatów zamiast surowych bajtów
mq_open, mq_send, mq_receive
Dostarczanie według priorytetu, a następnie kolejności nadejścia
Opcjonalne warianty nieblokujące i czasowe; sprzątanie za pomocą mq_close i mq_unlink

Często zadawane pytania

Czy lekcja „Kolejki komunikatów” jest bezpłatna?

Tak — pełny tekst „Kolejki komunikatów” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu C Academy, przejdź na CoddyKit PRO. Kurs C Academy zawiera 4 lekcji w sumie.

Co nauczysz się w „Kolejki komunikatów”?

Strukturyzowane komunikaty Ćwiczysz C Academy z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.

Czy potrzebuję doświadczenia, aby zacząć C Academy?

Nie wymagamy żadnego doświadczenia. C Academy w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 3 z 4.

Ile czasu zajmuje lekcja „Kolejki komunikatów”?

Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.

Czy mogę pisać i uruchamiać kod w tej lekcji C Academy?

Tak. Każda lekcja C Academy zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.

Wszystkie lekcje w tym kursie

← Powrót do C Academy