Dynamics CRM 365 and Azure Service Bus – Queue

why

　　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>
　　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!