QX项目实战-10.基础架构实验一：传递消息、序列化对象和数据库封装

为了验证ActiveMQ传递序列化对象与同步的可行性，搭建一个小的测试系统来测试。这个系统的结构为：

其中DB为数据库，服务器端和客户端数据定义和数据是一致的。服务器端CURD为数据库操作类，它将操作对象信息序列化后发送给MQAPP，MQAPP负责和ActiveMQ交互传递序列化后的信息。客户端MQAPP接收到序列化后对象反序列化后，重新交给CURD程序写到数据库中。以上步骤来保证数据库同步。

这个实验的步骤大体如下：

1. 对象序列化、重建对象

2. 传递序列化消息、重建对象

3. 建立数据库、数据库操作类、封装操作对象

4. 传递操作信息、重建对象、数据库操作

5. 消息平台实现与完善

实验一的实现方法，序列化对象需要实现Serializable接口，由ObjectOutputStream输出对象到文件或网络，再由ObjectInputStream接受流重新生成对象。序列化代码如下：

ConsumerTool ct = new ConsumerTool();                   ct.consumeMessage();                   ct.close();

参考

1. QX项目实战-7.ActiveMQ的安装与测试

2. QX项目实战-8.ActiveMQ的Queue消息和Topic消息

3. QX项目实战-9.ActiveMQ编程实例