随笔-341  评论-2670  文章-0  trackbacks-0
    今天将Serialization进行了重构,让其支持容器。于是使用以前的基础设施就能完成这个Demo了。

    为什么要做成这个样子呢?因为模板没有运行时匹配功能。虽然仍然大量使用模板,但是接口上就没有了。模板被用来处理其他的事情。

    这个程序分为服务器端和客户端两个部分,使用Socket连接。服务器端监听到一个客户端之后将一棵树发送过去之后退出。客户端接收到这棵树之后将内容打印到屏幕上。于是我们实现一颗多态的树。树的节点分为数字节点、字符串节点和列表节点三种,共同继承自一个基类。这样的话就可以使用多态来构造成一棵树并进行操作了:
 1 class Node : public VL_SerializableObject
 2 {
 3 public:
 4     typedef VL_AutoPtr<Node> Ptr;
 5 
 6     virtual VUnicodeString ToString(VUnicodeString Prefix)=0;
 7 };
 8 
 9 class NumberNode : public Node
10 {
11 public:
12     VInt Number;
13 
14     NumberNode()
15     {
16         VL_SERIALIZABLE_FIELD(NumberNode,Number);
17     }
18 
19     VUnicodeString ToString(VUnicodeString Prefix)
20     {
21         return Prefix+VUnicodeString(Number);
22     }
23 };
24 
25 class IdNode : public Node
26 {
27 public:
28     VUnicodeString Id;
29 
30     IdNode()
31     {
32         VL_SERIALIZABLE_FIELD(IdNode,Id);
33     }
34 
35     VUnicodeString ToString(VUnicodeString Prefix)
36     {
37         return Prefix+Id;
38     }
39 };
40 
41 class ListNode : public Node
42 {
43 public:
44     VL_List<Ptr , false , Node*> Children;
45 
46     ListNode()
47     {
48         VL_SERIALIZABLE_FIELD(ListNode,Children);
49     }
50 
51     VUnicodeString ToString(VUnicodeString Prefix)
52     {
53         VUnicodeString Result;
54         Result+=Prefix+L"List  {\r\n";
55         for(VInt i=0;i<Children.GetCount();i++)
56         {
57             if(Children[i])
58             {
59                 Result+=Children[i]->ToString(Prefix+L"    ")+L"\r\n";
60             }
61             else
62             {
63                 Result+=Prefix+L"    <NULL>\r\n";
64             }
65         }
66         Result+=Prefix+L"}";
67         return Result;
68     }
69 };

    接下来初始化Serializer:
1 void InitializeSeriailzer(VL_Serializer& Serializer)
2 {
3     VL_SERIALIZABLE_CLASS(&Serializer,NumberNode);
4     VL_SERIALIZABLE_CLASS(&Serializer,IdNode);
5     VL_SERIALIZABLE_CLASS(&Serializer,ListNode);
6 }

    然后实现一个服务器端的逻辑:
 1 Node::Ptr BuildNode()
 2 {
 3     ListNode* Root=new ListNode;
 4     {
 5         NumberNode* Number=new NumberNode;
 6         Number->Number=10;
 7         Root->Children.Add(Number);
 8     }
 9     {
10         ListNode* List=new ListNode;
11         {
12             NumberNode* Number=new NumberNode;
13             Number->Number=20;
14             List->Children.Add(Number);
15         }
16         List->Children.Add(0);
17         {
18             IdNode* Id=new IdNode;
19             Id->Id=L"Serialization";
20             List->Children.Add(Id);
21         }
22         Root->Children.Add(List);
23     }
24     {
25         IdNode* Id=new IdNode;
26         Id->Id=L"VCZH";
27         Root->Children.Add(Id);
28     }
29     return Root;
30 }
31 
32 void ServerMain()
33 {
34     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication [Server]");
35 
36     VL_Serializer Serializer;
37     InitializeSeriailzer(Serializer);
38 
39     VL_SocketServer Server(vspTCP,L"8000",false);
40     if(Server.IsSuccess())
41     {
42         VL_ServerSocket* Socket=Server.WaitForConnection();
43         if(Socket)
44         {
45             GetConsole()->Write(L"监听到客户端。\r\n");
46             Node::Ptr MyNode=BuildNode();
47             WriteCommonObject(Socket->GetWriterStream(),Serializer.Serialize(MyNode.Object()));
48             delete Socket;
49             GetConsole()->Write(L"发送成功,关闭服务端。\r\n");
50         }
51         else
52         {
53             GetConsole()->Write(L"监听端口时发生错误。\r\n");
54         }
55     }
56     else
57     {
58             GetConsole()->Write(L"创建Socket时发生错误。\r\n");
59     }
60 }

    下面是客户端的逻辑:
 1 void ClientMain()
 2 {
 3     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication [Client]");
 4 
 5     VL_Serializer Serializer;
 6     InitializeSeriailzer(Serializer);
 7 
 8     VL_ClientSocket Socket(vspTCP,L"127.0.0.1",L"8000");
 9     if(Socket.Connect())
10     {
11         GetConsole()->Write(L"连接到服务端。\r\n");
12         Node::Ptr MyNode=Serializer.Deserialize(ReadCommonObject(Socket.GetReaderStream()));
13         GetConsole()->Write(MyNode->ToString(L""));
14     }
15     else
16     {
17         GetConsole()->Write(L"连接服务端时发生错误。\r\n");
18     }
19 }

    最后用Main函数来构造一个Event。程序将被启动两次,先启动的成为服务器,后启动的成为客户端,方便将两部分的代码都放在同一个文件里面:
 1 void vlmain()
 2 {
 3     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication");
 4     GetConsole()->SetTestMemoryLeaks(true);
 5     GetConsole()->SetPauseOnExit(true);
 6 
 7     VL_SynEvent Event;
 8     switch(Event.Create(false,false,L"VCZH"))
 9     {
10     case VL_SynObject::arSucceed:
11         ServerMain();
12         break;
13     case VL_SynObject::arAlreadyExists:
14         ClientMain();
15         break;
16     case VL_SynObject::arFail:
17         GetConsole()->Write(L"构造Event时发生错误。\r\n");
18         break;
19     }
20 }

    让我们看看运行结果:


    下面是完整的代码:
  1 #include "..\..\..\Library\Platform\VL_Console.h"
  2 #include "..\..\..\Library\Data\VL_CommonData.h"
  3 #include "..\..\..\Library\Data\VL_Serialization.h"
  4 #include "..\..\..\Library\Data\VL_Communication.h"
  5 #include "..\..\..\Library\Data\VL_Stream.h"
  6 #include "..\..\..\Library\Data\VL_System.h"
  7 
  8 using namespace vl;
  9 using namespace vl::platform;
 10 using namespace vl::stream;
 11 using namespace vl::system;
 12 using namespace vl::system::synchronization;
 13 using namespace vl::serialization;
 14 using namespace vl::commondata;
 15 using namespace vl::communication;
 16 
 17 class Node : public VL_SerializableObject
 18 {
 19 public:
 20     typedef VL_AutoPtr<Node> Ptr;
 21 
 22     virtual VUnicodeString ToString(VUnicodeString Prefix)=0;
 23 };
 24 
 25 class NumberNode : public Node
 26 {
 27 public:
 28     VInt Number;
 29 
 30     NumberNode()
 31     {
 32         VL_SERIALIZABLE_FIELD(NumberNode,Number);
 33     }
 34 
 35     VUnicodeString ToString(VUnicodeString Prefix)
 36     {
 37         return Prefix+VUnicodeString(Number);
 38     }
 39 };
 40 
 41 class IdNode : public Node
 42 {
 43 public:
 44     VUnicodeString Id;
 45 
 46     IdNode()
 47     {
 48         VL_SERIALIZABLE_FIELD(IdNode,Id);
 49     }
 50 
 51     VUnicodeString ToString(VUnicodeString Prefix)
 52     {
 53         return Prefix+Id;
 54     }
 55 };
 56 
 57 class ListNode : public Node
 58 {
 59 public:
 60     VL_List<Ptr , false , Node*> Children;
 61 
 62     ListNode()
 63     {
 64         VL_SERIALIZABLE_FIELD(ListNode,Children);
 65     }
 66 
 67     VUnicodeString ToString(VUnicodeString Prefix)
 68     {
 69         VUnicodeString Result;
 70         Result+=Prefix+L"List  {\r\n";
 71         for(VInt i=0;i<Children.GetCount();i++)
 72         {
 73             if(Children[i])
 74             {
 75                 Result+=Children[i]->ToString(Prefix+L"    ")+L"\r\n";
 76             }
 77             else
 78             {
 79                 Result+=Prefix+L"    <NULL>\r\n";
 80             }
 81         }
 82         Result+=Prefix+L"}";
 83         return Result;
 84     }
 85 };
 86 
 87 void InitializeSeriailzer(VL_Serializer& Serializer)
 88 {
 89     VL_SERIALIZABLE_CLASS(&Serializer,NumberNode);
 90     VL_SERIALIZABLE_CLASS(&Serializer,IdNode);
 91     VL_SERIALIZABLE_CLASS(&Serializer,ListNode);
 92 }
 93 
 94 Node::Ptr BuildNode()
 95 {
 96     ListNode* Root=new ListNode;
 97     {
 98         NumberNode* Number=new NumberNode;
 99         Number->Number=10;
100         Root->Children.Add(Number);
101     }
102     {
103         ListNode* List=new ListNode;
104         {
105             NumberNode* Number=new NumberNode;
106             Number->Number=20;
107             List->Children.Add(Number);
108         }
109         List->Children.Add(0);
110         {
111             IdNode* Id=new IdNode;
112             Id->Id=L"Serialization";
113             List->Children.Add(Id);
114         }
115         Root->Children.Add(List);
116     }
117     {
118         IdNode* Id=new IdNode;
119         Id->Id=L"VCZH";
120         Root->Children.Add(Id);
121     }
122     return Root;
123 }
124 
125 void ServerMain()
126 {
127     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication [Server]");
128 
129     VL_Serializer Serializer;
130     InitializeSeriailzer(Serializer);
131 
132     VL_SocketServer Server(vspTCP,L"8000",false);
133     if(Server.IsSuccess())
134     {
135         VL_ServerSocket* Socket=Server.WaitForConnection();
136         if(Socket)
137         {
138             GetConsole()->Write(L"监听到客户端。\r\n");
139             Node::Ptr MyNode=BuildNode();
140             WriteCommonObject(Socket->GetWriterStream(),Serializer.Serialize(MyNode.Object()));
141             delete Socket;
142             GetConsole()->Write(L"发送成功,关闭服务端。\r\n");
143         }
144         else
145         {
146             GetConsole()->Write(L"监听端口时发生错误。\r\n");
147         }
148     }
149     else
150     {
151             GetConsole()->Write(L"创建Socket时发生错误。\r\n");
152     }
153 }
154 
155 void ClientMain()
156 {
157     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication [Client]");
158 
159     VL_Serializer Serializer;
160     InitializeSeriailzer(Serializer);
161 
162     VL_ClientSocket Socket(vspTCP,L"127.0.0.1",L"8000");
163     if(Socket.Connect())
164     {
165         GetConsole()->Write(L"连接到服务端。\r\n");
166         Node::Ptr MyNode=Serializer.Deserialize(ReadCommonObject(Socket.GetReaderStream()));
167         GetConsole()->Write(MyNode->ToString(L""));
168     }
169     else
170     {
171         GetConsole()->Write(L"连接服务端时发生错误。\r\n");
172     }
173 }
174 
175 void vlmain()
176 {
177     GetConsole()->SetTitle(L"Vczh Library++ 2.0 Communication");
178     GetConsole()->SetTestMemoryLeaks(true);
179     GetConsole()->SetPauseOnExit(true);
180 
181     VL_SynEvent Event;
182     switch(Event.Create(false,false,L"VCZH"))
183     {
184     case VL_SynObject::arSucceed:
185         ServerMain();
186         break;
187     case VL_SynObject::arAlreadyExists:
188         ClientMain();
189         break;
190     case VL_SynObject::arFail:
191         GetConsole()->Write(L"构造Event时发生错误。\r\n");
192         break;
193     }
194 }
posted on 2008-11-22 02:26 陈梓瀚(vczh) 阅读(2045) 评论(6)  编辑 收藏 引用 所属分类: C++

评论:
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-11-22 03:57 | 肥仔
都依赖于自己造的轮子,对别没有价值,除非别人愿意用你的轮子。否则也就落到自娱自乐了。  回复  更多评论
  
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-11-22 04:00 | 陈梓瀚(vczh)
其实,支持了std::string你就不能支持wxString。你难道可以做一个库同时支持所有流行的库的string?

道理是一样的,我只选择一个来支持。不过事实上想扩展并且支持其他容器或类型也很容易的,只需要再特化一点模板就行了,对库来说不用侵入式修改。  回复  更多评论
  
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-11-22 18:00 | 蚂蚁终结者
8 using namespace vl;
9 using namespace vl::platform;
10 using namespace vl::stream;
11 using namespace vl::system;
12 using namespace vl::system::synchronization;
13 using namespace vl::serialization;
14 using namespace vl::commondata;
15 using namespace vl::communication;
居然都是自己封装的。。。难道是想模拟C#  回复  更多评论
  
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-11-22 23:22 | 陈梓瀚(vczh)
本不想模拟的,但是做到最后又很像,只能说明c#的库很合理吧……

但其实是很不像的,除了WinForm那部分……  回复  更多评论
  
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-11-26 06:28 | E剑仙
很快Native C++下就有VCZH.NET库可以使用了……  回复  更多评论
  
# re: Vczh Serialization Demo :在网络上传递复杂对象 2008-12-15 18:07 | 123
好厉害的孩子!!!!!!!!!!  回复  更多评论
  

只有注册用户登录后才能发表评论。
【推荐】超50万行VC++源码: 大型组态工控、电力仿真CAD与GIS源码库
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理