소켓 프로그래밍과 시스템 프로그래밍에서 자주 사용되는 기법을 적절히 조화시켜야 하는데 가장 핵심적인 기능 중 하나는, write 명령이 클라이언트로부터 왔을 때, 서버는 한줄씩 데이터를 받아들이는 겁니다. 이걸 구현하는 것이 이 과제의 핵심 중 하나가 아닌가 생각하네요.

소켓의 본질을 알고 있어야, 이 기능을 구현할 수 있거든요.

소켓의 본질은 파일입니다. 파일은 데이터 단위가 Stream인데,

이 스트림은 시작은 확실히 정해져 있지만, 끝이 어딘지 확실하지 않다는 특징을 갖고 있습니다. 그렇기 때문에 ‘줄 입력‘이 여기서 종료되었다는 판단을 아무런 정보가 없다면 서버는 할 수 없죠.

따라서 적절한 시그널을 주고받는 프로토콜 절차가 있어야 합니다.

인터뷰에서 시그널을 주고받음으로써 줄의 끝이 어디까지인지 서버가 알도록 한다는 말씀을 드렸을 때, 인터뷰 평가 사항에 무엇인가를 막 적고 계시더라구요. 그때 조금 확실히 알게된 것 같습니다.

과제의 의도가 결국 ‘소켓’이 무엇인지 정확히 알고 있느냐라는 걸요.. 사실 이 얘기는 네트워크 이론과 운영체제론을 알고 있어야 이해할 수 있을 겁니다. 조금 더 다듬어서 비동기 입출력까지 지원하는 서버를 한번 만들어 보려구요. 설계 구조를 완전히 바꿔야 겠지만, 오랜만에 아주 재미있는 프로젝트를 하게 되어서 이 내용물은 깃허브에 올려 볼 것 같습니다.

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <pthread.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#define MAX_DOCS 100

#define MAX_SECTIONS 10

#define MAX_TITLE 64

#define MAX_LINE 256

#define MAX_LINES 10

#define BUF_SIZE 1024

typedef struct {

char title[MAX_TITLE];

char section_titles[MAX_SECTIONS][MAX_TITLE];

char section_contents[MAX_SECTIONS][MAX_LINES][MAX_LINE];

int section_line_count[MAX_SECTIONS];

int section_count;

} Document;

typedef struct WriteRequest {

int client_sock;

int estimated_lines;

struct WriteRequest *next;

} WriteRequest;

Document docs[MAX_DOCS];

int doc_count = 0;

pthread_mutex_t docs_mutex = PTHREAD_MUTEX_INITIALIZER;

pthread_mutex_t section_mutex[MAX_DOCS][MAX_SECTIONS];

pthread_cond_t section_cond[MAX_DOCS][MAX_SECTIONS];

int section_writing[MAX_DOCS][MAX_SECTIONS] = {{0}};

WriteRequest *section_queue[MAX_DOCS][MAX_SECTIONS] = {{{0}}};

pthread_mutex_t section_queue_mutex[MAX_DOCS][MAX_SECTIONS];

pthread_cond_t section_queue_cond[MAX_DOCS][MAX_SECTIONS];

void send_all(int sock, const char *msg) {

send(sock, msg, strlen(msg), 0);

}

Document* find_doc(const char* title) {

for (int i = 0; i < doc_count; ++i) {

if (strcmp(docs[i].title, title) == 0)

return &docs[i];

}

return NULL;

}

ssize_t read_line(int sock, char *buf, size_t max_len) {

size_t i = 0;

char ch;

while (i < max_len - 1) {

ssize_t n = recv(sock, &ch, 1, 0);

if (n <= 0) break;

if (ch == '\n') break;

buf[i++] = ch;

}

buf[i] = '\0';

return i;

}

void parse_command(const char* input, char* args[], int* argc) {

*argc = 0;

const char* p = input;

while (*p) {

while (*p == ' ' || *p == '\t') p++;

if (*p == '"') {

p++;

const char* start = p;

while (*p && *p != '"') p++;

int len = p - start;

args[*argc] = malloc(len + 1);

strncpy(args[*argc], start, len);

args[*argc][len] = '\0';

(*argc)++;

if (*p == '"') p++;

} else {

const char* start = p;

while (*p && *p != ' ' && *p != '\t' && *p != '\n') p++;

int len = p - start;

args[*argc] = malloc(len + 1);

strncpy(args[*argc], start, len);

args[*argc][len] = '\0';

(*argc)++;

}

void* client_handler(void* arg);

int main(int argc, char* argv[]) {

if (argc != 3) {

fprintf(stderr, "Usage: %s <IP> <Port>\n", argv[0]);

exit(1);

}

for (int i = 0; i < MAX_DOCS; ++i)

for (int j = 0; j < MAX_SECTIONS; ++j) {

pthread_mutex_init(§ion_mutex[i][j], NULL);

pthread_cond_init(§ion_cond[i][j], NULL);

pthread_mutex_init(§ion_queue_mutex[i][j], NULL);

pthread_cond_init(§ion_queue_cond[i][j], NULL);

}

int server_sock = socket(AF_INET, SOCK_STREAM, 0);

struct sockaddr_in server_addr, client_addr;

socklen_t addrlen = sizeof(client_addr);

server_addr.sin_family = AF_INET;

server_addr.sin_port = htons(atoi(argv[2]));

inet_pton(AF_INET, argv[1], &server_addr.sin_addr);

bind(server_sock, (struct sockaddr*)&server_addr, sizeof(server_addr));

listen(server_sock, 10);

printf("[Server] Listening on %s:%s\n", argv[1], argv[2]);

while (1) {

int *client_sock = malloc(sizeof(int));

*client_sock = accept(server_sock, (struct sockaddr*)&client_addr, &addrlen);

pthread_t tid;

pthread_create(&tid, NULL, client_handler, client_sock);

pthread_detach(tid);

}

close(server_sock);

return 0;

}

void* client_handler(void* arg) {

int client_sock = *(int*)arg;

free(arg);

char buf[BUF_SIZE];

char* args[64];

int argc;

while (1) {

memset(buf, 0, sizeof(buf));

if (read_line(client_sock, buf, sizeof(buf)) <= 0) break;

parse_command(buf, args, &argc);

if (argc == 0) continue;

if (strcmp(args[0], "create") == 0) {

pthread_mutex_lock(&docs_mutex);

if (argc < 3 || doc_count >= MAX_DOCS) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Invalid create command.\n");

continue;

}

if (find_doc(args[1])) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Document already exists.\n");

continue;

}

int section_count = atoi(args[2]);

if (section_count <= 0 || section_count > MAX_SECTIONS || argc != 3 + section_count) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Invalid section count or titles.\n");

continue;

}

strcpy(docs[doc_count].title, args[1]);

docs[doc_count].section_count = section_count;

for (int i = 0; i < section_count; ++i) {

strcpy(docs[doc_count].section_titles[i], args[3 + i]);

docs[doc_count].section_line_count[i] = 0;

}

++doc_count;

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[OK] Document created.\n");

}

else if (strcmp(args[0], "write") == 0) {

if (argc < 3) {

send_all(client_sock, "[Error] Invalid write command.\n");

continue;

}

pthread_mutex_lock(&docs_mutex);

Document* doc = find_doc(args[1]);

if (!doc) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Document not found.\n");

continue;

}

int section_idx = -1;

for (int i = 0; i < doc->section_count; ++i)

if (strcmp(doc->section_titles[i], args[2]) == 0) {

section_idx = i;

break;

}

if (section_idx == -1) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Section not found.\n");

continue;

}

int doc_idx = doc - docs;

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[OK] You can start writing. Send <END> to finish.\n>> ");

int line_count = 0;

char line[MAX_LINE];

char temp_lines[MAX_LINES][MAX_LINE];

while (1) {

if (read_line(client_sock, line, sizeof(line)) <= 0) break;

if (strcmp(line, "<END>") == 0) break;

if (line_count < MAX_LINES)

strncpy(temp_lines[line_count++], line, MAX_LINE - 1);

send_all(client_sock, ">> ");

}

WriteRequest *req = malloc(sizeof(WriteRequest));

req->client_sock = client_sock;

req->estimated_lines = line_count;

req->next = NULL;

pthread_mutex_lock(§ion_queue_mutex[doc_idx][section_idx]);

if (!section_queue[doc_idx][section_idx] || line_count < section_queue[doc_idx][section_idx]->estimated_lines) {

req->next = section_queue[doc_idx][section_idx];

section_queue[doc_idx][section_idx] = req;

} else {

WriteRequest *cur = section_queue[doc_idx][section_idx];

while (cur->next && cur->next->estimated_lines <= line_count)

cur = cur->next;

req->next = cur->next;

cur->next = req;

}

pthread_cond_signal(§ion_queue_cond[doc_idx][section_idx]);

pthread_mutex_unlock(§ion_queue_mutex[doc_idx][section_idx]);

pthread_mutex_lock(§ion_mutex[doc_idx][section_idx]);

while (section_queue[doc_idx][section_idx]->client_sock != client_sock)

pthread_cond_wait(§ion_queue_cond[doc_idx][section_idx], §ion_mutex[doc_idx][section_idx]);

pthread_mutex_lock(&docs_mutex);

doc->section_line_count[section_idx] = 0;

for (int i = 0; i < line_count && i < MAX_LINES; ++i)

strncpy(doc->section_contents[section_idx][i], temp_lines[i], MAX_LINE - 1);

doc->section_line_count[section_idx] = line_count;

pthread_mutex_unlock(&docs_mutex);

section_queue[doc_idx][section_idx] = section_queue[doc_idx][section_idx]->next;

pthread_cond_broadcast(§ion_queue_cond[doc_idx][section_idx]);

pthread_mutex_unlock(§ion_mutex[doc_idx][section_idx]);

send_all(client_sock, "[Write_Completed]\n");

}

else if (strcmp(args[0], "read") == 0) {

pthread_mutex_lock(&docs_mutex);

if (argc == 1) {

for (int i = 0; i < doc_count; ++i) {

char line[BUF_SIZE];

snprintf(line, sizeof(line), "%s\n", docs[i].title);

send_all(client_sock, line);

for (int j = 0; j < docs[i].section_count; ++j) {

snprintf(line, sizeof(line), " %d. %s\n", j + 1, docs[i].section_titles[j]);

send_all(client_sock, line);

}

} else if (argc >= 3) {

Document* doc = find_doc(args[1]);

if (!doc) {

pthread_mutex_unlock(&docs_mutex);

send_all(client_sock, "[Error] Document not found.\n");

continue;

}

int found = 0;

for (int i = 0; i < doc->section_count; ++i)

if (strcmp(doc->section_titles[i], args[2]) == 0) {

found = 1;

char header[BUF_SIZE];

snprintf(header, sizeof(header), "%s\n %d. %s\n", doc->title, i + 1, doc->section_titles[i]);

send_all(client_sock, header);

for (int j = 0; j < doc->section_line_count[i]; ++j) {

char line[BUF_SIZE];

snprintf(line, sizeof(line), " %s\n", doc->section_contents[i][j]);

send_all(client_sock, line);

}

break;

}

if (!found)

send_all(client_sock, "[Error] Section not found.\n");

}

send_all(client_sock, "__END__\n");

pthread_mutex_unlock(&docs_mutex);

}

else if (strcmp(args[0], "bye") == 0) {

send_all(client_sock, "[Disconnected]\n");

break;

} else {

send_all(client_sock, "[Error] Unknown command.\n");

}

for (int i = 0; i < argc; ++i) free(args[i]);

}

close(client_sock);

return NULL;

}

팔로우 156

[ Mechanica 물리학1 시리즈 2026 ]　한 권으로 끝내는 전설의 물리학1 개념서

[ 만점의 생각 - 수능 국어 비문학 2025 ]　완전한 이해, 적절한 적용

[ E-BOOK 감기약 국어 시리즈 2026 ]　의,치,한,약대 출신의 독서 노베용 처방!

0 XDK (+0)

유익한 글을 읽었다면 작성자에게 XDK를 선물하세요.

✨컴공주✨ [1052682]

쪽지 보내기

알림
스크랩
신고

8질라 · 1393273 · 05/31 00:22 · MS 2025

반가워요

좋아요 0 답글 달기 신고

안유지니어스
3시간 전

국어잘하고싶다 1

ㄹㅇ
부산사투리연습중
3시간 전

야뎊 제본하면 처벌받음? 1

텔레에서 얻은걸로;; 패드는 눈 아파서;;
파마늘
3시간 전

금테까지는 뉴비 1
그래프를찢어
3시간 전

과탐이 통합표본이였다면 1

1컷을 9%로 늘린다면(과탐 인원 2.25배) 물1 48 -> 45 화1 50 ->...
렐머벨
3시간 전

언매 화작 문학 해설할 사람 구함 1

걍 우리 대르비가 최초하자
departure
6시간 전

잡대특)강의실에 담배냄새 오짐 4

아오 ㅋㅋ
별。
7시간 전

루시드님? 5

흠냐뇨잇
파마늘
6시간 전

지나간것은 지나간대로 3

그런 의미가 있죠
Antcooo
5시간 전

생기부 중복 내용 괜찮을까요 2

이전에 과학탐구실험에서 패러다임의 전환을 주제로 멘델 유전법칙에 대해 탐구활동한적이...
노력파
6시간 전

6모대비 서바 국어 1회 4

언매 1컷 몇임?
국어를
7시간 전

6평 커하 찍엇음 5

칭찬좀
파마늘
6시간 전

슬슬 각성할때가 왔음 4

팔 깨물고 거인화
천후
6시간 전

개혁신당 "親이재명 댓글조작 사이트 'DDDLIST'부터 해명하라" 3

더불어민주당과 이재명 대선 후보가 보수 성향 단체의 댓글 조작 의혹 공세를 펼치고...
파마늘
7시간 전

그냥 5

8시40분부터4시37분까지 시간은 그대로 유지하고 그 안에서 자기 마음대로 보고싶은...
국어를
3시간 전

기하 1

미적
쿨뷰티장발미녀현우진
3시간 전

너가 한다 development 1

You do 개발
국어를
7시간 전

6모 수학 순서 5

1 30 2 29 3 28 ,,,
국어를
6시간 전

비문학 3

몇분 목표로 잡으심
램쥐썬더
3시간 전

개야한거 알아넴 1

개야함
1.0 강해린 08
7시간 전

금테출신 현역인설의 5

내가 해보겠어

글쓰기

오르비 1395829번째 회원 가입

1,422,072 건의 게시물이
블록체인에 디지털 공증되었습니다.

901,751

497,321

22,267

574

159

2026 수능D - 164

오르비

오르비 과외시장

Move our corporate site
Orbi Class on-line classes
Atom educational books & resources
Gae9 humor and fun

orbisoptimus (v17-e6bd24)

컴공 일기278

최근 게시글 · 더보기

공부를 도와주는 학습자료