从 MS CRM 插件（沙盒）向 Azure 服务总线发送自定义消息

Question

我知道我可以在 MS CRM 中注册一个新的“服务端点”并使用它向 Azure 服务总线发送消息，但这...并不是我真正想要的。上述方法最终发送一个序列化的RemoteExecutionContext。

就我而言，我希望完全控制服务总线消息将包含的内容。这意味着序列化我自己的类。

我尝试使用WindowsAzure.ServiceBus nugget（和 ILmerging 新 DLL），但这仅适用于非沙盒设置（本地 CRM），但我也希望我的解决方案在 CRM 中工作在线的。当尝试在 CRM Online 中使用相同的代码然后尝试创建 TopicClient 时会引发错误：

System.Security.SecurityException：该程序集不允许部分受信任的调用者

有没有办法解决上述问题？

Answer 1

这是一种无需额外类且不使用 ILMerge 的方法。我在 CRM 在线版本 9.1.0.646（Dynamics 365 Customer Engagement）中验证了此功能

您的插件项目将需要以下引用和 using 语句。

参考：System.Net、System.Net.Http 使用：System.Net、System.Net.Http、System.Security.Cryptography、System.Globalization

在这个示例代码中，我构建了一个名为 json 的字符串变量，它是我要发布的 JSON 消息。然后下面的代码会发送消息。

string asbUri = 
    "https://<azurenamespace>.servicebus.windows.net/<topicname>/messages";
TimeSpan ts = new TimeSpan(0, 0, 90);
string sasToken = GetSASToken("sb://<azurenamespace>.servicebus.windows.net", " 
    <nameofSASkey>", "<SASKeyValue>", ts);

HttpClient client = new HttpClient();
client.DefaultRequestHeaders.Add("Authorization", sasToken);
HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, asbUri)
{
    Content = new StringContent(json, Encoding.UTF8, "application/json")
};
HttpResponseMessage response = client.SendAsync(request).Result;

private static string GetExpiry(TimeSpan ttl)
{
   TimeSpan expirySinceEpoch = DateTime.UtcNow - new DateTime(1970, 1, 1) + ttl;
   return Convert.ToString((int)expirySinceEpoch.TotalSeconds);
}

public static string GetSASToken(string resourceUri, string keyName, string key, 
TimeSpan ttl)
{
   var expiry = GetExpiry(ttl);
   //string stringToSign = HttpUtility.UrlEncode(resourceUri) + "\n" + expiry;
   //NOTE: UrlEncode is not supported in CRM, use System.Uri.EscapeDataString instead
   string stringToSign = Uri.EscapeDataString(resourceUri).ToLowerInvariant() + "\n" 
        + expiry;
        HMACSHA256 hmac = new HMACSHA256(Encoding.UTF8.GetBytes(key));

   var signature = 
   Convert.ToBase64String(hmac.ComputeHash(Encoding.UTF8.GetBytes(stringToSign)));
   var sasToken = String.Format(CultureInfo.InvariantCulture, "SharedAccessSignature 
       sr={0}&sig={1}&se={2}&skn={3}",
       Uri.EscapeDataString(resourceUri).ToLowerInvariant(), 
       Uri.EscapeDataString(signature), expiry, keyName);
   return sasToken;
}

Answer 2

我找到了一种与 Sandboxed MS CRM 兼容的方法。

这个想法是使用 Azure REST 端点向其发送消息。验证和使用相当容易......至少如果你有一个工作示例，我能够找到here。

这是一个相当不错的样本，虽然有点乱。尽管如此，它仍然展示了如何让基础工作，即身份验证和实际调用。

（次要注意：根据示例从 ASB 读取主题消息对我来说无法可靠地工作 - 它会工作一次，然后在身份验证密钥超时之前无法工作......这并没有因为我需要而困扰我仅发送消息，但如果这是您需要的功能，那么这可能不那么简单。）

Answer 3

我知道这是一个老问题，但我最近不得不做一些类似的事情，我使用 SharedVariable Collection 将其他详细信息和参数传递给 ServiceBus。

这是一个例子：

context.SharedVariables.Add("AttachmentType", attachmentType);

Answer 4

对于 CRM Online，您可以将消息转换/处理的逻辑置于沙盒之外。它需要有一些外部计算。考虑到您已经在线使用 CRM，这应该不是问题。

您可以采取的一种方法是将 CRM 构造的 RemoteExecutionContext 转换为您想要的任何类型。有一个sample 介绍如何将 Dynamics 365 与 NServiceBus 集成，它也采用这种方法。我所指的计算相当于示例中的CRMAdapterEndpoint 端点。端点使用Mapper 对象将JSON 序列化RemoteExecutionContext 转换为自定义类型ContactCreate 和ContactUpdate。这样你就可以实现你想要的。