Хабарламалармен жұмыс жасауға

213 
UNIX хабарламаларымен жұмыс жасау үшін интерфейс файлдармен 
жұмыс істейтін интерфейсті еске түсіреді — мұнда объектілерді жасау 
үшін функциялар, одан ақпараттарды жазу мен оқу, оның жағдайын 
басқару бар. Обьекті ретіндегі файлдар үшін екілік жолдар немесе 
мәтіндік файлдардың ақпараттары рөліндегі хабарламалар түседі. 
Файлдың күйі — оған қолжеткізу құқығы мен режимі. Обьектілер 
рөліндегі хабарламалар үшін хабарламалардың кезегі, ақпараттар 
рөліне — хабарламалардың өзі түседі, кезектің күйі оған қол жеткізудің 
құқығы мен режимін анықтайды. 
Осыған сәйкес, кезекпен жұмыс жасау үшін төрт негізгі функциялар 
бар. Бұл функциялардың барлығы тақырыптық файлдардың sys/types.h, 
sys/ipc.h және sys/msg.h қосылуын талап етеді:
#include 
#include 
#include 
int msgget( key_t key, int flag);
Кезекті құру және ашу үшін msgget() функциясы қызмет етеді. Бұл 
функцияның key параметрі ретінде, бірегей сандық идентификатор 
кезегі беріледі (файлдармен жұмыс жасауға арналған fopen() тәрізді 
функцияның аналогы). Егер key параметрі ретінде IPC_PRIVATE 
тұрақты шамасы берілсе, онда оны құрған процеспен ғана 
қолданылатын кезек жасалады. Flag параметрі кезекті құруға арналған 
параметрлерді береді. Параметр ретінде IPC_CREAT тұрақты шамасын 
берілсе, онда msgget шақыртуы бірегей идентификаторлы берілген 
кезекті құрады. Кезекке қолжетімділік құқығын анықтау үшін 
IPC_CREAT тұрақты шамасын қолжетімділік құқығы жазбасының 
сандық формасын біріктіреді, мынадай:
m_id= msgget (500, IPC_CREAT | 0644);
Сонымен қатар r құқығы кезектен хабрламаларды оқу мүмкіндігін 
береді, w құқығы — кезекке хабарламаларды сыйғызады, ал x құқығы 
— кезектегі параметрлерді басқаруға мүмкіндік береді. 
Мsgget() функциясы кезектің дескрипторын қайтарады, одан кейін 
ол жіберілімдер және хабарламаларды қабылдау функциясымен 
қолданылады (файлдармен жұмыс жасау үшін дескриптордың аналогы,
FILE* типтік файлдық дескрипторы болып табылады).
Егер msgget() функциясының параметрі ретінде 0 жіберуге болады, 
ол идентификатормен берілген кезекті ашады және оның дескрипторын 
қайтарады. Егер кезекті құруды IPC_EXCL тұрақты шамасымен 
біріктірсе, және кезекті құру және ашу сәтсіз болса, функция -1 
қайтарады.

214 
Хабарламалар құрылым ретінде ұсынылып, мына параметрлерге ие 
болады:
#define LENGTH 25 6
struct message
{
long m_type;
char m_text[LENGTH];
}
Ұзақ бүтін m_type хабарлама түріндегі идентификаторды, m_text 
символдар алабын — хабарламалар мәтінін береді. Бағдарламалармен 
өңделген хабарламалардың, максималды мүмкін болатын ұзындығын 
беретін LENGTH тұрақты шамасы (қаралатын мысалда — 256 символ), 
кезекке сыйған хабарламалардың мүмкін болатын ұзындығын беретін 
MSGMAX жүйелік тұрақты шамасына тең немесе аз болуы керек:
int msgsnd (int msgfd, void *msgPtr, int len, int 
flag);
Кезекке хабарламаларды жіберу үшін msgsnd() функциясы қызмет 
етеді, ол msgget() шақыртуының нәтижесінде болатын, msgfd 
параметрі ретінде кезектің дескрипторын қабылдайды, msgPtr 
шақыртуы ретінде — хабарламалардан тұратын ақпараттар құрылымын 
көрсетеді; len параметрі хабарламаның m_text элементінің ұзындығын 
береді. Егер flag параметрі ретінде 0 берсе, онда процестің 
орындалуын, хабарламаны кезекке сәтті орналастырған сәтке дейін 
тоқтата тұруға болады дегенді білдіреді. Мұндай кідірістер, хабарлама 
кезегі, msgsnd() шақыртуы кезінде толып және кезектен оның орнын 
босатуы үшін хабарламалардың, жеткілікті алуын күту қажеттілігімен 
байланысты болуы мүмкін. Егер flag параметрі ретінде IPC_NOWAIT 
тұрақты 
шамасын 
көрсетсе, 
онда 
операциялардың 
сәтсіз 
орындалуындағыдай, функция орындалуы тоқтатылады және -1 
қайтарады. 
Келесі бағдарлама кезек құрады және оған хабарлама жібереді: 
#include 
#include 
#include 
#include 
#include 
struct message

215 
{
long length;
char text[256];
} my_msg = { 25, "Sample text message" };
int main()
{
int fd;
fd = msgget(500, IPC_CREAT | IPC_EXCL |0644 );
if (fd != -1 )
{
msgsnd(fd, &my_msg, strlen(my_msg.text)+1,
IPC_NOWAIT);
}
return 0;
}
Келтірілген үлгіде, msgget() функциясының сәтісз қайтару кодының 
қарапайым өңделуі енгізілген — кезекті құру мүмкін болмаған 
жағдайда (мысалы, кезекті сақтауға арналған жүйелік жады облысы 
толып қалса немесе мұндай сандық идентификаторлы кезек болған 
болса) хабарлама кезекке жіберілмейді.
Кезектегі хабарламаны алу үшін msgrcv() функциясы қызмет етеді:
int msgrcv(int msgfd, void *msgPtr, int len, int mtype, 
int flag);
Мsgfd параметрі ретінде, оған кезектің дескрипторы беріледі; 
параметр msgPtr, түскен хабарламаны сыйғызатын, жады облысының 
көрсеткішін анықтайды; параметр len, қабылданатын хабарламаның 
максималды мүмкін болатын ұзындығын береді. Mtype мәні 
қабылданатын хабарламаның типін береді. Бұл параметр келесі 
мәндерді қабылдайды: 
■ 
0 — кезектен кез келген типтен ең көне хабарлама алынатын 
болады;
■ 
Оң бүтін сан — кезектен, осы санға тең типті, ең көне хабарлама 
алынатын болады;
■ 
Теріс бүтін сан — кезектен, осы санға тең немесе кіші типті ең көне 
хабарлама алынатын болады. Егер кезекте, осы белгіні 
қанағаттандыратын бірден көп хабарлама болса, типтің аз мәніне ие 
хабарлама қабылданатын болады.
Flag параметрі ретінде 0 көрсетуге болады, бұл жағдайда кезектегі 

216 
хабарламалардың жоқтығы кезінде, процесс хабарлама алғанға дейін 
өзінің орындалуын тоқтатады. Егер параметр ретінде, IPC_NOWAIT 
тұрақты шамасын көрсетсе, онда кезектегі қабылдауға арналған қол 
жетімді хабарламалар болмаған жағдайда, процесс өзінің орындалуын 
жалғастырады. Функция хабарламаны сәтті қабылдаған кезде немесе -
1 сәтсіз болғанда, мысалы хабарлама ұзындығы, len параметрімен 
берген ұзындықтан асып кетсе хабарламаның мәтіндік бөлігінің 
байттар санын қайтарады. Мұндай жағдайдың алдын алу үшін және 
алғашқы len символдарын қабылдау үшін flag параметрі ретінде 
MSG_NOERROR тұрақты шамасын көрсетуге болады. Барлық 
көрсетілген тұрақты шамаларды ИЛИ операциясының топтары арқылы 
біріктіруге болады. 
Келесі бағдарламаға алдыңғы бағдарламаның кезекке салған 
хабарламалардын қабылдайды және оның мәтіндік бөлігін экранға 
шығарады: 
#include 
#include 
#include 
#include 
#include 
struct message 
{
long length; 
char text[256];
} my_msg = { 0, " --------------- " };
int main()
{
int fd, rcv_res;
fd = msgget(500, IPC_EXCL ) ;
if (fd != -1)
{
rcv_msg = msgrcv(fd, &my_msg, 1024, MSG_NOERROR); if 
(rcv_msg != 1)
{
printf("%s\n", &my_msg.text)
}
}
return 0;
} 
Хабарламаны сәтсіз қабылдаған кезде бағдарлама экранға ештеңе 

217 
msqid ds {
ipc perm msg perm; /* кезекке қол жетімділік 
права доступа к очереди
msg *msg first
; 
/* 
кезектегі 
алғашқы 
хабарламаны көрсетуші */
msg *msg last
; 
/* 
кезектегі 
соңғы 
хабарламаны көрсетуші */
msg stime;
/* msgsnd соңғы шақыртуының 
уақыты*/
msg rtime;
/* msgrcv соңғы шақыртылған 
уақыты*/
msg ctime;
/* кезектегі соңғы өзгерістің 
уақыты */
msg cbytes;
/* кезектегі барлық 
хабарламалардың сомалық өлшемі 
суммарный размер всех сообщений 
в очереди */
msg qnum;
/* кезектегі хабарламалар саны 
*/
msg qbytes;
/* кезектің байтпен максималды 
өлшемі */
msg lspid;
/* кезектегі мәндерді оқитын 
соңғы процесс PID */
msg lrpid;
/* кезекке мәндерді жазатын PID 
соңғы процесі *

жүктеу/скачать 3.83 Mb.

Достарыңызбен бөлісу: