클라이언트 서버 소켓 - keullaieonteu seobeo sokes

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

#include <stdio.h>

#include <signal.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <sys/un.h>

#define DEFAULT_PROTOCOL 0

int main()

{

int clientFd,serverLen,result;

struct sockaddr_un serverUNIXAddress;

struct sockaddr* serverSockAddrPtr;

serverSockAddrPtr=(struct sockaddr*)&serverUNIXAddress;

serverLen=sizeof(serverUNIXAddress);

// 양방향, 디폴트 프로토콜의 유닉스 소켓생성

clientFd = socket(AF_UNIX, SOCK_STREAM, DEFAULT_PROTOCOL);

serverUNIXAddress.sun_family=AF_UNIX; //서버 도메인

strcpy(serverUNIXAddress.sun_path,"recipe"); //서버 이름

do{ //서버와 연결되기까지 루프

result = connect(clientFd,serverSockAddrPtr,serverLen);

if(result==-1) sleep(1); //대기 후 다시 시도

}while(result==-1);

readRecipe(clientFd); //조리법 읽기

close(clientFd); //소켓 닫기

return 0;

}

void readRecipe(int fd)

{

char str[200];

while(readLine(fd,str)) //입력 끝까지 줄 읽기

printf("%s\n",str); //소켓으로부터 줄 출력

}

void readLine(int fd, char* str)

{

int n;

do{

n=read(fd,str,1);

}

while(n>0 && *str++ != NULL);

return (n>0);

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

#include <stdio.h>

#include <signal.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <sys/un.h> // AF_UNIX 소켓용

#include <stdlib.h>

#define DEFAULT_PROTOCOL 0

int main()

{

int serverFd,clientFd,serverLen,clientLen;

struct sockaddr_un serverUNIXAddress; // 서버 주소

struct sockaddr_un clientUNIXAddress; //클라이언트 주소

struct sockaddr* serverSockAddrPtr; //서버 주소에 대한 포인터

struct sockaddr* clientSockAddrPtr; //클라이언트 주소에 대한 포인트

signal(SIGCHLD,SIG_IGN); //좀비를 방지하기 위해 자식-죽음 시그널은 무시

serverSockAddrPtr=(struct sockaddr*)&serverUNIXAddress;

serverLen=sizeof(serverUNIXAddress);

clientSockAddrPtr=(struct sockaddr*)&clientUNIXAddress;

clientLen=sizeof(clientUNIXAddress);

//양방향, 디폴트 프로토콜의 유닉스 소켓 생성

serverFd=socket(AF_UNIX,SOCK_STREAM,DEFAULT_PROTOCOL);

serverUNIXAddress.sun_family=AF_UNIX; //도메인 유형 설정

strcpy(serverUNIXAddress.sun_path,"recipe"); // 이름 설정

unlink("recipe"); //이미 존재한다면, 파일 제거

bind(serverFd,serverSockAddrPtr,serverLen); //파일 생성

listen(serverFd,5); //대기 중인 연결의 최대 길이

while(1){

clientFd=accept(serverFd,clientSockAddrPtr,&clientLen); //클라이어트 연결 받기

printf("Server called!");

if(fork()==0){ //조리법을 전송할 자식 생성

writeRecipe(clientFd); //조리법 전송

close(clientFd); //소켓 닫기

exit(/*EXIT_SUCCES*/0); //종료

}else

close(clientFd); //클라이언트 기술자 닫기

}

return 0;

}

void writeRecipe(int fd)

{

static char* line1="spam,spam,spam,spam,spam,";

static char* line2="spam, and spam.";

write(fd,line1,strlen(line1)+1); //첫째줄 쓰기

write(fd,line2,strlen(line2)+1); //두번째 줄 쓰기

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <arpa/inet.h>

#include <sys/types.h>

#include <sys/socket.h>

void error_handling(char *message);

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

{

int sock;

struct sockaddr_in serv_addr;

char message[30];

int str_len=0;

int idx=0, read_len=0;

if(argc!=3){

printf("Usage : %s <IP> <port>\n", argv[0]);

exit(1);

}

sock=socket(PF_INET, SOCK_STREAM, 0);

if(sock == -1)

error_handling("socket() error");

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() error!");

while(read_len=read(sock, &message[idx++], 1))

{

if(read_len==-1)

error_handling("read() error!");

str_len+=read_len;

}

printf("Message from server: %s \n", message);

printf("Function read call count: %d \n", str_len);

close(sock);

return 0;

}

void error_handling(char *message)

{

fputs(message, stderr);

fputc('\n', stderr);

exit(1);

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <arpa/inet.h>

#include <sys/types.h>

#include <sys/socket.h>

void error_handling(char *message);

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

{

int serv_sock;

int clnt_sock;

struct sockaddr_in serv_addr;

struct sockaddr_in clnt_addr;

socklen_t clnt_addr_size;

char message[]="Hello World!";

if(argc!=2){

printf("Usage : %s <port>\n", argv[0]);

exit(1);

}

serv_sock=socket(PF_INET, SOCK_STREAM, 0);

if(serv_sock == -1)

error_handling("socket() error");

memset(&serv_addr, 0, sizeof(serv_addr));

serv_addr.sin_family=AF_INET;

serv_addr.sin_addr.s_addr=htonl(INADDR_ANY);

serv_addr.sin_port=htons(atoi(argv[1]));

if(bind(serv_sock, (struct sockaddr*) &serv_addr, sizeof(serv_addr))==-1)

error_handling("bind() error"); 

if(listen(serv_sock, 5)==-1)

error_handling("listen() error");

clnt_addr_size=sizeof(clnt_addr);  

while(1)

{//클라이언트가 접속하면 접속을 허용하고 클라이언트 소켓을 생성함

clnt_sock=accept(serv_sock, (struct sockaddr*)&clnt_addr,&clnt_addr_size);

if(clnt_sock==-1){

error_handling("accept() error");}

printf("Client: %s\n",inet_ntoa(clnt_addr.sin_addr));

if(write(clnt_sock,message,sizeof(message))<=0)

{perror("write error:");}

close(clnt_sock);

}

close(serv_sock);

return 0;

}

void error_handling(char *message)

{

fputs(message, stderr);

fputc('\n', stderr);

exit(1);

}