2012-09-05 45 views
3

我使用Azure ServiceBus API发布到Service Bus上。 sb协议在防火墙后面不起作用。因此,我将ServiceBusEnvironment.SystemConnectivity.Mode设置为ConnectivityMode.Http。只要我直接连接到互联网,这就工作了。即使在配置了http代理之后,这也不适用于我的办公室。 ServiceBus API有问题吗?感谢您的帮助。通过http后台代理发布到Azure服务总线

下面是一块的,我用的代码....

public static void Initialize() 
    { 
     // Using Http to be friendly with outbound firewalls 
     ServiceBusEnvironment.SystemConnectivity.Mode = 
      ConnectivityMode.Http; 

     //InitializeQueue(); 
    } 


    // The name of your queue 
    public const string QueueName = "ordersqueue"; 

    public static NamespaceManager CreateNamespaceManager() 
    { 
     // Create the namespace manager which gives you access to 
     // management operations 
     var uri = ServiceBusEnvironment.CreateServiceUri(
      "sb", Namespace, String.Empty); 
     var tP = TokenProvider.CreateSharedSecretTokenProvider(
      IssuerName, IssuerKey); 
     return new NamespaceManager(uri, tP); 
    } 

    private static void InitializeQueue() 
    { 
     // Create the namespace manager which gives you access to 
     // management operations 
     var namespaceManager = CreateNamespaceManager(); 

     // Create the queue if it does not exist already 
     if (!namespaceManager.QueueExists(QueueName)) 
     { 
      namespaceManager.CreateQueue(QueueName); 
     } 

     // Get a client to the queue 
     var messagingFactory = MessagingFactory.Create(
      namespaceManager.Address, 
      namespaceManager.Settings.TokenProvider); 
     OrdersQueueClient = messagingFactory.CreateQueueClient(
      QueueName); 
    } 

下面是堆栈跟踪我得到................... ............. .................................... ...........................

Microsoft.ServiceBus.Messaging.MessagingCommunicationException was unhandled 
    Message=Unable to connect to ServiceBus using HTTP connectivity mode 
    Source=Microsoft.ServiceBus 
    IsTransient=true 
    StackTrace: 
     at Microsoft.ServiceBus.Messaging.Sbmp.SbmpMessageSender.EndSendCommand(IAsyncResult result) 
     at Microsoft.ServiceBus.Messaging.Sbmp.SbmpMessageSender.OnEndSend(IAsyncResult result) 
     at Microsoft.ServiceBus.Messaging.Sbmp.SbmpMessageSender.OnSend(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout) 
     at Microsoft.ServiceBus.Messaging.MessageSender.Send(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout) 
     at Microsoft.ServiceBus.Messaging.MessageSender.Send(BrokeredMessage message) 
     at Microsoft.ServiceBus.Messaging.QueueClient.Send(BrokeredMessage message) 
     at AzureServiceBusPublisher.QueueConnector.send(String arg) in C:\Users\prasanh\Documents\Visual Studio 2010\Projects\AzureServiceBusPublisher\AzureServiceBusPublisher\QueueConnector.cs:line 72 
     at AzureServiceBusPublisher.Program.sendMessagesToQueue() in C:\Users\prasanh\Documents\Visual Studio 2010\Projects\AzureServiceBusPublisher\AzureServiceBusPublisher\Program.cs:line 23 
     at AzureServiceBusPublisher.Program.Main(String[] args) in C:\Users\prasanh\Documents\Visual Studio 2010\Projects\AzureServiceBusPublisher\AzureServiceBusPublisher\Program.cs:line 13 
     at System.AppDomain._nExecuteAssembly(RuntimeAssembly assembly, String[] args) 
     at System.AppDomain.ExecuteAssembly(String assemblyFile, Evidence assemblySecurity, String[] args) 
     at Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly() 
     at System.Threading.ThreadHelper.ThreadStart_Context(Object state) 
     at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean ignoreSyncCtx) 
     at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state) 
     at System.Threading.ThreadHelper.ThreadStart() 
    InnerException: System.ServiceModel.CommunicationException 
     Message=Unable to connect to ServiceBus using HTTP connectivity mode 
     Source=Microsoft.ServiceBus 
     StackTrace: 
     Server stack trace: 
      at Microsoft.ServiceBus.WebStream..ctor(Uri factoryEndpointUri, String webSocketRole) 
      at Microsoft.ServiceBus.WebSocketConnection..ctor(Uri factoryEndpointUri, String webSocketRole, Int32 asyncReadBufferSize) 
      at Microsoft.ServiceBus.WebSocketOnewayConnectionInitiator.Connect(Uri uri, TimeSpan timeout) 
      at Microsoft.ServiceBus.WebSocketOnewayConnectionInitiator.BeginConnect(Uri uri, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.BufferedConnectionInitiator.BeginConnect(Uri uri, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.ConnectionPoolHelper.EstablishConnectionAsyncResult.OpenUsingNewConnection() 
      at Microsoft.ServiceBus.Channels.ConnectionPoolHelper.EstablishConnectionAsyncResult.Begin() 
      at Microsoft.ServiceBus.Channels.ConnectionPoolHelper.EstablishConnectionAsyncResult..ctor(ConnectionPoolHelper parent, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.ConnectionPoolHelper.BeginEstablishConnection(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.ClientFramingDuplexSessionChannel.OpenAsyncResult..ctor(ClientFramingDuplexSessionChannel duplexChannel, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.ClientFramingDuplexSessionChannel.OnBeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.CommunicationObject.OpenAsyncResult..ctor(CommunicationObject communicationObject, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.CommunicationObject.BeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.LayeredChannel`1.OnBeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.CommunicationObject.OpenAsyncResult..ctor(CommunicationObject communicationObject, TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Channels.CommunicationObject.BeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Messaging.Sbmp.DuplexRequestBindingElement.DuplexRequestSessionChannel.OnBeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at System.ServiceModel.Channels.CommunicationObject.OpenAsyncResult.InvokeOpen() 
      at System.ServiceModel.Channels.CommunicationObject.OpenAsyncResult..ctor(CommunicationObject communicationObject, TimeSpan timeout, AsyncCallback callback, Object state) 
      at System.ServiceModel.Channels.CommunicationObject.BeginOpen(TimeSpan timeout, AsyncCallback callback, Object state) 
      at Microsoft.ServiceBus.Messaging.Channels.SharedChannel`1.GetInstanceAsyncResult.<GetAsyncSteps>b__3(GetInstanceAsyncResult thisPtr, TimeSpan t, AsyncCallback c, Object s) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.EnumerateSteps(CurrentThreadType state) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.Start() 
     Exception rethrown at [0]: 
      at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.End(IAsyncResult asyncResult) 
      at Microsoft.ServiceBus.Messaging.Channels.SharedChannel`1.OnEndCreateInstance(IAsyncResult asyncResult) 
      at Microsoft.ServiceBus.Messaging.SingletonManager`1.EndGetInstance(IAsyncResult asyncResult) 
      at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.RequestAsyncResult.<GetAsyncSteps>b__f(RequestAsyncResult thisPtr, IAsyncResult r) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.EnumerateSteps(CurrentThreadType state) 
     Exception rethrown at [1]: 
      at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.End(IAsyncResult asyncResult) 
      at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.EndRequest(IAsyncResult result) 
      at Microsoft.ServiceBus.Messaging.Sbmp.SbmpTransactionalAsyncResult`1.<GetAsyncSteps>b__44(TIteratorAsyncResult thisPtr, IAsyncResult a) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.EnumerateSteps(CurrentThreadType state) 
     Exception rethrown at [2]: 
      at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result) 
      at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.End(IAsyncResult asyncResult) 
      at Microsoft.ServiceBus.Messaging.Sbmp.SbmpMessageSender.EndSendCommand(IAsyncResult result) 
     InnerException: System.ServiceModel.CommunicationException 
      Message=Unable to connect downstream 
      Source=Microsoft.ServiceBus 
      StackTrace: 
       at Microsoft.ServiceBus.WebStream.CreateDownStreamRequest(Uri endpointLocation) 
       at Microsoft.ServiceBus.WebStream.StartSession(Uri readEndpoint, Uri writeEndpoint) 
       at Microsoft.ServiceBus.WebStream..ctor(Uri factoryEndpointUri, String webSocketRole) 
      InnerException: System.Net.WebException 
       Message=The remote server returned an error: (403) Forbidden. 
       Source=System 
       StackTrace: 
         at System.Net.HttpWebRequest.GetResponse() 
         at Microsoft.ServiceBus.WebStream.CreateDownStreamRequest(Uri endpointLocation) 
       InnerException: 

回答

2

什么是详细的异常明白吗?

根据我的经验,太多的代理不支持HTTP 1.1的默认配置。服务总线正常工作需要HTTP 1.1。

除此之外,我建议你检查这guide to troubleshoot connectivity to Service Bus

+0

您遇到的详细异常应该有一条消息,例如“无法使用HTTP连接模式连接到ServiceBus”以及异常链中的更深层次“HTTP/1.0协议不支持”Chunked编码上传“。 – DavideB

+0

谢谢。我收到错误消息“无法使用HTTP连接模式连接到ServiceBus”,但深入它没有分块错误。相反,它有错误消息“远程服务器返回错误:(403)禁止”。为什么我会得到这个错误?在通过sb协议进行连接时,我没有得到这个错误,但是没有代理连接时我没有得到这个错误。 – phebbar

+0

我想你检查了[故障排除指南]中的所有内容(http://social.technet.microsoft.com/wiki/contents/articles/troubleshooting-connectivity-issues-in-the-windows-azure-appfabric-service-bus .aspx):通过浏览器进行访问,ping测试以及其他所有事情都可以从代理后台完成?指南(代理配置)中的第4部分可能会有用。 IMO它可能是一个与代理有关的问题,即使我可能发现HTTP 403错误有点令人困惑。 你的代码是好的,也是凭据,否则它会通过TCP失败;因此网络访问是进一步调查的其余领域。 – DavideB

1

我在Windows Azure的服务总线队的SDE。请尝试发布指南。

另请注意,自SDK 1.7起,Service Bus Messaging仅适用于支持POST分块的HTTP 1.1代理。我们正在为此制定一个长期解决方案,即将发布的SDK 1.8允许Service Bus Relay使用HTTPS而不是POST分块来处理这些代理以及HTTP 1.0代理。

我们也知道某些思科代理(也可能是其他)需要任何尝试的IP地址连接的名称地址。我们正在为此制定长期解决方案。

+0

很高兴知道您正在处理我们每天面临的问题:大约40%的客户使用防火墙,默认情况下会阻止HTTP 1.1。 – DavideB

+1

谢谢你们。我如何知道我的代理是否支持HTTP 1.1?我有webex共享工作的代理,我相信使用HTTP 1.1功能。 – phebbar