EnderSnowBaby 2015-07-12 05:29 采纳率: 0%
浏览 1631

有关ege和udp的问题,新手求大神,

我做的udp文件传输,在dos界面下服务端可以接收到来自客户端的文件,但我加上ege界面之后,发现服务端收不到了
这个是dos界面的服务端的接收函数
int file()
{

int err = INVALID_VALUE32;
WORD ver;
WSADATA wsaData;
int result;

ver = MAKEWORD(2, 2);  


err = WSAStartup(ver, &wsaData);
if (err != 0)   
{

    return 0;

}
if ((LOBYTE(wsaData.wVersion) != 2) || (HIBYTE(wsaData.wVersion) != 2))
{ 

    WSACleanup(); 
    return 0;

}
sockSc = socket(AF_INET, SOCK_DGRAM, 0); 
SOCKADDR_IN addrSc;
addrSc.sin_addr.S_un.S_addr = htonl(INADDR_ANY);;
addrSc.sin_family = AF_INET;
addrSc.sin_port = htons(7861); 
result=bind(sockSc, (SOCKADDR*)&addrSc, sizeof(SOCKADDR)); 
DWORD ID;
HANDLE handle=CreateThread(NULL,0,recvfunc,0,0,&ID);
while(recvexi<2)
{

  Sleep(100);

}

printf("退出成功\n");
return 0;
}
char TcharToChar(const TCHAR *tchar,char *_char)
{
int ilength;
ilength = WideCharToMultiByte(CP_ACP,0,tchar,-1,NULL,0,NULL,NULL);
WideCharToMultiByte(CP_ACP,0,tchar,-1,_char,ilength,NULL,NULL);
return *_char;
}//WCHAR到char类型的转换

DWORD WINAPI recvfunc(LPVOID lpParam)
{
recvexi=1;
FILE *p;
char name[5200];
char name1[5200];
getchar();
printf("请输入你想要接收的文件路径:\n");
gets_s(name);
fopen_s(&p,name,"wb");
while(recvexi==1)
{

    int rec=recvfrom(sockSc,(char *)(&data),2048,0,(sockaddr*)&server,&lenth);
    if(rec>0)
    {
        if(data.head.id=id)
        {
            fwrite(data.buf,sizeof(char),data.bufsize,p);
            recvsize=recvsize+data.bufsize;

            filesize = data.head.size;
            datahead.id = data.head.id;
            datahead.recvsize = recvsize;
            datahead.size = filesize;
            int d = sendto(sockSc,(char*)(&datahead),
            sizeof(datahead),0,(sockaddr*)&server,lenth);
            id = id+1;
        }

         else if(data.head.id < id)
         {

             datahead.id = data.head.id;
             datahead.recvsize=recvsize;
             datahead.size = filesize;
             int d = sendto(sockSc,(char*)(&datahead),
             sizeof(datahead),0,(sockaddr*)&server,lenth);

         }
           if(filesize == recvsize)
           {
               datahead.id=data.head.id;
               datahead.recvsize=-1;
               datahead.size=filesize;
               printf("filesize=%d\n",filesize);
               printf("recvsize=%d\n",recvsize);
               printf("文件已经收到了!");
               int d=sendto(sockSc,(char*)(&datahead),
               sizeof(datahead),0,(sockaddr*)&server,lenth);
               recvexi = 2;
               system("pause");
               break;
           }

        }
    }
   fclose(p);
   recvexi = 2;
   _tsystem(TEXT("pause"));
   return 0;

}//文件接收线程的具体使用
这个是加上ege之后的服务端的文件接收函数
int file()//文件传输函数
{
post();
system("pause");
outtextxy(300,300,silePath);
int err = INVALID_VALUE32;
WORD ver;
WSADATA wsaData;
int result;

ver = MAKEWORD(2, 2);  
err = WSAStartup(ver, &wsaData);//Windows异步套接字)的启动命令

if ( 0 != err )  // 判断函数返回值
{
    return 0;
}

if ( (2 != LOBYTE(wsaData.wVersion))//是取得16进制数最低(最右边)那个字节的内容
    || 2 != (HIBYTE(wsaData.wVersion)) )//取得16进制数最高(最左边)那个字节的内容
{ 
    WSACleanup(); //中止Windows Sockets在所有线程上的操作

    return 0;
}



sockSc = socket(AF_INET, SOCK_DGRAM, 0); 
addrSc.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
addrSc.sin_family           = AF_INET;
addrSc.sin_port             = htons(7861); 
result=bind(sockSc, (SOCKADDR*)&addrSc, sizeof(SOCKADDR)); 
DWORD ID;
HANDLE handle = CreateThread(NULL, 0, recvfunc, 0, 0, &ID);//创建文件接收线程
while( 2 > recvexi )
{
  Sleep(100);
}

printf("退出成功\n");

return 0;

}
char TcharToChar(const TCHAR *tchar,char *_char)//WCHAR到CHAR类型的转换
{
int ilength;
ilength = WideCharToMultiByte(CP_ACP, 0, tchar,-1, NULL, 0, NULL, NULL);
WideCharToMultiByte(CP_ACP, 0, tchar, -1, _char, ilength, NULL, NULL);

return *_char;

}

DWORD WINAPI recvfunc(LPVOID lpParam)//文件接收具体线程
{
recvexi=1;
FILE *p;

p = fopen(silePath,"wb");
outtextxy(300,300,silePath);

while( 1 == recvexi )
{   

    int rec = recvfrom(sockSc, (char *)(&data), 2048, 0, (sockaddr*)&server, &lenth);//接收到消息
    if( 0 < rec )
    {

        if( data.head.id = id )
        {
            fwrite(data.buf, sizeof(char), data.bufsize, p);//二进制流格式写入文件
            recvsize = recvsize + data.bufsize;         
            filesize = data.head.size;
            datahead.id = data.head.id;
            datahead.recvsize = recvsize;
            datahead.size = filesize;
            int d = sendto(sockSc, (char*)(&datahead),
            sizeof(datahead),0,(sockaddr*)&server,lenth);
            id = id + 1;
        }

        else if( data.head.id < id)
        {
            datahead.id = data.head.id;
            datahead.recvsize=recvsize;
            datahead.size = filesize;
            int d = sendto(sockSc, (char*)(&datahead),
            sizeof(datahead), 0, (sockaddr*)&server, lenth);

         }
         if( filesize == recvsize )
         {
             datahead.id = data.head.id;
             datahead.recvsize =- 1;
             datahead.size = filesize;
             char sFile = filesize; 
             char rFile = recvsize;
             outtextxy(170, 200, "filesize = ");
             outtextxy(200, 200, sFile);
             outtextxy(170, 210, "recvsize = ");
             outtextxy(200, 210, rFile);
             outtextxy(200, 220, "文件已经收到了!\n");
             int d = sendto(sockSc, (char*)(&datahead),
             sizeof(datahead), 0, (sockaddr*)&server, lenth);
             recvexi = 2;
             break;
         }
    }
}
fclose(p);
recvexi = 2;
_tsystem(TEXT("pause"));

return 0;

}

  • 写回答

3条回答

  • oyljerry 2015-07-12 05:44
    关注

    界面一般是在UI主线程。你接受代码不知道会不会影响。你可以多加点日志,起码看服务器有没有收到客户端发送的事件,还是客户端根本没发送过来

    评论

报告相同问题?

悬赏问题

  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥30 用arduino开发esp32控制ps2手柄一直报错
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题
  • ¥15 Visual Studio问题
  • ¥20 求一个html代码,有偿