用socket实现文件传输(手机文件传输时socket未连接)

要下班了，时间急，不写代码了先给你一个思路 1 实现最简单的udp socket 模型，实现发送一个字符串。2 实现一个简单的打开文件，读取文件的例子，如用fgets(),类似的函数有很多，然后再把读取的文件内容忘另一个文件里写(相关函数fopen(),write(),read())。3 把上面两个函数结合到一起，在客户端实现打开要传送的文件，按一定的大小读取，读取后调用sendto（）发送到服务器端。在服务器端创建一个文件，然后调用recvfrom（）接受客户端发送过来的数据，向来是创建的那个文件中写。下面是改好的udp发送文件的例子。服务器端程序的编译gcc -o file_server  file_server客户端程序的编译gcc -o file_client  file_client.c服务器程序和客户端程应当分别运行在2台计算机上.服务器端程序的运行,在一个计算机的终端执行./file_server客户端程序的运行,在另一个计算机的终端中执行./file_client  运行服务器程序的计算机的IP地址根据提示输入要传输的服务器上的文件，该文件在服务器的运行目录上在实际编程和测试中,可以用2个终端代替2个计算机,这样就可以在一台计算机上测试网络程序,服务器端程序的运行,在一个终端执行./file_server客户端程序的运行,在另一个终端中执行./file_client  127.0.0.1说明: 任何计算机都可以通过127.0.0.1访问自己. 也可以用计算机的实际IP地址代替127.0.0.1//////////////////////////////////////////////////////////////////////////////////////// file_server.c  文件传输顺序服务器示例////////////////////////////////////////////////////////////////////////////////////////本文件是服务器的代码#include     // for sockaddr_in#include     // for socket#include     // for socket#include         // for printf#include         // for exit#include         // for bzero/*#include #include #include #include */#define HELLO_WORLD_SERVER_PORT    6666#define LENGTH_OF_LISTEN_QUEUE  20#define BUFFER_SIZE 1024#define FILE_NAME_MAX_SIZE 512int main(int argc, char **argv){//设置一个socket地址结构server_addr,代表服务器internet地址, 端口struct sockaddr_in server_addr， pcliaddr;bzero(&server_addr,sizeof(server_addr)); //把一段内存区的内容全部设置为0server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htons(INADDR_ANY);server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);//创建用于internet的据报套接字（UDPt,用server_socket代表服务器socket// 创建数据报套接字（UDP）int server_socket = socket(PF_INET,SOCK_DGRAM,0);if( server_socket < 0){printf("Create Socket Failed!");exit(1);}//把socket和socket地址结构联系起来if( bind(server_socket,(struct sockaddr*)&server_addr,sizeof(server_addr))){printf("Server Bind Port : %d Failed!", HELLO_WORLD_SERVER_PORT);exit(1);}while (1) //服务器端要一直运行{//定义客户端的socket地址结构client_addrstruct sockaddr_in client_addr;socklen_t n = sizeof(client_addr) ;int length;char buffer[BUFFER_SIZE];bzero(buffer, BUFFER_SIZE);length = recvfrom(new_server_socket,buffer,BUFFER_SIZE,0,&pcliaddr,&n);if (length < 0){printf("Server Recieve Data Failed!n");break;}char file_name[FILE_NAME_MAX_SIZE+1];bzero(file_name, FILE_NAME_MAX_SIZE+1);strncpy(file_name, buffer, strlen(buffer)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer));//        int fp = open(file_name, O_RDONLY);//        if( fp < 0 )FILE * fp = fopen(file_name,"r");if(NULL == fp ){printf("File:t%s Not Foundn", file_name);}else{bzero(buffer, BUFFER_SIZE);int file_block_length = 0;//            while( (file_block_length = read(fp,buffer,BUFFER_SIZE))>0)while( (file_block_length = fread(buffer,sizeof(char),BUFFER_SIZE,fp))>0){printf("file_block_length = %dn",file_block_length);//发送buffer中的字符串到new_server_socket,实际是给客户端if(send(new_server_socket,buffer,file_block_length,0)<0){printf("Send File:t%s Failedn", file_name);break;}bzero(buffer, BUFFER_SIZE);}//            close(fp);fclose(fp);printf("File:t%s Transfer Finishedn",file_name);}}}//////////////////////////////////////////////////////////////////////////////////////// file_client.c  文件传输客户端程序示例////////////////////////////////////////////////////////////////////////////////////////本文件是客户机的代码#include     // for sockaddr_in#include     // for socket#include     // for socket#include         // for printf#include         // for exit#include         // for bzero/*#include #include #include #include */#define HELLO_WORLD_SERVER_PORT    6666#define BUFFER_SIZE 1024#define FILE_NAME_MAX_SIZE 512int main(int argc, char **argv){if (argc != 2){printf("Usage: ./%s ServerIPAddressn",argv[0]);exit(1);}//设置一个socket地址结构client_addr,代表客户机internet地址, 端口struct sockaddr_in client_addr;bzero(&client_addr,sizeof(client_addr)); //把一段内存区的内容全部设置为0client_addr.sin_family = AF_INET;    //internet协议族client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自动获取本机地址client_addr.sin_port = htons(0);    //0表示让系统自动分配一个空闲端口//创建用于internet的流协议(TCP)socket,用client_socket代表客户机socketint client_socket = socket(AF_INET,SOCK_DGRAM,0);if( client_socket < 0){printf("Create Socket Failed!n");exit(1);}//设置一个socket地址结构server_addr,代表服务器的internet地址, 端口struct sockaddr_in server_addr;bzero(&server_addr,sizeof(server_addr));server_addr.sin_family = AF_INET;if(inet_aton(argv[1],&server_addr.sin_addr) == 0) //服务器的IP地址来自程序的参数{printf("Server IP Address Error!n");exit(1);}server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);socklen_t server_addr_length = sizeof(server_addr);char file_name[FILE_NAME_MAX_SIZE+1];bzero(file_name, FILE_NAME_MAX_SIZE+1);printf("Please Input File Name On Server:t");scanf("%s", file_name);char buffer[BUFFER_SIZE];bzero(buffer,BUFFER_SIZE);strncpy(buffer, file_name, strlen(file_name)>BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));//向服务器发送buffer中的数据socklen_t n = sizeof(server_addr) ;sendto(client_socket,buffer,BUFFER_SIZE,0,(struct sockaddr*)&server_addr,n);//    int fp = open(file_name, O_WRONLY|O_CREAT);//    if( fp < 0 )FILE * fp = fopen(file_name,"w");if(NULL == fp ){printf("File:t%s Can Not Open To Writen", file_name);exit(1);}//从服务器接收数据到buffer中bzero(buffer,BUFFER_SIZE);int length = 0;while( length = recv(client_socket,buffer,BUFFER_SIZE,0)){if(length < 0){printf("Recieve Data From Server %s Failed!n", argv[1]);break;}//        int write_length = write(fp, buffer,length);int write_length = fwrite(buffer,sizeof(char),length,fp);if (write_length服务器端程序的编译 gcc -o file_serverfile_server客户端程序的编译gcc -o file_clientfile_client.c服务器程序和客户端程应当分别运行在2台计算机上.服务器端程序的运行,在一个计算机的终端执行./file_server客户端程序的运行,在另一个计算机的终端中执行./file_client运行服务器程序的计算机的IP地址根据提示输入要传输的服务器上的文件，该文件在服务器的运行目录上在实际编程和测试中,可以用2个终端代替2个计算机,这样就可以在一台计算机上测试网络程序,服务器端程序的运行,在一个终端执行./file_server客户端程序的运行,在另一个终端中执行./file_client127.0.0.1说明: 任何计算机都可以通过127.0.0.1访问自己. 也可以用计算机的实际IP地址代替127.0.0.1//////////////////////////////////////////////////////////////////////////////////////// file_server.c文件传输顺序服务器示例////////////////////////////////////////////////////////////////////////////////////////本文件是服务器的代码#include // for sockaddr_in#include // for socket#include // for socket#include // for printf#include // for exit#include // for bzero/*#include #include #include #include */#define HELLO_WORLD_SERVER_PORT6666#define LENGTH_OF_LISTEN_QUEUE20#define BUFFER_SIZE 1024#define FILE_NAME_MAX_SIZE 512int main(int argc, char **argv){//设置一个socket地址结构server_addr,代表服务器internet地址, 端口struct sockaddr_in server_addr;bzero(&server_addr,sizeof(server_addr)); //把一段内存区的内容全部设置为0server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htons(INADDR_ANY);server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);//创建用于internet的流协议(TCP)socket,用server_socket代表服务器socketint server_socket = socket(PF_INET,SOCK_STREAM,0);if( server_socket < 0){printf("Create Socket Failed!");exit(1);}//把socket和socket地址结构联系起来if( bind(server_socket,(struct sockaddr*)&server_addr,sizeof(server_addr))){printf("Server Bind Port : %d Failed!", HELLO_WORLD_SERVER_PORT);exit(1);}//server_socket用于监听if ( listen(server_socket, LENGTH_OF_LISTEN_QUEUE) ){printf("Server Listen Failed!");exit(1);}while (1) //服务器端要一直运行{//定义客户端的socket地址结构client_addrstruct sockaddr_in client_addr;socklen_t length = sizeof(client_addr);//接受一个到server_socket代表的socket的一个连接//如果没有连接请求,就等待到有连接请求--这是accept函数的特性//accept函数返回一个新的socket,这个socket(new_server_socket)用于同连接到的客户的通信//new_server_socket代表了服务器和客户端之间的一个通信通道//accept函数把连接到的客户端信息填写到客户端的socket地址结构client_addr中int new_server_socket = accept(server_socket,(struct sockaddr*)&client_addr,&length);if ( new_server_socket < 0){printf("Server Accept Failed!n");break;}char buffer[BUFFER_SIZE];bzero(buffer, BUFFER_SIZE);length = recv(new_server_socket,buffer,BUFFER_SIZE,0);if (length < 0){printf("Server Recieve Data Failed!n");break;}char file_name[FILE_NAME_MAX_SIZE+1];bzero(file_name, FILE_NAME_MAX_SIZE+1);strncpy(file_name, buffer, strlen(buffer)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer));//int fp = open(file_name, O_RDONLY);//if( fp < 0 )FILE * fp = fopen(file_name,"r");if(NULL == fp ){printf("File:t%s Not Foundn", file_name);}else{bzero(buffer, BUFFER_SIZE);int file_block_length = 0;//while( (file_block_length = read(fp,buffer,BUFFER_SIZE))>0)while( (file_block_length = fread(buffer,sizeof(char),BUFFER_SIZE,fp))>0){printf("file_block_length = %dn",file_block_length);//发送buffer中的字符串到new_server_socket,实际是给客户端if(send(new_server_socket,buffer,file_block_length,0)<0){printf("Send File:t%s Failedn", file_name);break;}bzero(buffer, BUFFER_SIZE);}//close(fp);fclose(fp);printf("File:t%s Transfer Finishedn",file_name);}//关闭与客户端的连接close(new_server_socket);}//关闭监听用的socketclose(server_socket);return 0;}//////////////////////////////////////////////////////////////////////////////////////// file_client.c文件传输客户端程序示例////////////////////////////////////////////////////////////////////////////////////////本文件是客户机的代码#include // for sockaddr_in#include // for socket#include // for socket#include // for printf#include // for exit#include // for bzero/*#include #include #include #include */#define HELLO_WORLD_SERVER_PORT6666#define BUFFER_SIZE 1024#define FILE_NAME_MAX_SIZE 512int main(int argc, char **argv){if (argc != 2){printf("Usage: ./%s ServerIPAddressn",argv[0]);exit(1);}//设置一个socket地址结构client_addr,代表客户机internet地址, 端口struct sockaddr_in client_addr;bzero(&client_addr,sizeof(client_addr)); //把一段内存区的内容全部设置为0client_addr.sin_family = AF_INET;//internet协议族client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自动获取本机地址client_addr.sin_port = htons(0);//0表示让系统自动分配一个空闲端口//创建用于internet的流协议(TCP)socket,用client_socket代表客户机socketint client_socket = socket(AF_INET,SOCK_STREAM,0);if( client_socket < 0){printf("Create Socket Failed!n");exit(1);}//把客户机的socket和客户机的socket地址结构联系起来if( bind(client_socket,(struct sockaddr*)&client_addr,sizeof(client_addr))){printf("Client Bind Port Failed!n");exit(1);}//设置一个socket地址结构server_addr,代表服务器的internet地址, 端口struct sockaddr_in server_addr;bzero(&server_addr,sizeof(server_addr));server_addr.sin_family = AF_INET;if(inet_aton(argv[1],&server_addr.sin_addr) == 0) //服务器的IP地址来自程序的参数{printf("Server IP Address Error!n");exit(1);}server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);socklen_t server_addr_length = sizeof(server_addr);//向服务器发起连接,连接成功后client_socket代表了客户机和服务器的一个socket连接if(connect(client_socket,(struct sockaddr*)&server_addr, server_addr_length) < 0){printf("Can Not Connect To %s!n",argv[1]);exit(1);}char file_name[FILE_NAME_MAX_SIZE+1];bzero(file_name, FILE_NAME_MAX_SIZE+1);printf("Please Input File Name On Server:t");scanf("%s", file_name);char buffer[BUFFER_SIZE];bzero(buffer,BUFFER_SIZE);strncpy(buffer, file_name, strlen(file_name)>BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));//向服务器发送buffer中的数据send(client_socket,buffer,BUFFER_SIZE,0);//int fp = open(file_name, O_WRONLY|O_CREAT);//if( fp < 0 )FILE * fp = fopen(file_name,"w");if(NULL == fp ){printf("File:t%s Can Not Open To Writen", file_name);exit(1);}//从服务器接收数据到buffer中bzero(buffer,BUFFER_SIZE);int length = 0;while( length = recv(client_socket,buffer,BUFFER_SIZE,0)){if(length < 0){printf("Recieve Data From Server %s Failed!n", argv[1]);break;}//int write_length = write(fp, buffer,length);int write_length = fwrite(buffer,sizeof(char),length,fp);if (write_length你传输文本的时候用的什么函数阿？send/recv?还是sendto/recvfrom？或者直接read/write？ 文件不是一样的？只不过需要自己拟定一个协议，比如先发送文件大小，然后把文件打开了往里放不就好了，没有难度吧

SOCKET用于在两个基于TCP/IP协议的应用程序之间相互通信。中文有的称为套接字，你可以理解为一个插座和插头，两者匹配才能进行数据通信。 SOCKET最早出现在UNIX系统中，是UNIX系统主要的信息传递方式。在WINDOWS系统中，SOCKET称为WINSOCK。 SOCKET有两个基本概念：客户方和服务方。当两个应用之间需要采用SOCKET通信时，首先需要在两个应用之间（可能位于同一台机器，也可能位于不同的机器）建立SOCKET连接，发起呼叫连接请求的一方为客户方，接受呼叫连接请求的一方成为服务方。客户方和服务方是相对的，同一个应用可以是客户方，也可以是服务方。在客户方呼叫连接请求之前，它必须知道服务方在哪里。所以需要知道服务方所在机器的IP地址或机器名称，如果客户方和服务方事前有一个约定就好了，这个约定就是PORT（端口号）。也就是说，客户方可以通过服务方所在机器的IP地址或机器名称和端口号唯一的确定方式来呼叫服务方。在客户方呼叫之前，服务方必须处于侦听状态，侦听是否有客户要求建立连接。一旦接到连接请求，服务方可以根据情况建立或拒绝连接。连接方式有两种，同步方式（Blocking）和(noBlocking). 客户方发送的消息可以是文本，也可以是二进制信息流。当客户方的消息到达服务方端口时，会自动触发一个事件（event），服务方只要接管该事件，就可以接受来自客户方的消息了。

1.采用了多线程的方法，文件传输时使用AfxBeginThread()开启新线程 void CClientsockDlg::OnBnClickedSend(){pThreadSend = AfxBeginThread(Thread_Send,this);/}文件的发送和接收都开起了新线程UINTThread_Send(LPVOID lpParam){代码略…}2.支持从配置文件configuration.ini中获取服务器参数采用GetPrivateProfileString()和GetPrivateProfileInt()分别获取位于ServerConfiguration.ini文件中的String类型的IP和int类型的portCString IP;int port;GetPrivateProfileString(L"ServerConfiguration",L"IP",L"没有读取到数据!",IP.GetBuffer(10),10,L".\configuration.ini");port=GetPrivateProfileInt(L"ServerConfiguration",L"port",0,L".\configuration.ini");3.采用了面向对象的设计方式，功能之间按模块划分MFC本身具有良好的面向对象的特性，本程序严格按照MFC框架结构编写代码，每个按钮对应一个功能函数，降低了代码之间的耦合性，有利于程序的扩展和复用。void CServersockDlg::OnBnClickedChoose()void CServersockDlg::OnBnClickedSend()void CServersockDlg::OnBnClickedRecvdata()void CServersockDlg::OnBnClickedAbout()void CServersockDlg::OnBnClickedWriteini()4.采用了CSocket类，代码相对更简单CSocket类是MFC框架对socket编程中的winsockAPI的封装，因此通过这个类管理收发数据更加便利。代码也跟那个既简单易懂。//创建if(!Clientsock.Socket()){CString str;str.Format(_T("Socket创建失败:%d"),GetLastError());AfxMessageBox(str);}//连接if(!Clientsock.Connect(IP,port)){CString str;str.Format(_T("Socket连接失败:%d"),GetLastError());AfxMessageBox(str);}else{AfxMessageBox(_T("Socket连接成功"));代码略…//发送while(nSizeGetDlgItem(IDC_SEND))->EnableWindow(TRUE);AfxMessageBox(_T("文件发送成功"));dlg->SetDlgItemTextW(IDC_FILEPATHNAME,_T(""));}return 0;5.支持数据在服务器与客户端之间双向传输本程序不但可以从客户端往服务器端传文件，而且可以从服务器端往客户端传文件。但是互传文件的方式并不是完全相同的。服务器端不管是接收文件还是发送文件始终是对绑定的端口进行监听。//绑定if(!Serversock.Bind(port)){CString str;str.Format(_T("Socket绑定失败: %d"),GetLastError());AfxMessageBox(str);}//监听if(!Serversock.Listen(10)){CString str;str.Format(_T("Socket监听失败:%d"),GetLastError());AfxMessageBox(str);}客户端不管是接收文件还是发送文件始终是进行连接。if(!Clientsock.Connect(IP,port)){CString str;str.Format(_T("Socket连接失ì败:%d"),GetLastError());AfxMessageBox(str);}else{略…6.完全图形化操作界面二．软件使用说明客户端主界面如图所示：单击“选择文件”弹出文件对话框，选择一个要发送的文件，同时保存文件的路径。单击“发送”则会读取ServerConfiguration.ini文件中的配置信息（IP和port），并根据此信息建立Socket连接，发送文件。注意：服务器端应该先单击了“接受客户端数据”，否则发送失败。单击“接收”也会读取ServerConfiguration.ini文件中的配置信息（IP和port），并根据此信息建立Socket连接，接收文件。注意：服务器端应该先选择了向客户端发送的文件，并单击了“发送”，否则接受失败。单击“读取配置文件”，会从ServerConfiguration.ini文件中读取配置信息，并以可编辑的文本形式显示出来，修改完后，单击“写入配置文件”，会将修改后的信息保存到配置文件中。单击“关于”可以了解到软件相关信息。代码注释里有更详细的说明服务器端主界面如图所示u 单击“接受客户端数据”，开始监听客户端的链接。u单击“选择文件”弹出文件对话框，选择一个要发送的文件，同时保存文件的路径。u单击“发送”则会读取ServerConfiguration.ini文件中的配置信息（port），并监听对应端口，准备发送文件。注意：客户端选择“接收”以后才能发送成功。u单击“读取配置文件”，会从ServerConfiguration.ini文件中读取配置信息，并以可编辑的文本形式显示出来，修改完后，单击“写入配置文件”，会将修改后的信息保存到配置文件中。但是服务器的IP是不可以修改的，它是在程序开始运行时从服务器所在机器的网卡上获取的。u单击“关于”可以了解到软件相关信息。u代码注释里有更详细的说明代码下载地址：http://download.csdn.net/detail/leixiaohua1020/6320417在此附上客户端使用CSocket发起连接的代码[cpp] view plain copy//----------------------------发送文件的线程------------------------------UINT Thread_Send(LPVOID lpParam){CClientsockDlg *dlg=(CClientsockDlg *)lpParam;(dlg->GetDlgItem(IDC_SEND))->EnableWindow(FALSE);CSocket Clientsock; //definition socket.if(!AfxSocketInit()){AfxMessageBox(IDP_SOCKETS_INIT_FAILED);}CString IP;int port;GetPrivateProfileString(L"ServerConfiguration",L"IP",L"没有读取到数据！",IP.GetBuffer(100),100,L".\configuration.ini");port=GetPrivateProfileInt(L"ServerConfiguration",L"port",0,L".\configuration.ini");//创建if(!Clientsock.Socket()){CString str;str.Format(_T("Socket创建失败: %d"),GetLastError());AfxMessageBox(str);}//连接//if(!Clientsock.Connect(_T("127.0.0.1"),8088))if(!Clientsock.Connect(IP,port)){CString str;str.Format(_T("Socket连接失败: %d"),GetLastError());AfxMessageBox(str);}else{AfxMessageBox(_T("Socket连接成功"));WIN32_FIND_DATA FindFileData;CString strPathName; //定义用来保存发送文件路径的CString对象dlg->GetDlgItemTextW(IDC_FILEPATHNAME,strPathName);FindClose(FindFirstFile(strPathName,&FindFileData));Clientsock.Send(&FindFileData,sizeof(WIN32_FIND_DATA));CFile file;if(!file.Open(strPathName,CFile::modeRead|CFile::typeBinary)){AfxMessageBox(_T("文件不存在"));return 1;}UINT nSize = 0;UINT nSend = 0;char *szBuff=NULL;//发送while(nSizeGetDlgItem(IDC_SEND))->EnableWindow(TRUE);AfxMessageBox(_T("文件发送成功"));dlg->SetDlgItemTextW(IDC_FILEPATHNAME,_T(""));}return 0;}以及服务器端使用CSocket监听的代码：[cpp] view plain copy//----------------------------监听文件的线程------------------------------UINT Thread_Func(LPVOID lpParam)//接收文件的线程函数{CServersockDlg *dlg = (CServersockDlg *)lpParam; //获取对话框指针(dlg->GetDlgItem(IDC_RECVDATA))->EnableWindow(FALSE);if(!AfxSocketInit()){AfxMessageBox(IDP_SOCKETS_INIT_FAILED);}CString IP;int port;GetPrivateProfileString(L"ServerConfiguration",L"IP",L"没有读取到数据！",IP.GetBuffer(100),100,L".\configuration.ini");port=GetPrivateProfileInt(L"ServerConfiguration",L"port",0,L".\configuration.ini");char errBuf[100]={0};// 临时缓存SYSTEMTIME t; //系统时间结构CFile logErrorfile;if(!logErrorfile.Open(_T("logErrorfile.txt"),CFile::modeCreate|CFile::modeReadWrite)){return 1;}CSocket Serversock;CSocket Clientsock;//创建if(!Serversock.Socket()){CString str;str.Format(_T("Socket创建失败: %d"),GetLastError());AfxMessageBox(str);}BOOL bOptVal = TRUE;int bOptLen = sizeof(BOOL);Serversock.SetSockOpt(SO_REUSEADDR,(void *)&bOptVal,bOptLen,SOL_SOCKET);//绑定if(!Serversock.Bind(port)){CString str;str.Format(_T("Socket绑定失败: %d"),GetLastError());AfxMessageBox(str);}//监听if(!Serversock.Listen(10)){CString str;str.Format(_T("Socket监听失败: %d"),GetLastError());AfxMessageBox(str);}GetLocalTime(&t);sprintf_s(errBuf,"服务器已经启动...正在等待接收文件...rn时间：%d年%d月%d日 %2d:%2d:%2d rn",t.wYear,t.wMonth,t.wDay,t.wHour,t.wMinute,t.wSecond);int len = strlen(errBuf);logErrorfile.Write(errBuf,len);AfxMessageBox(_T("启动成功等待接收文件"));while(1){//AfxMessageBox(_T("服务器启动成功..."));if(!Serversock.Accept(Clientsock)) //等待接收{continue;}else{WIN32_FIND_DATA FileInfo;Clientsock.Receive(&FileInfo,sizeof(WIN32_FIND_DATA));CFile file;file.Open(FileInfo.cFileName,CFile::modeCreate|CFile::modeWrite);//AfxMessageBox(FileInfo.cFileName);int length = sizeof(FileInfo.cFileName);logErrorfile.Write(FileInfo.cFileName,length);//Receive文件的数据UINT nSize = 0;UINT nData = 0;char *szBuff=NULL;while(nSizeGetDlgItem(IDC_RECVDATA))->EnableWindow(TRUE);sprintf_s(errBuf,"文件接收成功...rn时间：%d年%d月%d日 %2d:%2d:%2d rn",t.wYear,t.wMonth,t.wDay,t.wHour,t.wMinute,t.wSecond);int len = strlen(errBuf);logErrorfile.Write(errBuf,len);//AfxMessageBox(_T("文件接收成功..."));break;}}return 0; }
首先创建一个MFC项目，修改名称以及存放路径。 项目配置，在向导过程中选择“基于对话框”模式，并选择“windows”套接字。设计服务器界面，控件有：4个静态文本(Static Text)，最后一个用于指示用户连接个数；一个按钮(Button)，用于打开或关闭服务器；2个编辑框(Edit Control)，一个用于输入端口号，另一个只读的用于显示事件日志。修改各个控件的属性，注意编辑框2还要把Multiline和Vertical Scroll属性选为true，以实现多行显示并自带滚动条。1、 给控件添加变量和事件处理函数，这个通过类向导就可以完成，变量如上表所示，事件只有“按钮按下”一个，双击按钮自动生成函数，后面添加相关代码即可。2、 在类视图中添加一个新类CServerSocket，派生于CSocket类，对该类进行类向导添加三个函数: OnAccept()、OnClose()、OnReceive()

1.服务器端 package sterning;import java.io.BufferedInputStream;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.File;import java.io.FileInputStream;import java.net.ServerSocket;import java.net.Socket;public class ServerTest {int port = 8821;void start() {Socket s = null;try {ServerSocket ss = new ServerSocket(port);while (true) {// 选择进行传输的文件String filePath = "D:\lib.rar";File fi = new File(filePath);System.out.println("文件长度:" + (int) fi.length());// public Socket accept() throws// IOException侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。s = ss.accept();System.out.println("建立socket链接");DataInputStream dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));dis.readByte();DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));DataOutputStream ps = new DataOutputStream(s.getOutputStream());//将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java 4th里有现成的代码。ps.writeUTF(fi.getName());ps.flush();ps.writeLong((long) fi.length());ps.flush();int bufferSize = 8192;byte[] buf = new byte[bufferSize];while (true) {int read = 0;if (fis != null) {read = fis.read(buf);}if (read == -1) {break;}ps.write(buf, 0, read);}ps.flush();// 注意关闭socket链接哦，不然客户端会等待server的数据过来，// 直到socket超时，导致数据不完整。fis.close();s.close();System.out.println("文件传输完成");}} catch (Exception e) {e.printStackTrace();}}public static void main(String arg[]) {new ServerTest().start();}}2.socket的Util辅助类package sterning;import java.net.*;import java.io.*;public class ClientSocket {private String ip;private int port;private Socket socket = null;DataOutputStream out = null;DataInputStream getMessageStream = null;public ClientSocket(String ip, int port) {this.ip = ip;this.port = port;}/** *//*** 创建socket连接** @throws Exception* exception*/public void CreateConnection() throws Exception {try {socket = new Socket(ip, port);} catch (Exception e) {e.printStackTrace();if (socket != null)socket.close();throw e;} finally {}}public void sendMessage(String sendMessage) throws Exception {try {out = new DataOutputStream(socket.getOutputStream());if (sendMessage.equals("Windows")) {out.writeByte(0x1);out.flush();return;}if (sendMessage.equals("Unix")) {out.writeByte(0x2);out.flush();return;}if (sendMessage.equals("Linux")) {out.writeByte(0x3);out.flush();} else {out.writeUTF(sendMessage);out.flush();}} catch (Exception e) {e.printStackTrace();if (out != null)out.close();throw e;} finally {}}public DataInputStream getMessageStream() throws Exception {try {getMessageStream = new DataInputStream(new BufferedInputStream(socket.getInputStream()));return getMessageStream;} catch (Exception e) {e.printStackTrace();if (getMessageStream != null)getMessageStream.close();throw e;} finally {}}public void shutDownConnection() {try {if (out != null)out.close();if (getMessageStream != null)getMessageStream.close();if (socket != null)socket.close();} catch (Exception e) {}}}3.客户端package sterning;import java.io.BufferedOutputStream;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.FileOutputStream;public class ClientTest {private ClientSocket cs = null;private String ip = "localhost";// 设置成服务器IPprivate int port = 8821;private String sendMessage = "Windwos";public ClientTest() {try {if (createConnection()) {sendMessage();getMessage();}} catch (Exception ex) {ex.printStackTrace();}}private boolean createConnection() {cs = new ClientSocket(ip, port);try {cs.CreateConnection();System.out.print("连接服务器成功!" + "n");return true;} catch (Exception e) {System.out.print("连接服务器失败!" + "n");return false;}}private void sendMessage() {if (cs == null)return;try {cs.sendMessage(sendMessage);} catch (Exception e) {System.out.print("发送消息失败!" + "n");}}private void getMessage() {if (cs == null)return;DataInputStream inputStream = null;try {inputStream = cs.getMessageStream();} catch (Exception e) {System.out.print("接收消息缓存错误n");return;}try {//本地保存路径，文件名会自动从服务器端继承而来。String savePath = "E:\";int bufferSize = 8192;byte[] buf = new byte[bufferSize];int passedlen = 0;long len=0;savePath += inputStream.readUTF();DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath))));len = inputStream.readLong();System.out.println("文件的长度为:" + len + "n");System.out.println("开始接收文件!" + "n");while (true) {int read = 0;if (inputStream != null) {read = inputStream.read(buf);}passedlen += read;if (read == -1) {break;}//下面进度条本为图形界面的prograssBar做的，这里如果是打文件，可能会重复打印出一些相同的百分比System.out.println("文件接收了" +(passedlen * 100/ len) + "%n");fileOut.write(buf, 0, read);}System.out.println("接收完成，文件存为" + savePath + "n");fileOut.close();} catch (Exception e) {System.out.println("接收消息错误" + "n");return;}}public static void main(String arg[]) {new ClientTest();} }
java中的网络信息传输方式基于TCP协议和UD协议P的,socket是基于TCP协议的实现代码如下： import java.io.DataOutputStream;import java.io.File;import java.io.FileInputStream;import java.net.InetSocketAddress;import java.net.Socket;public class ClientTcpSend {public static void main(String[] args) {int length = 0;byte[] sendBytes = null;Socket socket = null;DataOutputStream dos = null;FileInputStream fis = null;try {try {socket = new Socket();socket.connect(new InetSocketAddress("127.0.0.1", 33456),dos = new DataOutputStream(socket.getOutputStream());File file = new File("/root/6674541037_c3a9c8b64c_b.jpg");Ffis = new FileInputStream(file);sendBytes = new byte[1024];while ((length = fis.read(sendBytes, 0, sendBytes.length)) > 0) {dos.write(sendBytes, 0, length);dos.flush();}} finally {if (dos != null)dos.close();if (fis != null)fis.close();if (socket != null)socket.close();}} catch (Exception e) {e.printStackTrace();}} }
代码如下： /*import java.io.*;import java.net.*;import java.util.*;*/private HttpURLConnection connection;//存储连接private int downsize = -1;//下载文件大小,初始值为-1private int downed = 0;//文加已下载大小,初始值为0private RandomAccessFile savefile;//记录下载信息存储文件private URL fileurl;//记录要下载文件的地址private DataInputStream fileStream;//记录下载的数据流try{/*开始创建下载的存储文件,并初始化值*/File tempfileobject = new File("h:\webwork-2.1.7.zip");if(!tempfileobject.exists()){/*文件不存在则建立*/tempfileobject.createNewFile();}savefile = new RandomAccessFile(tempfileobject,"rw");/*建立连接*/fileurl = new URL("https://webwork.dev.java.net/files/documents/693/9723/webwork-2.1.7.zip");connection = (HttpURLConnection)fileurl.openConnection();connection.setRequestProperty("Range","byte="+this.downed+"-");this.downsize = connection.getContentLength();//System.out.println(connection.getContentLength());new Thread(this).start();}catch(Exception e){System.out.println(e.toString());System.out.println("构建器错误");System.exit(0);}public void run(){/*开始下载文件,以下测试非断点续传,下载的文件存在问题*/try{System.out.println("begin!");Date begintime = new Date();begintime.setTime(new Date().getTime());byte[] filebyte;int onecelen;//System.out.println(this.connection.getInputStream().getClass().getName());this.fileStream = new DataInputStream(new BufferedInputStream(this.connection.getInputStream()));System.out.println("size = " + this.downsize);while(this.downsize != this.downed){if(this.downsize - this.downed > 262144){//设置为最大256KB的缓存filebyte = new byte[262144];onecelen = 262144;}else{filebyte = new byte[this.downsize - this.downed];onecelen = this.downsize - this.downed;}onecelen = this.fileStream.read(filebyte,0,onecelen);this.savefile.write(filebyte,0,onecelen);this.downed += onecelen;System.out.println(this.downed);}this.savefile.close();System.out.println("end!");System.out.println(begintime.getTime());System.out.println(new Date().getTime());System.out.println(begintime.getTime() - new Date().getTime());}catch(Exception e){System.out.println(e.toString());System.out.println("run()方法有问题!");}}/***//FileClient.javaimport java.io.*;import java.net.*;public class FileClient {public static void main(String[] args) throws Exception {//使用本地文件系统接受网络数据并存为新文件File file = new File("d:\fmd.doc");file.createNewFile();RandomAccessFile raf = new RandomAccessFile(file, "rw");// 通过Socket连接文件服务器Socket server = new Socket(InetAddress.getLocalHost(), 3318);//创建网络接受流接受服务器文件数据InputStream netIn = server.getInputStream();InputStream in = new DataInputStream(new BufferedInputStream(netIn));//创建缓冲区缓冲网络数据byte[] buf = new byte[2048];int num = in.read(buf);while (num != (-1)) {//是否读完所有数据raf.write(buf, 0, num);//将数据写往文件raf.skipBytes(num);//顺序写文件字节num = in.read(buf);//继续从网络中读取文件}in.close();raf.close();}}//FileServer.javaimport java.io.*;import java.util.*;import java.net.*;public class FileServer {public static void main(String[] args) throws Exception {//创建文件流用来读取文件中的数据File file = new File("d:\系统特点.doc");FileInputStream fos = new FileInputStream(file);//创建网络服务器接受客户请求ServerSocket ss = new ServerSocket(8801);Socket client = ss.accept();//创建网络输出流并提供数据包装器OutputStream netOut = client.getOutputStream();OutputStream doc = new DataOutputStream(new BufferedOutputStream(netOut));//创建文件读取缓冲区byte[] buf = new byte[2048];int num = fos.read(buf);while (num != (-1)) {//是否读完文件doc.write(buf, 0, num);//把文件数据写出网络缓冲区doc.flush();//刷新缓冲区把数据写往客户端num = fos.read(buf);//继续从文件中读取数据}fos.close();doc.close();}} */

我想做一个程序，一个客户端，一个服务器段，两个通过socket发送和传递文件，我不知道能不能用sendstream或其他实现，我找不到例程，望赐教，定给分！定给分！定给分！定给分！定给分！
只要把文件流分块便不会有问题，不能一次发送过大的数据我分为8K,no problem
10K左右吧mybuffer:array[0..10000]of byte;//设置接受缓冲区这就是每次发送流的大小