从 WCF 消息检查器发送到服务总线事件中心

Question

我有一个有效的网络服务和测试客户端，我可以截取它们之间的消息。但是当我添加要发送到我的事件中心的代码时，客户端显示错误：

An unhandled exception of type 'System.ServiceModel.FaultException`1' occurred in mscorlib.dll

Additional information: The argument Endpoints is null or empty.

Parameter name: Endpoints

更详细的异常：

System.ServiceModel.FaultException`1[System.ServiceModel.ExceptionDetail]:    The argument Endpoints is null or empty.
Parameter name: Endpoints (Fault Detail is equal to An ExceptionDetail,  likely created by IncludeExceptionDetailInFaults=true, whose value is:
System.ArgumentException: The argument Endpoints is null or empty.
Parameter name: Endpoints
at Microsoft.ServiceBus.ServiceBusConnectionStringBuilder.Validate()
at Microsoft.ServiceBus.ServiceBusConnectionStringBuilder.ToString()
at  Microsoft.ServiceBus.Messaging.Configuration.KeyValueConfigurationManager.
Initialize(String connection, Nullable`1 transportType)
at Microsoft.ServiceBus.Messaging.Configuration.KeyValueConfigurationManager.
.ctor(Nullable`1 transportType)
at Microsoft.ServiceBus.Messaging.EventHubClient.Create(String path)
at WCFInterceptor.MessageInspector.AfterReceiveRequest(Message& request,  ICli
entChannel channel, InstanceContext instanceContext)
at  System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.AfterReceiveReques
tCore(MessageRpc& rpc)
at System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.ProcessMessage2(Me
ssageRpc& rpc)
at System.ServiceModel.Dispatc...).

这是我添加的代码：

try
        {
            NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(GetServiceBusConnectionString());
            Manage.CreateEventHub(hubName, 16, namespaceManager);
        }
        catch (Exception e)
        {
            Console.WriteLine("SetupEHError" + e);
        }
        EventHubClient client = EventHubClient.Create(hubName);
        Console.WriteLine("eventhubclient iniciado");
        EventData messageData = new EventData(Encoding.UTF8.GetBytes(serializedString));

        try
        {
            client.Send(messageData);
            Console.WriteLine("MessageData enviada");
        }
        catch (Exception e)
        {

            Console.WriteLine("ErrorMessage:" + e);
        }

这里是 CreateEventHub 方法：

public static void CreateEventHub(string eventHubName, int        numberOfPartitions, NamespaceManager manager)
    {
        try
        {
            // Create the Event Hub
            Console.WriteLine("Creating Event Hub...");
            EventHubDescription ehd = new EventHubDescription(eventHubName);
            ehd.PartitionCount = numberOfPartitions;
            manager.CreateEventHubIfNotExistsAsync(ehd).Wait();
            Console.WriteLine("Created");
        }
        catch (AggregateException agexp)
        {
            Console.WriteLine(agexp.Flatten());
        }
    }

WebService 控制台应用最多可打印

Creating Event Hub
Created

所以我想我可能需要为 WebService 中的 MessageInspector 添加端点，以便能够将数据发送到服务总线事件中心。如果有，配置如何？

提前致谢

Answer 1

背景：

ServiceBus SDK 有 2 个主要接口：

1. NamespaceManager：用于所有管理操作 (aka Control Plane)，例如创建删除主题/EHub 等
2. EntityClients（TopicClient、EventHubClient 等）：用于运行时操作 (aka Data Plane) - 从 Topics/EventHubs 发送/接收。

这两个接口都需要自己的连接字符串来连接到 ServiceBus。例如：指定给 NamespaceManager 的连接字符串需要 ManageClaims，而 EntityClients 只需要 Send/Recv 声明。

您仅使用 EventHub 名称创建了 EventHubClient 并且没有在那里传递连接字符串。在这种情况下，我们的 ServiceBus 客户端 sdk 会抛出上述错误 - 当连接字符串未通过 app.config 传递时。 要解决此问题，请更改此行（因为您将 ConnectionString 直接用于 NamespaceManager 而没有使用任何 app.config）：

EventHubClient client = EventHubClient.Create(hubName);

改成：

----edit-----
    var eHubConnStr = GetServiceBusConnectionString();
    eHubConnStr.EntityPath = eventHubName;
    // Evaluate here, if you have to populate the Security related properties from the ConnectionString
    // eHubConnStr.SasKey and SasKeyName to Send only or Recv only
----edit-----
    EventHubClient client = EventHubClient.CreateFromConnectionString(eHubConnStr); // this connection string should be the EventHub Send conn str.

HTH！斯里

Answer 2

实际上，我需要做的就是使用连接字符串编辑我的 Web 服务服务器的应用程序配置。似乎 eventthubclient 的 Create 方法采用 eventthub 名称，然后转到 appconfig 获取密钥，因此没有找到它。