Dynamics CRM 365 and Azure Service Bus – Queue
Dynamics CRM 365 and Azure Service Bus – QueueThis 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>
classProgram
{
staticvoid 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"] asEntity;
Console.WriteLine("EntityName:{0}\nMessageName:{1}\nEntityId:{2}\nFirstName:{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!
页:
[1]