求助:点对点传文件的程序

Question

谁能帮小弟做一个点对点传文件的程序啊?(用VC的SOCKET编程的)
小弟实在是有急用!先在这里谢谢各位了!

Answer 1

http://www.vckbase.com/code/downcode.asp?id=1511
这里有个简单的程序

Answer 2

服务器文件发送程序：
typedef struct _SOCKET_STREAM_FILE_INFO {    TCHAR       szFileTitle[128];                   //文件的标题名
    DWORD       dwFileAttributes;                   //文件的属性
    FILETIME    ftCreationTime;                     //文件的创建时间
    FILETIME    ftLastAccessTime;                   //文件的最后访问时间
    FILETIME    ftLastWriteTime;                    //文件的最后修改时间
    DWORD       nFileSizeHigh;                      //文件大小的高位双字
    DWORD       nFileSizeLow;                       //文件大小的低位双字
    DWORD       dwReserved0;                        //保留，为0
    DWORD       dwReserved1;                        //保留，为0} SOCKET_STREAM_FILE_INFO, * PSOCKET_STREAM_FILE_INFO;
      CFileDialog Dlg(TRUE);
if(Dlg.DoModal()!=IDOK)
return;

CFile myFile;
if(!myFile.Open(Dlg.GetPathName(), CFile::modeRead | CFile::typeBinary))
{
AfxMessageBox("文件不存在!",MB_OK|MB_ICONERROR);
return;
}

CSocket sockSrvr;
sockSrvr.Create(800); sockSrvr.Listen();
CSocket sockRecv;
sockSrvr.Accept(sockRecv); SOCKET_STREAM_FILE_INFO StreamFileInfo;
WIN32_FIND_DATA             FindFileData; FindClose(FindFirstFile(Dlg.GetPathName(),&FindFileData));
    memset(&StreamFileInfo,0,sizeof(SOCKET_STREAM_FILE_INFO));
    strcpy(StreamFileInfo.szFileTitle,myFile.GetFileTitle());    StreamFileInfo.dwFileAttributes     =       FindFileData.dwFileAttributes;
    StreamFileInfo.ftCreationTime       =       FindFileData.ftCreationTime;
    StreamFileInfo.ftLastAccessTime     =       FindFileData.ftLastAccessTime;
    StreamFileInfo.ftLastWriteTime      =       FindFileData.ftLastWriteTime;
    StreamFileInfo.nFileSizeHigh        =       FindFileData.nFileSizeHigh;
    StreamFileInfo.nFileSizeLow         =       FindFileData.nFileSizeLow; sockRecv.Send(&StreamFileInfo,sizeof(SOCKET_STREAM_FILE_INFO)); UINT dwRead=0;
while(dwRead<StreamFileInfo.nFileSizeLow)
{
byte* data = new byte[1024];
UINT dw=myFile.Read(data, 1024);
sockRecv.Send(data, dw);
dwRead+=dw;
}
myFile.Close(); sockRecv.Close();
AfxMessageBox("发送完毕！");
客户端文件接收程序：typedef struct _SOCKET_STREAM_FILE_INFO {    TCHAR       szFileTitle[128];                   //文件的标题名
    DWORD       dwFileAttributes;                   //文件的属性
    FILETIME    ftCreationTime;                     //文件的创建时间
    FILETIME    ftLastAccessTime;                   //文件的最后访问时间
    FILETIME    ftLastWriteTime;                    //文件的最后修改时间
    DWORD       nFileSizeHigh;                      //文件大小的高位双字
    DWORD       nFileSizeLow;                       //文件大小的低位双字
    DWORD       dwReserved0;                        //保留，为0
    DWORD       dwReserved1;                        //保留，为0} SOCKET_STREAM_FILE_INFO, * PSOCKET_STREAM_FILE_INFO;
void CClientDlg::OnButtonSend() 
{
// TODO: Add your control notification handler code here
AfxSocketInit(NULL);
CSocket sockClient;
sockClient.Create(); CString szIP;
GetDlgItemText(IDC_EDIT_IPADDRESS,szIP);

if(!sockClient.Connect((LPCTSTR)szIP, 800))
{
AfxMessageBox("连接到对方机器失败!");
return;
}
SOCKET_STREAM_FILE_INFO StreamFileInfo;
WIN32_FIND_DATA             FindFileData;
sockClient.Receive(&StreamFileInfo,sizeof(SOCKET_STREAM_FILE_INFO)); //CFile destFile(StreamFileInfo.szFileTitle, CFile::modeCreate | CFile::modeWrite | CFile::typeBinary);
char *filename;
filename=StreamFileInfo.szFileTitle;
CFileDialog Dlg(FALSE,NULL,filename);
if(Dlg.DoModal()!=IDOK)
return;

CFile destFile;
if(!destFile.Open(Dlg.GetPathName(), CFile::modeCreate | CFile::modeWrite | CFile::typeBinary))
{
AfxMessageBox("文件不存在!",MB_OK|MB_ICONERROR);
return;
}
FindClose(FindFirstFile(Dlg.GetPathName(),&FindFileData));
UINT dwRead = 0;
while(dwRead<StreamFileInfo.nFileSizeLow)
{
byte* data = new byte[1024];
memset(data,0,1024); UINT dw=sockClient.Receive(data, 1024);
destFile.Write(data, dw); dwRead+=dw;
} SetFileTime((HANDLE)destFile.m_hFile,&StreamFileInfo.ftCreationTime,
                &StreamFileInfo.ftLastAccessTime,&StreamFileInfo.ftLastWriteTime);
destFile.Close();
SetFileAttributes(StreamFileInfo.szFileTitle,StreamFileInfo.dwFileAttributes);
sockClient.Close();
AfxMessageBox("接收完毕！");
}

Answer 3

链接的那个程序
要先把服务器端打开
然后再打开客户端
如果c:\autoexec.bat存在
就能够传送
可以看看代码传到什么地方去了

Answer 4

to hahu(dragon)
    
   我照着你说的方法做了，可是出现了错误
    错误是：
           Runtime error!
           program:F:\vc\filetransfer\fileTansfer\client\debug\sadfasdfas.exe
           abnormal program termination

Answer 5

发送：
#include "afxmt.h"
CString m_PATH;
DWORD filesize;
HWND hwnd_p;
int IsBegin;
void CNetSendDlg::OnTransfer(CString m_PATH)
{}UINT CNetSendDlg::ThreadA(LPVOID pParam)
{
IsBegin=0;
CFile myFile;
if(!myFile.Open(m_PATH, CFile::modeRead | CFile::typeBinary|CFile::shareDenyNone))
{
return 0;
} CString szIP;
struct sockaddr_in sin;
WSADATA wsaData;    
SOCKET sockSrvr,sockRecv;
char *IpAddr;
if(WSAStartup(0x0101, &wsaData ))
{
AfxMessageBox("初始化 TCP/IP 协议栈发生错误!");
return 0;
}
if(wsaData.wVersion != 0x0101)
{
AfxMessageBox("Winsock version is incorrect!");
WSACleanup();
return 0;
}

if ((sockSrvr = socket (PF_INET, SOCK_STREAM, IPPROTO_IP)) == INVALID_SOCKET)
{
AfxMessageBox("Create socket error!");
return 0;
} if ((sockRecv = socket (PF_INET, SOCK_STREAM, IPPROTO_IP)) == INVALID_SOCKET)
{
AfxMessageBox("Create socket error!");
return 0;
}
//////////////////////////////////////
  CString m_addr;
  CString m_strT;
  CString sNetBiosName;
  char hostname[128];
  struct hostent *phost;
  gethostname(hostname,128);
  m_addr = hostname;
  phost = gethostbyname(hostname);
  int m_iCounter=0;
  for(int j = 0;j<4;j++)
  {
  
  m_strT.Format("%u", (unsigned int)((unsigned char*)phost->h_addr_list[0])[j]);
  sNetBiosName+=m_strT;
  if(m_iCounter<3)
  {
  m_iCounter++;
  sNetBiosName+=".";
  }  
  }
//////////////////////////////////////
szIP=sNetBiosName;
IpAddr=szIP.GetBuffer(szIP.GetLength());
    sin.sin_family=AF_INET;
sin.sin_addr.s_addr=inet_addr(IpAddr);
sin.sin_port=htons(800);
if(bind(sockSrvr,(sockaddr*)&sin,sizeof(sin))<0)
{
AfxMessageBox("绑定错误");
return 0;
}
listen(sockSrvr,20);
int length=sizeof(sin);
sockRecv=accept(sockSrvr,(struct sockaddr*)&sin,&length);

int timeout=300; 
int status=setsockopt(sockRecv,SOL_SOCKET,SO_RCVTIMEO,(char*)&timeout,sizeof(timeout));
if(status)
{
AfxMessageBox("设置超时错误");
WSACleanup();
return 0;
}
int buf=10240;
    int status2=setsockopt(sockRecv,SOL_SOCKET,SO_RCVBUF,(char*)&buf,sizeof(int));
if(status2)
{
AfxMessageBox("设置缓冲区大小错误");
WSACleanup();
return 0;
}
//////////////////////////////////////////////////////////////////
WIN32_FIND_DATA             FindFileData;
FindClose(FindFirstFile(m_PATH,&FindFileData));
   send(sockRecv,(char*)&FindFileData,sizeof(WIN32_FIND_DATA),0);
////////////////////////////////////////////////////////
//PROGRESS
    filesize=(short)FindFileData.nFileSizeLow; 
::PostMessage(hwnd_p,WM_USER_PROG,NULL,NULL);
////////////////////////////////////////////////////
UINT dwRead=0;
byte* data;
while(dwRead<FindFileData.nFileSizeLow)
{
data = new byte[2048];
UINT dw=myFile.Read(data, 2048);
send(sockRecv,(char*)data,2048,0);
dwRead+=dw;
delete [] data;
IsBegin=1;
::PostMessage(hwnd_p,WM_USER_PROG,NULL,NULL);
}
IsBegin=2;
//::PostMessage(hwnd_p,WM_USER_PROG,NULL,NULL); myFile.Close();
closesocket(sockRecv);
closesocket(sockSrvr);
WSACleanup(); return 0;
}LRESULT CNetSendDlg::OnProgress(WPARAM wParam, LPARAM lParam)
{
CString st;
st.Format("%d",filesize); if(IsBegin==0)
{
m_Progress.SetRange(0,(short)filesize/1000); 
m_Progress.SetPos(0);
m_Progress.SetStep(1);
}
else if(IsBegin==1)
{
m_Progress.StepIt();
}
else if(IsBegin==2)
{
m_Progress.SetPos((short)filesize/1000);
} return 0;}static char BASED_CODE szFilter[]="|*.*|";
void CNetSendDlg::OnButton1() 
{
OPENFILENAME ofn ;
TCHAR  szFullName[_MAX_PATH];
::ZeroMemory (&ofn, sizeof(OPENFILENAME)) ;
szFullName[0] = TEXT('\0') ;
ofn.lStructSize       = sizeof (OPENFILENAME) ;
    ofn.hwndOwner         = m_hWnd;
    ofn.hInstance         = NULL ;
    ofn.lpstrFilter       = "*.txt\0\0" ;
    ofn.lpstrCustomFilter = NULL ;
    ofn.nMaxCustFilter    = 0 ;
    ofn.nFilterIndex      = 0 ;
    ofn.nMaxFile          = MAX_PATH ;
    ofn.nMaxFileTitle     = MAX_PATH ;
    ofn.lpstrInitialDir   = "c:\\" ;
    ofn.lpstrTitle        = "保存到";
ofn.lpstrFile   = szFullName ;
    ofn.nFileExtension    = 0 ;
    ofn.lpstrDefExt       = TEXT("txt") ;
    ofn.lCustData         = 0 ;
    ofn.lpfnHook          = NULL ;
    ofn.lpTemplateName    = NULL ;
    ofn.Flags             = OFN_ENABLESIZING | OFN_OVERWRITEPROMPT ;
    

if(!::GetOpenFileName(&ofn))
return;
  GetDlgItem(IDC_EDIT1)->SetWindowText(ofn.lpstrFile);

}void CNetSendDlg::OnButton2() 
{
// m_PATH="c:\\1.jpg";
GetDlgItem(IDC_EDIT1)->GetWindowText(m_PATH);    hwnd_p=this->m_hWnd;
AfxBeginThread(ThreadA,NULL,THREAD_PRIORITY_IDLE);
}

Answer 6

接收
void CNetRecvDlg::OnButton1() 
{
CString szIP;
GetDlgItem(IDC_EDIT1)->GetWindowText(szIP);
struct sockaddr_in sin;
WSADATA wsaData;    
SOCKET sockClient;
int IpPort;
char *IpAddr;
IpAddr=szIP.GetBuffer(szIP.GetLength());
IpPort=800;

if(WSAStartup(0x0101, &wsaData ))
{
AfxMessageBox("初始化 TCP/IP 协议栈发生错误!");
return;
}
if(wsaData.wVersion != 0x0101)
{
AfxMessageBox("Winsock version is incorrect!");
WSACleanup();
return;
}

if ((sockClient = socket (PF_INET, SOCK_STREAM, IPPROTO_IP)) == INVALID_SOCKET)
{
AfxMessageBox("Create socket error!");
return;
}


sin.sin_family=AF_INET;
sin.sin_addr.s_addr=inet_addr(IpAddr);
sin.sin_port=htons((short)IpPort);


int timeout=300; 
int status=setsockopt(sockClient,SOL_SOCKET,SO_RCVTIMEO,(char*)&timeout,sizeof(timeout));
if(status)
{
MessageBox("设置超时错误");
WSACleanup();
return ;
}
int buf=10240;
    int status2=setsockopt(sockClient,SOL_SOCKET,SO_RCVBUF,(char*)&buf,sizeof(int));
if(status2)
{
MessageBox("设置缓冲区大小错误");
WSACleanup();
return ;
}


if(connect (sockClient, (struct sockaddr *)&sin, sizeof (sin)) == SOCKET_ERROR)
{
MessageBox("连接错误");
closesocket(sockClient);
WSACleanup();
return;
}
else{
WIN32_FIND_DATA fd;
::Sleep(20);
recv(sockClient,(char*)&fd,sizeof(WIN32_FIND_DATA),0);
////////////////////////////////////////////////////////
//PROGRESS
m_Progress.SetRange(0,(short)fd.nFileSizeLow); 
m_Progress.SetPos(0);
m_Progress.SetStep(1);
        ////////////////////////////////////////////////////
CString m_ProDir="e:\\";
CFile destFile(m_ProDir+fd.cFileName, CFile::modeCreate | CFile::modeWrite | CFile::typeBinary);
UINT dwRead = 0;
while(dwRead<fd.nFileSizeLow)
{
byte* data = new byte[2048];
memset(data,0,2048);
    UINT dw=recv(sockClient,(char*)data,2048,0);
destFile.Write(data, dw);
dwRead+=dw;
delete [] data;
m_Progress.StepIt();
}
m_Progress.SetPos((short)fd.nFileSizeLow); 
SetFileTime((HANDLE)destFile.m_hFile,&fd.ftCreationTime,
&fd.ftLastAccessTime,&fd.ftLastWriteTime);
SetFileAttributes(m_ProDir+fd.cFileName,fd.dwFileAttributes);
destFile.Close();
closesocket (sockClient);
WSACleanup();
}
}

Answer 7

发送端
while (文件结束)
{
   读固定字节
   用sock发送  
}
接收段
接收事件  接收字节
  写文件

Answer 8

to  jwyhit(温柔的噩梦) 
    太长了，还是发到信箱吧,多谢了
     [email protected]

Answer 9

to  jwyhit(温柔的噩梦) 
能不能也给我发一个，谢谢了~
 [email protected]

Answer 10

一个TCP和UPD聊天、传收文件程序
作者：河北 CA王雪松
http://www.vckbase.com/document/viewdoc.asp?id=639