计算机网络与通讯作业学号 : 姓名 : 张士广

Size: px

Start display at page:

Download "计算机网络与通讯作业学号 : 姓名 : 张士广"

垒干
5 years ago
Views:

1 计算机网络与通讯作业学号 : 姓名 : 张士广

/ FilePoster 关键代码作者 : 张士广学号 : 35030907 E-mail: andy.zhshg@163.com 日期 : 2008.12.25 程序描述 : FilePoster 是基于 Win32 平台的网络文件传输程序开发平台为 Visual C++6.

2 / FilePoster 关键代码作者 : 张士广学号 : andy.zhshg@163.com 日期 : 程序描述 : FilePoster 是基于 Win32 平台的网络文件传输程序开发平台为 Visual C++6.0 程序采用服务器 / 客户机模式, 服务器用于接收数据, 客户机负责发送数据利用 windows 多线程原理, 集接收和发送功能于一体网络传输采用 UDP 原理, 为解决 UDP 传输的不可靠性, 用 Windows 消息对收发的双方进行同步, 即发送方先发送消息请求传送文件同时发送要传文件的基本信息, 收取方收到后回复发送发一个确认消息, 然后发送方依次发送被分成固定大小块 (256 字节 ) 的文件数据, 收取方每收到一个数据块就写入自己的文件并回复发送方一个接收完毕消息, 以使得发送方发送下一个数据块发送方发送最后一个数据块时添加发送结束标记, 接受方接收完毕后关闭文件, 至此发送过程结束问题阐述 : 程序的缺陷在于只能用于具有固定 IP 的主机之间的文件传输在处于不同的内网中的主机无能为力因为对于内网中的计算机其 IP 是主机通过映射后分配来的所以如果不借助于服务器很难从外网访问内网的计算机不过对于处于同一局域网的计算机, 本程序还是能够完全应付的限于篇幅, 与文件传输无关的代码省略, 以 "..." 代替 / - 1 -

3 / 程序的初始化函数 / BOOL CFilePosterApp::InitInstance() // 加载套接字库 if(!afxsocketinit()) AfxMessageBox(" 加载套接字库失败!"); return FALSE;... / 主窗口的初始化函数 struct RECVPARAM 用于传递线程数据 / struct RECVPARAM HWND hwnd; SOCKET sock; ; BOOL CFilePosterDlg::OnInitDialog()... // 设定进度条的步进值 m_progress.setstep(1); m_progress_r.setstep(1); // 创建套接字 m_socket=socket(af_inet,sock_dgram,0); if(invalid_socket==m_socket) MessageBox(" 套接字创建失败!"); return FALSE; SOCKADDR_IN addrsock; addrsock.sin_family=af_inet; addrsock.sin_port=htons(6800); addrsock.sin_addr.s_un.s_addr=htonl(inaddr_any); // 绑定套接字 int retval; retval=bind(m_socket, (SOCKADDR)&addrSock, sizeof(sockaddr)); - 2 -

4 if(socket_error==retval) closesocket(m_socket); MessageBox(" 绑定失败!"); return FALSE; // 产生一个用于接收数据的线程 struct RECVPARAM precvparam=new RECVPARAM; precvparam->sock=m_socket; precvparam->hwnd=m_hwnd; HANDLE hthread=createthread(null, 0, RecvProc, (LPVOID)pRecvParam, 0, NULL); CloseHandle(hThread);... / 接收线程的回调函数发送的数据块结构解析 : 类别字节号内容 H 1 通信头, 申请发送 H 2~257 文件名 H 258~... 文件大小 D 1 通信头, 拒绝接收 R 1 通信头, 同意接收 F 1 通信头, 发送文件块 F 2~17 保留 F 18~... 文件数据块 E 1 通信头, 文件尾发送 E 2~17 块大小 E 18~... 文件数据块 / DWORD WINAPI CFilePosterDlg::RecvProc(LPVOID lpparameter) SOCKET sock=((recvparam)lpparameter)->sock; HWND hwnd=((recvparam)lpparameter)->hwnd; delete lpparameter; SOCKADDR_IN addrfrom; int len=sizeof(sockaddr); char recvbuf[0x112]; // 字节的接受缓冲数组 char filename[0x100]; //256 字节的文件名存储区 int retval, i; FILE file = NULL; - 3 -

5 while(true) // 接受 UDP 数据 retval=recvfrom(sock, recvbuf, 0x112, 0, (SOCKADDR)&addrFrom, &len); ", if(socket_error == retval) // 收到消息头为 'R', 即对方同意让你继续发送数据 if (recvbuf[0] == 'R') char wparam = 'R'; (WPARAM)&wParam, 0); // 收到消息头为 'D', 即对方拒绝让你继续发送数据 else if (recvbuf[0] == 'D') char wparam = 'D'; (WPARAM)&wParam, 0); // 收到消息头为 'H', 即对方申请给你发送信息, 并送来文件的信息 else if (recvbuf[0] == 'H') // 从收到的数据中提取文件名信息 for (i = 1; i <= 0x100 && recvbuf[i]!= '\0'; i++) filename[i-1] = recvbuf[i]; filename[i-1] = '\0'; // 从收到的数据中提取文件大小信息 CString recvmsg; nfilesize = atoi(&recvbuf[0x101]); recvmsg.format(" 收到来自于 (%s) 的文件 :%s\n 文件大小 :%i 字节 \n 是否接收? inet_ntoa(addrfrom.sin_addr), filename, nfilesize); // 用消息框提示用户有人要发送文件 if (IDOK == AfxMessageBox(recvMsg, MB_OKCANCEL)) // 若用户同意接收, 提供一个文件保存对话框用于设定保存的路径 CFileDialog savedlg(false, NULL, filename); if (IDOK == savedlg.domodal()) // 创建一个文件用于复制接收的文件数据 - 4 -

6 if (!(file = fopen(savedlg.getpathname(), "wb"))) AfxMessageBox(" 创建本地文件失败!"); continue; char wparam = 'H'; (WPARAM)&wParam, (LPARAM)&addrFrom); else char wparam = 'C'; (WPARAM)&wParam, (LPARAM)&addrFrom); else // 用户拒绝接收 char wparam = 'C'; (WPARAM)&wParam, (LPARAM)&addrFrom); // 收到的消息头为 'F', 即对方发来的是文件数据 else if (recvbuf[0] == 'F') // 将文件数据写入本地文件中 fwrite(&recvbuf[0x12], 1, 0x100, file); char wparam = 'F'; (WPARAM)&wParam, (LPARAM)&addrFrom); // 收到的消息头为 'E', 即对方发来最后一个数据块 else if (recvbuf[0] == 'E') // 获取数据块的大小 int bufsize = atoi(&recvbuf[1]); // 将数据块写入本地文件, 并关闭文件 fwrite(&recvbuf[0x12], 1, bufsize, file); fclose(file); char wparam = 'E'; (WPARAM)&wParam, (LPARAM)&addrFrom); - 5 -

7 // 收到未定义的数据头 else AfxMessageBox(" 传送数据过程中出现错误!"); return (DWORD)NULL; / 按下发送键, 发出文件信息的函数 / void CFilePosterDlg::OnOK() if (m_posting) //bool m_posting 表示程序是否正在发送文件 MessageBox(" 数据发送中, 请稍候再试 "); return; UpdateData(); if (m_filepath == "") MessageBox(" 请输入要发送的文件路径!"); return; if (m_ipaddr.isblank()) MessageBox(" 请添入接收者的 IP 地址 "); return; WIN32_FIND_DATA FindFileData; if (INVALID_HANDLE_VALUE == FindFirstFile(m_filePath, &FindFileData)) MessageBox(" 文件路径错误或文件不存在!\n 请重新指定文件路径 "); return; DWORD dwip; m_ipaddr.getaddress(dwip); SOCKADDR_IN addrto; - 6 -

8 addrto.sin_family=af_inet; addrto.sin_port=htons(6800); addrto.sin_addr.s_un.s_addr=htonl(dwip); // 构建文件信息数据块 char sendbuf[0x112]; int i; // 消息头 sendbuf[0] = 'H'; // 文件名 for (i = 1; i <= 0x100 && FindFileData.cFileName[i-1]!= '\0'; i++) sendbuf[i] = FindFileData.cFileName[i-1]; sendbuf[i] = '\0'; // 文件大小 _itoa(findfiledata.nfilesizelow, &sendbuf[0x101], 10); sendbuf[0x111] = '\0'; // 发送数据块 sendto(m_socket, sendbuf, 0x112, 0, (SOCKADDR)&addrTo, sizeof(sockaddr)); // 打开文件, 等待读取 if (!(m_file = fopen(m_filepath, "rb"))) MessageBox(" 读取文件失败!"); m_nsend = 0; // 已发送的块数 m_nfilesize_s = FindFileData.nFileSizeLow; // 文件大小 m_progress.setrange(0, m_nfilesize_s/0x100+1);// 设置发送进度条 m_posting = true; // 标明发送正进行 / 消息响应函数响应自定义消息 WM_READY_TO_RECEIVE / void CFilePosterDlg::OnReadyToRecv(WPARAM wparam,lparam lparam) char sendbuf[0x112]; DWORD dwip; m_ipaddr.getaddress(dwip); SOCKADDR_IN addrto; addrto.sin_family=af_inet; addrto.sin_port=htons(6800); addrto.sin_addr.s_un.s_addr=htonl(dwip); int nread; - 7 -

9 switch ((char)wparam) // 对方拒绝接收文件, 关闭已打开的文件 case 'D': MessageBox(" 对方拒绝接受你发送的文件!"); fclose(m_file); m_posting = false; // 对方同意接收文件 case 'R': nread = fread(&sendbuf[0x12], 1, 0x100, m_file); // 读取的文件小于 256 字节, 则读到文件尾 if (nread < 0x100) sendbuf[0] = 'E'; _itoa(nread, &sendbuf[1], 10); sendto(m_socket, sendbuf, nread+0x12, 0, (SOCKADDR)&addrTo, sizeof(sockaddr)); fclose(m_file); m_progress.setpos(m_nfilesize_s/0x100+1); m_posting = false; m_send = " 发送进度 :(100%)"; MessageBox(" 发送完毕!"); m_progress.setpos(0); m_send = " 发送进度 :"; // 读到文件等于 256 字节, 则文件还未读完 else sendbuf[0] = 'F'; sendto(m_socket, sendbuf, 0x112, 0, (SOCKADDR)&addrTo, sizeof(sockaddr)); m_progress.stepit(); m_nsend++; m_send.format(" 发送进度 :(%.1f%%)", (float)m_nsend/(m_nfilesize_s/0x100+1)100); // 同意接收对方文件 case 'H': - 8 -

10 m_progress_r.setrange(0, nfilesize/0x100+1); m_nrecv = 0; case 'F': sendto(m_socket, "R", 2, 0, (SOCKADDR)lParam, sizeof(sockaddr)); m_progress_r.stepit(); m_nrecv++; m_recv.format(" 接收进度 :(%.1f%%)", (float)m_nrecv/(nfilesize/0x100+1)100); // 接受完毕, 提示用户 case 'E': m_progress_r.setpos(nfilesize/0x100+1); m_recv = " 接收进度 :(100%)"; MessageBox(" 接收完毕!"); m_recv = " 接收进度 :"; m_progress_r.setpos(0); // 拒绝接收, 通知对方 case 'C': sendto(m_socket, "D", 2, 0, (SOCKADDR)lParam, sizeof(sockaddr)); - 9 -

概述

OPC Version 1.8 build 0925 KOCRDK Knight OPC Client Rapid Development Toolkits Knight Workgroup, eehoo Technology 2002-9 OPC 1...4 2 API...5 2.1...5 2.2...5 2.2.1 KOC_Init...5 2.2.2 KOC_Uninit...5 2.3...5

计算机网络与通讯作业 学号 : 姓名 : 张士广

计算机网络与通讯作业学号 : 姓名 : 张士广