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

发布时间:2017-3-23 12:27:07 编辑:www.fx114.net 分享查询网我要评论
本篇文章主要介绍了"Window Azure ServiceBus Messaging消息队列技术系列2-编程SDK入门 ",主要涉及到Window Azure ServiceBus Messaging消息队列技术系列2-编程SDK入门 方面的内容,对于Window Azure ServiceBus Messaging消息队列技术系列2-编程SDK入门 感兴趣的同学可以参考一下。

各位,上一篇基本概念和架构中,我们介绍了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的特性。

上一篇:SpringAOP代理报错问题
下一篇:[GraphQL] Serve a GraphQL Schema as Middleware in Express

相关文章

相关评论

本站评论功能暂时取消,后续此功能例行通知。

一、不得利用本站危害国家安全、泄露国家秘密,不得侵犯国家社会集体的和公民的合法权益,不得利用本站制作、复制和传播不法有害信息!

二、互相尊重,对自己的言论和行为负责。

好贷网好贷款