2

我使用 Servicebus 作为 Web 应用程序和 BizTalk 之间的链接。在 web 应用程序中，我之前在 web.config 中定义了整个端点，但端点必须是动态的，所以我尝试通过代码设置端点。

更改后，我仅在尝试向队列发送消息时出现异常。（ArgumentException - 参数 entityName 为 null 或空）

以下是将消息发送到队列的代码：

string queuename = Company.GetQueueName(O.companyId);
var factory = new ChannelFactory<IOrder>("requestQueueClientEndpoint", new EndpointAddress(ServiceBusEnvironment.CreateServiceUri("sb", queuename, string.Empty)));
var OrdRspChannel = factory.CreateChannel();

OrdRspChannel.Order(O);

这是配置：

<system.serviceModel>
<behaviors>
  <endpointBehaviors>
    <behavior name="securityBehavior">
      <TransportClientEndpointBehavior>
        <tokenProvider>
          <sharedSecret issuerName="owner" issuerSecret="SECRET REMOVED" />
          <serviceCertificate>
            <authentication revocationMode="NoCheck"/>
          </serviceCertificate>
        </tokenProvider>
      </TransportClientEndpointBehavior>
    </behavior>
  </endpointBehaviors>
</behaviors>

<bindings>
  <netMessagingBinding>
    <binding name="netMessagingBinding" sendTimeout="00:10:00" receiveTimeout="00:10:00" openTimeout="00:10:00" closeTimeout="00:10:00" sessionIdleTimeout="00:10:00" prefetchCount="-1">
      <transportSettings batchFlushInterval="00:00:01" />
    </binding>
  </netMessagingBinding>
</bindings>

<client>
  <!-- Invoke BizTalk via Service Bus Queue -->
  <endpoint address="ADDRESS REMOVED" behaviorConfiguration="securityBehavior" binding="netMessagingBinding" bindingConfiguration="netMessagingBinding" contract="Procurement_MVC3.IOrder" name="requestQueueClientEndpoint" />
</client>
</system.serviceModel>

这是堆栈跟踪：

{System.ArgumentException: The argument entityName is null or empty.
Parameter name: entityName

Server stack trace: 
   at Microsoft.ServiceBus.Messaging.MessagingFactory.CheckValidEntityName(String entityName, Int32 maxEntityNameLength, Boolean allowSeparator, String paramName)
   at Microsoft.ServiceBus.Messaging.MessagingFactory.<>c__DisplayClass1d.<BeginCreateMessageSender>b__1b(AsyncCallback c, Object s)
   at Microsoft.ServiceBus.Messaging.OpenOnceManager.OpenOnceManagerAsyncResult`1.BeginOpenCompleted(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.OpenOnceManager.OpenOnceManagerAsyncResult`1.BeginOpen()
   at Microsoft.ServiceBus.Messaging.OpenOnceManager.OpenOnceManagerAsyncResult`1..ctor(OpenOnceManager openOnceManager, TimeSpan openTimeout, AsyncCallback callback, Object state, Func`3 beginOperation, EndOperation`1 endOperation)
   at Microsoft.ServiceBus.Messaging.OpenOnceManager.Begin[T](AsyncCallback callback, Object state, Func`3 beginOperation, Func`2 endOperation)
   at Microsoft.ServiceBus.Messaging.MessagingFactory.BeginCreateMessageSender(String entityPath, TimeSpan timeout, AsyncCallback callback, Object state)
   at Microsoft.ServiceBus.Messaging.Channels.ServiceBusOutputChannel.OpenMessagingFactoryAndMessageSenderAsyncResult.CreateFactoryComplete(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Channels.ServiceBusOutputChannel.OpenMessagingFactoryAndMessageSenderAsyncResult..ctor(ServiceBusOutputChannel outputChannel, TimeSpan timeout, AsyncCallback callback, Object state)
   at Microsoft.ServiceBus.Messaging.Channels.ServiceBusOutputChannel.OnOpen(TimeSpan timeout)
   at System.ServiceModel.Channels.CommunicationObject.Open(TimeSpan timeout)
   at System.ServiceModel.Channels.ServiceChannel.OnOpen(TimeSpan timeout)
   at System.ServiceModel.Channels.CommunicationObject.Open(TimeSpan timeout)
   at System.ServiceModel.Channels.ServiceChannel.CallOnceManager.CallOnce(TimeSpan timeout, CallOnceManager cascade)
   at System.ServiceModel.Channels.ServiceChannel.EnsureOpened(TimeSpan timeout)
   at System.ServiceModel.Channels.ServiceChannel.Call(String action, Boolean oneway, ProxyOperationRuntime operation, Object[] ins, Object[] outs, TimeSpan timeout)
   at System.ServiceModel.Channels.ServiceChannelProxy.InvokeService(IMethodCallMessage methodCall, ProxyOperationRuntime operation)
   at System.ServiceModel.Channels.ServiceChannelProxy.Invoke(IMessage message)

Exception rethrown at [0]: 
   at System.Runtime.Remoting.Proxies.RealProxy.HandleReturnMessage(IMessage reqMsg, IMessage retMsg)
   at System.Runtime.Remoting.Proxies.RealProxy.PrivateInvoke(MessageData& msgData, Int32 type)
   at Procurement_MVC3.IOrder.Order(Order Order)
   at Procurement_MVC3.Controllers.HomeController.ViewOrder(String id, Nullable`1 date, Nullable`1 confirmqty, String orderrowid, String supplierorderId, Boolean confirm) in c:\Projects2\trunk\Procurement_MVC3\Procurement_MVC3\Controllers\HomeController.cs:line 229}

我在 Google 和 StackOverflow 上都搜索过类似的场景，但一无所获。我还必须使用此代码更新生产环境，这是拼图的最后一块，所以它开始拖延。

4

1 回答 1

0

ServiceBusEnvironment.CreateServiceUri API采用三个参数，协议、命名空间和服务路径（对于您正在使用的绑定，它们映射到队列名称）。在您提供的示例中，您将队列名称作为命名空间传递，并且您缺少实体名称，从而导致缺少实体名称异常。

尝试将您的代码段切换为以下内容：

var factory = new ChannelFactory<IOrder>("requestQueueClientEndpoint", new EndpointAddress(ServiceBusEnvironment.CreateServiceUri("sb", namespaceName, queuename)));
于 2012-11-07T00:47:08.200 回答