内蒙古java团队

http://hostname/mapGuide/mapagent.fcig?OPERATION=EnumerateResources&VERSION=1.0.0& RESOURCEID=Library:// &TYPE=FeatureSource&DEPTH=3

服务器扩展模块

源代码位置

isapi_MapAgent.dll

\Web\src\IsapiAgent

MapAgent.exe

\Web\src\CgiAgent

mod_mgmapagent.so

\Web\src\ApacheAgent

DWORD WINAPI HttpExtensionProc(EXTENSION_CONTROL_BLOCK *pECB)

{

Initialize(pECB);

// 调用GetServerVariable读取诸如服务器名称、端口号等服务器变量信息

......

// 创建MgHttpRequest的实例，用于处理HTTP请求

Ptr request = new MgHttpRequest(wUrl);

// 解析HTTP请求中的参数，并且将这些参数置入MgHttpRequest对象中

Ptr params = request->GetRequestParam();

......

IsapiPostParser postParser(pECB);

postParser.Parse(params);

......

// 创建IsapiResponseHandler的实例，用于将响应请求返回给客户端

IsapiResponseHandler responseHandler(pECB);

......

// 将HTTP请求转发给MapGuide服务器，当MapGuide服务器处理完这个请求，

// 将请求结果返回给Web扩展之后，这个方法会返回一个MgHttpResponse对象，

// 它表示HTTP请求的响应结果。

Ptr response = request->Execute();

// 将响应结果返回给客户端

responseHandler.SendResponse(response);

......

}

MgHttpResponse* MgHttpRequest::Execute()

{

Ptr hResponse;

Ptr result;

// 创建MgHttpResponse对象，用于返回HTTP请求响应结果

hResponse = new MgHttpResponse();

result = hResponse->GetResult();

// 获得HTTP请求中参数“OPERATION”的值

STRING sParamValue = m_requestParam->GetParameterValue(MgHttpResourceStrings::reqOperation);

......

// 根据参数“OPERATION”的值取得对应操作的请求响应处理器

Ptr rrHandler =

CreateRequestResponseHandler(sParamValue, result);

.......

// 处理HTTP请求

if(rrHandler != NULL) rrHandler->Execute(*hResponse);

......

// 返回响应结果

return SAFE_ADDREF((MgHttpResponse*)hResponse);

}

// 定义一个全局map对象，用于存放每种操作对应的请求响应处理器类对象

static map

httpClassCreators;

bool InitializeStaticData()

{

httpClassCreators[MgHttpResourceStrings::opGetMap] =

MgHttpGetMap::CreateObject;

httpClassCreators[MgHttpResourceStrings::opGetMapUpdate] =

MgHttpGetMapUpdate::CreateObject;

httpClassCreators[MgHttpResourceStrings::opGetDrawing] =

MgHttpGetDrawing::CreateObject;

......

httpClassCreators[MgHttpResourceStrings::opDescribeDrawing] = MgHttpDescribeDrawing::CreateObject;

httpClassCreators[MgHttpResourceStrings::opEnumerateResources] = MgHttpEnumerateResources::CreateObject;

......

}

void MgHttpEnumerateResources::Execute(MgHttpResponse& hResponse)

{

Ptr hResult;

hResult = hResponse.GetResult();

// 检查HTTP请求中的参数

ValidateCommonParameters();

// 创建MgProxyResourceService实例

Ptr mgprService =

(MgResourceService*)(CreateService(MgServiceType::ResourceService));

......

// 执行枚举资源操作

Ptr byteReader = mgprService->

EnumerateResources(&mgrIdentifier, m_depth, m_type, m_computeChildren);

// 如果需要，转换响应请求的格式

ProcessFormatConversion(byteReader);

// 将操作结果放入响应请求中的MgHttpResult对象

hResult->SetResultObject(byteReader, byteReader->GetMimeType());

}

MgByteReader* MgProxyResourceService::EnumerateResources(

MgResourceIdentifier* resource, INT32 depth, CREFSTRING type,

INT32 properties, CREFSTRING fromDate, CREFSTRING toDate,

bool computeChildren)

{

MgCommand cmd;

cmd.ExecuteCommand(m_connProp,

MgCommand::knObject,

MgResourceService::opIdEnumerateResources,

7,

Resource_Service,

BUILD_VERSION(1,0,0),

MgCommand::knObject, resource,

MgCommand::knInt32, depth,

MgCommand::knString, &type,

MgCommand::knInt32, properties,

MgCommand::knString, &fromDate,

MgCommand::knString, &toDate,

MgCommand::knInt8, (int)computeChildren,

MgCommand::knNone);

SetWarning(cmd.GetWarningObject());

return (MgByteReader*)cmd.GetReturnValue().val.m_obj;

}