C# Azure 消息队列ServiceBus (服务总线队列)

时间:2021-12-20 04:09:03

https://www.azure.cn/documentation/articles/service-bus-create-queues/

2. 介绍

1) service bus的队列,若当前消息被成功处理后,则这个消息会从队列中消失。

2) service bus是先进先出的队列,当取队列时,一直停留做等待,直到有消息进入。

3) Windows Azure Service Bus 提供安全且广泛可用的托管基础结构,以实现广泛通信、大范围事件分布、命名和服务发布。Service Bus 为 Windows Communication Foundation (WCF) 和其他服务终结点(包括 REST 终结点)提供连接选项,没有这些连接选项将很难或不可能访问这些终结点。可以将终结点置于网络地址转换 (NAT) 边界的后面并/或绑定到经常更改的、动态分配的 IP 地址。

4)Service Bus 提供“中继”和“中转”消息传递功能。在中继消息传递模式下,中继服务支持直接单向消息传递、请求/响应消息传递和对等消息传递。中转消息传递提供了持久异步消息传递组件(如队列、主题和订阅),具有支持发布-订阅和临时分离的功能:发送者和接收者不必同时处于联机状态;该消息传递基础结构能够可靠地存储消息,直到接收方准备好接收消息。

3. 开始创建

1)登录到Azure https://manage.windowsazure.cn/

2)打开服务总线

3)新建消息队列

在左下角—>新建 —> 服务总线—>队列—>自定义创建

我们输入队列名称与命名空间名称如下:队列名称:myqueue;命名空间名称:testnamespace

点击下一步,如下。用默认的值,你也可以用自己自定义的值

这时候,,我们等待创建,命名空间与队列都创建成功,如下:

4)设置队列

我们依次进入 命名空间—>队列—>myqueue—>配置,填写名称与权限。用来配置队列连接属性与连接字符串

我们填写名称alun,有管理、发送、侦听的权限。

5)查看连接信息

打开命名空间testnamespace—>队列,选中myqueue,然后查看连接信息

可以看到连接字符串

到此,创建队列结束

4. 代码开始

1)首先,创建一个项目,这里我们创建一个控制台项目 ConsoleApplicationServiceBus

2)导入相应的包

Install-Package WindowsAzure.ServiceBus

3)连接servicebus

如果代码中不对 ConnectivityMode 做预先设置,service bus 客户端( web 应用)默认使用了 AutoDetect 模式 连接 service bus 服务。 AutoDetect 会优先使用 TCP 连接模式。由于 TCP 连接模式也是加密的,所以客户端需要首先验证 service bus 服务器证书 CN = servicebus.chinacloudapi.cn 的有效性,证书链信息在 SSL 协议的 server hello 消息中返回。

如果证书链中的某些中间证书没有安装在 web 应用实例上,web 应用需要发起额外的请求到 CA 服务器上下载中间证书并安装。

//最好设置连接模式为Https,默认是Tcp。如果是Tcp的话,放到云端WEB应用上会报错 ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https; //开始连接 QueueClient Client = QueueClient.CreateFromConnectionString(connStr, queueName);

取得消息

public MessageData GetMessage() { var vMsg = Client.Receive(); if (vMsg == null) { return null; } messageData = vMsg.GetBody<MessageData>(); vMsg.Complete(); return messageData; }

添加消息