socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp)
socket.Blocking = true
IPEndPoint computernode1 = new IPEndPoint(serverIpadress, 8080)
socket.Bind(computernode1)
socket.Listen(-1)
当有其他的计算机发出连接请求的时候，被请求的计算机将对每一个连接请求分配一个线程，用于处理文件传输和其他服务。
while ( true )
{
clientsock = socket.Accept()
if ( clientsock.Connected )
{
Thread tc = new Thread(new ThreadStart(listenclient))
tc.Start()
}
}
下面的代码展示了listenclient方法是如何处理另外一台计算机发送过来的请求。首先并对发送过来的请求字符串作出判断，看看是何种请求，然后决定相应的处理方法。
void listenclient()
{
Socket sock = clientsock
try
{
while ( sock != null )
{
byte[] recs = new byte[32767]
int rcount = sock.Receive(recs,recs.Length,0)
string message = System.Text.Encoding.ASCII.GetString(recs)
//对message作出处理，解析处请求字符和参数存储在cmdList 中
execmd＝cmdList[0]
sender = null
sender = new Byte[32767]
string parm1 = ""
//目录列举
if ( execmd == "LISTING" )
{
ListFiles(message)
continue
}
//文件传输
if ( execmd == "GETOK" )
{
cmd = "BEGINSEND " + filepath + " " + filesize
sender = new Byte[1024]
sender = Encoding.ASCII.GetBytes(cmd)
sock.Send(sender, sender.Length , 0 )
//转到文件下载处理
DownloadingFile(sock)
continue
}
}
}
catch(Exception Se)
{
string s = Se.Message
Console.WriteLine(s)
}
}
至此，基本的工作已经完成了，下面我们看看如何处理文件传输的。
while(rdby <total &&nfs.CanWrite)
{
//从要传输的文件读取指定长度的数据
len =fin.Read(buffed,0,buffed.Length)
//将读取的数据发送到对应的计算机
nfs.Write(buffed, 0,len)
//增加已经发送的长度
rdby=rdby+len
}
从上面的代码可以看出是完成文件转换成FileStream 流，然后通过NetworkStream绑定对应的套节子，最后调用他的write方法发送到对应的计算机。
我们再看看接受端是如何接受传输过来的流，并且转换成文件的：
NetworkStream nfs = new NetworkStream(sock)
try
{
//一直循环直到指定的文件长度
while(rby <size)
{
byte[] buffer = new byte[1024]
//读取发送过来的文件流
int i = nfs.Read(buffer,0,buffer.Length)
fout.Write(buffer,0,(int)i)
rby=rby+i
}
fout.Close()
从上面可以看出接受与发送恰好是互为相反的过程，非常简单。
至此，单方向的文件传输就完成了，只需要在每个对等的节点上同时实现上面的发送和接受的处理代码就可以做到互相传输文件了。
1. 采用了多线程的方法，文件传输时使用AfxBeginThread()开启新线程
void CClientsockDlg::OnBnClickedSend()
{
pThreadSend = AfxBeginThread(Thread_Send,this)/
}
文件的发送和接收都开起了新线程
UINTThread_Send(LPVOID lpParam)
{
代码略…
}
2. 支持从配置文件configuration.ini中获取服务器参数
采用GetPrivateProfileString()和GetPrivateProfileInt()分别获取位于ServerConfiguration.ini文件中的String类型的IP和int类型的port
CString 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(nSize<FindFileData.nFileSizeLow)
{
szBuff = new char[1024]
memset(szBuff,0x00,1024)
nSend =file.Read(szBuff,1024)
Clientsock.Send(szBuff,nSend)//发送数据
nSize += nSend
}
file.Close()
delete szBuff
Clientsock.Close()
(dlg->GetDlgItem(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. 完全图形化 *** 作界面
二．软件使用说明
客户端主界面如图所示：
单击“选择文件”d出文件对话框，选择一个要发送的文件，同时保存文件的路径。
单击“发送”则会读取ServerConfiguration.ini文件中的配置信息（IP和port），并根据此信息建立Socket连接，发送文件。注意：服务器端应该先单击了“接受客户端数据”，否则发送失败。
单击“接收”也会读取ServerConfiguration.ini文件中的配置信息（IP和port），并根据此信息建立Socket连接，接收文件。注意：服务器端应该先选择了向客户端发送的文件，并单击了“发送”，否则接受失败。
单击“读取配置文件”，会从ServerConfiguration.ini文件中读取配置信息，并以可编辑的文本形式显示出来，修改完后，单击“写入配置文件”，会将修改后的信息保存到配置文件中。
单击“关于”可以了解到软件相关信息。
代码注释里有更详细的说明
服务器端主界面如图所示
u 单击“接受客户端数据”，开始监听客户端的链接。
u 单击“选择文件”d出文件对话框，选择一个要发送的文件，同时保存文件的路径。
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(nSize<FindFileData.nFileSizeLow)
{
szBuff = new char[1024]
memset(szBuff,0x00,1024)
nSend = file.Read(szBuff,1024)
Clientsock.Send(szBuff,nSend)//发送数据
nSize += nSend
}
file.Close()
delete szBuff
Clientsock.Close()
(dlg->GetDlgItem(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,"服务器已经启动...正在等待接收文件...\r\n时间：%d年%d月%d日 %2d:%2d:%2d \r\n",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(nSize<FileInfo.nFileSizeLow)
{
szBuff = new char[1024]
memset(szBuff,0x00,1024)
nData=Clientsock.Receive(szBuff,1024)
file.Write(szBuff,nData)
nSize+=nData
}
delete szBuff
Serversock.Close()
Clientsock.Close()
file.Close()
(dlg->GetDlgItem(IDC_RECVDATA))->EnableWindow(TRUE)
sprintf_s(errBuf,"文件接收成功...\r\n时间：%d年%d月%d日 %2d:%2d:%2d \r\n",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
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）