当前位置：主页>产 业>技术与方法>基本技术>

利用 Amazon Web Services 集成企业应用程序--使用 Amazon SQS 发送 XML 消息(2)

Product prod = new Product(Widget, 1.5M);string accessKeyId = ConfigurationSettings.AppSettings[AmazonAccessKeyID];string secretAccessKey = ConfigurationSettings.AppSettings[AmazonSecretAccessKey];Am

				
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 消息的输出的屏幕截图
　　最后一步是从队列接收 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 消息输出
接收 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. 解决方案概图
显示了客户、分销商、Amazon SQS 和制造商的解决方案概图
　　创建 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. 数据库实体模型
列出 customer、customerorder、customerorderdetail、inventory 和 vendororder 实体的数据库实体模型
　　Reseller 数据实体包括以下内容：
　　Customer 包含订单的客户联系信息。
　　CustomerOrder 包含客户订单的订单信息。
　　CustomerOrderDetail 包含客户订单的商品细节。
　　Inventory 包含分销商的库存。
　　Manufacturer 数据实体为：
　　VendorOrder 跟踪由制造商的 Order Processing Service 处理的购买订单。
　　定义消息队列
　　最后需要定义的组建是消息队列。表 3 显示了这个解决方案的消息队列。

(责任编辑：)

顶一下
(1)
100%
踩一下
(0)
0%
发表评论
请自觉遵守互联网相关的政策法规，严禁发布色情、暴力、反动的言论。
评价:
表情:
用户名: 验证码:点击我更换图片
最新评论 进入详细评论页>>
热点内容
相关文章
图片资讯

企业需要全新方式管理安全风险

企业需要全新方式管理安全风险

如今随着企业的信息化水平不断提高，IT系统的规模在不断的扩大，网络结构也日益复杂，...[详细]

如何搞定Fedora 18上的防火墙配置？

如何搞定Fedora 18上的防火墙配置？

经历了几次跳票之后Fedora 18正式版于2013年1月15日面世，凝聚了许多开发者的心血。很...[详细]

揭穿黑客关于Ashx脚本写aspx木马的方法

揭穿黑客关于Ashx脚本写aspx木马的方法汇总

.Net环境,上传处未限制Ashx和Asmx，后者上传无法运行，提示Asmx脚本只能在本地运行，...[详细]

家用路由器巧用防火墙免攻击

家用路由器巧用防火墙免攻击

随着网络信息安全的需求度提高，个人信息与网络安全逐渐被提上了台面。人们越来越意识...[详细]

Windows安全攻略:教你完全修复系统漏洞

Windows安全攻略:教你完全修复系统漏洞

目前互联网上的病毒集团越来越猖狂，对用户的危害也愈演愈烈，大家要懂得保护自己的电...[详细]

Copyright © 2008-2013 版权所有 中国信息安全博士网
邮箱：secdoctor007@163.com
关于我们|联系我们|人才招聘|法律说明|站点地图
未经书面许可 禁止转载、摘编、复制和镜像京ICP备09032960号