手册   游戏   WEB   字典   单词   在线工具  

网络报文的数据格式定义及使用 4

服务端, 使用缓冲区来接受客户端数据

服务端:

  1. //vc 的第一套 socket, 第二套 socket, 可能存在冲突
  2. #define WIN32_LEAN_AND_MEAN
  3. #define  _WINSOCK_DEPRECATED_NO_WARNINGS // 也可以放到工程属性, 预处理中
  4. #include <Windows.h>
  5. #include <WinSock2.h>
  6. #include <stdio.h>
  7. #pragma comment(lib, "ws2_32.lib")
  8. enum CMD
  9. {
  10.     CMD_LOGIN,
  11.     CMD_LOGIN_RET,
  12.     CMD_LOGOUT,
  13.     CMD_LOGOUT_RET,
  14.     CMD_ERROR
  15. };
  16. struct DataHeader
  17. {
  18.     int dataLength;
  19.     CMD    cmd;
  20. };
  21. struct Login :public DataHeader
  22. {
  23.     Login()
  24.     {
  25.         dataLength = sizeof(Login);
  26.         cmd = CMD_LOGIN;
  27.     }
  28.     char userName[32];
  29.     char passWord[32];
  30. };
  31. struct LoginResult :public DataHeader
  32. {
  33.     LoginResult()
  34.     {
  35.         dataLength = sizeof(LoginResult);
  36.         cmd = CMD_LOGIN_RET;
  37.         ret = 0;
  38.     }
  39.     int ret;
  40. };
  41. struct LogOut :public DataHeader
  42. {
  43.     LogOut()
  44.     {
  45.         dataLength = sizeof(LogOut);
  46.         cmd = CMD_LOGOUT;
  47.     }
  48.     char userName[32];
  49. };
  50. struct LogOutResult :public DataHeader
  51. {
  52.     LogOutResult()
  53.     {
  54.         dataLength = sizeof(LogOutResult);
  55.         cmd = CMD_LOGOUT_RET;
  56.         ret = 0;
  57.     }
  58.     int ret;
  59. };
  60. int main()
  61. {
  62.     // 启动 Windows socket 2.x 环境
  63.     Word ver = MAKEWORD(2, 2);
  64.     WSADATA dat;
  65.     WSAStartup(ver, &dat);
  66.     //-- 用 Socket API 建立简易 TCP 服务端
  67.     //1. 建立一个 socket
  68.     SOCKET _sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  69.     //2 bind 绑定用于接受客户端连接的网络端口
  70.     sockaddr_in _sin = {};
  71.     _sin.sin_family = AF_INET;
  72.     _sin.sin_port = htons(4567);//host to.NET unsigned
  73.     _sin.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
  74.     // 使用 127.0.0.1 可以防止外网访问
  75.     // 启用本机全部的 ip 地址可以使用, INADDR_ANY
  76.     if (SOCKET_ERROR == bind(_sock, (sockaddr*)&_sin, sizeof(sockaddr_in)))
  77.     {
  78.         printf("错误, 绑定网络端口失败...\n");
  79.     }
  80.     else
  81.     {
  82.         printf("绑定网络端口成功...\n");
  83.     }
  84.     //3 listen 监听网络端口
  85.     if (SOCKET_ERROR == listen(_sock, 5))
  86.     {
  87.         printf("错误, 监听网络端口失败...\n");
  88.     }
  89.     else
  90.     {
  91.         printf("监听网络端口成功...\n");
  92.     }
  93.     //4 accept 等待接受客户端连接
  94.     sockaddr_in clientAddr = {};
  95.     int nAddrLen = sizeof(clientAddr);
  96.     SOCKET _cSock = INVALID_SOCKET;
  97.     _cSock = accept(_sock, (sockaddr*)&clientAddr, &nAddrLen);
  98.     if (INVALID_SOCKET == _cSock)
  99.     {
  100.         printf("错误, 接受到无效客户端 socket...\n");
  101.     }
  102.     printf("新客户端加入: IP=%s\n", inet_ntoa(clientAddr.sin_addr));
  103.     while (true)
  104.     {
  105.         //5 接收客户端数据
  106.         char szRecv[1024] = {};
  107.         int nLen = recv(_cSock, szRecv, sizeof(DataHeader), 0);
  108.         if (nLen <0)
  109.         {
  110.             printf("客户端已退出, 任务结束.\n");
  111.             break;
  112.         }
  113.         DataHeader* pHeader = (DataHeader*)szRecv;
  114.         switch (pHeader->cmd)
  115.         {
  116.         case CMD_LOGIN:
  117.         {
  118.             recv(_cSock, szRecv+sizeof(DataHeader), pHeader->dataLength - sizeof(DataHeader), 0);
  119.             Login *pLogin = (Login*)szRecv;
  120.             printf("cmd logint,user:%s,password:%s\n", pLogin->userName, pLogin->passWord);
  121.             //----------------------------
  122.             //----------------------------
  123.             LoginResult longinRet = {};
  124.             send(_cSock, (const char*)&longinRet, sizeof(LoginResult), 0);
  125.         }
  126.         break;
  127.         case CMD_LOGOUT:
  128.         {
  129.             recv(_cSock, szRecv + sizeof(DataHeader), pHeader->dataLength - sizeof(DataHeader), 0);
  130.             LogOut *pLogOut = (LogOut*)szRecv;
  131.             printf("cmd logout,user:%s\n", pLogOut->userName);
  132.             //----------------------------
  133.             LogOutResult logOutRet = {};
  134.             send(_cSock, (const char*)&logOutRet, sizeof(LogOutResult), 0);
  135.         }
  136.         break;
  137.         default:
  138.         {
  139.             // 剩余的垃圾数据是否要读取出来?
  140.             if (pHeader->dataLength>0 )
  141.             {
  142.                 recv(_cSock, szRecv + sizeof(DataHeader), pHeader->dataLength - sizeof(DataHeader), 0);
  143.             }
  144.             DataHeader header = {};
  145.             header.cmd = CMD_ERROR;
  146.             header.dataLength = 0;
  147.             send(_cSock, (const char*)&header, sizeof(DataHeader), 0);
  148.         }
  149.         break;
  150.         }
  151.     }
  152.     //6 关闭套接字 closesocket
  153.     closesocket(_sock);
  154.     // 清除 Windows socket 环境
  155.     WSACleanup();
  156.     printf("已退出.\n");
  157.     getchar();
  158.     return 0;
  159. }

客户端:

  1. #define WIN32_LEAN_AND_MEAN
  2. #define _WINSOCK_DEPRECATED_NO_WARNINGS // 也可以放到工程属性, 预处理中
  3. //#define _CRT_SECURE_NO_WARNINGS
  4. #include <Windows.h>
  5. #include <WinSock2.h>
  6. #include <stdio.h>
  7. #pragma comment(lib, "ws2_32.lib")
  8. enum CMD
  9. {
  10.     CMD_LOGIN,
  11.     CMD_LOGIN_RET,
  12.     CMD_LOGOUT,
  13.     CMD_LOGOUT_RET,
  14.     CMD_ERROR
  15. };
  16. struct DataHeader
  17. {
  18.     int dataLength;
  19.     CMD    cmd;
  20. };
  21. struct Login:public DataHeader
  22. {
  23.     Login()
  24.     {
  25.         dataLength = sizeof(Login);
  26.         cmd = CMD_LOGIN;
  27.     }
  28.     char userName[32];
  29.     char passWord[32];
  30. };
  31. struct LoginResult :public DataHeader
  32. {
  33.     LoginResult()
  34.     {
  35.         dataLength = sizeof(LoginResult);
  36.         cmd = CMD_LOGIN_RET;
  37.         ret = 1;
  38.     }
  39.     int ret;
  40. };
  41. struct LogOut :public DataHeader
  42. {
  43.     LogOut()
  44.     {
  45.         dataLength = sizeof(LogOut);
  46.         cmd = CMD_LOGOUT;
  47.     }
  48.     char userName[32];
  49. };
  50. struct LogOutResult :public DataHeader
  51. {
  52.     LogOutResult()
  53.     {
  54.         dataLength = sizeof(LogOutResult);
  55.         cmd = CMD_LOGOUT_RET;
  56.         ret = 1;
  57.     }
  58.     int ret;
  59. };
  60. int main()
  61. {
  62.     // 启动 Windows socket 2.x 环境
  63.     Word ver = MAKEWORD(2, 2);
  64.     WSADATA dat;
  65.     WSAStartup(ver, &dat);
  66.     //---------------------------
  67.     //-- 用 Socket API 建立简易 TCP 客户端
  68.     //1 建立一个 socket
  69.     SOCKET _sock = INVALID_SOCKET;
  70.     _sock = socket(AF_INET, SOCK_STREAM, 0);
  71.     if (INVALID_SOCKET == _sock)
  72.     {
  73.         printf("错误, 建立 Socket 失败...\n");
  74.     }
  75.     else
  76.     {
  77.         printf("建立 Socket 成功...\n");
  78.     }
  79.     //2 连接服务器 connect
  80.     sockaddr_in _sin = {};
  81.     _sin.sin_family = AF_INET;
  82.     _sin.sin_port = htons(4567);//host to.NET unsigned
  83.     _sin.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
  84.     int ret = connect(_sock, (sockaddr*)&_sin, sizeof(sockaddr_in));
  85.     if (SOCKET_ERROR == ret)
  86.     {
  87.         printf("错误, 连接服务端失败...\n");
  88.         closesocket(_sock);
  89.         // 清除 Windows socket 环境
  90.         WSACleanup();
  91.         printf("已退出.");
  92.         getchar();
  93.         return 0;
  94.     }
  95.     else
  96.     {
  97.         printf("连接服务端成功...\n");
  98.     }
  99.     while (true)
  100.     {
  101.         //3 输入请求命令
  102.         char cmdBuf[128] = {};
  103.         scanf_s("%s", cmdBuf, 128);
  104.         getchar();
  105.         //4 处理请求
  106.         if (0 == strcmp(cmdBuf, "exit"))
  107.         {
  108.             printf("收到 exit 命令, 任务结束.\n");
  109.             break;
  110.         }
  111.         else if(0 == strcmp(cmdBuf, "login"))
  112.         {
  113.             Login login = {};
  114.             strcpy_s(login.userName, "jj");
  115.             strcpy_s(login.passWord, "ww");
  116.             send(_sock, (const char*)&login, sizeof(Login), 0);
  117.             LoginResult cmd_ret = {};
  118.             recv(_sock, (char*)&cmd_ret, sizeof(LoginResult), 0);
  119.             printf("Login result:%d\n", cmd_ret.ret);
  120.         }
  121.         else if (0 == strcmp(cmdBuf, "logout"))
  122.         {
  123.             LogOut log_out = {};
  124.             strcpy_s(log_out.userName, "jj");
  125.             send(_sock, (const char*)&log_out, sizeof(LogOut), 0);
  126.             LogOutResult cmd_ret = {};
  127.             recv(_sock, (char*)&cmd_ret, sizeof(LogOutResult), 0);
  128.             printf("LogOut result:%d\n", cmd_ret.ret);
  129.         }
  130.         else
  131.         {
  132.             printf("wrong cmd, please input cmd again.\n");
  133.         }
  134.     }
  135.     //7 关闭套接字 closesocket
  136.     closesocket(_sock);
  137.     // 清除 Windows socket 环境
  138.     WSACleanup();
  139.     printf("已退出");
  140.     getchar();
  141.     return 0;
  142. }

来源: http://www.bubuko.com/infodetail-3716289.html


与本文相关文章

  1. Git 原理与高级使用 (4)
  2. 解析 PHP 使用 curl 提交 json 格式数据
  3. LoadRunner 编写 Socket 协议脚本方法 (xml/16 进制报文 data.ws 格式)
  4. TCP报文段的首部格式
  5. Python3 网络爬虫开发实战 3 - 基本库的使用 - 4 抓取猫眼电影排行
  6. 网络应用 (6):http 报文结构与 curl 的使用
  7. OSPF报头及各种报文格式
  8. 高效传输数据格式以及基于 HTTP2 的 RPC 框架 ---gRPC 的使用
暂无,快来抢沙发吧！
更多





黑ICP备17005318号-1