IOT集线器消息处理器

处理在Azure IoT Hub中创建的消息时遇到一些问题。IOT集线器消息处理器

获取以下错误：抛出的异常：Microsoft.ServiceBus.dll中的'Microsoft.ServiceBus.Messaging.Amqp.AmqpException'（“发生AMQP错误（condition ='amqp：link：redirect'）。”）

任何人都可以指向正确的方向吗？

问候，乔纳斯

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading.Tasks; 
using Microsoft.ServiceBus.Messaging; 

namespace IOTHubMessageProcessor 
{ 
    class Program 
    { 
     static string connectionString = "HostName=yaddaaaa.azure-devices.net;SharedAccessKeyName=iothubowner;SharedAccessKey=keydataasdss+tacsCxwkWQeUm9sMCc2GHnQkIZHM="; 
     static string iotHubD2cEndpoint = "messages/events"; 
     static EventHubClient eventHubClient; 
     static void Main(string[] args) 
     { 

      Console.WriteLine("Receive messages\n"); 
      eventHubClient = EventHubClient.CreateFromConnectionString(connectionString, iotHubD2cEndpoint); 

      var d2cPartitions = eventHubClient.GetRuntimeInformation().PartitionIds; 

      foreach (string partition in d2cPartitions) 
      { 
       ReceiveMessagesFromDeviceAsync(partition); 
      } 
      Console.ReadLine(); 
     } 


     private async static Task ReceiveMessagesFromDeviceAsync(string partition) 
     { 
      var eventHubReceiver = eventHubClient.GetDefaultConsumerGroup().CreateReceiver(partition, DateTime.UtcNow); 

      while (true) 
      { 
       EventData eventData = await eventHubReceiver.ReceiveAsync(); 
       if (eventData == null) continue; 

       string data = Encoding.UTF8.GetString(eventData.GetBytes()); 
       Console.WriteLine(string.Format("Message received. Partition: {0} Data: '{1}'", partition, data)); 
      } 
     } 
    } 
}

来源

2016-03-01 Jonas K

您不应该使用Event Hub兼容端点来使用EventHubClient吗？ – juunas

嗨，你还有这个问题吗？ – neolursa