C# Azure 消息队列ServiceBus （服务总线队列）

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

1. 前言

在阅读本文之前，可以查看微软官方的说明。

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

添加消息

public void AddMessage(MessageData msg)
{
var vmsg = new BrokeredMessage(msg);
Client.Send(vmsg);
}
}

下面是我们自定义的 MessageData类

[DataContract]
public class MessageData
{
[DataMember]
public string Content { get; set; } [DataMember]
public string id { get; set; }
}