服务器与客户机互传消息

2019-11-17 05:36:51

字体：大中小

来源：转载

供稿：网友

　　一、服务器程序
创建一个名为“server" 的项目, 单文档界面。
在serverview.h 中加入代码：
           ＃include “winsock.h"
      添加变量：
            CSize       sizeTotal;// 控制滚动条
            int   count;// 信息条数
            CString m_data[1000];// 信息存放
            char    Hostname[260];
            char  Hostaddress[20];// 主机ip 地址
            SOCKET      m_sock;
            HANDLE      m_hListenThread;// 线程
            BOOL  m_bInitialized;// 是否初始化
            WSADATA     WSAData;
            BOOL  flag;
            SOCKADDR_IN saClnt;
            int   saClntLen;
            BOOL  Isconnect;// 是否连接

在serverview.cpp 中重载CServerView() 构造器, 创建并绑定嵌套字：
      CServerView::CServerView()
{     // TODO: add constrUCtion code here
      Isconnect=FALSE;
      flag=FALSE;
      sizeTotal.cy=350;
      sizeTotal.cx=300;
      m_hListenThread;
      count=5;
      int status;
      WSADATA wsaData;
   m_data[0]=“initializing Windows Sockets DLL....";
      if((status=WSAStartup(0x0101, ＆wsaData))==0)
      {     m_data[0] ＋=“Succeeded";
            m_bInitialized=TRUE;

      }
      else
      {     m_bInitialized=FALSE;
      }
      m_sock=socket(AF_INET,SOCK_DGRAM,0);
      m_data[1]=“Creating socket....";
      if(m_sock==INVALID_SOCKET)
      {     m_data[1] ＋=“Failed";
      }
      m_data[1] ＋=“Succeeded";
      m_data[2]=“Binding socket....";
      sockaddr_in sa;
      sa.sin_family=AF_INET;
      sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
      sa.sin_port=htons(5050);
      if(bind(m_sock,(PSOCKADDR)
     ＆sa,sizeof(sa))==SOCKET_ERROR)
      {     m_data[2] ＋=“Failed";
            closesocket(m_sock);
      }
      m_data[2] ＋=“Succeeded";
      m_data[3]=“Creating listener thread....";
      unsigned long idThread;
m_hListenThread=CreateThread(NULL,0,
(LPTHREAD_START_ROUTINE)Listen,
(void        if(m_hListenThread)
      {     m_data[3] ＋=“Succeeded";
            m_data[4] ＋=“Listening....";
      }
      else
            m_data[4] ＋=“Failed";
}

在析构函数中完成必需的清除操作:
      CServerView:: ～CServerView()
{     if(m_bInitialized)
      WSACleanup();
      closesocket(m_sock);
      if(m_hListenThread)
      ::TerminateThread(m_hListenThread,0);
}

定义接收和处理消息的线程:
      long WINAPI Listen(CServerView ＊pView)
{     char msg[2000]=“";

      int   nchar;
      SOCKADDR_IN saClnt;
      int saClntLen;
      while(1)
      { saClntLen=sizeof(saClnt);
        nchar=recvfrom(pView －>m_sock,msg,1024,0,
(PSOCKADDR) ＆saClnt, ＆saClntLen);
        if(nchar<0)
        {     pView －>m_data[pView －>count ＋＋] ＋
             =“Error in recvfrom/n";
        pView －>InvalidateRect(NULL);
        }
        else
        {switch(msg[0])
        {
        case  ‘A':
        wsPRintf(msg,“A:Client from ％s attached/n",
               inet_ntoa(saClnt.sin_addr));
        pView －>m_data[pView －>count ＋＋]=msg;
        pView －>flag=TRUE;
        pView －>InvalidateRect(NULL);
        pView －>Isconnect=TRUE;
        pView －>saClnt=saClnt;
        pView －>saClntLen=saClntLen;
        sendto(pView －>

上一篇：分而治之算法---残缺棋盘

下一篇：非安全编程演示之高级篇