Подключение к Azure SignalR Hub из веб-приложения .Net Framework, консольного приложения - PullRequest
Новая
       13

Подключение к Azure SignalR Hub из веб-приложения .Net Framework, консольного приложения

0 голосов
/ 07 февраля 2019

У меня есть веб-приложение .Net Framework (v 4.6.1), которое в настоящее время использует ASP.Net SignalR.Я пытаюсь добавить еще один SignalR Hub, но разрешить этому подключаться с помощью Azure SignalR Service , чтобы мы могли использовать REST API для отправки односторонних сообщений конечным пользователям.

Я следовал этим примерам здесь и здесь для реализации этой функции.

Есть 3 основные части

  • Подключение кконцентратор ( половина работает)
  • Отправка сообщений через REST API (работает успешно)
  • Получение сообщений от конечного пользователя ( не работает)

Служба Hub и Azure SignalR созданы и просты, отображать их не нужно.

Примеры кода

Подключение к концентратору в .Net Framework Web App Startup.cs 

app.MapAzureSignalR(GetType().FullName, new HubConfiguration { EnableDetailedErrors = true },
    options =>
    {
        options.ConnectionString =
                    ConfigurationManager.ConnectionStrings["AzureSignalR"].ConnectionString;
    });

MapAzureSignalR взято из этого пакета nuget

У меня также есть клиентский JavaScript для обработки соединений и событий хабов, он работает уже несколько месяцев со стандартным ASP.Net SignalR.

Клиентское соединение регистрирует следующую информацию: 

Error: You are using a version of the client that isn't compatible with the server. Client version 1.5, server version 2.0.
at Object.error (jquery.signalR.js:179)
at Object.success (jquery.signalR.js:728)
at i (scripts.bundle.js:2)
at Object.fireWith [as resolveWith] (scripts.bundle.js:2)
at A (scripts.bundle.js:4)
at XMLHttpRequest.<anonymous> (scripts.bundle.js:4)
at XMLHttpRequest.wrapFn (zone.js:1166)
at ZoneDelegate.invokeTask (zone.js:421)
at Zone.runTask (zone.js:188)
at ZoneTask.invokeTask [as invoke] (zone.js:496)

Веб-приложение имеет следующие пакеты: 

  <package id="Microsoft.AspNet.SignalR" version="2.4.0" targetFramework="net461" />
  <package id="Microsoft.AspNet.SignalR.Core" version="2.4.0" targetFramework="net461" />
  <package id="Microsoft.AspNet.SignalR.JS" version="2.4.0" targetFramework="net461" />
  <package id="Microsoft.AspNet.SignalR.SqlServer" version="2.2.2" targetFramework="net45" />
  <package id="Microsoft.AspNet.SignalR.SystemWeb" version="2.4.0" targetFramework="net461" />
  <package id="Microsoft.AspNet.WebApi.Client" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.AspNet.WebApi.Core" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.AspNet.WebApi.Owin" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.AspNet.WebApi.WebHost" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.AspNetCore.Authentication.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Authorization" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Authorization.Policy" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Connections.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Hosting.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Hosting.Server.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Connections" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Connections.Client" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Connections.Common" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Extensions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Http.Features" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Routing" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.Routing.Abstractions" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.SignalR" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.SignalR.Common" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.SignalR.Core" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.SignalR.Protocols.Json" version="1.0.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.WebSockets" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.AspNetCore.WebUtilities" version="2.1.0" targetFramework="net461" />
  <package id="Microsoft.Azure.SignalR" version="1.0.6" targetFramework="net461" />
  <package id="Microsoft.Azure.SignalR.AspNet" version="1.0.0-preview1-10317" targetFramework="net461" />
  <package id="Microsoft.Azure.SignalR.Protocols" version="1.0.6" targetFramework="net461" />

Подключение к концентратору в .Net Framework Console App

var serviceUtils = new ServiceUtils(ConfigurationManager.ConnectionStrings["Azure:SignalR:ConnectionString"].ConnectionString);

var url = GetClientUrl(serviceUtils.Endpoint);

_connection = new HubConnection(url)
{
    ConnectionToken = serviceUtils.GenerateAccessToken(url, userId)
};

IHubProxy proxy = _connection.CreateHubProxy(hubName);

proxy.On("broadcastMessage", (string server, string message) =>
{
    Console.WriteLine($"[{DateTime.Now.ToString()}] Received message from server {server}: {message}");
});


_connection.Start();

При регистрации состояния соединения отображается: Отключено, Соединение, Отключено .

. Пример кода ядра сети. 

var serviceUtils = new ServiceUtils(connectionString);

var url = GetClientUrl(serviceUtils.Endpoint);

_connection = new HubConnectionBuilder()
    .WithUrl(url, options =>
    {
        options.AccessTokenProvider = () =>
            {
                return Task.FromResult(serviceUtils.GenerateAccessToken(url, userId));
            };
    }).Build();

_connection.On("broadcastMessage", (string server, string message) =>
{
    Console.WriteLine($"[{DateTime.Now.ToString()}] Received message from server {server}: {message}");
});

await _connection.StartAsync(CancellationToken.None);

Это успешно соединяет и получает сообщения от моей REST API трансляции (см. Ниже)

REST API Broadcast 

var url = $"{authenticationUtility.Endpoint}/api/v1/hubs/{hubName.ToLower()}";
var request = new HttpRequestMessage
{
    Method = HttpMethod.Post,
    RequestUri = new Uri(url)
};

request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", authenticationUtility.GenerateAccessToken(url, sender));
request.Headers.Accept.Clear();
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
request.Headers.AcceptCharset.Clear();
request.Headers.AcceptCharset.Add(new StringWithQualityHeaderValue("UTF-8"));

var content = JsonConvert.SerializeObject(new MessageContent{ Target = "broadcastMessage", Arguments = new []{ sender, message}});
request.Content = new StringContent(content, Encoding.UTF8, "application/json");
var response = await httpClient.SendAsync(request);

Возвращает 202 Accepted код, как я ожидаю, и отправляет сообщение в консольное приложение .Net Core.

На моем портале Azure я могу видеть соединения, но не могу получать сообщения в концентраторе моего веб-приложенияПодключение

...