這部分的作用是客戶端可以存放任意格式的私有xml數據到服務器上,并且在想要查看的時候取回!
1.協議 - XEP-0049 - http://xmpp.org/extensions/xep-0049.html
2. jabber client可以保存任意的xml數據到服務器,通過一個<iq type="set">的請求.該請求需要包含一個名稱空間
為jabber:iq:private的<query/>子元素. <query/>的子元素就是我們需要保存的私有的xml的根節點,必須有一個私有的名稱空間.
3. 通過一個<iq type="get">的請求來獲取保存在服務器上的私有數據.該請求需要包含一個名稱空間為jabber:iq:private
的<query/>子元素.<query>的子節點是包含一個命名空間的根節點.
4. 客戶端保存私有信息到服務器.
存儲下列xml到服務器:
<exodus xmlns="exodus:prefs">
<defaultnick>Hamlet</defaultnick>
</exodus>
(C->S)
<iq type="set" id="xxx1">
<query xmlns="jabber:iq:private">
<exodus xmlns="exodus:prefs">
<defaultnick>Hamlet</defaultnick>
</exodus>
</query>
</iq>
(S->C)
<iq type="result"
from="hamlet@shakespeare.lit/denmark"
to="hamlet@shakespeare.lit/denmark"
id="xxx1"/>
5. 客戶端獲得私有信息從服務器
(C->S)
<iq type="get" id="xxx2">
<query xmlns="jabber:iq:private">
<exodus xmlns="exodus:prefs"/>
</query>
</iq>
(S->C)
<iq type="result"
from="hamlet@shakespeare.lit/denmark"
to="hamlet@shakespeare.lit/denmark"
id="xxx2"/>
<query xmlns="jabber:iq:private">
<exodus xmlns="exodus:prefs">
<defaultnick>Hamlet</defaultnick>
</exodus>
</query>
</iq>
6. 服務器段的存儲方式: 如果采用DB的話,實質上exodus + exodus:prefs為key,也就是私有的根節點名字和
私有的根節點的命名空間一起作為key.
下面看一段事例代碼(服務器為openfire):
1
#include <iostream>
2
#include "client.h"
3
#include "connectionlistener.h"
4
#include "discohandler.h"
5
#include "disco.h"
6
#include "privatexml.h"
7
8
#pragma comment( lib, "gloox.lib" )
9
using namespace gloox;
10
11
#define SERVERNAME "ziz-wrks-tfsxp1"
12
#define HEADERTO "ziz-wrks-tfsxp1"
13
14
#define USERNAME "user123"
15
#define PASSWORD "user@123"
16
17
// APIs of PrivateXML
18
// requestXML - get the data stored in serve side
19
// storeXML - send the store data request to the server
20
21
// scenario1 - store data
22
// scenario2 - get data
23
//
24
// how to run the testcases?
25
// Note: run scenario1 first, then comment scenario1, run scenario2
26
class PrivateXMLImpl : public PrivateXMLHandler, ConnectionListener
{
27
public:
28
void run();
29
30
//implement PrivateXMLHandler
31
void handlePrivateXML( const std::string& tag, Tag *xml );
32
void handlePrivateXMLResult( const std::string& uid, PrivateXMLResult pxResult );
33
34
//implement ConnectionListener
35
void onConnect();
36
void onDisconnect( ConnectionError e );
37
void onResourceBindError( ResourceBindError error );
38
void onSessionCreateError( SessionCreateError error );
39
bool onTLSConnect( const CertInfo& info );
40
void onStreamEvent( StreamEvent event );
41
42
private:
43
Client* client_;
44
PrivateXML* privateXmlHandler_;
45
};
46
47
void PrivateXMLImpl::run()
{
48
client_ = new Client(SERVERNAME);
49
client_->setHeaderTo(HEADERTO);
50
client_->registerConnectionListener(this);
51
client_->setUsername(USERNAME);
52
client_->setPassword(PASSWORD);
53
54
privateXmlHandler_ = new PrivateXML( client_ );
55
56
client_->connect();
57
58
delete privateXmlHandler_;
59
delete client_;
60
}
61
62
// this function can receive the data of PrivateXML::requestXML().
63
void PrivateXMLImpl::handlePrivateXML( const std::string& tag, Tag *xml )
{
64
std::cout<<"impl# get the data."<<std::endl;
65
std::cout<<"impl# name: "<<tag<<std::endl;
66
std::cout<<"impl# xml: "<<xml->xml()<<std::endl;
67
}
68
69
// the function can be called of PrivateXML::storeXML().
70
void PrivateXMLImpl::handlePrivateXMLResult( const std::string& uid, PrivateXMLResult pxResult )
{
71
if( pxResult == PxmlStoreOk )
{
72
std::cout<<"impl# operation success."<<std::endl;
73
} else
{
74
std::cout<<"impl# operation failed."<<std::endl;
75
}
76
}
77
78
void PrivateXMLImpl::onConnect()
{
79
std::cout<<"impl# connect to server success."<<std::endl;
80
81
// scenario1 - store the privateXml to server
82
Tag* privatexml = new Tag( "privatedata" );
83
privatexml->addAttribute( "xmlns","privatedata-namespace" );
84
Tag* child = new Tag( "child-test", "cdata-test" );
85
privatexml->addChild( child );
86
privateXmlHandler_->storeXML( privatexml, this );
87
88
89
// scenario2 - get the privateXml from the server side
90
// privateXmlHandler_->requestXML( "privatedata", "privatedata-namespace", this );
91
92
}
93
94
void PrivateXMLImpl::onDisconnect( ConnectionError e )
{
95
std::cout<<"impl# disconnected."<<std::endl;
96
}
97
98
void PrivateXMLImpl::onResourceBindError( ResourceBindError error )
{
99
//TODO:
100
}
101
102
void PrivateXMLImpl::onSessionCreateError( SessionCreateError error )
{
103
//TODO:
104
}
105
106
bool PrivateXMLImpl::onTLSConnect( const CertInfo& info )
{
107
std::cout<<"impl# tls connect to server success."<<std::endl;
108
return true;
109
}
110
111
void PrivateXMLImpl::onStreamEvent( StreamEvent event )
{
112
//TODO:
113
}
114
115
int main( int argc, char* argv[] )
{
116
PrivateXMLImpl impl;
117
impl.run();
118
return 0;
119
}