System.Net.Socket Error using Azure-Iot-device-read-message

Hi team

I have this error on my console application;

using System;
using System.Threading;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.EventHubs;
namespace ReadMessageApplication
{
class Program
{
private readonly static string s_eventHubsCompartibleEndpoint ="sb://iothub-ns-university-2081416-42bc501981.servicebus.windows.net/";
private readonly static string s_eventHubsCompartiblePath = "universityiothub";
private readonly static string s_iotHubSasKey = "****=";
private readonly static string s_iotHubSasKeyName = "iothubowner";
private static EventHubClient s_eventhubClient;
private static async Task ReceivedMessageFromDeviceAsync(string partition, CancellationToken ct)
{
var eventHubReciver = s_eventhubClient.CreateReceiver("$Default", partition, EventPosition.FromEnqueuedTime(DateTime.Now));
Console.WriteLine("Create receiver on partition:" + partition);
while (true)
{
if (ct.IsCancellationRequested) break;
Console.WriteLine("Listening for messages on:" + partition);
var events = await eventHubReciver.ReceiveAsync(100);
if (events == null) continue;
foreach(EventData eventData in events)
{
string data = Encoding.UTF8.GetString(eventData.Body.Array);
Console.WriteLine("Message received on partition {0}:", partition);
Console.WriteLine(" {0}:", data);
Console.WriteLine("Application properties (set by device)");
foreach(var prop in eventData.Properties)
{
Console.WriteLine(" {0}: {1}", prop.Key, prop.Value);
}
Console.WriteLine("System properties (set by Iot Hub)");
foreach(var prop in eventData.SystemProperties)
{
Console.WriteLine(" {0}: {1}", prop.Key, prop.Value);
}
}
}
}
private static async Task Main(string[] args)
{
Console.WriteLine("IOT Hub Device Message - Read device to cloud message. Ctrl-C to exit.\n");
var connectionString = new EventHubsConnectionStringBuilder(new Uri(s_eventHubsCompartibleEndpoint), s_eventHubsCompartiblePath, s_iotHubSasKeyName, s_iotHubSasKey);
s_eventhubClient = EventHubClient.CreateFromConnectionString(connectionString.ToString());
//partition receiver for each hub.
var runtimeInfo = await s_eventhubClient.GetRuntimeInformationAsync();
var dtwoPartition = runtimeInfo.PartitionIds;
CancellationTokenSource ct = new CancellationTokenSource();
Console.CancelKeyPress += (s, e) =>
{
e.Cancel = true;
ct.Cancel();
Console.WriteLine("Exiting..");
};
var tasks = new List();
foreach(string partition in dtwoPartition)
{
tasks.Add(ReceivedMessageFromDeviceAsync(partition, ct.Token));
}
Task.WaitAll(tasks.ToArray());
}
}
}

2 Replies

Know the answer? Post it — somebody with the same question will find it here.

Guest User7y ago
Thanks mate will work on this based on links shared, raise hands if i persist same problem.
Rajanikant Hawaldar7y ago
please check this may help https://github.com/Azure/azure-event-hubs-dotnet/issues/364 Microsoft.Azure.EventHubs.EventHubClient.GetRuntimeInformationAsync https://stackoverflow.com/questions/35673206/how-to-read-from-multiple-eventhub-partitions-simultaneously-with-high-throughpu