spacepaste

Paste details

reply | raw

  1.  
  2. // EchoTCPClient.cpp : 定义控制台应用程序的入口点。
  3. //
  5. #include "stdafx.h"
  7. #include "SocketFrame.h"
  8. int tcp_client_fun_recvn(FILE *fp,SOCKET s);
  9. UINT tcp_client_fun_recvn_receive( LPVOID pParam );
  10. #define ECHOPORT "7210"
  11. #include "winsock2.h"
  12. // 唯一的应用程序对象
  14. CWinApp theApp;
  16. using namespace std;
  17. CSocketFrame frame;
  18. int flen;
  19. int main(int argc, char* argv[])
  20. {
  21. CSocketFrame frame;
  22. int iResult;
  23. SOCKET ClientSocket;
  24. CWinThread *pThread= NULL;
  25. //输入参数合法性检查
  26. if (argc != 3)
  27. {
  28. printf("usage: EchoTCPClient-recvn <IPaddress> <定长接收长度>");
  29. return -1;
  30. }
  32. //Windows Sockets Dll初始化
  33. frame.start_up();
  35. //创建客户端的流式套接字，并与服务器建立连接
  36. printf("连接建立成功，请输入回射字符串。。。\n");
  37. ClientSocket = frame.tcp_client( ( char *)argv[1], ECHOPORT );
  38. if ( ClientSocket == -1 )
  39. return -1;
  41. flen = atoi(argv[2]);
  42. pThread = AfxBeginThread( tcp_client_fun_recvn_receive, &ClientSocket );
  43. //开始回射请求的发送与接收
  44. iResult = tcp_client_fun_recvn(stdin,ClientSocket);
  45. WaitForSingleObject(pThread,INFINITE);
  46. frame.quit( ClientSocket );
  47. return iResult;
  48. return 0;
  49. }
  51. /********************************************************
  52. 函数名：tcp_client_fun_recvn
  53. 输入参数：FILE *fp:指向FILE类型的对象
  54. SOCKET s:服务器的连接套接字
  55. 输出参数：0：成功，-1：失败
  56. 功能：测试服务器定长接收能力，根据用户输入，持续向服务器发送数据
  57. *********************************************************/
  58. int tcp_client_fun_recvn(FILE *fp,SOCKET s)
  59. {
  60. int iResult;
  61. char sendline[MAXLINE];
  62. memset(sendline,0,MAXLINE);
  64. //循环发送用户的输入数据，并接收服务器返回的应答，直到用户输入"Q"结束
  65. while(fgets(sendline,MAXLINE,fp)!=NULL)
  66. {
  67. if( *sendline == 'Q'){
  68. printf("input end!\n");
  69. // 数据发送结束，调用shutdown()函数声明不再发送数据，此时客户端仍可以接收数据
  70. iResult = shutdown(s, SD_SEND);
  71. if (iResult == SOCKET_ERROR) {
  72. printf("shutdown failed with error: %d\n", WSAGetLastError());
  73. }
  74. return 0;
  75. }
  76. iResult = send(s,sendline,strlen(sendline),0);
  77. if(iResult == SOCKET_ERROR)
  78. {
  79. printf("send 函数调用错误，错误号： %ld\n", WSAGetLastError());
  80. return -1;
  81. }
  82. printf("\r\n客户端发送数据：%s\r\n", sendline);
  84. memset(sendline,0,MAXLINE);
  85. }
  86. return iResult;
  87. }
  89. UINT tcp_client_fun_recvn_receive( LPVOID pParam )
  90. {
  91. int iResult = 0;
  92. char recvline[MAXLINE];
  94. //将输入参数转换为连接套接字
  95. SOCKET s =*( (SOCKET *)pParam);
  97. do {
  98. memset( recvline, 0, MAXLINE );
  99. //接收数据
  100. iResult = frame.recvn( s, recvline, flen);
  101. if (iResult > 0)
  102. printf("服务器端接收到数据%s\n", recvline);
  103. else{
  104. if (iResult == 0)
  105. printf("对方连接关闭，退出\n");
  106. else{
  107. printf("recv 函数调用错误，错误号: %d\n", WSAGetLastError());
  108. iResult = -1;
  109. }
  110. }
  111. } while (iResult > 0);
  112. printf("THREAD BEGIN TO END");
  113. return iResult;
  114. }
  115.  
Powered by spacepaste. Paste removal.