Symbian开发论坛-Socket封装HTTP 断点续传创建接入点不弹框联网-DEVDIV.COM

5223

smilepander Socket封装HTTP 断点续传创建接入点不弹框联网

case ECmwapConn:
{
//对以前的数据进行清理
iPrintBuf.SetLength(0) ;
iFirstIn = ETrue ;
if(iHttpDown) delete iHttpDown ;
//new出下载引擎进行链接
iHttpDown = CM5HttpDown::NewL(*this, HTTP_DOWN_CMWAP) ;
iHttpDown->HttpConnPorxy(s8) ; //s8为网址
iRecvSize = 0 ;
// check whether the file exists
User::LeaveIfError(iFs.Connect()) ;
iRecvSize = 0 ;
if(BaflUtils::FileExists(iFs, KTargetFilename)) {
TInt seek_pos = 0 ;
iFile.Open(iFs, KTargetFilename, EFileStream | EFileWrite) ;
if(iFile.Size(iRecvSize) != KErrNone)
iRecvSize = 0 ;
//如果文件存在并且没有异常的话，打开文件并移到文件末尾，为追加模式
iFile.Seek(ESeekEnd, seek_pos) ;
} else {
iFile.Replace(iFs, KTargetFilename, EFileStream | EFileWrite) ;
}
break ;
}
//下面来看CM5HttpDown引擎
//那么这个是我们引擎给外界提供的观察者
class M5HttpDownNotifier {
public:
virtual void M5PrintNotify(const TDesC & aMessage) = 0 ;
virtual void M5RecvNotify(const TDesC8 & recv_buf) = 0 ;
virtual void M5TimerExpireNotify() = 0 ;
virtual void M5ErrorNotify(const TDesC& aErrMessage, TInt aErrCode = 0) = 0 ;
};
#endif
class CM5HttpDown : public CBase, public MUINotifier {
protected:
// socket data
TInt m_down_type ;
CSocketsEngine * m_sock_eng ; //联网的socke引擎，此类肯定是比较重要的一部分
TBool m_running ;
TBool m_is_first_resp ;
TInt m_web_port ;
TInt m_total_bytes ;
TInt m_recv_bytes;
TBuf8<HTTP_SEND_BUF_LEN> m_send_buf ;
TBuf8<HTTP_TEMP_BUF_LEN> m_web_addr ;
TBuf8<HTTP_TEMP_BUF_LEN> m_web_fname ;
M5HttpDownNotifier& m_m5_notifier ; //给外界提供的接口
public: // MUINotifier implements
void PrintNotify(const TDesC& aMessage, TUint aAttributes = 0) ;
void RecvNotify(const TDesC8& aMessage) ;
void ErrorNotify(const TDesC& aErrMessage, TInt aErrCode) ;
void SetStatus(const TDesC& aStatus) ;
protected: //自己使用的方法
TInt Str2Int(const TDesC8 & s) ;
TBool CheckRecv(const TDesC8& recv_buf) ;
TBool ParseUri(TDesC8& uri, TDes8& web_addr, TDes8& web_fname, TInt& web_port) ;
TBool ParseWebFileInfo(const TDesC8& recv_buf, TInt& total_length, TInt& jump_len) ;
TBool GetRespField(const TDesC8& recv_buf, TDesC8& field_name, TDesC8& end_flag, TDes8& res) ;
TBool InitSock(TDesC8& server_name, TInt server_port) ;
TBool SendReq(TDesC8& req_str) ;
TBool CloseSock() ;
private:
CM5HttpDown(M5HttpDownNotifier & m5_notifier) ;
void ConstructL(TInt down_type) ;
public: //引擎暴露给外界的借口如下，当然还有观察者的那些接口用以通知
~CM5HttpDown() ;
static CM5HttpDown * NewL(M5HttpDownNotifier& m5_notifie, TInt down_type) ;
static CM5HttpDown * NewLC(M5HttpDownNotifier& m5_notifier, TInt down_type) ;
TBool IsRunning() {return m_running ; }
TInt HttpTotalSize() { return m_total_bytes ; }
TInt HttpRecvSize() { return m_recv_bytes ; }
//其实主要就暴露了以下三个接口
TBool HttpConnPorxy(TDesC8& uri) ;
TBool HttpDown(TDesC8& uri, TInt recv_bytes = 0) ;
TBool HttpStopDown() ;
} ;
#endif
//下面来分析一下引擎暴露给我们接口
TBool CM5HttpDown::HttpConnPorxy(TDesC8& uri)
{
m_running = true ;
//解析我们传递进去的URL：地址文件名称端口号，当让HTTP是80
ParseUri(uri, m_web_addr, m_web_fname, m_web_port) ;
if(m_down_type == HTTP_DOWN_CMWAP) {
TBuf8<20> proxy_svr ;
proxy_svr.Copy(KCMCCWapProxy) ; //_LIT(KCMCCWapProxy, "10.0.0.172") ;
//我们看到如果是wap链接，传递进去的是wap的代理地址，至于原理是什么，我们再慢慢分析
if(!InitSock(proxy_svr, 80)) return EFalse ;
} else {
if(!InitSock(m_web_addr, m_web_port)) return EFalse ;
}
return ETrue ;
}
TBool CM5HttpDown::HttpDown(TDesC8& uri, TInt recv_bytes)
{
TBuf8<20> tmp_str ;
m_recv_bytes = recv_bytes ;
m_send_buf.SetLength(0) ;
//此处主要是对是否已经有下载下来的内容进行分析
if(m_recv_bytes == 0)
{
m_send_buf.Append(KHttpCommonGet1) ;
//如果是wap链接，这个地方放的是uri，否则为文件名称
//此处实际是用Socket组织了一个http的包，打算发送
if(m_down_type == HTTP_DOWN_CMWAP)
m_send_buf.Append(uri) ;
else
m_send_buf.Append(m_web_fname) ;
m_send_buf.Append(KHttpCommonGet2) ;
m_send_buf.Append(m_web_addr) ;
m_send_buf.Append(KHttpCommonGet3) ;
tmp_str.Format(_L8("%d"), m_web_port) ;
m_send_buf.Append(tmp_str) ;
m_send_buf.Append(KHttpCommonGet4) ;
}
else
{
m_send_buf.Append(KHttpResumeGet1) ;
if(m_down_type == HTTP_DOWN_CMWAP)
m_send_buf.Append(uri) ;
else
m_send_buf.Append(m_web_fname) ;
m_send_buf.Append(KHttpResumeGet2) ;
m_send_buf.Append(m_web_addr) ;
m_send_buf.Append(KHttpResumeGet3) ;
tmp_str.Format(_L8("%d"), m_web_port) ;
m_send_buf.Append(tmp_str) ;
//这里才是断点续传的要点，就是将已经下载的字节数传递到服务器（这个是HTTP协议本身来进行处理的）
//不要想的有多神秘哦
m_send_buf.Append(KHttpResumeGet4) ;
tmp_str.Format(_L8("%d"), m_recv_bytes) ;
m_send_buf.Append(tmp_str) ;
m_send_buf.Append(KHttpResumeGet5) ;
}
// send the request
//进行socke发送
return SendReq(m_send_buf) ;
}
//关闭链接
TBool CM5HttpDown::HttpStopDown()
{
return CloseSock() ;
}
//通过上面的观察，我们发现，我们现在需要弄明白
//SendReq(m_send_buf) ;
//InitSock(proxy_svr, 80)的实现，下面我们来看看，我也是学习，说的乱不要怪哦，呵呵
TBool CM5HttpDown::InitSock(TDesC8& server_name, TInt server_port)
{
TBuf<50> svr_name ;
svr_name.Copy(server_name) ;
m_sock_eng->SetServerName(svr_name) ;
m_sock_eng->SetPort(server_port) ;
m_sock_eng->ConnectL() ;
return ETrue ;
}
TBool CM5HttpDown::SendReq(TDesC8& req_str)
{
if(m_sock_eng->Connected()) {
m_sock_eng->WriteL(req_str) ;
return ETrue ;
}
return EFalse ;
}
//我们看到，其实上面的两个函数很简单，无非就是发送和链接，设置参数，主要功能是由
//SocketEngine来实现的，我们去看看socketengine吧
//这是对SocketEngine进行了一段截取
#ifndef HTTP_DOWN_CMWAP
#define HTTP_DOWN_CMWAP 0
#define HTTP_DOWN_CMNET 1
#endif
class CSocketsEngine : public CActive, public MTimeOutNotifier, public MEngineNotifier
{
public: // new methods
//这些是我们比较关心的接口
void ConnectL();
void Disconnect();
void WriteL(const TDesC8& aData);
void Read();
//我们需要对以下接口也进行关注和注意
TUint32 CreateCmnetIap() ;
TUint32 CreateCmwapIap() ;
void ConnectSmoothCMNET() ;
void ConnectSmoothCMWAP() ;
void ConnectL(TUint32 aAddr);
}
//下面我们对上面说需要注意的方法进行分析；
void CSocketsEngine::ConnectL()
{
// Initiate connection process
if (iEngineStatus == ENotConnected)
{
TInetAddr addr;
if (addr.Input(iServerName) == KErrNone)
{
// server name is already a valid ip address
ConnectL(addr.Address());
}
else // need to look up name using dns
{
//如果发现不合法，则需要去寻找IP地址，域名解析
// Initiate DNS
User::LeaveIfError(iResolver.Open(iSocketServ, KAfInet, KProtocolInetUdp));
// DNS request for name resolution
iResolver.GetByName(iServerName, iNameEntry, iStatus);
//将引擎状态进行改变，方便RunL函数去进行处理
ChangeStatus(ELookingUp);
// Request time out
iTimer->After(KTimeOut);
SetActive();
}
}
}
void CSocketsEngine::WriteL(const TDesC8& aData)
{
// Write data to socket
if (iEngineStatus == EConnected)
{
iSocketsWriter->IssueWriteL(aData);
}
}
void CSocketsEngine::Read()
{
// Initiate read of data from socket
if ((iEngineStatus == EConnected) && (!iSocketsReader->IsActive()))
{
iSocketsReader->Start();
}
}
// from CActive
void CSocketsEngine::RunL()
{
// Active object request complete handler.
// iEngineStatus flags what request was made, so its
// completion can be handled appropriately
iTimer->Cancel(); // Cancel TimeOut timer before completion
switch(iEngineStatus)
{
case EConnecting:
// IP connection request
if (iStatus == KErrNone)
// Connection completed successfully
{
//如果链接成功，则开始监听读取
ChangeStatus(EConnected);
Read(); //Start CSocketsReader Active object
}
else
{
iSocket.Close();
iConsole.ErrorNotify(KErrConnectionFailed, iStatus.Int());
ChangeStatus(ENotConnected);
}
break;
case ELookingUp:
iResolver.Close();
if (iStatus == KErrNone)
{
//域名解析成功则开始链接
// DNS look up successful
iNameRecord = iNameEntry();
// Extract domain name and IP address from name record
Print(KStrDomainName);
Print(iNameRecord.iName);
TBuf<15> ipAddr;
TInetAddr::Cast(iNameRecord.iAddr).Output(ipAddr);
Print(KStrIPAddr);
Print(ipAddr);
Print(KStrNewLine);
// And connect to the IP address
ChangeStatus(ENotConnected);
ConnectL(TInetAddr::Cast(iNameRecord.iAddr).Address());
}
else
{
// DNS lookup failed
iConsole.ErrorNotify(KErrDNSFailed, iStatus.Int());
ChangeStatus(ENotConnected);
}
break;
default:
User::Panic(KPanicSocketsEngine, ESocketsBadStatus);
break;
};
}

复制代码

36.63 KB, 下载次数: 2296

已有 1 人评分	技术分	收起理由
dymx101	+ 5

总评分: 技术分 + 5 查看全部评分

遨游于移动平台开发中

高级构架师 2^# smilepander 发表于 2010-9-10 23:33:04

//感觉又被骗了，socketEngine本身并没有进行读写，而是有reader和writer来完成的，所以我又厚着脸皮来了
//Reader中我们只需要关心IssueRead和Runl，了解它是怎么发起的，还有就是它怎么对读取的东西进行操作的。
void CSocketsReader::IssueRead()
{
// Initiate a new read from socket into iBuffer
__ASSERT_ALWAYS(!IsActive(), User::Panic(KPanicSocketsEngineRead, ESocketsBadState));
iSocket.RecvOneOrMore(iBuffer, 0, iStatus, iDummyLength);
SetActive();
}
void CSocketsReader::RunL()
{
// Active object request complete handler
switch (iStatus.Int())
{
case KErrNone:
//没有错误，通知外边然后继续读取，发现reader好无私，一直默默的读取哦
// Character has been read from socket
iEngineNotifier.ResponseReceived(iBuffer);
IssueRead(); // Immediately start another read
break;
case KErrDisconnected:
//如果已经断开了链接，也通知外边
iEngineNotifier.ReportError(MEngineNotifier::EDisconnected,
iStatus.Int());
break;
default:
//其他错误都报呈是读取错误，reader也不知道怎么回事了，如果你知道的话就帮忙给补充一下吧，呵呵
iEngineNotifier.ReportError(MEngineNotifier::EGeneralReadError,
iStatus.Int());
break;
}
}
//下面来看writer
void CSocketsWriter::IssueWriteL(const TDesC8& aData)
{
if ((iWriteStatus != EWaiting) && (iWriteStatus != ESending))
{
User::Leave(KErrNotReady);
}
if ((aData.Length() + iTransferBuffer.Length()) > iTransferBuffer.MaxLength())
{
// Not enough space in buffer
User::Leave(KErrOverflow);
}
// Add new data to buffer
iTransferBuffer.Append(aData);
//其实发现上面就是将数据写到缓冲区中
//等待活动对象比较清闲的时候进行发送
if (!IsActive())
{
SendNextPacket();
}
}
void CSocketsWriter::SendNextPacket()
{
if (iTransferBuffer.Length() > 0)
{
// Move data from transfer buffer to actual write buffer
iWriteBuffer = iTransferBuffer;
iTransferBuffer.Zero();
iSocket.Write(iWriteBuffer, iStatus); // Initiate actual write
// Request timeout
iTimer->After(iTimeOut);
SetActive();
iWriteStatus = ESending;
}
else
{
iWriteStatus = EWaiting;
}
}
//至此，我们学会了用socket封装HTTP，也知道了HTTP断点续传的东西，可是好奇怪，
//我们应该关注的有几个函数并没有用到，为什么呢，要不我们去看看他们构造的时候都干嘛了
void CSocketsEngine::ConstructL(TInt down_type)
{
ChangeStatus(ENotConnected);
// Start a timer
iTimer = CTimeOutTimer::NewL(EPriorityHigh, *this);
CActiveScheduler::Add(this);
//我们这时候发现，此处是非常重要的一部分，因为他们能默默的去链接网络，而不用惊动用户，
//相信这也是大家在做网络的时候梦寐以求的东西，我们一块去瞧瞧吧
// Open channel to Socket Server
if(down_type == HTTP_DOWN_CMNET)
ConnectSmoothCMNET() ;
else
ConnectSmoothCMWAP() ;
// Create socket read and write active objects
iSocketsReader = CSocketsReader::NewL(*this, iSocket);
iSocketsWriter = CSocketsWriter::NewL(*this, iSocket);
}
//无声的链接wap
void CSocketsEngine::ConnectSmoothCMWAP()
{
#ifdef __WINSCW__
User::LeaveIfError(iSocketServ.Connect()) ;
#else
TBuf<20> iap_name_buf ;
TBuf<20> cmwap_str ;
TUint32 iap_id = -1 ;
cmwap_str.Append(KCmwapIapName) ;
// prepare conn
User::LeaveIfError(iSocketServ.Connect());
User::LeaveIfError(iConn.Open(iSocketServ)) ;
// visit commdb for iap
CCommsDatabase* const comm_db = CCommsDatabase::NewL(EDatabaseTypeIAP);
CleanupStack::PushL(comm_db);
// visit the table of comm_db
CCommsDbTableView *iap_table_view = comm_db->OpenTableLC(TPtrC(IAP));
// switch pointer to the first iap record
if(iap_table_view->GotoFirstRecord() == KErrNone) {
// search comm_db for cmnet iap
do {
// get the iap name from comm_db
iap_name_buf.SetLength(0) ;
iap_table_view->ReadTextL(TPtrC(COMMDB_NAME), iap_name_buf);
// test the cmnet iap name
if((iap_name_buf.Find(cmwap_str) != KErrNotFound)) {
iap_table_view->ReadUintL(TPtrC(COMMDB_ID), iap_id) ;
break ;
}
} while (KErrNone == iap_table_view->GotoNextRecord()) ;
}
CleanupStack::PopAndDestroy(2, comm_db); // iap_table_view, comm_db
if(iap_id == -1) iap_id = CreateCmwapIap() ;
// use the iap, construct preference
TCommDbConnPref conn_pref;
conn_pref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt) ;
conn_pref.SetDirection(ECommDbConnectionDirectionOutgoing) ;
conn_pref.SetBearerSet(ECommDbBearerGPRS) ;
conn_pref.SetIapId(iap_id) ;
// perform the smooth connection
iConn.Start(conn_pref);
#endif
}
//无声的链接cmnet
void CSocketsEngine::ConnectSmoothCMNET()
{
#ifdef __WINSCW__
User::LeaveIfError(iSocketServ.Connect()) ;
#else
TBuf<20> iap_name_buf ;
TBuf<20> cmnet_str ;
TUint32 iap_id = -1 ; // set invalid iap first
cmnet_str.Append(KCmnetIapName) ;
// prepare conn
User::LeaveIfError(iSocketServ.Connect());
User::LeaveIfError(iConn.Open(iSocketServ)) ;
// visit commdb for iap
CCommsDatabase* const comm_db = CCommsDatabase::NewL(EDatabaseTypeIAP);
CleanupStack::PushL(comm_db);
// visit the table of comm_db
CCommsDbTableView *iap_table_view = comm_db->OpenTableLC(TPtrC(IAP));
// switch pointer to the first iap record
if(iap_table_view->GotoFirstRecord() == KErrNone) {
// search comm_db for cmnet iap
do {
// get the iap name from comm_db
iap_name_buf.SetLength(0) ;
iap_table_view->ReadTextL(TPtrC(COMMDB_NAME), iap_name_buf);
// test the cmnet iap name
if((iap_name_buf.Find(cmnet_str) != KErrNotFound)) {
iap_table_view->ReadUintL(TPtrC(COMMDB_ID), iap_id) ;
break ;
}
} while (KErrNone == iap_table_view->GotoNextRecord()) ;
}
CleanupStack::PopAndDestroy(2, comm_db); // iap_table_view, comm_db
// make sure the iap is valid
if(iap_id == -1) iap_id = CreateCmnetIap() ;
// use the iap, construct preference
TCommDbConnPref conn_pref;
conn_pref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt) ;
conn_pref.SetDirection(ECommDbConnectionDirectionOutgoing) ;
conn_pref.SetBearerSet(ECommDbBearerGPRS) ;
conn_pref.SetIapId(iap_id) ;
// perform the smooth connection
iConn.Start(conn_pref);
#endif
}
//现在明白了怎么创建接入点，联网不弹出提示框，Socket封装HTTP，断点续传，感觉真不错呀，给大家分享，附件为完整的例子

复制代码

已有 1 人评分	技术分	收起理由
xiejiangquan	+ 5	写的不错支持

总评分: 技术分 + 5 查看全部评分

遨游于移动平台开发中

支持(0) 反对(0)

研究员 3^# wuyuezhouzhou 发表于 2010-9-10 23:35:13

还是标记一下的好，虽然也写过

支持(0) 反对(0)

研究员 4^# symbian_love 发表于 2010-9-10 23:35:26

好东西，顶起

爱拼才会赢

支持(0) 反对(0)

研究员 5^# cleanriceking 发表于 2010-9-10 23:36:38

直接放入收藏夹，以备后用
顺便顶起
赞一个

Shuddhodana

支持(0) 反对(0)

首席构架师 6^# Sylvanas 发表于 2010-9-10 23:37:07

LZ够低调
谢谢

支持(0) 反对(0)

高级构架师 7^# smilepander 发表于 2010-9-10 23:37:38

回复 5# cleanriceking

饭王哈哈你原来是饭王啊

支持(0) 反对(0)

研究员 8^# cleanriceking 发表于 2010-9-10 23:39:13

回复 7# smilepander

难道阁下是YoYo

支持(0) 反对(0)

见习构架师 9^# jebai0521 发表于 2010-9-10 23:40:23

顶！！！！！！！！

支持(0) 反对(0)

首席构架师 10^# Brian1900 发表于 2010-9-10 23:41:57

MARK

Everything happend for a reason!Work work hard,day day up!

支持(0) 反对(0)

高级构架师 11^# drfang07 发表于 2010-9-10 23:44:13

收藏了，谢谢分享

支持(0) 反对(0)

中级构架师 12^# vance 发表于 2010-9-10 23:49:02

感谢分享，学习了！！
大神，有几个问题我想请教。
第一，KCmwapIapName，您这个常量的内容是cmwap吗，不知道为什么，我的cmwap,cmnet匹配不到table里的iapname。我扫了一边table，打出来的iapname很多是中文，而我看很多的例子里都是cmnet等，这样能找到相应的name而获得相应的id吗？
第二，您在constructL里设置不提示连接接入点，程序开启的时候自动调用，但是这个过程我真机测试要6到8秒，这段时间内程序就像卡在那里一样，不知道您是不是也是这样？有什么好的解决方法没？

人始终是要有梦想的

支持(0) 反对(0)

中级构架师 13^# yuanqiyao 发表于 2010-9-10 23:49:34

回复 12# vance
同意，一直想弄明白接入点对话框不弹出后时间的问题，我用的RConnection：：Start的同步方法就感觉好慢，是不是异步会快点。。

支持(0) 反对(0)

高级构架师 14^# smilepander 发表于 2010-9-10 23:50:06

回复 12# vance

1.KCmwapIapName是个字符串，你看附件那个例子吧，cmwap是移动，其他运营商好像不是这个名字，所以匹配的时候一般是用“wap”去匹配，而不是cmwap，如果实在找不到了，就创建一个吧把例子里面的东西copy一下，哈哈！
2.你所说的联网慢的问题，就是因为你用的start方法是同步的方式，用异步方式去试试，我感觉还不错哦。

支持(0) 反对(0)