当前位置:   article > 正文

网络编程作业day2

网络编程作业day2

1.将TPC和UDP通信模型各敲两遍

(1)TPC通信模型:

服务器代码:

  1. #include <myhead.h>
  2. #define SERVER_IP "192.168.125.136"
  3. #define SERVER_PORT 1314
  4. int main(int argc, const char *argv[])
  5. {
  6. //1、创建用于监听的套接字
  7. int sfd=socket(AF_INET,SOCK_STREAM,0);
  8. if(sfd==-1)
  9. {
  10. perror("socket error");
  11. return -1;
  12. }
  13. //2、绑定ip和端口号
  14. //先定义地址信息结构体
  15. struct sockaddr_in sin;
  16. sin.sin_family=AF_INET;//地址族
  17. sin.sin_port=htons(SERVER_PORT);//服务器端口号
  18. sin.sin_addr.s_addr=inet_addr(SERVER_IP);//服务器ip地址
  19. //再进行绑定
  20. if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
  21. {
  22. perror("bind error");
  23. return -1;
  24. }
  25. //3、设置套接字为监听状态
  26. if(listen(sfd,128)==-1)
  27. {
  28. perror("listen error");
  29. return -1;
  30. }
  31. //4、服务器接收客户端连接,并获获取客户端的地址信息
  32. //定义客户端地址信息结构体
  33. struct sockaddr_in cin;
  34. int size=sizeof(cin);
  35. int newfd=accept(sfd,(struct sockaddr*)&cin,&size);
  36. if(newfd==-1)
  37. {
  38. perror("nwefd error");
  39. return -1;
  40. }
  41. printf("连接的客户端的ip地址:%s,端口号:%d\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));
  42. //5、交互数据
  43. char rbuf[1024];
  44. while(1)
  45. {
  46. //服务器接收客户端发来的数据存入到rbuf中
  47. bzero(rbuf,sizeof(rbuf));//清空容器
  48. int res=recv(newfd,rbuf,sizeof(rbuf),0);//阻塞接收
  49. if(strcmp(rbuf,"end")==0)
  50. {
  51. break;
  52. }
  53. printf("接收到的数据:%s\n",rbuf);
  54. //服务器回复客户端已收到数据
  55. char wbuf[100]="已收到数据";
  56. send(newfd,wbuf,sizeof(wbuf),0);
  57. }
  58. //6、关闭套接字
  59. close(sfd);
  60. close(newfd);
  61. return 0;
  62. }

客户端代码:

  1. #include <myhead.h>
  2. #define SERVER_IP "192.168.125.136"
  3. #define SERVER_PORT 1314
  4. int main(int argc, const char *argv[])
  5. {
  6. //1、创建套接字
  7. int sfd=socket(AF_INET,SOCK_STREAM,0);
  8. if(sfd==-1)
  9. {
  10. perror("socket error");
  11. return -1;
  12. }
  13. //2、绑定ip和端口号(可选)
  14. //3、客户端绑定服务器
  15. //定义需要绑定的地址信息结构体
  16. struct sockaddr_in sin;
  17. sin.sin_family=AF_INET;//地址族
  18. sin.sin_port=htons(SERVER_PORT);//服务器端口号
  19. sin.sin_addr.s_addr=inet_addr(SERVER_IP);//服务器ip地址
  20. //连接
  21. if(connect(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
  22. {
  23. perror("connect error");
  24. return -1;
  25. }
  26. //4、交互数据
  27. char rbuf[1024];
  28. while(1)
  29. {
  30. //从终端接的数据存入到rbuf中
  31. bzero(rbuf,sizeof(rbuf));//清空容器
  32. printf("请输入:");
  33. fgets(rbuf, sizeof(rbuf),stdin);
  34. rbuf[strlen(rbuf)-1]=0;
  35. if(strcmp(rbuf,"end")==0)
  36. {
  37. break;
  38. }
  39. send(sfd,rbuf,sizeof(rbuf),0);
  40. printf("发送成功\n");
  41. //客户端从服务器接收数据
  42. char wbuf[100];
  43. bzero(wbuf,sizeof(wbuf));
  44. recv(sfd,wbuf,sizeof(wbuf),0);
  45. printf("收到服务器信息:%s\n",wbuf);
  46. }
  47. //5、关闭套接字
  48. close(sfd);
  49. return 0;
  50. }

(2)UDP通信模型:

服务器代码:

  1. #include <myhead.h>
  2. #define SERVER_IP "192.168.101.104"
  3. #define SERVER_PORT 1314
  4. int main(int argc, const char *argv[])
  5. {
  6. //1、创建套接字
  7. int sfd=socket(AF_INET,SOCK_DGRAM,0);
  8. if(sfd==-1)
  9. {
  10. perror("socket error");
  11. return -1;
  12. }
  13. //2、绑定ip和端口号
  14. //先定义地址信息结构体
  15. struct sockaddr_in sin;
  16. sin.sin_family=AF_INET;//地址族
  17. sin.sin_port=htons(SERVER_PORT);//服务器端口号
  18. sin.sin_addr.s_addr=inet_addr(SERVER_IP);//服务器ip地址
  19. //再进行绑定
  20. if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)
  21. {
  22. perror("bind error");
  23. return -1;
  24. }
  25. //3、收发数据
  26. char rbuf[1024];
  27. //定义容器接收对端地址信息结构体
  28. struct sockaddr_in cin;
  29. int size=sizeof(cin);
  30. while(1)
  31. {
  32. bzero(rbuf, sizeof(rbuf));
  33. //接收数据
  34. recvfrom(sfd, rbuf, sizeof(rbuf),0,(struct sockaddr*)&cin, &size);
  35. printf("收到客户端发来的消息为:%s\n", rbuf);
  36. if(strcmp(rbuf,"end")==0)
  37. {
  38. break;
  39. }
  40. //回复已收到
  41. char wbuf[100]="已收到数据";
  42. sendto(sfd, wbuf, sizeof(wbuf), 0, (struct sockaddr*)&cin,size);
  43. }
  44. //4、关闭套接字
  45. close(sfd);
  46. return 0;
  47. }

客户端代码:

  1. #include <myhead.h>
  2. #define SERVER_IP "192.168.101.104"
  3. #define SERVER_PORT 1314
  4. int main(int argc, const char *argv[])
  5. {
  6. //1、创建套接字
  7. int sfd=socket(AF_INET,SOCK_DGRAM,0);
  8. if(sfd==-1)
  9. {
  10. perror("socket error");
  11. return -1;
  12. }
  13. //2、绑定ip和端口号(可选)
  14. //定义服务器的地址信息结构体
  15. struct sockaddr_in sin;
  16. sin.sin_family = AF_INET;
  17. sin.sin_port = htons(SERVER_PORT);
  18. sin.sin_addr.s_addr = inet_addr(SERVER_IP);
  19. int maxsize=sizeof(sin);
  20. //3、交互数据
  21. char rbuf[1024];
  22. while(1)
  23. {
  24. //从终端接的数据存入到rbuf中
  25. bzero(rbuf,sizeof(rbuf));//清空容器
  26. printf("请输入:");
  27. fgets(rbuf, sizeof(rbuf),stdin);
  28. rbuf[strlen(rbuf)-1]=0;
  29. sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&sin, sizeof(sin));//客户端数据发送到服务器
  30. printf("发送成功\n");
  31. if(strcmp(rbuf,"end")==0)
  32. {
  33. break;
  34. }
  35. //客户端从服务器接收数据
  36. char wbuf[100];
  37. bzero(wbuf,sizeof(wbuf));
  38. recvfrom(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&sin,&maxsize);
  39. printf("收到服务器信息:%s\n",wbuf);
  40. }
  41. //4、关闭套接字
  42. close(sfd);
  43. return 0;
  44. }

思维导图

声明:本文内容由网友自发贡献,转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号