#PRagma once#include <afxsock.h>

#define   WM_FILELIST   WM_USER + 101  //接收文件列表#define   WM_FILEUPDATE  WM_USER + 102  //反映文件下載狀態(tài)#define   WM_FILEDOWNLOAD  WM_USER + 103    //發(fā)送文件列表

#define   FILELIST      1000    //請(qǐng)求文件列表#define   FILEUPDATE   2000    //請(qǐng)求文件上傳#define   FILEDOWNLOAD  3000    //請(qǐng)求文件下載

#define   RECVSIZE   1024*16       //一次性發(fā)送/接收的數(shù)據(jù)塊大小

//與服務(wù)器通信語(yǔ)言結(jié)構(gòu)typedef struct{ int  iCommand; long lFileOffset; long lFileLength; char sFilePath[128];}MSGFILE;

//請(qǐng)求線程參數(shù)typedef struct{ char sip[15];  //IP地址 int  iPort;   //端口 MSGFILE msgFile; //通信語(yǔ)言結(jié)構(gòu) LPVOID ptr;  //指針}MSGPARAM;

//文件列表結(jié)構(gòu)typedef struct{ long lFileLength; char sFilePath[128];}MSGFILELIST;

//反映文件狀態(tài)的結(jié)構(gòu)typedef struct{ long lFileOffset;//偏移 char sFilePath[128];//路徑}MSGFILESTATUS;

//接收線程參數(shù)typedef struct{ SOCKET sock; LPVOID ptr;}PARAMRECV;

//服務(wù)器端 類 頭文件

// Ftp_Server.h: interface for the CFtp_Server class.////////////////////////////////////////////////////////////////////////

#if !defined(AFX_FTP_SERVER_H__DCFE7BE8_C212_475E_AAC8_811898047B46__INCLUDED_)#define AFX_FTP_SERVER_H__DCFE7BE8_C212_475E_AAC8_811898047B46__INCLUDED_

#if _MSC_VER > 1000#pragma once#endif // _MSC_VER > 1000

#include "basedef.h"#define WM_FINISHUPDATE WM_USER+401

class CFtp_Server  {public: CFtp_Server(); virtual ~CFtp_Server();

 BOOL StartListen(CWnd *pWnd, int nPort, char *sPath); void StopListen();

protected: //監(jiān)聽線程 static DWord WINAPI ListenThread(LPVOID lpParam);  //接收線程 static DWORD WINAPI RecvThread(LPVOID lpParam);private: //監(jiān)聽線程結(jié)束符 BOOL m_bEndListenThread;

 //監(jiān)聽端口 int m_iListenPort;

 //窗口指針 CWnd* m_pWnd;

 //服務(wù)器套接字 SOCKET m_socket;

 //保存本機(jī)地址 SOCKADDR_IN m_sin;

 //存儲(chǔ)路徑 char m_sPath[128];};

#endif // !defined(AFX_FTP_SERVER_H__DCFE7BE8_C212_475E_AAC8_811898047B46__INCLUDED_)

//服務(wù)器端 類 CPP

// Ftp_Server.cpp: implementation of the CFtp_Server class.////////////////////////////////////////////////////////////////////////

#include "stdafx.h"#include "Ftp_Server.h"

#ifdef _DEBUG#undef THIS_FILEstatic char THIS_FILE[] = __FILE__;#define new DEBUG_NEW#endif

//////////////////////////////////////////////////////////////////////// Construction/Destruction//////////////////////////////////////////////////////////////////////

CFtp_Server::CFtp_Server(){}

CFtp_Server::~CFtp_Server(){}

BOOL CFtp_Server::StartListen(CWnd *pWnd, int nPort, char *sPath){ //初始化套接字 if (!AfxSocketInit()) {  return FALSE; }

 //獲得端口號(hào)和窗口指針 m_iListenPort = nPort; m_pWnd = pWnd; strcpy(m_sPath, sPath);

 m_bEndListenThread = FALSE;//開始監(jiān)聽

 DWORD id; HANDLE h = CreateThread(NULL, 0, ListenThread, this, 0, &id);//創(chuàng)建句柄 //線程要執(zhí)行的函數(shù)為ThreadListen,將this指針傳遞給線程，線程ID為id，創(chuàng)建成功，返回新線程的一個(gè)句柄 CloseHandle(h); //關(guān)閉句柄，并不終止線程

 return TRUE;}

void CFtp_Server::StopListen(){ m_bEndListenThread = TRUE; Sleep(100); closesocket(m_socket);}

DWORD WINAPI CFtp_Server::ListenThread(LPVOID lpParam){ CFtp_Server* pServer = (CFtp_Server*)lpParam;

 SOCKET sockListen = socket(AF_INET, SOCK_STREAM, 0);//創(chuàng)建socket //地址家族為internet，用于TCP和UDP，字節(jié)流，特定的協(xié)議

 SOCKADDR_IN sin; //轉(zhuǎn)換地址 sin.sin_family = AF_INET; sin.sin_addr.s_addr = 0; //ip地址，以網(wǎng)路字節(jié)順序。 sin.sin_port = htons(pServer->m_iListenPort);

 if (bind(sockListen, (SOCKADDR*)&sin, sizeof(sin)) == SOCKET_ERROR) {  closesocket(sockListen); //關(guān)閉socket  return FALSE; }

 if (listen(sockListen, 5) == SOCKET_ERROR) {//若將socket置于監(jiān)聽失敗  closesocket(sockListen);  return FALSE; }

 fd_set fdListen;//結(jié)構(gòu)體，將socket放進(jìn)一個(gè)集合 timeval seltime;//結(jié)構(gòu)體，指定時(shí)間值（秒+毫秒） seltime.tv_sec = 0; //秒 seltime.tv_usec = 10000;//毫秒==10秒

 while (!pServer->m_bEndListenThread) {//服務(wù)器在監(jiān)聽狀態(tài)  FD_ZERO(&fdListen);//將集合清零  FD_SET(sockListen, &fdListen);//將socket添加到set中

  if (select(0, &fdListen, NULL, NULL, &seltime) <= 0 || !FD_ISSET(sockListen, &fdListen))   continue;  //如果在規(guī)定時(shí)間內(nèi)，set中無(wú)socket可讀出||socket不在set中，結(jié)束本次循環(huán)，繼續(xù)下次循環(huán)

  int len = sizeof(sin);  SOCKET sock = accept(sockListen, (SOCKADDR*)&sin, &len);  //接受socket上的連接

  PARAMRECV* pParamRecv = new PARAMRECV;//結(jié)構(gòu)體，接收線程參數(shù)  pParamRecv->sock = sock;  pParamRecv->ptr = pServer;

  DWORD id;  HANDLE h = CreateThread(NULL, 0, RecvThread, pParamRecv, 0, &id);  //創(chuàng)建ThreadRecv線程，將pParamRecv傳遞給線程  CloseHandle(h); }

 return 0;}

DWORD WINAPI CFtp_Server::RecvThread(LPVOID lpParam){ PARAMRECV* pParam = (PARAMRECV*)lpParam;//指向接收線程的指針 CFtp_Server* pServer = (CFtp_Server*)pParam->ptr;//指向Server的指針

 fd_set fdRecv;//結(jié)構(gòu)體，接收線程集合 timeval seltime;//結(jié)構(gòu)體，指定時(shí)間值==10s seltime.tv_sec = 0; seltime.tv_usec = 10000;

 while (1) {  FD_ZERO(&fdRecv);//集合清零  FD_SET(pParam->sock, &fdRecv);//將已連接的socket加入集合

  if (select(0, &fdRecv, NULL, NULL, &seltime) <= 0 || !FD_ISSET(pParam->sock, &fdRecv))   continue;  //如果在指定時(shí)間內(nèi)，結(jié)構(gòu)體內(nèi)無(wú)可讀接收線程||sock不在結(jié)構(gòu)體內(nèi)

  MSGFILE msgFile;  int iRecvCnt = recv(pParam->sock, (char*)&msgFile, sizeof(msgFile), 0);  //成功，返回接收字節(jié)數(shù)；正常結(jié)束，返回0；否則<0  if (iRecvCnt <= 0)   break;

  //請(qǐng)求文件列表  if (msgFile.iCommand == FILELIST)  {   while (!pServer->m_bEndListenThread)   {    MSGFILELIST msgFileList;    iRecvCnt = recv(pParam->sock, (char*)&msgFileList, sizeof(msgFileList), 0);    if (iRecvCnt <= 0)     break;

    pServer->m_pWnd->SendMessage(WM_FILELIST, (WPARAM)&msgFileList, 0);   }  }

  //請(qǐng)求文件下載  else if (msgFile.iCommand == FILEDOWNLOAD)  {   long lFileOffset = msgFile.lFileOffset;//文件偏移

   CFile file;   CString strPath, strName;   strPath.Format("%s", msgFile.sFilePath);   int iPos = strPath.ReverseFind('//');   strName = strPath.Right(strPath.GetLength() - iPos - 1);   strPath.Format("%s", pServer->m_sPath);   strPath += strName;

   BOOL bResult = file.Open(strPath, CFile::modeRead | CFile::shareDenyNone, NULL);   //打開指定路徑的文件，只讀||可共享，成功，返回非零；否則，0   if (!bResult)   {    break;   }

   char sSendBuf[RECVSIZE];//發(fā)送緩沖區(qū),16K      while (lFileOffset < msgFile.lFileLength)   {    int iSeek = file.Seek(lFileOffset, CFile::begin);//尋找新的文件偏移，距離開始處    int iReadCnt = file.Read(sSendBuf, RECVSIZE);    if (iReadCnt == 0)     break;

    int iSendCnt = send(pParam->sock, sSendBuf, iReadCnt, 0);    //如果發(fā)送失敗就終止線程    if (iSendCnt == -1)     break;    else     lFileOffset += iSendCnt;//修改偏移量   }

   file.Close();  }

  //請(qǐng)求文件上傳  else if (msgFile.iCommand == FILEUPDATE)  {   char sRecvBuf[RECVSIZE] = "/0"; //接收緩沖區(qū)置空   long lFileOffset = msgFile.lFileOffset;   CFile file;

   //將客戶端路徑改為服務(wù)端保存路徑   CString strPath, strName;   strPath.Format("%s", msgFile.sFilePath);   int iPos = strPath.ReverseFind('//');   strName = strPath.Right(strPath.GetLength() - iPos - 1);   strPath.Format("%s", pServer->m_sPath);   strPath += strName;

   BOOL bResult = file.Open(strPath, CFile::modeCreate | CFile::modeWrite | CFile::modeNoTruncate, NULL);   //打開接收端文件，寫模式||若創(chuàng)建的文件已存在，不截短。   while (bResult && lFileOffset < msgFile.lFileLength)   {    int iRecvCnt = recv(pParam->sock, sRecvBuf, RECVSIZE, 0);    if (iRecvCnt <= 0)     break;

    file.Seek(lFileOffset, CFile::begin);    file.Write(sRecvBuf, iRecvCnt);    lFileOffset += iRecvCnt;//修改偏移

    MSGFILESTATUS msgFileStatus;//文件狀態(tài)結(jié)構(gòu)體    msgFileStatus.lFileOffset = lFileOffset;    strcpy(msgFileStatus.sFilePath, msgFile.sFilePath);    pServer->m_pWnd->SendMessage(WM_FILEUPDATE, (WPARAM)&msgFileStatus, 0);   }   file.Close();   pServer->m_pWnd->SendMessage(WM_FINISHUPDATE, 0, 0);  }

  break; } delete pParam;

 return 0;}

//對(duì)話框 頭文件

// Server_FTPDlg.h : header file//

#if !defined(AFX_SERVER_FTPDLG_H__492B251E_B713_4E0F_A5A4_C1BC9EB8EF08__INCLUDED_)#define AFX_SERVER_FTPDLG_H__492B251E_B713_4E0F_A5A4_C1BC9EB8EF08__INCLUDED_

#if _MSC_VER > 1000#pragma once#endif // _MSC_VER > 1000

#include "Ftp_Server.h"/////////////////////////////////////////////////////////////////////////////// CServer_FTPDlg dialog

class CServer_FTPDlg : public CDialog{// Constructionpublic: void InitListColumn(); CServer_FTPDlg(CWnd* pParent = NULL); // standard constructor

 CFtp_Server *m_pFtp_Server;

 BOOL m_bConnected; //已連接 int m_nUpdateNum; //已上傳文件// Dialog Data //{{AFX_DATA(CServer_FTPDlg) enum { IDD = IDD_SERVER_FTP_DIALOG }; CListCtrl m_ListFile; int  m_nPort; //}}AFX_DATA

 // ClassWizard generated virtual function overrides //{{AFX_VIRTUAL(CServer_FTPDlg) protected: virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support //}}AFX_VIRTUAL

// Implementationprotected: HICON m_hIcon;

 // Generated message map functions //{{AFX_MSG(CServer_FTPDlg) virtual BOOL OnInitDialog(); afx_msg void OnSysCommand(UINT nID, LPARAM lParam); afx_msg void OnPaint(); afx_msg HCURSOR OnQueryDragIcon(); afx_msg BOOL OnEraseBkgnd(CDC* pDC); afx_msg void OnBtnListen(); afx_msg void OnBtnScan(); afx_msg void OnDestroy(); //}}AFX_MSG afx_msg LRESULT OnFileList(WPARAM wp, LPARAM lp); afx_msg LRESULT OnFileUpdate(WPARAM wp, LPARAM lp); afx_msg LRESULT OnFinishUpdate(WPARAM wp, LPARAM lp);

 DECLARE_MESSAGE_MAP()};

//{{AFX_INSERT_LOCATION}}// Microsoft Visual C++ will insert additional declarations immediately before the previous line.

#endif // !defined(AFX_SERVER_FTPDLG_H__492B251E_B713_4E0F_A5A4_C1BC9EB8EF08__INCLUDED_)

//對(duì)話框 CPP文件

// Server_FTPDlg.cpp : implementation file//

#include "stdafx.h"#include "Server_FTP.h"#include "Server_FTPDlg.h"

#ifdef _DEBUG#define new DEBUG_NEW#undef THIS_FILEstatic char THIS_FILE[] = __FILE__;#endif

/////////////////////////////////////////////////////////////////////////////// CAboutDlg dialog used for App About

class CAboutDlg : public CDialog{public: CAboutDlg();

// Dialog Data //{{AFX_DATA(CAboutDlg) enum { IDD = IDD_ABOUTBOX }; //}}AFX_DATA

 // ClassWizard generated virtual function overrides //{{AFX_VIRTUAL(CAboutDlg) protected: virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support //}}AFX_VIRTUAL

// Implementationprotected: //{{AFX_MSG(CAboutDlg) //}}AFX_MSG DECLARE_MESSAGE_MAP()};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD){ //{{AFX_DATA_INIT(CAboutDlg) //}}AFX_DATA_INIT}

void CAboutDlg::DoDataExchange(CDataExchange* pDX){ CDialog::DoDataExchange(pDX); //{{AFX_DATA_MAP(CAboutDlg) //}}AFX_DATA_MAP}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog) //{{AFX_MSG_MAP(CAboutDlg)  // No message handlers //}}AFX_MSG_MAPEND_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////// CServer_FTPDlg dialog

CServer_FTPDlg::CServer_FTPDlg(CWnd* pParent /*=NULL*/) : CDialog(CServer_FTPDlg::IDD, pParent){ //{{AFX_DATA_INIT(CServer_FTPDlg) m_nPort = 7000; //}}AFX_DATA_INIT // Note that LoadIcon does not require a subsequent DestroyIcon in Win32 m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME); m_bConnected = FALSE; m_nUpdateNum = 0;}

void CServer_FTPDlg::DoDataExchange(CDataExchange* pDX){ CDialog::DoDataExchange(pDX); //{{AFX_DATA_MAP(CServer_FTPDlg) DDX_Control(pDX, IDC_LIST_FILE, m_ListFile); DDX_Text(pDX, IDC_EDIT_PORT, m_nPort); //}}AFX_DATA_MAP}

BEGIN_MESSAGE_MAP(CServer_FTPDlg, CDialog) //{{AFX_MSG_MAP(CServer_FTPDlg) ON_WM_SYSCOMMAND() ON_WM_PAINT() ON_WM_QUERYDRAGICON() ON_WM_ERASEBKGND() ON_BN_CLICKED(IDC_BTN_LISTEN, OnBtnListen) ON_BN_CLICKED(IDC_BTN_SCAN, OnBtnScan) ON_WM_DESTROY() //}}AFX_MSG_MAP ON_MESSAGE(WM_FILELIST, OnFileList) ON_MESSAGE(WM_FILEUPDATE, OnFileUpdate) ON_MESSAGE(WM_FINISHUPDATE, OnFinishUpdate)END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////// CServer_FTPDlg message handlers

BOOL CServer_FTPDlg::OnInitDialog(){ CDialog::OnInitDialog();

 // Add "About..." menu item to system menu.

 // IDM_ABOUTBOX must be in the system command range. ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX); ASSERT(IDM_ABOUTBOX < 0xF000);

 CMenu* pSysMenu = GetSystemMenu(FALSE); if (pSysMenu != NULL) {  CString strAboutMenu;  strAboutMenu.LoadString(IDS_ABOUTBOX);  if (!strAboutMenu.IsEmpty())  {   pSysMenu->AppendMenu(MF_SEPARATOR);   pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);  } }

 // Set the icon for this dialog.  The framework does this automatically //  when the application's main window is not a dialog SetIcon(m_hIcon, TRUE);   // Set big icon SetIcon(m_hIcon, FALSE);  // Set small icon  InitListColumn();

 m_pFtp_Server = new CFtp_Server(); // TODO: Add extra initialization here  return TRUE;  // return TRUE  unless you set the focus to a control}

void CServer_FTPDlg::OnSysCommand(UINT nID, LPARAM lParam){ if ((nID & 0xFFF0) == IDM_ABOUTBOX) {  CAboutDlg dlgAbout;  dlgAbout.DoModal(); } else {  CDialog::OnSysCommand(nID, lParam); }}

// If you add a minimize button to your dialog, you will need the code below//  to draw the icon.  For MFC applications using the document/view model,//  this is automatically done for you by the framework.

void CServer_FTPDlg::OnPaint() { if (IsIconic()) {  CPaintDC dc(this); // device context for painting

  SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);

  // Center icon in client rectangle  int cxIcon = GetSystemMetrics(SM_CXICON);  int cyIcon = GetSystemMetrics(SM_CYICON);  CRect rect;  GetClientRect(&rect);  int x = (rect.Width() - cxIcon + 1) / 2;  int y = (rect.Height() - cyIcon + 1) / 2;

  // Draw the icon  dc.DrawIcon(x, y, m_hIcon); } else {  CDialog::OnPaint(); }}

// The system calls this to obtain the cursor to display while the user drags//  the minimized window.HCURSOR CServer_FTPDlg::OnQueryDragIcon(){ return (HCURSOR) m_hIcon;}

BOOL CServer_FTPDlg::OnEraseBkgnd(CDC* pDC) { // TODO: Add your message handler code here and/or call default //更改背景顏色 CRect rect; GetClientRect(&rect); pDC->FillSolidRect(&rect, RGB(202, 225, 243)); return TRUE; // return CDialog::OnEraseBkgnd(pDC);}

void CServer_FTPDlg::OnBtnListen() { // TODO: Add your control notification handler code here if (m_bConnected) {  m_pFtp_Server->StopListen();  SetDlgItemText(IDC_BTN_LISTEN, _T("啟動(dòng)監(jiān)聽"));  GetDlgItem(IDC_EDIT_PORT)->EnableWindow(TRUE);  m_bConnected = FALSE;  return; } CString sPath; GetDlgItemText(IDC_EDIT_PATH, sPath); if (sPath.IsEmpty()) {  AfxMessageBox(_T("請(qǐng)先設(shè)置文件存儲(chǔ)路徑!"));  return; } int nPort = GetDlgItemInt(IDC_EDIT_PORT); if (m_pFtp_Server->StartListen(this, nPort, sPath.GetBuffer(0))) {  SetDlgItemText(IDC_BTN_LISTEN, _T("停止監(jiān)聽"));  GetDlgItem(IDC_EDIT_PORT)->EnableWindow(FALSE);  m_bConnected = TRUE;  return; }

 AfxMessageBox(_T("服務(wù)器啟動(dòng)失敗!"));}

void CServer_FTPDlg::OnBtnScan() { // TODO: Add your control notification handler code here BROWSEINFO bi; //定義后面將被SHBrowseForFolder調(diào)用參數(shù) char buffer[MAX_PATH];  ZeroMemory(buffer,MAX_PATH);  bi.hwndOwner = this->m_hWnd; bi.pidlRoot = NULL;  bi.pszDisplayName=buffer;  bi.lpszTitle = "指定文件夾";  bi.ulFlags = BIF_RETURNONLYFSDIRS;  bi.lpfn = NULL;  bi.lParam = 0;  bi.iImage = 0; LPITEMIDLIST pList = NULL;  if((pList=SHBrowseForFolder(&bi)) != NULL)  {  char path[MAX_PATH];  ZeroMemory(path,MAX_PATH);  SHGetPathFromIDList(pList,path);//根據(jù)你設(shè)置的屬性  打開 返回路徑到path  SetDlgItemText(IDC_EDIT_PATH, path); }}

void CServer_FTPDlg::InitListColumn(){ int iWidth = 50; m_ListFile.InsertColumn(0, "文件名", LVCFMT_LEFT, 3*iWidth, -1); m_ListFile.InsertColumn(1, "文件大小", LVCFMT_LEFT, 2*iWidth, -1); m_ListFile.InsertColumn(2, "上傳速度", LVCFMT_LEFT, 2*iWidth, -1); m_ListFile.InsertColumn(3, "上傳狀態(tài)", LVCFMT_LEFT, 2*iWidth, -1); m_ListFile.InsertColumn(4, "上傳時(shí)間", LVCFMT_LEFT, 2*iWidth, -1); m_ListFile.InsertColumn(5, "文件保存路徑", LVCFMT_LEFT, 5*iWidth, -1); m_ListFile.InsertColumn(6, "時(shí)間標(biāo)記", LVCFMT_LEFT, 2*iWidth, -1); //插入列：左對(duì)齊，無(wú)子列 m_ListFile.SetExtendedStyle(LVS_EX_FULLROWSELECT|LVS_EX_GRIDLINES);}

void CServer_FTPDlg::OnDestroy() { CDialog::OnDestroy();  // TODO: Add your message handler code here if(m_pFtp_Server != NULL) {  m_pFtp_Server->StopListen();  delete m_pFtp_Server; }}

LRESULT CServer_FTPDlg::OnFileUpdate(WPARAM wp, LPARAM lp){ MSGFILESTATUS* pmsg = (MSGFILESTATUS*)wp; CString strPath; strPath.Format("%s", pmsg->sFilePath); int iTotal = m_ListFile.GetItemCount(); int iSel = 0; for(; iSel<iTotal; iSel++) {  CString strListPath;  strListPath = m_ListFile.GetItemText(iSel, 5);  if(strPath.Compare(strListPath) == 0)//路徑相同   break; } if(iSel == iTotal)  return 1;

 long lFileLength = m_ListFile.GetItemData(iSel); CString strStatus; strStatus.Format("%0.2f%%", (float)pmsg->lFileOffset/lFileLength*100); //顯示狀態(tài) %,精確到小數(shù)點(diǎn)后兩位 m_ListFile.SetItemText(iTotal-1, 3, strStatus.GetBuffer(0));  //顯示時(shí)間 DWORD dwNowTick, dwStartTick;//毫秒 dwNowTick = GetTickCount(); sscanf(m_ListFile.GetItemText(iSel, 6), "%u", &dwStartTick);  long iEllapsed = (dwNowTick-dwStartTick);//間隔：微秒 strStatus.Format("%dms", iEllapsed); m_ListFile.SetItemText(iSel, 4, strStatus.GetBuffer(0));  //顯示速度 if(iEllapsed > 0) {  strStatus.Format("%dk/s", (pmsg->lFileOffset/1024/iEllapsed)*1000);  m_ListFile.SetItemText(iSel, 2, strStatus.GetBuffer(0)); }

 return 0;}

LRESULT CServer_FTPDlg::OnFileList(WPARAM wp, LPARAM lp){ MSGFILELIST* pmsgList = (MSGFILELIST*)wp; int iItem = m_ListFile.GetItemCount(); for (int i = m_nUpdateNum; i < iItem; i++) {  m_ListFile.DeleteItem(i); } iItem = m_nUpdateNum;

 CString strServerPath, strFileName, strFileSize; strServerPath.Format("%s", pmsgList->sFilePath); int iPos = strServerPath.ReverseFind('//'); //設(shè)置文件名到緩沖區(qū) strFileName = strServerPath.Right(strServerPath.GetLength()-iPos-1); strFileSize.Format("%0.2fk", (float)pmsgList->lFileLength/1024);  LV_ITEM lvi; lvi.mask = LVIF_TEXT|LVIF_PARAM; lvi.iItem = iItem; lvi.iSubItem = 0; lvi.lParam = pmsgList->lFileLength; //顯示 lvi.pszText = strFileName.GetBuffer(0); m_ListFile.InsertItem(&lvi); m_ListFile.SetItemText(iItem, 1, strFileSize.GetBuffer(0)); m_ListFile.SetItemText(iItem, 5, strServerPath.GetBuffer(0));

 //設(shè)置初始時(shí)間點(diǎn) DWORD dwStartTick = GetTickCount(); char sStartTick[20]; sprintf(sStartTick, "%u", dwStartTick); m_ListFile.SetItemText(iItem, 6, sStartTick);

 return 0;}

LRESULT CServer_FTPDlg::OnFinishUpdate(WPARAM wp, LPARAM lp){ ++ m_nUpdateNum; return 0;}