利用 Amazon Web Services 集成企业应用程序--使用 Amazon SQS 发送 XML 消息(2)
Product prod = new Product("Widget", 1.5M);
string accessKeyId = ConfigurationSettings.AppSettings["AmazonAccessKeyID"];
string secretAccessKey = ConfigurationSettings.AppSettings["AmazonSecretAccessKey"];
AmazonSQS service = new AmazonSQSClient(accessKeyId, secretAccessKey);
SendMessageRequest request = new SendMessageRequest();
request.MessageBody = prod.ToXml();
request.QueueName = "TestQueue";
SendMessageResponse response = service.SendMessage(request);
if (response.IsSetSendMessageResult())
{
Console.WriteLine("Send Message Response: ");
SendMessageResult sendMessageResult = response.SendMessageResult;
if (sendMessageResult.IsSetMessageId())
{
Console.WriteLine(String.Format("MessageId {0}",
sendMessageResult.MessageId));
}
if (sendMessageResult.IsSetMD5OfMessageBody())
{
Console.WriteLine(String.Format("MD5OfMessageBody: {0}",
sendMessageResult.MD5OfMessageBody));
}
}
|
图 1 显示了 清单 5 的输出结果。
图 1. 发送 XML 消息的输出
最后一步是从队列接收 XML 消息，并反系列化实例。清单 6 显示了将 XML 消息反系列化到 Product 实例的代码。
清单 6. 反序列化 XML 消息
Product prod = null;
string accessKeyId = ConfigurationSettings.AppSettings["AmazonAccessKeyID"];
string secretAccessKey = ConfigurationSettings.AppSettings["AmazonSecretAccessKey"];
AmazonSQS service = new AmazonSQSClient(accessKeyId, secretAccessKey);
ReceiveMessageRequest request = new ReceiveMessageRequest();
request.QueueName = "TestQueue";
ReceiveMessageResponse response = service.ReceiveMessage(request);
if (response.IsSetReceiveMessageResult())
{
Console.WriteLine("Receive Message Result:");
ReceiveMessageResult receiveMessageResult = response.ReceiveMessageResult;
List<Message> messageList = receiveMessageResult.Message;
foreach (Message message in messageList)
{
if (message.IsSetMessageId())
{
Console.WriteLine(String.Format("MessageId: {0}",
message.MessageId));
}
if (message.IsSetBody())
{
Console.WriteLine(string.Format("Body: {0}", message.Body));
String xml = message.Body;
StringReader sr = new StringReader(xml);
XmlSerializer serializer = new XmlSerializer(typeof(Product));
prod = (Product) serializer.Deserialize(sr);
Console.WriteLine(string.Format("Id: {0}", prod.Id));
Console.WriteLine(string.Format("Name: {0}", prod.ProductName));
Console.WriteLine(string.Format("Price: {0}", prod.ProductPrice));
}
}
}
|
图 2 显示了 清单 6 的输出结果。
图 2. 接收 XML 消息输出
尽管以上的例子非常简单，但是它们是非常强大的，因为您可以系列化一个对象，并向另一个不局限于本地物理网络的应用程序发送消息。这里没有复杂的防火墙限制或安全性考虑事项。此外，不需要用相同的语言编写消息的发送器和接收器，甚至不需要使用相同的平台。
技术概述和设计
这个示例解决方案包含需要集成业务流程的分销商和制造商。分销商 从制造商 处购买商品并出售给客户。
当客户需要商品时，分销商使用 C# WinForm 客户端提交一个客户订单。订单提交程序将订单细节存储在一个本地 MySQL 数据库中。该客户端还允许用户浏览库存、查看订单和 Amazon SQS 队列。
一般而言，分销商的库存能够满足客户的订购需求。如果库存不足的话，分销商会及时向制造商发送一个购买订单。然后，当物品已经发出时，制造商发送回一个订单汇总。所有这些通信都使用 Amazon SQS 来完成。
分销商的 Order Fulfillment 和 Inventory Management 服务也是使用 C# 构建的，它轮询进入的商品和待处理的客户订单。当处理客户订单时发现商品库存少于订购数量，那么将使用 Amazon SQS 向制造商发送一个购买订单。队列项的消息体是一个包含购买订单的 XML 文档。
制造商的 Order Processing Service 是基于 Java 平台构建的，它处理购买订单队列。当物品已经发出时，它将使用 Amazon SQS 向分销商回复一条消息。该消息的消息体是包含订单汇总的 XML 文档。
图 3 显示了涉及到的系统。
图 3. 解决方案概图
创建 XML 模式
第一步是为在分销商和制造商之间发送的消息定义 XML 模式。您需要两个模式：一个购买订单和一个订单汇总。
清单 7 显示了购买订单的模式。
清单 7. 购买订单模式
<?xml version="1.0" encoding="utf-8"?>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema">
<xs:element name="PurchaseOrder">
<xs:complexType>
<xs:sequence>
<xs:element name="Id" type="xs:string" minOccurs="0" />
<xs:element name="OrderDate" type="xs:string" minOccurs="0" />
<xs:element name="Company" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="CompanyName" type="xs:string" minOccurs="0" />
<xs:element name="StreetAddress" type="xs:string" minOccurs="0" />
<xs:element name="City" type="xs:string" minOccurs="0" />
<xs:element name="State" type="xs:string" minOccurs="0" />
<xs:element name="ZipCode" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="Vendor" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="CompanyName" type="xs:string" minOccurs="0" />
<xs:element name="StreetAddress" type="xs:string" minOccurs="0" />
<xs:element name="City" type="xs:string" minOccurs="0" />
<xs:element name="State" type="xs:string" minOccurs="0" />
<xs:element name="ZipCode" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="Items" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="Item" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:attribute name="Id" type="xs:string" />
<xs:attribute name="Name" type="xs:string" />
<xs:attribute name="Quantity" type="xs:string" />
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:schema>
|
Purchase Order XML 模式包含下列关键元素：
表 1. 购买订单模式中的关键元素
|
关键元素
|
描述
|
|
Id
|
包含 Purchase Order 的唯一标识符的字符串
|
|
OrderDate
|
包含 Purchase Order 日期的字符串
|
|
Company
|
包含分销商的关键地址信息，包括公司名称、街道地址、城市、州和邮政编码
|
|
Vendor
|
包含制造商的关键地址信息，包括公司名称、街道地址、城市、州和邮政编码
|
|
Items
|
包含订购商品的所有信息，包括商品 ID、商品名称和数量
|
清单 8 显示了订单汇总的模式。
清单 8. 订单汇总模式
<?xml version="1.0" encoding="utf-8"?>
<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema">
<xs:element name="OrderSummary">
<xs:complexType>
<xs:sequence>
<xs:element name="OrderId" type="xs:string" minOccurs="0" />
<xs:element name="ReferenceId" type="xs:string" minOccurs="0" />
<xs:element name="OrderDate" type="xs:string" minOccurs="0" />
<xs:element name="CompanyAddress" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="CompanyName" type="xs:string" minOccurs="0" />
<xs:element name="StreetAddress" type="xs:string" minOccurs="0" />
<xs:element name="City" type="xs:string" minOccurs="0" />
<xs:element name="State" type="xs:string" minOccurs="0" />
<xs:element name="ZipCode" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="CustomerAddress" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="CompanyName" type="xs:string" minOccurs="0" />
<xs:element name="StreetAddress" type="xs:string" minOccurs="0" />
<xs:element name="City" type="xs:string" minOccurs="0" />
<xs:element name="State" type="xs:string" minOccurs="0" />
<xs:element name="ZipCode" type="xs:string" minOccurs="0" />
</xs:sequence>
</xs:complexType>
</xs:element>
<xs:element name="Items" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:sequence>
<xs:element name="Item" minOccurs="0" maxOccurs="unbounded">
<xs:complexType>
<xs:attribute name="ItemId" type="xs:string" />
<xs:attribute name="ItemName" type="xs:string" />
<xs:attribute name="Quantity" type="xs:string" />
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:schema>
|
Order Summary XML 模式包含下列关键元素：
表 2. 订单汇总模式中的关键元素
|
Id
|
包含 Order Summary 的唯一标识符的字符串
|
|
ReferenceId
|
包含初始 Purchase Order 的 ID 的字符串
|
|
OrderDate
|
包含 Order Summary 日期的字符串
|
|
CustomerAddress
|
包含分销商的关键地址信息，包括公司名称、街道地址、城市、州和邮政编码
|
|
VendorAddress
|
包含制造商的关键地址信息，包括公司名称、街道地址、城市、州和邮政编码
|
|
Items
|
包含订购商品的所有信息，包括商品 ID、商品名称和数量
|
定义数据库实体模型
接下来，我们定义数据库模式。图 4 显示了数据库实体模型。
图 4. 数据库实体模型
Reseller 数据实体包括以下内容：
Customer 包含订单的客户联系信息。
CustomerOrder 包含客户订单的订单信息。
CustomerOrderDetail 包含客户订单的商品细节。
Inventory 包含分销商的库存。
Manufacturer 数据实体为：
VendorOrder 跟踪由制造商的 Order Processing Service 处理的购买订单。
定义消息队列
最后需要定义的组建是消息队列。表 3 显示了这个解决方案的消息队列。
(责任编辑：)
相关阅读:
- 如何运维网站能让其稳定高效之稳定篇 2015.08.10
- 黑客、Geek等高手们都是这样上网的 2015.07.15
- 如何选择最佳的数据中心闪存？ 2015.06.17
- 手机解锁：图案、数字谁更强？ 2015.06.03
- 黑客声称一款流行的加密App竟然只用了异或加密！ 2015.04.08
最新内容
热点内容
图文资讯
如何运维网站能让其稳定高效之稳定篇
作为一名运维工程师，工作中最大的希望就是自己运维的网站能够稳定高效运行，但理想很...[详细]
黑客、Geek等高手们都是这样上网的
电脑高手们都会尽可能地寻找各种快捷高效的操作方式，譬如很多快速启动类的工具(如Exe...[详细]
如何选择最佳的数据中心闪存？
全闪存数据中心是个未来概念，同样还有不少方法实现数据中心内服务器或基于阵列的闪存...[详细]
手机解锁：图案、数字谁更强？
手机九宫格解锁到底安全不？九宫格能画出多少图案啊？我自己设置的九宫格总是被同学分...[详细]
黑客声称一款流行的加密App竟然只用了异或
一名黑客生成加密程序的作者竟然没有实现其核心的功能：加密！ 这位ID为NinjaDoge24(...[详细]