From e6ed7d102b94079100236e0efa16f9ff7d84b93f Mon Sep 17 00:00:00 2001 From: sjdok9612 <56342332+sjdok9612@users.noreply.github.com> Date: Mon, 17 May 2021 08:08:57 +0900 Subject: [PATCH] Add files via upload MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 게임을 일부분만 제외한 구현 --- c.c | 152 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ s.c | 115 +++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 267 insertions(+) create mode 100644 c.c create mode 100644 s.c diff --git a/c.c b/c.c new file mode 100644 index 0000000..c1775b3 --- /dev/null +++ b/c.c @@ -0,0 +1,152 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#define BOARD_SIZE 5 +#define BUF_SIZE 100 + +void* send_msg(void* arg); +void* recv_msg(void* arg); + +void error_handling(char* mse); // ˻ +void game_print(int any); + +int turn_count = 0; +int board[BOARD_SIZE][BOARD_SIZE]; + + +int main(int argc, char* argv[]) +{ + int sock; + struct sockaddr_in serv_addr; + pthread_t snd_thread, rcv_thread, gam_thread; + void* thread_return; + + + + //Ӻ ũ + + srand(time(NULL)); //ð ڷ ־ + int check_number[BOARD_SIZE * BOARD_SIZE] = { 0 }; //ߺſ 迭 + for (int i = 0; i < BOARD_SIZE; i++) + { + for (int j = 0; j < BOARD_SIZE; j++) + { + while (1) + { + int temp = rand() % 25; //0~24 ߻ + + if (check_number[temp] == 0) //ߺ ˰. 0~24 ޾ƿ, ߺſ 迭 ǥس´. + { + check_number[temp] = 1; + board[i][j] = temp + 1; + break; + } + } + } + } + + + + if (argc != 3) { + printf("ip, Ʈȣ Է"); + exit(1); + } + + sock = socket(PF_INET, SOCK_STREAM, 0); + + memset(&serv_addr, 0, sizeof(serv_addr)); + serv_addr.sin_family=AF_INET; + serv_addr.sin_addr.s_addr = inet_addr(argv[1]); + serv_addr.sin_port = htons(atoi(argv[2])); + + if (connect(sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == -1) + error_handling("connect err"); + + pthread_create(&snd_thread, NULL, send_msg, (void*)&sock); + pthread_create(&rcv_thread, NULL, recv_msg, (void*)&sock); + pthread_join(snd_thread, &thread_return); + pthread_join(rcv_thread, &thread_return); + + close(sock); + return 0; +} + +void* send_msg(void* arg) { + int sock = *((int*)arg); + char msg[BUF_SIZE]; + while (1) { + fgets(msg, BUF_SIZE, stdin); + if (!strcmp(msg, "q\n")||!strcmp(msg,"Q\n")) + { + close(sock); + exit(0); + } + sprintf(msg, "%s", msg); + write(sock, msg, strlen(msg)); + } + return NULL; +} +void* recv_msg(void* arg) { + int sock = *((int*)arg); + char msg[BUF_SIZE]; + int str_len; + while (1) { + str_len = read(sock, msg, BUF_SIZE - 1); + if (str_len == -1) + return (void*)-1; + msg[str_len] = 0; + fputs(msg, stdout); + game_print(0); + } + return NULL; +} + +void error_handling(char* msg) +{ + fputs(msg, stderr); + fputc('\n', stderr); + exit(1); +} + +void game_print(int any) +{ + int i, j; + + system("clear"); // ȿ ȭ ʱȭ + printf("%c[1;33m", 27); //͹̳ ڻ + + printf("@------ Ŭ ------@\n"); + printf(" ϼ: %d\n", turn_count++); + printf("+----+----+----+----+----+\n"); + for (i = 0; i < BOARD_SIZE; i++) + { + for (j = 0; j < BOARD_SIZE; j++) + { + if (board[i][j] == 0) + { + printf("| "); + printf("%c[1;31m", 27); + printf("%2c ", 88); + printf("%c[1;33m", 27); + } + else + printf("| %2d ", board[i][j]); + } + printf("|\n"); + printf("+----+----+----+----+----+\n"); + } + printf("%c[0m", 27); //͹̳ ڻ + if (turn_count != 0) + { + printf(": %d\n", 1); + printf(": %d\n", 1); + } +} \ No newline at end of file diff --git a/s.c b/s.c new file mode 100644 index 0000000..c7d620c --- /dev/null +++ b/s.c @@ -0,0 +1,115 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#define BOARD_SIZE 5 +#define BUF_SIZE 100 +#define BACKLOG 3 // ť +#define MAX_CLNT 256 + +//Ʈũ +void error_handling(char* mse); // ˻ +void* handle_clnt(void* arg); +void send_msg(char* msg, int len); //send to all + +int turn[4]; //ø̼ +int clnt_cnt = 0; +int clnt_socks[MAX_CLNT]; +pthread_mutex_t mutx; +pthread_t t_id; + + + +/* + turn[0]=÷̾ ڼ + turn[1]=Ŭ̾Ʈ + turn[2]= + turn[3]=Ῡ(0=, 1=Ŭ̾Ʈ ¸, 2= ¸, 3=º) +*/ + +int main(int argc, char* argv[]) +{ + int serv_sock, clnt_sock; + struct sockaddr_in serv_adr, clnt_adr; + int clnt_adr_sz; + pthread_t t_id; + if (argc != 2) { + printf("Ʈ ԷϽÿ."); + } + pthread_mutex_init(&mutx, NULL); + serv_sock = socket(PF_INET, SOCK_STREAM, 0); + + memset(&serv_adr, 0, sizeof(serv_adr)); //ü ʱȭ + serv_adr.sin_family = AF_INET; //IPv4 + serv_adr.sin_addr.s_addr = htonl(INADDR_ANY); //IPּ Ҵ + serv_adr.sin_port = htons(atoi(argv[1])); //Ʈ Ҵ + + if (bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr)) == 1) { + error_handling("bind() error"); + } + if (listen(serv_sock, 5) == -1) { + error_handling("listen() error"); + } + printf("ʱȭ,IP,ƮҴ糡, Ӵ"); + while (1) { + clnt_adr_sz = sizeof(clnt_adr); + clnt_sock = accept(serv_sock, (struct sockaddr*)&clnt_adr, &clnt_adr_sz); + + pthread_mutex_lock(&mutx); + clnt_socks[clnt_cnt++] = clnt_sock; + pthread_mutex_unlock(&mutx); + + pthread_create(&t_id, NULL, handle_clnt, (void*)&clnt_sock); + pthread_detach(t_id); + printf("Connected Clnt IP : %s \n", inet_ntoa(clnt_adr.sin_addr)); + + printf("* %s:%d û\n", inet_ntoa(clnt_adr.sin_addr), ntohs(clnt_adr.sin_port)); + printf(".\n"); + } + close(serv_sock); + return 0; +} + +void error_handling(char* msg) +{ + fputs(msg, stderr); + fputc('\n', stderr); + exit(1); +} + +void* handle_clnt(void* arg) { + int clnt_sock = *((int*)arg); + int str_len = 0, i; + char msg[BUF_SIZE]; + + while ((str_len = read(clnt_sock, msg, sizeof(msg))) != 0) + send_msg(msg, str_len); + pthread_mutex_lock(&mutx); + for (i = 0; i < clnt_cnt; i++) //eliminated disconnections + { + if (clnt_sock == clnt_socks[i]) + { + while (i++ < clnt_cnt - 1) + clnt_socks[i] = clnt_socks[i + 1]; + break; + } + } + clnt_cnt--; + pthread_mutex_unlock(&mutx); + close(clnt_sock); + return NULL; +} +void send_msg(char* msg, int len) { + int i; + pthread_mutex_lock(&mutx); + for (i = 0; i < clnt_cnt; i++) + write(clnt_socks[i], msg, len); + pthread_mutex_unlock(&mutx); +}