why 发表于 2017-6-30 18:25:42

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>
  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]
查看完整版本: Dynamics CRM 365 and Azure Service Bus – Queue