发送端：
void CAceClientDlg::OnFileSend()
{
// TODO: Add your control notification handler code here
CString str;
sendFile.Abort();
sendFile.Open(sendFileName,CFile::modeRead );
sendFileLen = sendFile.GetLength();
if(sendFileLen<MAX_DATA_BUFF)
MessageBox("OK");
else
{
MessageBox("Too Large");
return ;
}
int size=8191;
int i=0;
iovec send;
while(sendFileLen>size)
{
char* membuf= (char*)LocalAlloc(LMEM_FIXED,size+1);
memset(membuf,0,size+1);
sendFile.ReadHuge(membuf,size);
membuf='%';
send.iov_base = membuf;
send.iov_len = size+1;
i++;
sendFileLen -= size;
LocalFree(membuf);
}
char* membuf= (char*)LocalAlloc(LMEM_FIXED,sendFileLen+1);
memset(membuf,0,sendFileLen+1);
sendFile.ReadHuge(membuf,sendFileLen);
membuf='%';
send.iov_base = membuf;
send.iov_len = sendFileLen+1;
i++;
pc->peer().send(send,i);
LocalFree(membuf);
}
接受端：
const size_t INPUT_SIZE =1000*1000;//INPUT_SIZE的值可以修改，具体多大不会出错待定
// charbuffer;
char *buffer;
DWORD recv_cnt,send_cnt;
iovec response;
const int MAXHOSTNAMELEN=32;
ACE_TCHAR peer_name;
ACE_INET_Addr peer_addr;
CString str;
CAceTestDlg *dlg=(CAceTestDlg*)AfxGetApp()->GetMainWnd();
this->sock_.get_remote_addr(peer_addr);
peer_addr.addr_to_string(peer_name,MAXHOSTNAMELEN);
recv_cnt = this->sock_.recvv(&response);
buffer = response.iov_base ;
// recv_cnt = this->sock_.recv(buffer,sizeof(buffer));
if(recv_cnt <=0 )
{
ACE_DEBUG((LM_DEBUG,
ACE_TEXT("%s Connection closed\n"),peer_name));
num--;
str.Format("%s Connection closed\n",peer_name);
m_lbx->AddString(str);
return -1;
}
if( buffer == '@')
{ //文字信息
buffer = '\0';
str.Format("%s send : ",peer_name);
str += buffer;
m_lbx->AddString(str);
return 0;
}
if( buffer == '$')
{ //文件名
buffer = '\0';
recvFileName = buffer;
dlg->MessageBox(recvFileName);
return 0;
}
if(buffer =='%')
{ //文件内容
buffer = '\0';
str.Format("%d",recv_cnt-1);
dlg->MessageBox(str);
if (dlg->MessageBox("是否接收数据?","提示",MB_YESNO)==IDYES)
{
/* CString returnPath;
TCHAR szPath;
BROWSEINFO bInfo;
bInfo.hwndOwner = NULL;
bInfo.pidlRoot= NULL;
bInfo.pszDisplayName = szPath;
bInfo.lpszTitle ="请选择目的路径";
bInfo.ulFlags = BIF_BROWSEINCLUDEFILES|BIF_RETURNFSANCESTORS|BIF_RETURNONLYFSDIRS|BIF_BROWSEFORCOMPUTER;
bInfo.lParam=NULL;
bInfo.lpfn=NULL;
LPITEMIDLIST lpList =SHBrowseForFolder(&bInfo);
SHGetPathFromIDList(lpList,szPath);
CString filePath = szPath ;
filePath += "\\";
//用来区分哪个客户端发来的文件,把其IP地址放在文件名的前一级目录。
// filePath += peer_name
// filePath += "\\";
filePath += recvFileName;
*/
CString filePath = "E://" + recvFileName;
dlg->MessageBox(filePath);
//往文件里写内容
//保存文件对话框的问题
if (file_connector.connect(file,
ACE_FILE_Addr (filePath),
0,
ACE_Addr::sap_any,
0,
O_RDWR|O_CREAT|O_APPEND
) == -1)
{
printf("error");
}
int len=recv_cnt-1;
if (file.send (buffer, len) != len)
ACE_ERROR_RETURN ((LM_ERROR,
"%p\n",
"send"),
1);
//所传文件的信息
if (file.close () == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"%p\n",
"close"),
1);
dlg->MessageBox("传送完毕");
}
return 0;
}
LocalFree(buffer);
return 0;
}
回复 #11 psycheqiqi 的帖子
为什么会有很少量的乱码而且利用最大的缓冲为8192有点投机取巧的意思。
有没有别的方法？ 原帖由 psycheqiqi 于 2009-9-16 16:05 发表 http://www.acejoy.com/bbs/images/common/back.gif
我试了下，最多一次传8192个字节。我想传更多怎么设置？
能修改缓冲区的大小吗？或者其它方法？
我想楼主遇到的问题不是ACE的使用的问题，
关于楼主提的问题，我想在一些网络编程的基础书籍上应该可以找到很好的答案。
可以选择参考windows 网络编程的第九章。
或者unix网络编程第七章。 遇到问题有思考是好事，
不过多看书多学习累积基础知识是必不可少的过程、
回复 #13 modern 的帖子
卷1还是卷2？。。。回复 #15 psycheqiqi 的帖子
搞错了，以为C++。字数回复 #16 psycheqiqi 的帖子
我用iovec把数据分成多个缓冲区来传收信息，但数据很大时为什么在数据的分段的地方有少量的乱码？回复 #17 psycheqiqi 的帖子
解决了大文本的发送我把文本分成段，直接发就行，不用iovec，简单问题复杂化了。:D
回复 #18 psycheqiqi 的帖子
已经搞定了。好像因为一个localalloc的问题，改完再研究，还是自己写代码比较好。
页:
1
[2]