2012-02-08 8 views
0

Я принимаю мои службы REST приложением ASP.NET на Windows Azure. Он работает отлично, но мне понадобилось услугу связи Inter-Role несколько дней назад, я построил службу, но у меня проблемы с ее хостингом.Хостинг WCF REST и NET.TCP конечные точки вместе на Azure с ASP.NET

Этот код в моем Global.asax отлично работает на моем локальном сервере разработки Azure, но он не работает в Azure Cloud.

Что является лучшим способом разместить их правильно?

Global.asax:

public class Global : HttpApplication 
{ 
    void Application_Start(object sender, EventArgs e) 
    { 
     StartNotificationServiceHost(); 
     RegisterRoutes(); 
    } 

    public ServiceHost ServiceHost { get; private set; } 
    private void RegisterRoutes() 
    { 
     var hostfactory = new WebServiceHostFactory(); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Companies",hostfactory, typeof(Companies))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Public", hostfactory, typeof(Public))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Users", hostfactory, typeof(Users))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Contacts", hostfactory, typeof(Contacts))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Projects", hostfactory, typeof(Projects))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Instances", hostfactory, typeof(Instances))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Activity", hostfactory, typeof(Activity))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Search", hostfactory, typeof(Search))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Tasks", hostfactory, typeof(Tasks))); 
     RouteTable.Routes.Add(new ServiceRoute("REST/Documents", hostfactory, typeof(Documents))); 
    } 
    private void StartNotificationServiceHost() 
    { 
     Trace.WriteLine("Starting Service Host", "Information"); 
     NotificationServiceHost serviceHostBase = new NotificationServiceHost(); 
     serviceHostBase.RecycleNotificationRecieved += new RecycleNotificationRecievedEventHandler(ServiceHost_RecycleNotificationRecieved); 
     serviceHostBase.CheckInstanceStatusRecieved += new CheckInstanceStatusRecievedEventHandler(serviceHostBase_CheckInstanceStatusRecieved); 
     ServiceHost = new ServiceHost(serviceHostBase); 
     this.ServiceHost.Faulted += (sender, e) => 
     { 
      Trace.TraceError("Service Host fault occured"); 
      this.ServiceHost.Abort(); 
      Thread.Sleep(500); 
      this.StartNotificationServiceHost(); 

     }; 
     NetTcpBinding binding = new NetTcpBinding(SecurityMode.None); 
     RoleInstanceEndpoint notificationServiceHostEndPoint = RoleEnvironment.CurrentRoleInstance.InstanceEndpoints["NotificationServiceEndPoint"]; 
     this.ServiceHost.AddServiceEndpoint(
      typeof(INotifyService), 
      binding, 
      String.Format("net.tcp://{0}/NotifyService", notificationServiceHostEndPoint.IPEndpoint) 
      ); 
     try 
     { 
      this.ServiceHost.Open(); 
      Trace.TraceInformation("Service Host Opened"); 
     } 
     catch (TimeoutException timeoutException) 
     { 
      Trace.TraceError("Service Host open failure, Time Out: " + timeoutException.Message); 
     } 
     catch (CommunicationException communicationException) 
     { 
      Trace.TraceError("Service Host open failure, Communication Error: " + communicationException.Message); 
     } 
     Trace.WriteLine("Service Host Started", "Information"); 
    } 
     InstanceItem serviceHostBase_CheckInstanceStatusRecieved(object sender, int e) 
     { 
... 
     } 
     void ServiceHost_RecycleNotificationRecieved(object sender, NotificationMessage e) 
     { 
... 

     } 
} 

Web.config/ServiceModel раздел:

<system.serviceModel> 
    <behaviors> 
     <serviceBehaviors> 
     <behavior> 
      <!-- This behavior enables API Key Verification --> 
      <serviceAuthorization serviceAuthorizationManagerType="OfisimCRM.Webservice.APIKeyAuthorization, OfisimCRM.Webservice" /> 
     </behavior> 
     </serviceBehaviors> 
     <endpointBehaviors> 
     <behavior> 
      <webHttp /> 
      <serviceValidator /> 
     </behavior> 
     </endpointBehaviors> 
    </behaviors> 
    <extensions> 
     <behaviorExtensions> 
     <add name="serviceValidator" type="OfisimCRM.Webservice.WebHttpWithValidationBehaviorExtension, OfisimCRM.Webservice, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null" /> 
     </behaviorExtensions> 
    </extensions> 
    <serviceHostingEnvironment multipleSiteBindingsEnabled="true" aspNetCompatibilityEnabled="true" /> 
    <standardEndpoints> 
     <webHttpEndpoint> 
     <!-- 
      Configure the WCF REST service base address via the global.asax.cs file and the default endpoint 
      via the attributes on the <standardEndpoint> element below 
     --> 
     <standardEndpoint crossDomainScriptAccessEnabled="true" faultExceptionEnabled="true" hostNameComparisonMode="WeakWildcard" name="" defaultOutgoingResponseFormat="Json" helpEnabled="true" automaticFormatSelectionEnabled="true" maxBufferSize="65536" maxReceivedMessageSize="104857600" transferMode="Streamed" /> 
     </webHttpEndpoint> 
    </standardEndpoints> 
    </system.serviceModel> 

ServiceDefinition/WebRole:

<WebRole name="OfisimCRM.WebClient" vmsize="Small"> 
    <Sites> 
     <Site name="Web"> 
     <Bindings> 
      <Binding name="Endpoint1" endpointName="Endpoint1" /> 
     </Bindings> 
     </Site> 
    </Sites> 
    <Endpoints> 
     <InputEndpoint name="Endpoint1" protocol="http" port="80" /> 
     <InternalEndpoint name="NotificationServiceEndPoint" protocol="tcp" /> 
    </Endpoints> 
    <Imports> 
     <Import moduleName="Diagnostics" /> 
     <Import moduleName="RemoteAccess" /> 
    </Imports> 
    <ConfigurationSettings> 
    </ConfigurationSettings> 
    </WebRole> 

Ошибка:

The server encountered an error processing the request. The exception message is 'Could not connect to net.tcp://x.x.x.29:8000/NotifyService. The connection attempt lasted for a time span of 00:00:21.0918600. TCP error code 10060: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond x.x.x.29:8000. '. See server logs for more details. 

ответ

6

Доступ к экземплярам ролей ограничен брандмауэром. Обычно экземпляр принимает соединения только из балансировки нагрузки. Вы добавляете параметр в файл определения службы (* .csdef) следующим образом, и необходимо принять соединение.

 
<?xml version="1.0" encoding="utf-8" ?> 
    <ServiceDefinition name="RoleCommunication" xmlns="http://schemas.microsoft.com/ServiceHosting/2008/10/ServiceDefinition"> 
: 
    <NetworkTrafficRules> 
    <OnlyAllowTrafficTo> 
     <Destinations> 
     <RoleEndpoint endpointName="YourEndPointName" roleName="YourRole" /> 
     <Destinations> 
     <WhenSource matches="AnyRole"> 
     <FromRole roleName="YourRole" /> 
     </WhenSource> 
    </OnlyAllowTrafficTo> 
    </NetworkTrafficRules> 
</ServiceDefinition > 

В качестве альтернативы вы можете добавить правильное соединение expresily, используя команду netsh в Startup Task.

ех) Netsh advfirewall брандмауэра добавить имя правила = "YourEndPoint" реж = в действии = позволяют локальный_порт = 80 = протокол TCP

====

Является ли 'InternalEndpoint' динамический порт? Если возможно, не удалось установить фиксированный порт в .csdef и задаче запуска.

экс)

 
<InternalEndpoint name="NotificationServiceEndPoint" protocol="tcp" port="8000"/> 

и

 
netsh advfirewall firewall add rule name="NotificationServiceEndPoint" dir=in action=allow localport=8000 protocol=tcp 

====

Или, переменная окружения можно следующим образом:

 
    <Endpoints> 
     <InputEndpoint name="Endpoint1" protocol="http" port="80" /> 
     <InternalEndpoint name="NotificationServiceEndPoint" protocol="tcp" /> 
    </Endpoints> 

     <Startup> 
      <Task commandLine="configfirewall.cmd" executionContext="elevated" taskType="simple"> 
       <Environment> 
        <Variable name="NotificationServiceEndPointPort" value="/RoleEnvironment/CurrentInstance/Endpoints/Endpoint[@name='NotificationServiceEndPoint']/@port" /> 
       </Environment> 
      </Task> 
     </Startup> 

и Вы можете использовать переменную окружения при запуске задачи

 
netsh advfirewall firewall add rule name="ServiceEndPoint" dir=in action=allow localport=%NotificationServiceEndPointPort% protocol=tcp 
+0

нет, это не сработало. Я добавил свое определение webrole к вопросу. – iboware

+0

Я отредактировал более ранний ответ. –

+0

Я пробовал все ваши предложения. Я удалил все блоки try catch, чтобы легко увидеть ошибку. Тем не менее, я получаю ту же ошибку. Я поставил сообщение об ошибке на мой вопрос. – iboware