大佬教程收集整理的这篇文章主要介绍了Azure Messaging-ServiceBus Messaging消息队列技术系列2-编程SDK入门，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
各位，上一篇基本概念和架构中，我们介绍了Window Azure serviceBus的消息队列技术的概览。接下来，我们进入编程模式和详细功能介绍模式，一点一点把serviceBus技术研究出来。
本章我们主要介绍serviceBus的编程SDK编程入门。
首先，微软提供了两个主要的Nuget Packages：
@H_950_0@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=主秘钥"/> </>
后续，所有的serviceBus的连接操作，都会读取这个配置节。我们通过case by case的方式，show 给大家：
首先：serviceBus的命名空间管理器：@H_753_105@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( ReceiveMode.ReceiveAndDelete) { var namespaceClient =return QueueClient.Create(queuename,modE); }
3. 主题的创建、删除、是否存在判断
void Createtopic(String topicName) { (nm.TopicExists(topicName)) { nm.deletetopic(topicName); } var topic = new TopicDescription(topicName); nm.Createtopic(topic); nm.deletetopic(topicName); }
4. 创建Topicclient，用于主题的发送和订阅接收消息
创建主题客户端 主题客户端public Topicclient GetTopicclient( NamespaceManager.Create(); Topicclient.Create(topicName); }
5. 创建消息brokeredmessage，设置消息的属性
构造消息 <param name="serializabLeobject">可序列化的对象</param> 消息public static brokeredmessage Create(Object serializabLeobject) { var serializer = new DataContractserializer(serializabLeobject.GetType(),1)">new DataContractserializerSetTings(){ IgnoreExtensionDataObject = true,PreserveObjectReferences = false}); var message = brokeredmessage(serializabLeobject); message.Properties.Add("Type",serializabLeobject.GetType().ToString()); message; }
6.发送消息
/// 发送多条消息 <param name="receivePayBills">收发货订单集合</param> 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. 接收消息
接收消息 收付款订单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>()); } bills; }
还有很多其他的示例代码。本文只是一个简单的入门级教程，接下来我们将按MQ场景逐个展示serviceBus messaging的特性。
以上是大佬教程为你收集整理的Azure Messaging-ServiceBus Messaging消息队列技术系列2-编程SDK入门全部内容，希望文章能够帮你解决Azure Messaging-ServiceBus Messaging消息队列技术系列2-编程SDK入门所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。