C++博客-woomsg

gloox代码分析4 - private xml storage

ysong.lee — Thu, 06 Nov 2008 09:18:00 GMT

摘要: 这部分的作用是客户端可以存放任意格式的私有xml数据到服务器上,并且在想要查看的时候取回!1.协议 - XEP-0049 - http://xmpp.org/extensions/xep-0049.html2. jabber client可以保存任意的xml数据到服务器，通过一个的请求.该请求需要包含一个名称空间为jabber:iq:priva... 阅读全文

ysong.lee 2008-11-06 17:18 发表评论

gloox代码分析3 - 注册模块

ysong.lee — Thu, 06 Nov 2008 04:59:00 GMT

摘要: #jabber协议中如何注册一个用户？首先要与服务器建立一个连接, 在完成TLS握手之后就可以进行注册了,为什么不需要SASL握手呢?因为SASL握手只针对已经注册的用户在登陆服务器的时候使用.(修改密码和删除用户的时候需要SASL握手)下面以openfire作为服务器，注册一个用户的过程如下:(假设已经完成了TLS握手)1. ( C->S ) 阅读全文

ysong.lee 2008-11-06 12:59 发表评论

openssl使用

ysong.lee — Mon, 03 Nov 2008 06:08:00 GMT

摘要: 1. websiteSSL(secure Socket Layer)TLS(transport Layer Security) - SSL3.0基础之上提出的安全通信标准,目前版本是1.0openssl 主页 -> http://www.openssl.org/openssl 中文文档 -> http://www.chinaunix.net/jh/13/478901.html 2. 如何编译O... 阅读全文

ysong.lee 2008-11-03 14:08 发表评论

如何利用jabber协议与gtalk服务器通讯 - 建立会话

ysong.lee — Tue, 28 Oct 2008 16:29:00 GMT

客户端与gtalk server建立会话的过程如下(默认中间没有错误发生):

1. ( C->S ) 连接到服务器, 发送'hello'信息.
http://etherx.jabber.org/streams" xmlns="jabber:client">

2. ( S->C ) 服务器回应'hello'信息

http://etherx.jabber.org/streams" xmlns="jabber:client">

3. ( S->C ) 服务器要求TLS, SASL

    X-GOOGLE-TOKEN

4. ( C->S ) 开始TLS

5. ( S->C ) 服务器允许继续TLS

6. ( C->S ) TLS握手
客户端向服务器发起TLS握手请求, 如果握手成功, 执行#7 (可以使用openssl实现TLS的握手功能)

7. ( C->S ) TLS握手结束后, 发送新的'hello'消息
http://etherx.jabber.org/streams" xmlns="jabber:client">

8. ( S->C ) 服务器回应'hello'消息

http://etherx.jabber.org/streams" xmlns="jabber:client">

9. ( S->C ) 服务器要求SASL

    PLAIN
    X-GOOGLE-TOKEN

10. ( C->S ) 客户端执行SASL

AHlzb25nLmxlZUBnbWFpbC5jb20AeXNvbmdAMTk4NA==

auth的cdata的格式 '\0'+username+'\0'+password 的base64编码, username和password必须是经过认证的.
例如:
'\0' + 'ysong.lee@gmail.com' + '\0' + 123456 -> 经过base64编码处理后变为cdata

11. ( S->C ) SASL成功

12. ( C->S ) 客户端发送新的'hello'消息
http://etherx.jabber.org/streams" xmlns="jabber:client">

13. ( S->C ) 服务器回应'hello'消息

http://etherx.jabber.org/streams" xmlns="jabber:client">

14. ( S->C ) 服务器要求绑定资源和建立一个会话

15. ( C->S ) 客户端绑定申请一个资源

16. ( S->C ) 服务器返回绑定资源的结果

    ysong.lee@gmail.com/BC20B630

17. ( C->S ) 客户端申请建立会话

18. ( S->C ) 服务器返回建立会话成功

到此, Client和Gtalk server的一个会话已经建立, 可以根据jabber协议进行其它操作. 请求联系人列表, 发消息等.

ysong.lee 2008-10-29 00:29 发表评论

openssl使用(补)

ysong.lee — Wed, 22 Oct 2008 02:48:00 GMT

摘要: 1. 使用OpenSSL内置的数据结构BIO可以方便的创建安全和非安全链接,在IBM Web上的"使用OpenSSL进行安全编程"系列的三篇文章是个不错的入门:http://www.ibm.com/developerworks/cn/linux/l-openssl.htmlhttp://www.ibm.com/developerworks/cn/linux/l-openssl2.htmlhttp:... 阅读全文

ysong.lee 2008-10-22 10:48 发表评论

gloox代码分析2 - xml parser模块

ysong.lee — Sat, 18 Oct 2008 06:51:00 GMT

gloox自己实现了xml的解析模块，没有用到第三方的库(tinyXML，expat )
主要涉及的文件:
tag.h (tag.cpp)
taghandler.h
parser.h (parser.cpp)

1. Tag一个Tag就是一个XML元素
例如:
a.

    qiang

b.
c. name1

首先介绍一个概念: escape-string，何为escape-string?
在escape-string中:
'&'转换成&, '<'转换成<, '>'转换成>.
编码表如下:
//////////////////////////////////////////////////////////////////////////
// 编码表（中间的空格去掉，这里只是为了方便显示）:
// -------------------------------------------------------
// | 字符     | 十进制 | 十六进制 | THML字符集 | Unicode |
// -------------------------------------------------------
// | " 双引号 | & # 34; | & # x22;   | "          | \u0022 |
// -------------------------------------------------------
// | ' 单引号 | & # 39; | & # x27;   | & apos;     | \u0027 |
// -------------------------------------------------------
// | & 与     | & # 38; | & # x26;   | & amp;      | \u0026 |
// -------------------------------------------------------
// | < 小于号 | & # 60; | & # x3C;   | & lt;       | \u003c |
// -------------------------------------------------------
// | > 大于好 | & # 62; | & # x3E;   | & gt;       | \u003e |
// -------------------------------------------------------
gloox - APIs
Tag::escape()    功能: string -> escape-string
Tag::relax() 功能: escape-string -> string

主要成员变量:
attributes - 所有属性的list
name - 节点名字
cdata - 节点数据，例如cdata中的cdata
children - 所有的子节点
parent - 父节点指针，如果没有则为空
bool incoming - 表示构造xml node的时候传入的字符串是否是escape-string，如果是，需要在构造的时候调用relex把escape-string转换成string.

主要方法:
也就是一些针对name\children\attributes\cdata进行增加\删除\修改的方法
xml()方法返回该节点的一个完整的xml数据流
findTag和findTagList提供对XPath的支持.

例如:
屏幕将输出:
qiang

1#include <iostream>
2#include "tag.h"
3
4#pragma comment( lib, "gloox.lib" )
5using namespace gloox;
6
7//
8//
9//
10//     qiang
11//
12//
13//
14
15
16int main( int argc, char* argv[] ) {
17  Tag* tag_book = new Tag( "book");
18  tag_book->addAttribute( "kind", "computer" );
19
20  Tag* tag_store = new Tag( "store" );
21  tag_store->addAttribute( "id", "32" );
22
23  Tag* tag_author = new Tag( "author", "qiang" );
24
25  tag_book->addChild( tag_store );
26  tag_book->addChild( tag_author );
27
28  std::cout<<tag_book->xml()<<std::endl;
29  return 0;
30}

2. TagHandler是一个接收parser解析完成的tag的接口，继承该类，则可以接收parser解析的tag对象事件.
只有一个接口
virtual void handleTag( Tag *tag ) = 0 - 接收解析完的tag

3. Parser一个XML解析器
提供的接口非常简洁，只需要一个TagHandler来构造，该handler接收并处理解析的tag，另外只有一个feed接口来填充数据.
要注意的是feed接口填充的数据必须是一个格式正确的xml，否则无法解析，也就是说parser不会判断xml的格式。

例如:
下面的例子中对feed来说分开填充和一次性填充数据的效果是一样的，也就是scenario1和scenario2的效果是一样的，这也刚好和上层应用中TCP 流处理的方式统一，对于接收到服务器端的XML流，无论是否完整，只需要直接feed就可以了。handlerTag方法将收到两个
xml tag解析完成的事件，分别来自scenario1和scenario2，屏幕将输出:
qiang
qiang

1#include <iostream>
2#include "tag.h"
3#include "parser.h"
4
5#pragma comment( lib, "gloox.lib" )
6using namespace gloox;
7
8//
9//
10//
11//     qiang
12//
13//
14//
15//
16
17class TagHandlerImpl : public TagHandler {
18public:
19    ~TagHandlerImpl() {}
20
21    void run() {
22      Parser* parser = new Parser(this);
23      // scenario1
24      std::string data = "qiang";
25      parser->feed( data );
26
27      // scenario2
28      std::string data1 = "";
29      std::string data2 = "'>";
30      std::string data3 = "or>qiang";
31      parser->feed( data1 );
32      parser->feed( data2 );
33      parser->feed( data3 );
34    }
35
36    void handleTag( Tag *tag ) {
37      std::cout<<tag->xml()<<std::endl;
38    }
39};
40
41int main( int argc, char* argv[] ) {
42  TagHandlerImpl* taghandlerImpl = new TagHandlerImpl();
43  taghandlerImpl->run();
44
45  return 0;
46}

ysong.lee 2008-10-18 14:51 发表评论

gloox代码分析1 - connect模块

ysong.lee — Fri, 17 Oct 2008 13:20:00 GMT

主要分析gloox的connect模块，涉及的文件:
connectionbase.h
connectiondatahander.h
connectionhandler.h
connectiontcpbase.h (connectiontcpbase.cpp)
connectiontcpclient.h (connectiontcpclient.cpp)
connectiontcpserver.h (connectiontcpserver.cpp)

1. ConnectionBase抽象连接类，表示一个socket连接。
3个数据成员:
server和ip - 需要连接到的目标地址和端口(在ConnectionTcpServer是要绑定的本地地址)
connectionState - 连接的当前状态 (一个三种状态disconnected | connecting | connected)
connectionDataHandler - 处理三类ConnectionBase中的三类事件 ( 数据接收 | 连接建立 | 连接断开 )
5个主要方法:
connect - 建立一个socket连接
disconnect - 断开一个socket连接
send - 发送数据，该方法直到要发送的数据全部发送完毕才返回
recv( int timeout ) - 接收数据，接收到数据或者timeout返回
receive - 把connection设置成"接收模式"，也就是循环的调用recv接收数据，直到连接断开该方法返回，
               该方法保证这个连接可以循环的接收数据.

注意: recv和receive的区别。

2. ConnectionDataHandler处理继承自ConnectionBase的对象的事件
handlerReceivedData - 接收到数据
handlerConnect - 一个原始的套接字连接建立
handlerDisconnect - 一个原始的套接字连接断开

3. ConnectionTcpBase一个基本的TCP连接，继承自ConnectionBase
数据成员
bool cancel - 表示连接是否应该断开，默认为true. (true表示连接断开)
                     函数disconnect也就是仅仅设置cancel为true.
                     在函数receive循环接收数据的逻辑中会检测cancel，如果为true，则表示连接断开，则返回，退出"接收模式"
int bufSize - buf的大小，默认是1024
char* buf - 缓冲区，大小事bufSize + 1 (在ConnectionTcpBase中并没有用到这个缓冲区，供上层使用E.g. ConnectionTcpClient的recv来接收数据)

实现的主要方法:
send - 发送数据
receive - "循环"接收数据
dataAvailable( int timeout ) - 一个私有方法，作用是测试socket上目前是否有数据可读，如果有返回true. 可以供recv调用. 避免了阻塞的调用原始套接字方法::receive或者::accept.

4. ConnectionTcpClient实现一个基本的TCP连接，继承自ConnectionTcpBase
实现的主要方法
connect - 连接到目标地址，如果成功，则调用handler->handlerConnect，失败则调用handler->handlerDisconnect
recv - 接收数据，如果接收到数据，马上调用handler->handlerReceiveData，接收发生错误，表示连接断开，调用handler->handlerDisconnect

5. ConnectionHandler一个抽象类，用来接收一个客户端连接的请求，该类用于ConnectionTcpServer
只有一个接口:
handleIncomingConnection( ConnectionBase *connect ) - &connect表示新建立的连接请求，哪原始的socket做类比相当于accept返回的socket.

注意: 区别于ConnectionDataHandler用于处理一个特定连接的中的事件(数据到来，连接断开，连接建立)，ConnectionListener用于XMPP Stream.

6. ConnectionTcpServer，实质上就是一个侦听socket，同原始的socket做类比就是一个调用了bind/listen之后处于侦听状态的socket.
主要数据成员:
connectionHandler - 接收新到来的连接，接收到之后调用handlerIncomingConnection
主要方法:
connect - 建立套接字，绑定到本地地址，侦听bind/listen
recv - 调用accept接收一个socket连接，如果成功，则用accpet返回的socket创建一个ConnectionTCPClient，调用handlerIncomingConnection来处理新进的连接.

总结:
ConnectionTcpServer和ConnectionTcpClient的区别:
connect (client) - 连接到服务器，使connection处于可以接收数据的状态
connect(server) - 绑定到本地地址，侦听，使connection处于可以接收新连接的状态(accept)

recv(client) - 接收数据，调用connectionDataHandler->handlerReceivedData
recv(server) - 接收新连接，调用connectionHandler->handlerIncomingConnection

receive(Client) - 接收数据状态，循环接收数据，调用disconnect时退出
receive(Server) - 接收连接状态，循环接收连接，调用disconnect时退出.

所以ConnectionTcpClient有发送数据和循环接收数据的能力，ConnectionTcpServer有侦听客户端连接的能力。当有特定的事件发生的时候，会自动触发相关的handler来进行处理，如数据到来，连接建立\断开，新连接到来等等。

问题:
这种设计模式使receive处于一个无限的while循环，不断的调用select+accpet或者select+receive，是否利于send之类的方法在同一个socket上发送数据?

ysong.lee 2008-10-17 21:20 发表评论

如何在windows编译gloox

ysong.lee — Thu, 16 Oct 2008 12:42:00 GMT

1. Enviroment
"gloox - 0.9.9.5" + "Windows Server 2008" + "VC++ 2008"

2. config.h.win
HAVE_WINTLS
HAVE_WINDNS_H
HAVE_SETSOCKOPT

默认编译的时候出错:
dns.obj : error LNK2019: unresolved external symbol _DnsFree@8 referenced in function "public: static class std::map,class std::allocator >,int,struct std::less,class std::allocator > >,class std::allocator,class std::allocator > const ,int> > > __cdecl gloox::DNS::resolve(class std::basic_string,class std::allocator > const &,class std::basic_string,class std::allocator > const &,class std::basic_string,class std::allocator > const &,class gloox::LogSink const &)" (?resolve@DNS@gloox@@SA?AV?$map@V?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@HU?$less@V?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@@2@V?$allocator@U?$pair@$$CBV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@H@std@@@2@@std@@ABV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@4@00ABVLogSink@2@@Z)
dns.obj : error LNK2019: unresolved external symbol _DnsQuery_A@24 referenced in function "public: static class std::map,class std::allocator >,int,struct std::less,class std::allocator > >,class std::allocator,class std::allocator > const ,int> > > __cdecl gloox::DNS::resolve(class std::basic_string,class std::allocator > const &,class std::basic_string,class std::allocator > const &,class std::basic_string,class std::allocator > const &,class gloox::LogSink const &)" (?resolve@DNS@gloox@@SA?AV?$map@V?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@HU?$less@V?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@@2@V?$allocator@U?$pair@$$CBV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@H@std@@@2@@std@@ABV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@4@00ABVLogSink@2@@Z)
tlsschannel.obj : error LNK2019: unresolved external symbol _EncryptMessage@16 referenced in function "public: virtual bool __thiscall gloox::SChannel::encrypt(class std::basic_string,class std::allocator > const &)" (?encrypt@SChannel@gloox@@UAE_NABV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@@Z)
tlsschannel.obj : error LNK2019: unresolved external symbol _DecryptMessage@16 referenced in function "public: virtual int __thiscall gloox::SChannel::decrypt(class std::basic_string,class std::allocator > const &)" (?decrypt@SChannel@gloox@@UAEHABV?$basic_string@DU?$char_traits@D@std@@V?$allocator@D@2@@std@@@Z)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__FreeCredentialsHandle@4 referenced in function "public: virtual void __thiscall gloox::SChannel::cleanup(void)" (?cleanup@SChannel@gloox@@UAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__DeleteSecurityContext@4 referenced in function "public: virtual void __thiscall gloox::SChannel::cleanup(void)" (?cleanup@SChannel@gloox@@UAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol _FreeContextBuffer@4 referenced in function "public: virtual bool __thiscall gloox::SChannel::handshake(void)" (?handshake@SChannel@gloox@@UAE_NXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol _InitializeSecurityContextA@48 referenced in function "public: virtual bool __thiscall gloox::SChannel::handshake(void)" (?handshake@SChannel@gloox@@UAE_NXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol _AcquireCredentialsHandleA@36 referenced in function "public: virtual bool __thiscall gloox::SChannel::handshake(void)" (?handshake@SChannel@gloox@@UAE_NXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol _QueryContextAttributesA@12 referenced in function "private: void __thiscall gloox::SChannel::setSizes(void)" (?setSizes@SChannel@gloox@@AAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__CertFreeCertificateChain@4 referenced in function "private: void __thiscall gloox::SChannel::validateCert(void)" (?validateCert@SChannel@gloox@@AAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__CertVerifyCertificateChainPolicy@16 referenced in function "private: void __thiscall gloox::SChannel::validateCert(void)" (?validateCert@SChannel@gloox@@AAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__CertGetCertificateChain@32 referenced in function "private: void __thiscall gloox::SChannel::validateCert(void)" (?validateCert@SChannel@gloox@@AAEXXZ)
tlsschannel.obj : error LNK2019: unresolved external symbol __imp__CertNameToStrA@20 referenced in function "private: void __thiscall gloox::SChannel::certData(void)" (?certData@SChannel@gloox@@AAEXXZ)

3. 加入需要的lib, 编译成功
ws2_32.lib Dnsapi.lib Secur32.lib Crypt32.lib

ysong.lee 2008-10-16 20:42 发表评论