[Linux & Ubuntu] C 프로그래밍을 통한 공유 메모리 & 메시지 큐 사용 프로세스 구현 #3

🩰 C 프로그래밍을 통한 공유 메모리 & 메시지 큐 사용 프로세스 구현 # 3

# 구현할 프로그램 개요

프로그램 번호	프로그램 1	프로그램 2	프로그램 3
수행 작업	1초 간격으로 1~10까지 값을 공유 메모리에 차례로 입력	루프를 돌며 공유 메모리 값을 읽어와 메시지 큐에 입력	루프를 돌며 대기 후 메시지 큐에 입력된 값 중 짝수만을 읽어와 출력

 

---

💮 C 언어를 통한 프로그램 # 3 구현

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define MSG_KEY 5678

// 메시지 큐 구조체 정의
struct Message {
ㅤㅤlong mtype;
ㅤㅤint data;
};

int main() {
ㅤㅤ// 메시지 큐 연결
ㅤㅤint msqid = msgget(MSG_KEY, 0666);
ㅤㅤif (msqid == -1) {
ㅤㅤㅤㅤperror("msgget");
ㅤㅤㅤㅤexit(1);
ㅤㅤ}

ㅤㅤprintf("Program 3 is running...\n");

ㅤㅤint received_count = 0;
ㅤㅤwhile (received_count < 5) {
ㅤㅤㅤㅤstruct Message message;
ㅤㅤㅤㅤmsgrcv(msqid, &message, sizeof(int), 1, 0);  // 메시지 타입 1인 메시지 수신
ㅤㅤㅤㅤif (message.data % 2 == 0) {
ㅤㅤㅤㅤㅤㅤprintf("Program 3 received even value from message queue: %d\n", message.data);
ㅤㅤㅤㅤㅤㅤreceived_count++;
ㅤㅤㅤㅤ}
ㅤㅤ}

ㅤㅤ// 메시지 큐 삭제하지 않음

ㅤㅤprintf("Program 3 finished.\n");

ㅤㅤreturn 0;
}

---

1.  프로그램 실행에 필요한 라이브러리 include

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

 

++ 각 Include 문 상세 설명

include 문	역할
stdio.h	표준 입출력 함수를 포함하는 헤더 파일
stdlib.h	C 프로그래밍 언어에서 기본적인 유틸리티 함수들을 포함하는 헤더 파일
unistd.h	유닉스 및 리눅스 시스템에서 제공하는 시스템 호출을 포함하는 헤더 파일
sys/types.h	시스템 데이터 형식을 정의하는 헤더 파일
sys/ipc.h	IPC(Inter-Process Communication) 기능을 사용하기 위해 필요한 헤더 파일
sys/msg.h	시스템 V IPC 메시지 큐를 다루기 위한 헤더 파일

2.  메시지 큐를 식별하는 데 사용될 키 정의

#define MSG_KEY 5678

3.  메시지 큐에서 교환되는 메시지 형식을 정의

// 메시지 큐 구조체 정의
struct Message {
ㅤㅤlong mtype;
ㅤㅤint data;
};

4.  메시지 큐 연결

int main() {
ㅤㅤ// 메시지 큐 연결
ㅤㅤint msqid = msgget(MSG_KEY, 0666);
ㅤㅤif (msqid == -1) {
ㅤㅤㅤㅤperror("msgget");
ㅤㅤㅤㅤexit(1);
ㅤㅤ}

 

++  코드 설명 상세

코드	설명
msgget(MSG_KEY, 0666)	MSG_KEY 매크로 정의 후 메시지 큐 연결
perror("msgget")	에러 발생 시 메세지 출력
exit(1)	에러 발생 시 프로그램 종료

5.  5개의 짝수 메시지를 수신할 때까지 while 루프 실행

printf("Program 3 is running...\n");

ㅤㅤint received_count = 0;
ㅤㅤwhile (received_count < 5) {
ㅤㅤㅤㅤstruct Message message;
ㅤㅤㅤㅤmsgrcv(msqid, &message, sizeof(int), 1, 0);  // 메시지 타입 1인 메시지 수신
ㅤㅤㅤㅤif (message.data % 2 == 0) {
ㅤㅤㅤㅤㅤㅤprintf("Program 3 received even value from message queue: %d\n", message.data);
ㅤㅤㅤㅤㅤㅤreceived_count++;
ㅤㅤㅤㅤ}
ㅤㅤ}

 

++  코드 설명 상세

코드	설명
received_count	받은 메시지 수를 저장하는 변수
while (received_count < 5)	짝수 메시지 5개 수신 시 종료
msgrcv(msqid, &message, sizeof(int), 1, 0)	메시지 큐에서 유형이 1인 짝수 메시지 수신

6.  메시지 큐를 보존한 상태에서 프로그램 종료

// 메시지 큐 삭제하지 않음

ㅤㅤprintf("Program 3 finished.\n");

ㅤㅤreturn 0;
}