我想故我在的BLOG

class HalfStructuredMessageBuilder

{

public:

    virtual void Build(HalfStructuredMessageSmartPtr psmsg,

                       ServiceLayerMessage& strMsg ) = 0;

};

class XMLMessageBuilder : public HalfStructuredMessageBuilder

{

    DECLARE_STATIC_SINGLETON(XMLMessageBuilder)

public:

    virtual void Build(HalfStructuredMessageSmartPtr psmsg,

                       ServiceLayerMessage& strMsg);

private:

    XMLDOMSerializer   m_serializer;

};

#ifdef _USE_XML_MESSAGE_FORMAT_

typedef XMLMessageBuilder   MessageBuilderFactory;

#endif  // _USE_XML_MESSAGE_FORMAT_

void XMLMessageBuilder::Build(HalfStructuredMessageSmartPtr psmsg,

                              ServiceLayerMessage& strMsg)

{

    if (psmsg == NULL || psmsg->m_msgHeader == NULL)

        return;

    strMsg.erase(strMsg.begin(), strMsg.end());

    // 创建空的DOM树，树根为元素<msg>

    DOMDocumentPair docPair = \

        XMLDOMDocumentCreator::createDOMDocument( \

              XMLRootElement_msg::name());

    if (docPair.first == NULL || docPair.second == NULL)

        return;

    XMLElement *pRootElem = docPair.second;  // 指向根元素<msg>

    // 检查消息类型

    MessageType curMsgType(psmsg->m_msgHeader->GetMessageType());

    if (curMsgType != MESSAGE_TYPE_REQUEST &&

        curMsgType != MESSAGE_TYPE_ACK &&

        curMsgType != MESSAGE_TYPE_NOTIFY &&

        curMsgType != MESSAGE_TYPE_BROADCAST)

            return;

    //  向DOM树根添加子元素<Header>

    XMLElement *pHeaderElement = \

        pRootElem->append_element(XMLSubElement_Header::name());

    if (pHeaderElement == NULL) return;

    //  添加消息头的内容

    XMLLeaf *pLeaf = NULL;

    pLeaf = pHeaderElement->append_leaf(XMLSubElement_type::name(), \

            curMsgType.c_str());

    if (pLeaf == NULL) return;

    pLeaf = pHeaderElement->append_leaf(XMLSubElement_source::name(), \

            Convert(psmsg->m_msgHeader->GetSource()).c_str());

    if (pLeaf == NULL) return;

    pLeaf = pHeaderElement->append_leaf(XMLSubElement_dest::name(), \

            Convert(psmsg->m_msgHeader->GetDestination()).c_str());

    if (pLeaf == NULL) return;

    pLeaf = pHeaderElement->append_leaf(XMLSubElement_sn::name(), \

            Convert(psmsg->m_msgHeader->GetSn()).c_str());

    if (pLeaf == NULL) return;

    pLeaf = pHeaderElement->append_leaf(XMLSubElement_id::name(), \

            psmsg->m_msgHeader->GetMessageID().c_str());

    if (pLeaf == NULL) return;

    // 导入消息体（DOM子树）

    if (!(psmsg->m_msgBody.IsEmpty()))

        {

        XERCES_CPP_NAMESPACE::DOMNode *pNode = \

            pRootElem->import_node(psmsg->m_msgBody.GetDummyRootElement());

        if (pNode == NULL) return;

        }

    // 将整棵DOM树串化

    m_serializer.convert_to_string(pRootElem, strMsg);

}

    HalfStructuredMessageSmartPtr pNotifyMsg(new XMLHalfStructuredMessage());

    MessageHeaderSmartPtr pMsgHeader(new MessageHeader);

    pMsgHeader->SetMessageType(MESSAGE_TYPE_NOTIFY);  // 设置消息类型

    pMsgHeader->SetSource(25);                        // 设置源端ID

    pMsgHeader->SetDestination(63);                   // 设置目的端ID

    pMsgHeader->SetSn(0);                             // 设置消息序列号

    pMsgHeader->SetMessageID("Hello");                // 设置消息ID

    pNotifyMsg->m_msgHeader = pMsgHeader;

    pNotifyMsg->m_msgBody.AppendLeafAsRoot("LikeThis", \

           "How are you! or How do you do!");         // 构造消息体

    ServiceLayerMessage strMsg;

    HalfStructuredMessageBuilder *pMsgBuilder = \

           MessageBuilderFactory::get_instance();

    pMsgBuilder->Build(pNotifyMsg, strMsg);

class BinMessageBuilder : public HalfStructuredMessageBuilder

{

    DECLARE_STATIC_SINGLETON(BinMessageBuilder)

public:

    virtual void Build(HalfStructuredMessageSmartPtr psmsg,

                       ServiceLayerMessage& appMsg);

};

#ifdef _USE_BINARY_MESSAGE_FORMAT_

typedef BinMessageBuilder   MessageBuilderFactory;

#endif  // _USE_BINARY_MESSAGE_FORMAT_

void BinMessageBuilder::Build(HalfStructuredMessageSmartPtr psmsg,

                              ServiceLayerMessage& appMsg)

{

    if (psmsg  == NULL || psmsg->m_msgHeader == NULL)

        return;

    appMsg.clear();

    appMsg.reserve(15 + psmsg->m_msgBody.size());

    // 拼接消息类型字段

    appMsg.push_back((BYTE)psmsg->m_msgHeader->GetMessageType());

    // 拼接消息源ID字段

    u_long source_in_netwk = \

    ::htonl((u_long)psmsg->m_msgHeader->GetSource());

    BYTE *pSource = (BYTE*)&source_in_netwk;

    appMsg.insert(appMsg.end(), pSource, pSource+4);

    // 拼接消息宿ID字段

    u_long dest_in_netwk = \

    ::htonl((u_long)psmsg->m_msgHeader->GetDestination());

    BYTE *pDest = (BYTE*)&dest_in_netwk;

    appMsg.insert(appMsg.end(), pDest, pDest+4);

    // 拼接序列号字段

    u_short sn_in_netwk = \

    ::htons((u_short)psmsg->m_msgHeader->GetSn());

    BYTE *pSn = (BYTE*)&sn_in_netwk;

    appMsg.insert(appMsg.end(), pSn, pSn+2);

    // 拼接消息ID字段

    u_long msgid_in_netwk = \

    ::htonl((u_long)psmsg->m_msgHeader->GetMessageID());

    BYTE *pMsgId = (BYTE*)&msgid_in_netwk;

    appMsg.insert(appMsg.end(), pMsgId, pMsgId+4);

    // 拷贝消息体

    appMsg.insert(appMsg.end(), psmsg->m_msgBody.begin(), \

              psmsg->m_msgBody.end());

}