Dynamics CRM 365 and Azure Service Bus – Queue

Dynamics CRM 365 and Azure Service Bus – Queue

This blog will not contain details of any terminology.

对于某些应用场景，我们需要以队列的方式来处理CRM 的业务流程消息，我们可以使用微软的服务总线技术来达到目的。

我们知道CRM的流程任务也是以排队的方式去处理任务的，那微软服务总线的队列与CRM 的工作流有什么区别呢？

我的理解是，CRM 的流程任务只能在异步服务器里面去处理；而微软的服务总线，客户端可以在任何地方去读取队列消息，不一定是服务器，

普通的桌面应用程序也可以。我们可以把不同类型的消息，放进不同的队列，客户端读取对应的队列消息。下面来实战一下。

首先，我们登录微软Azure门户网站，新增一个服务总线和队列。

添加共享访问策略

复制服务总线地址。

使用插件注册程序来注册服务终端点，把复制的连接字符串贴进去

接下来，注册一个Step触发消息

注册完后，在CRM 365 里面新增一个联系人，就可以在系统作业里面看到事件了。

在"服务总线"->"队列"的消息面板中可以看到一条活动消息。

我们可以创建应用程序来读取队列的消息并做一些任务处理。

使用VisualStudio创建一个控制台应用程序，打开Nuget程序包管理器。

搜索WindowsAzure.ServiceBus并安装。

VS自动为我们添加了三个引用

这里额外添加了两个引用，Microsoft.Xrm.Sdk和System.configuration下面是实例代码

using Microsoft.ServiceBus.Messaging;
using Microsoft.Xrm.Sdk;
using System;
using System.Configuration; 

namespace ServiceBusConsoleApp
{

/// <summary>
/// ServiceBus QueueService
/// Tencent Lee
/// </summary>
class Program
{

static void Main(string[] args)
{

//使用插件注册程序注册服务终端点(ServiceEndPoint)时的连接字符串，并配置到App.config文件里面
var connectionString = ConfigurationManager.AppSettings["Microsoft.ServiceBus.ConnectionString"];

//也可以使用MessagingFactory来创建QueueClient
//var factory = MessagingFactory.CreateFromConnectionString(connectionString);
//var client = factory.CreateQueueClient("crm");
//需要指定队列名称，这里为crm，消息接收模式默认为：PeekLock
var client = Microsoft.ServiceBus.Messaging.QueueClient.CreateFromConnectionString(connectionString,"crm",ReceiveMode.PeekLock); 

//接收消息
client.OnMessage(message => { 

//这里的上下文就是平时写插件的上下文
var context = message.GetBody<Microsoft.Xrm.Sdk.RemoteExecutionContext>(); 
Entity contact = context.InputParameters["Target"] as Entity; 
Console.WriteLine("EntityName:{0}
MessageName:{1}
EntityId:{2}
FirstName:{3}"
, context.PrimaryEntityName
, context.MessageName
, context.PrimaryEntityId
,contact.GetAttributeValue<string>("fullname")

);

});

Console.Read();

}
}
}

运行程序后可输出相应的内容

EntityName:contact

MessageName:Create

EntityId:dc450c03-7126-e711-80f3-c4346bad279c

FirstName:TencentTest

返回消息面板，队列消息已经被读取而变为0条活动消息。

如果有多条消息，OnMessage方法会把所有的消息都读取完。

Hope this help!