httpexampleengine.cpp

一个比较完整的有关移动开发的例子 vc++6.0下编译通过

/**
*
* @brief Definition of CHTTPExampleEngine
*
* Copyright (c) EMCC Software Ltd 2003
* @version 1.0
*/

// INCLUDE FILES

// Class include
#include "HTTPExampleEngine.h"

// System includes
#include <chttpformencoder.h>        // CHTTPFormEncoder
#include <httpstringconstants.h>    // HTTP string table
#include <rhttpheaders.h>            // RHTTPHeaders
#include <utf.h> 

#define MEM_FREE(p) if (NULL != (p)){delete (p); (p) = NULL;}
// CONSTANTS
// HTTP header values
_LIT8(KUserAgent, "HTTPExample (1.0)");    // Name of this client app
_LIT8(KAccept, "text/*");                // Accept any (but only) text content

_LIT8(KPostParamName, "NAME");            // Name of the parameter sent in a POST request
_LIT8(KPostContentType, "text/plain");    // Content type sent in a POST request

// URL for POST request.
_LIT8(KPostUri, "http://www.ldci.mobi/snsProject/update");
_LIT(KGetUri, "http://www.ldci.mobi/snsProject/download?mobile=15811293361&pass=111111");

// ================= MEMBER FUNCTIONS =======================

/**
* 2-phase constructor
*
* @param aObserver An observer of this engine (e.g. the UI)
*/
CHTTPExampleEngine* CHTTPExampleEngine::NewL(MHTTPExampleEngineObserver& aObserver)
{
    CHTTPExampleEngine* self = new (ELeave) CHTTPExampleEngine(aObserver);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
}

/**
* C++ constructor
*
* @param aObserver An observer of this engine (e.g. the UI)
*/
CHTTPExampleEngine::CHTTPExampleEngine(MHTTPExampleEngineObserver& aObserver)
: iObserver(aObserver)
{
}

/**
* 2nd-phase constructor
*/
void CHTTPExampleEngine::ConstructL()
{
    // Open the RHTTPSession
    iSession.OpenL();
	
    // Construct the form encoder
    iFormEncoder = CHTTPFormEncoder::NewL();
}

/**
* C++ destructor
*/
CHTTPExampleEngine::~CHTTPExampleEngine()
{
    // Close session
    iSession.Close();    // Will also close any open transactions
    delete iResponseBuffer;
    delete iFormEncoder;
    delete iUri;
}

/**
* Override of pure virtual method in MHTTPTransactionCallback.
* Called to report progress by a currently outstanding transaction.
*
* @param aTransaction The transaction reporting progress
* @param aEvent The event being notified
*/
void CHTTPExampleEngine::MHFRunL(RHTTPTransaction aTransaction, const THTTPEvent& aEvent)
{
    switch (aEvent.iStatus)
    {
	case THTTPEvent::EGotResponseHeaders:
        {
            // HTTP response headers have been received.
            // Pass status information to observer.
            RHTTPResponse resp = aTransaction.Response();
			
            // Get status code
            TInt statusCode = resp.StatusCode();
			
            // Get status text
            RStringF statusStr = resp.StatusText();
            HBufC* statusBuf = HBufC::NewLC(statusStr.DesC().Length());
            statusBuf->Des().Copy(statusStr.DesC());
			
            // Inform observer
            iObserver.ResponseStatusL(statusCode, *statusBuf);
			
            CleanupStack::PopAndDestroy(statusBuf);
        }
		break;
		
		
	case THTTPEvent::EGotResponseBodyData:
        {
            // Get text of response body
            MHTTPDataSupplier* dataSupplier = aTransaction.Response().Body();
            TPtrC8 ptr;
            dataSupplier->GetNextDataPart(ptr);
			
            // Convert to 16-bit descriptor
			//	HBufC* pTemp = HBufC::NewLC(ptr.Length());
            
			
            
			HBufC* buf = HBufC::NewLC(ptr.Length());
			
			
			CnvUtfConverter::ConvertToUnicodeFromUtf8(buf->Des(),ptr);
			
			//	buf->Des().Copy(ptr);
			
            // Append to iResponseBuffer
            if (!iResponseBuffer)
            {
                iResponseBuffer = buf->AllocL();
            }
            else
            {
                iResponseBuffer = iResponseBuffer->ReAllocL(iResponseBuffer->Length() + buf->Length());
                iResponseBuffer->Des().Append(*buf);
            }
			
            // Release buf
            CleanupStack::PopAndDestroy(buf);
			
            // Release the body data
            dataSupplier->ReleaseData();
        }
		break;
		
	case THTTPEvent::EResponseComplete:
        {
            // Pass the response buffer by reference to the observer
            iObserver.ResponseReceivedL(/*iResponseBuffer*/);
        }
		break;
    }
}

/**
*/
TInt CHTTPExampleEngine::MHFRunError(TInt aError, RHTTPTransaction /*aTransaction*/, const THTTPEvent& /*aEvent*/)
{
    return aError;
}


HBufC*  CHTTPExampleEngine::GetResponse()
{
	return iResponseBuffer;
}
void CHTTPExampleEngine::MEMFREE()
{
	if(NULL!=iResponseBuffer)
	{
		delete iResponseBuffer;
		iResponseBuffer = NULL;
	} 
}
/**
* Initiate a GET request
*
* @param aUri The URI to get
*/
void CHTTPExampleEngine::GetRequestL()
{
    // Parse the URI
    ParseUriL(KGetUri);
	
    // Create the transaction
    iTransaction = iSession.OpenTransactionL(iUriParser, *this,
        iSession.StringPool().StringF(HTTP::EGET, RHTTPSession::GetTable()));
	
    // Set transaction headers
    RHTTPHeaders headers = iTransaction.Request().GetHeaderCollection();
    AddHeaderL(headers, HTTP::EUserAgent, KUserAgent);
    AddHeaderL(headers, HTTP::EAccept, KAccept);
	
    // Submit the request
    iTransaction.SubmitL();
}


/**
* Initiate a POST request
*
* @param aName The user's name
*/
void CHTTPExampleEngine::PostRequestL(RPointerArray<CBookInfo> m_pBookInfoArray)
{
    // Build form encoder
    // Start by removing any previous content
	delete iFormEncoder;
    iFormEncoder = NULL;
	
    iFormEncoder = CHTTPFormEncoder::NewL();
    HBufC8*  buf8 = HBufC8::NewL(2048);
	//  TBuf8<1024> buf8;
	//转换成UTF8编码
	// 	MEM_FREE(m_pConutf8);
	// 	m_pConutf8 = HBufC8::NewL(1024);
	
	HBufC*  buf16 = HBufC::NewL(2048); 
	
    
    buf16->Des().Copy(_L("<rss>\n<type>update</type>\n<mobile>15811293361</mobile>\n"));
    TBuf<50> temp;
    
	for(TInt ni = 0 ; ni < m_pBookInfoArray.Count(); ni++ )
	{
		temp.Copy(_L("<record>\n"));
		buf16->Des().Append(temp);
		
		temp.Copy(_L("<lname>"));
		buf16->Des().Append(temp);
		temp.Copy(m_pBookInfoArray[ni]->GetLastName()->Des());
		buf16->Des().Append(temp);
		temp.Copy(_L("</lname>\n"));
		buf16->Des().Append(temp);
		
		temp.Copy(_L("<fname>"));
		buf16->Des().Append(temp);
		temp.Copy(m_pBookInfoArray[ni]->GetFirstName()->Des());
		buf16->Des().Append(temp);
		temp.Copy(_L("</fname>\n"));
		buf16->Des().Append(temp);
		
		temp.Copy(_L("<mob>"));
		buf16->Des().Append(temp);
		temp.Copy(m_pBookInfoArray[ni]->GetTelephone()->Des());
		buf16->Des().Append(temp);
		temp.Copy(_L("</mob>\n"));
		buf16->Des().Append(temp);  
		
		temp.Copy(_L("<mail>"));
		buf16->Des().Append(temp);
		temp.Copy(_L("</mail>\n"));
		buf16->Des().Append(temp);   
		
		temp.Copy(_L("<addr>"));
		buf16->Des().Append(temp);
		temp.Copy(_L("</addr>\n"));
		buf16->Des().Append(temp);   
		
		temp.Copy(_L("<company>"));
		buf16->Des().Append(temp);
		temp.Copy(_L("</company>\n"));
		buf16->Des().Append(temp);   
		
		temp.Copy(_L("</record>\n"));
		buf16->Des().Append(temp);
	}
    temp.Copy(_L("</rss>\n"));
	buf16->Des().Append(temp);
	
	CnvUtfConverter::ConvertFromUnicodeToUtf8(buf8->Des(),buf16->Des());
	
    iFormEncoder->AddFieldL(KPostParamName, buf8->Des());
    // Create transaction
    iUriParser.Parse(KPostUri);
    iTransaction = iSession.OpenTransactionL(iUriParser, *this,
        iSession.StringPool().StringF(HTTP::EPOST, RHTTPSession::GetTable()));
	
    // Set transaction headers
    RHTTPHeaders headers = iTransaction.Request().GetHeaderCollection();
    AddHeaderL(headers, HTTP::EUserAgent, KUserAgent);
    AddHeaderL(headers, HTTP::EAccept, KAccept);
    AddHeaderL(headers, HTTP::EContentType, KPostContentType);
	
    // Set the form encoder as the data supplier
    iTransaction.Request().SetBody(*iFormEncoder);
	
    // Submit the request
    iTransaction.SubmitL();
	MEM_FREE(buf8);
	MEM_FREE(buf16);
	
}


//
// Utility methods
//

/**
* Parse a URI
*
* @param aUri The URI to be parsed
*/
void CHTTPExampleEngine::ParseUriL(const TDesC& aUri)
{
    // Convert the URI to an 8-bit descriptor
    // then set iUriParser to point at it
    delete iUri;
    iUri = NULL;
    iUri = HBufC8::NewL(aUri.Length());
    iUri->Des().Copy(aUri);
    User::LeaveIfError(iUriParser.Parse(*iUri));
}


/**
* Add a header to a header set
*
* @param aHeaders The header set to be modified
* @param aHeaderField The name of the header to be added
* @param aHeaderValue The value for the header to be added
*/
void CHTTPExampleEngine::AddHeaderL(RHTTPHeaders aHeaders, TInt aHeaderField, const TDesC8& aHeaderValue)
{
    RStringPool stringPool = iSession.StringPool();
    RStringF valStr = stringPool.OpenFStringL(aHeaderValue);
    THTTPHdrVal headerVal(valStr);
    aHeaders.SetFieldL(stringPool.StringF(aHeaderField, RHTTPSession::GetTable()), headerVal);
    valStr.Close();
}


/**
* Cancel any outstanding transaction
*/
void CHTTPExampleEngine::Cancel()
{
    iTransaction.Cancel();
}