该楼层疑似违规已被系统折叠 隐藏此楼查看此楼

/*made by ebhrz*/

#include

#include

#include

#include

#include

#include

#include

/*---------global define---------*/

int cfd; /* 文件描述符 */

int recbytes;

int sin_size;

char buffer[1024] = { 0 }; /* 接受缓冲区 */

struct sockaddr_in s_add, c_add; /* ip、端口 */

unsigned short portnum = 1234;//端口可自己修改

char msg[1024];

/*-----------global define end-----*/

int set_link()

{

cfd = socket(AF_INET, SOCK_STREAM, 0);

if (-1 == cfd)

{

printf("socket fail ! \r\n");

return -1;

}

printf("socket ok !\r\n");

bzero(&s_add, sizeof(struct sockaddr_in));

s_add.sin_family = AF_INET;

s_add.sin_addr.s_addr = inet_addr("127.0.0.1"); /* ip转换为4字节整形，使用时自己修改 */

s_add.sin_port = htons(portnum);

if (-1 ==

connect(cfd, (struct sockaddr *)(&s_add), sizeof(struct sockaddr)))

{

printf("connect fail !\n");

return -1;

}

return 1;

}

int rec()

{

if (-1 == (recbytes = read(cfd, buffer, 1024)))

{

printf("read data fail !\n");

return -1;

}

printf("%s\n", buffer);

if(strcmp(buffer,"bye bye")==1)

exit(0);

memset(buffer,0,1024);

}

int snd()

{

scanf("%[^\n]", msg);

if (-1 == write(cfd, msg, 32))

{

printf("write fail!\n");

return -1;

}

memset(msg, 0, 1024);

getchar();//接收遗留\n

}

int main()

{

printf("Hello,welcome to client !\n");

pid_t pid;

if (set_link() != 1)

{

printf("sth wrong");

return -1;

}

pid = fork();

if (pid < 0)

perror("fork error");

else if (pid > 0)

{

while (1)

rec();

close(cfd);

}

else

{

while (1)

snd();

close(cfd);

}

return 0;

}

/*made by ebhrz*/

#include

#include

#include

#include

#include

#include

#include

/*---------global define---------*/

int sfp, nfp;// 文件描述符

int recbytes;

int sin_size;

char buffer[1024] = { 0 };//接受缓冲区

struct sockaddr_in s_add, c_add; //ip、端口

unsigned short s_portnum = 1234;

char msg[1024];

/*-----------global define end-----*/

int set_link()

{

sfp = socket(AF_INET, SOCK_STREAM, 0);

if (-1 == sfp)

{

printf("socket fail ! \n");

return -1;

}

printf("socket ok !\n");

bzero(&c_add, sizeof(struct sockaddr_in));

s_add.sin_family = AF_INET;

s_add.sin_addr.s_addr = htonl(INADDR_ANY);//ip不定

s_add.sin_port = htons(s_portnum);

if (-1 == bind(sfp, (struct sockaddr *)(&s_add), sizeof(struct sockaddr)))

{

printf("bind fail !\r\n");

return -1;

}

printf("bind ok !\r\n");

sin_size = sizeof(struct sockaddr_in);

return 1;

}

int rec()

{

if (-1 == (recbytes = read(nfp, buffer, 1024)))

{

printf("read data fail !\n");

return -1;

}

printf("%s\n", buffer);

if(strcmp(buffer,"bye bye")==1)

exit(0);

memset(buffer,0,1024);

}

int snd()

{

scanf("%[^\n]", msg);

printf("%s", msg);

if (-1 == write(nfp, msg, 32))

{

printf("write fail!\n");

return -1;

}

memset(msg, 0, 1024);

getchar();

}

int main()

{

printf("Hello,welcome to service !\n");

pid_t pid;

if (set_link() != 1)

{

printf("sth wrong");

return -1;

}

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

{

printf("listen fail !\n");

return -1;

}

nfp = accept(sfp, (struct sockaddr *)(&c_add), &sin_size);

if (-1 == nfp)

{

printf("accept fail !\n");

return -1;

}

pid = fork();

if (pid < 0)

perror("fork error");

else if (pid > 0)

{

while (1)

snd();

close(nfp);

close(sfp);

}

else

{

while (1)

rec();

close(nfp);

close(sfp);

}

return 0;

}