Azure Messaging-ServiceBus Messaging消息队列技术系列2-编程SDK入门

89ou

　　各位，上一篇基本概念和架构中，我们介绍了Window Azure ServiceBus的消息队列技术的概览。接下来，我们进入编程模式和详细功能介绍模式，一点一点把ServiceBus技术研究出来。
　　本章我们主要介绍ServiceBus的编程SDK编程入门。
　　首先，微软提供了两个主要的Nuget Packages：
　　Microsoft Azure Service Bus 3.4.0
　　主要的NameSpace有以下几个：
　　1.　Microsoft.ServiceBus，这个下面有两个主要的类：TokenProvider（用于创建Azure ServiceBus连接Token）NamespaceManager（管理ServiceBus的命名空间）。
　　2.　Microsoft.ServiceBus.Messaging，这个命名空间下面主要提供了：MessageSession、BrokeredMessage、QueueClient、TopicClient、TopicDescription、QueueDescription、SubscriptionClient、SubscriptionDescription等核心类。
　　在正式编码之前，需要我们在Windows Azure的Portal上建立ServiceBus的NameSpace：

　　我们新建一个命名空间：servicebustest，选择的类型是：消息

　　新建完成后处于活动（可用）的状态：

　　接下来，我们要获取两个重要的配置：连接串和主秘钥

　　请将连接字符串拷贝下来，备用。

　　请将主秘钥拷贝下来，备用。
　　启动我们的ServiceBus的连接编码，首先需要在应用程序配置文件中增加ServiceBus的连接信息:



<appSettings>
<!-- Service Bus specific app setings for messaging connections -->
<add key="Microsoft.ServiceBus.ConnectionString" value="Endpoint=sb://servicebustest.servicebus.chinacloudapi.cn/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=主秘钥"/>
</appSettings>
　　后续，所有的ServiceBus的连接操作，都会读取这个配置节。我们通过case by case的方式，show 给大家：
　　首先：ServiceBus的命名空间管理器：Microsoft.ServiceBus.NamespaceManager
　　这里，我们主要用以下两个方法来实例化：
　　public static NamespaceManager Create(); 例如：



var namespaceClient = NamespaceManager.Create();
　　通过NamespaceManager这个类，我们可以创建、删除、获取、重命名、更新、判断是否存在：队列、主题、订阅、规则等
　　1. 消息队列的创建、是否存在判断、删除操作



  private void CreateQueue(string queueName, bool isRequiresSession = true)
{
var nm = NamespaceManager.Create();
if (nm.QueueExists(queueName))
{
nm.DeleteQueue(queueName);
}
var queue = new QueueDescription(queueName) { RequiresSession = isRequiresSession };
nm.CreateQueue(queue);
nm.DeleteQueue(queueName);
}
　　2. 创建QueueClient，用于发送、接收消息



        /// <summary>
/// 创建队列客户端
/// </summary>
/// <returns>队列客户端</returns>
public QueueClient CreateQueueClient(string queueName, ReceiveMode mode = ReceiveMode.ReceiveAndDelete)
{
var namespaceClient = NamespaceManager.Create();
return QueueClient.Create(queueName,mode);
}
　　3. 主题的创建、删除、是否存在判断



private void CreateTopic(string topicName)
{
var nm = NamespaceManager.Create();
if (nm.TopicExists(topicName))
{
nm.DeleteTopic(topicName);
}
var topic = new TopicDescription(topicName);
nm.CreateTopic(topic);
nm.DeleteTopic(topicName);
}
　　4. 创建TopicClient，用于主题的发送和订阅接收消息



/// <summary>
/// 创建主题客户端
/// </summary>
/// <returns>主题客户端</returns>
public TopicClient GetTopicClient(string topicName)
{
var namespaceClient = NamespaceManager.Create();            
return TopicClient.Create(topicName);
}
　　5. 创建消息BrokeredMessage，设置消息的属性



   /// <summary>
/// 构造消息
/// </summary>
/// <param name="serializableObject">可序列化的对象</param>
/// <returns>消息</returns>
public static BrokeredMessage Create(Object serializableObject)
{            
var serializer = new DataContractSerializer(serializableObject.GetType(),new DataContractSerializerSettings(){ IgnoreExtensionDataObject = true, PreserveObjectReferences = false});
var message = new BrokeredMessage(serializableObject);              
message.Properties.Add("Type", serializableObject.GetType().ToString());
return message;
}
　　6.发送消息



        /// <summary>
/// 发送多条消息
/// </summary>
/// <param name="receivePayBills">收发货订单集合</param>
public void Send(List<ReceivePayBill> receivePayBills)
{
var queueClient = GetQueueClient(queueName);
foreach (var receivePayBill in receivePayBills)
{
var message = this.Create(receivePayBill);
queueClient.Send(message);
}
queueClient.Close();
}
　　7. 接收消息



        /// <summary>
/// 接收消息
/// </summary>
/// <returns>收付款订单</returns>
public List<ReceivePayBill> Receive()
{
var bills = new List<ReceivePayBill>(2);
var queueClient = GetReceiveQueueClient(queueName, ReceiveMode.ReceiveAndDelete);
BrokeredMessage message;
while ((message = queueClient.Receive()) != null)
{
bills.Add(message.GetBody<ReceivePayBill>());
}
return bills;
}
　　
还有很多其他的示例代码。本文只是一个简单的入门级教程，接下来我们将按MQ场景逐个展示ServiceBus Messaging的特性。