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

偏执的太偏执、 2023-01-06 01:15 113阅读 0赞

各位，上一篇基本概念和架构中，我们介绍了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：

![609d0e52822e431485c8516c79d4491b.png][]

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

![f3b7a5753724634519abc8960c615f3b.png][]

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

![a58a5d70335266feeb5c5cee63dc2477.png][]

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

![f0d2fb64aa94b65ae2f80f4be66374f8.png][]

![e88063a874cd777ebbc92b1bdbe5a6ef.png][]

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

![0a86221bc6647a929a2c37a14a920142.png][]

请将主秘钥拷贝下来，备用。

启动我们的ServiceBus的连接编码，首先需要在应用程序配置文件中增加ServiceBus的连接信息:

<appSettings>
        
        <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. 消息队列的创建、是否存在判断、删除操作

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

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);
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

2. 创建QueueClient，用于发送、接收消息

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

/// <summary>
            /// 创建队列客户端
            /// </summary>
            /// <returns>队列客户端</returns>
            public QueueClient CreateQueueClient(string queueName, ReceiveMode mode = ReceiveMode.ReceiveAndDelete)
            {
                var namespaceClient = NamespaceManager.Create();
                return QueueClient.Create(queueName,mode);
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

3. 主题的创建、删除、是否存在判断

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

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);
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

4. 创建TopicClient，用于主题的发送和订阅接收消息

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

/// <summary>
            /// 创建主题客户端
            /// </summary>
            /// <returns>主题客户端</returns>
            public TopicClient GetTopicClient(string topicName)
            {
                var namespaceClient = NamespaceManager.Create();            
                return TopicClient.Create(topicName);
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

5. 创建消息BrokeredMessage，设置消息的属性

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

/// <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;
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

6.发送消息

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

/// <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();
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

7. 接收消息

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

/// <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;
            }

![复制代码][48304ba5e6f9fe08f3fa1abda7d326ab.png]

还有很多其他的示例代码。本文只是一个简单的入门级教程，接下来我们将按MQ场景逐个展示ServiceBus Messaging的特性。

[609d0e52822e431485c8516c79d4491b.png]: /images/20221119/5ec72f66244a43b5a6f779299f7f39bc.png
[f3b7a5753724634519abc8960c615f3b.png]: /images/20221119/3199de8171e24e41861519454d7165de.png
[a58a5d70335266feeb5c5cee63dc2477.png]: https://img-blog.csdnimg.cn/img_convert/a58a5d70335266feeb5c5cee63dc2477.png
[f0d2fb64aa94b65ae2f80f4be66374f8.png]: https://img-blog.csdnimg.cn/img_convert/f0d2fb64aa94b65ae2f80f4be66374f8.png
[e88063a874cd777ebbc92b1bdbe5a6ef.png]: https://img-blog.csdnimg.cn/img_convert/e88063a874cd777ebbc92b1bdbe5a6ef.png
[0a86221bc6647a929a2c37a14a920142.png]: https://img-blog.csdnimg.cn/img_convert/0a86221bc6647a929a2c37a14a920142.png
[48304ba5e6f9fe08f3fa1abda7d326ab.png]: https://img-blog.csdnimg.cn/img_convert/48304ba5e6f9fe08f3fa1abda7d326ab.png

发表评论取消回复

表情：

评论列表（有 0 条评论，113人围观）

还没有评论，来说两句吧...

相关阅读

相关消息队列Message Queue 0基础学习

一、定义消息队列：一般我们会简称它为MQ(Message Queue)。 Message Query（MQ），消息队列中间件，很多初学者认为，MQ通过消息的

心已赠人/ 2024年03月16日 23:01/ 0 赞/ 83 阅读

相关【转】Azure Messaging-ServiceBus Messaging消息队列技术系列2-编程SDK入门

各位，上一篇基本概念和架构中，我们介绍了Window Azure ServiceBus的消息队列技术的概览。接下来，我们进入编程模式和详细功能介绍模式，一点一点把Service

偏执的太偏执、/ 2023年01月06日 01:15/ 0 赞/ 114 阅读

相关【转】Azure Messaging-ServiceBus Messaging消息队列技术系列1-基本概念和架构

前段时间研究了Window Azure ServiceBus Messaging消息队列技术，搞了很多技术研究和代码验证，最近准备总结一下，分享给大家。首先，Windows

ゝ一纸荒年。/ 2023年01月06日 01:15/ 0 赞/ 119 阅读

相关 Windows Azure功能更新：远程调试、新的VM镜像、Azure SDK 2.2

本月Windows Azure推出了多项更新，比较重要的是Azure SDK 2.2，这个更新主要包括如下内容：在Visual studio里面可以直接登录Azure连接A

本是古典何须时尚/ 2022年09月17日 15:18/ 0 赞/ 202 阅读

相关消息队列技术

[再谈消息队列技术][Link 1] 上周，我们举办了第二届技术沙龙，我这边主要演讲了消息队列技术的议题，现分享给大家：在我们团队内部，随着消息应用中心（任务中心）的

快来打我*/ 2022年06月13日 09:45/ 0 赞/ 242 阅读

相关什么是消息队列(Message queue)

最近接触到消息中间件，想通过本篇博文总结一些关于消息队列的知识，以及 Java 语言中面向消息中间件（MOM）的API(JMS)，希望能够帮助大家更好的理解消息中间件。一

布满荆棘的人生/ 2022年05月27日 07:09/ 0 赞/ 274 阅读

相关 SpringBoot2.0系列--09--消息队列(Rabbit)

SpringBoot2.0系列–09–消息队列(Rabbit) 文章目录 SpringBoot2.0系列--09--消息队列(Rabbit) 前言

青旅半醒/ 2022年04月16日 00:29/ 0 赞/ 247 阅读

相关消息队列技术介绍

一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。是大型分布式系统不可缺

Bertha 。/ 2022年03月28日 12:38/ 0 赞/ 340 阅读

相关消息队列总结（转）

转自：https://www.cnblogs.com/LipeiNet/p/9877189.html 作者：朝向远方作者博客：https://www.cnblo

我会带着你远行/ 2021年12月22日 13:39/ 0 赞/ 300 阅读

相关消息中间件：消息队列（Message Queue）解读

什么是消息队列呢？解读一下：队列，应该都知道，一种先进先出的数据结构。那什么是消息队列呢？可以简单理解为：当有大批的数据请求处理的时候，我们作为管理人员，必须保证整

左手的ㄟ右手/ 2021年10月09日 07:28/ 0 赞/ 303 阅读