Я использую ASP.NET Core 2.1 RC1. Я также использую для этого Signal-R (здесь):
https://docs.microsoft.com/en-us/aspnet/core/signalr/javascript-client?view=aspnetcore-2.1
Я создаю консольное приложение .NET Core, в котором размещается Kestrel и используется Signal-R. Я в значительной степени настроил его точно, как указано в документации по началу работы для настройки Startup.
Все это отлично работает. Я могу подключиться к нему, получить свой HTML-код со сценарием signal-R в нем, получать сообщения, созданные с помощью Clients.All.SendAsync. Работает отлично.
НО Я хочу иметь возможность отправлять сообщения клиентам за пределами Хаба. Когда в моем приложении происходит какое-то событие, и сообщение отправляется клиентам. В полной версии .NET я бы использовал GlobalHost и получил контекст. В ВСЕ мои поисковые запросы в Stack Overflow они ссылаются на то, что больше не работает или используется в контроллере REST API, переданном в IHubContext.
У меня есть прослушиватель событий в моем файле program.cs, и когда событие запускается, я хотел бы иметь возможность отправлять сообщение на свой UserInterfaceHub.
Итак - как мне получить контекст концентратора в Program.CS - чтобы я мог отправлять ему сообщения (вызывать метод SwitchUI) из делегата события, который у меня есть в Program.CS?
StartUp.cs
public void ConfigureServices(IServiceCollection services) {
services.Configure<CookiePolicyOptions>(options => {
options.CheckConsentNeeded = context => true;
options.MinimumSameSitePolicy = SameSiteMode.None;
});
services.AddMvc();
services.AddCors(options => options.AddPolicy("CorsPolicy",
builder => {builder.AllowAnyMethod().AllowAnyHeader().AllowAnyOrigin().AllowCredentials();}));
services.AddSignalR();
var provider = services.BuildServiceProvider();
}
public void Configure(IApplicationBuilder app, IHostingEnvironment env) {
if (env.IsDevelopment()) app.UseDeveloperExceptionPage();
app.UseStaticFiles();
app.UseCookiePolicy();
app.UseCors("CorsPolicy");
app.UseSignalR(routes => {routes.MapHub<UserInterfaceHub>("/uihub");});
app.UseMvc();
//app.Run(async (context) =>{await context.Response.WriteAsync("Active");});
}
Program.CS
CreateWebHostBuilder(args)
.UseKestrel()
.UseUrls("http://0.0.0.0:" + appProperties.HostPort.ToString().Trim())
.UseContentRoot(Directory.GetCurrentDirectory())
.UseIISIntegration()
.Build()
.Start();
UserInterfaceHub.cs
namespace InterfaceModule.Hubs {
public class UserInterfaceHub : Hub {
public async Task SwitchUI(string message) {
await Clients.All.SendAsync("ReceiveEvent", message);
}
public override async Task OnConnectedAsync() {
//await SwitchUI("HOWDY NEW PERSON!");
await base.OnConnectedAsync();
}
}
}
редактировать, добавляя ясности.
В Program.CS у меня есть делегат события: // теперь, когда мы готовы, начинаем слушать. Ждите
deviceClient.SetInputMessageHandlerAsync(ModuleProperties.InputName, OnReceiveEvent, deviceClient);
Console.WriteLine("INIT: Event Message Input handler created: [{0}]", ModuleProperties.InputName);
что это:
static async Task<MessageResponse> OnReceiveEvent(Message message, object userContext) {
//HOW DO I REACH THE HUB FROM HERE SO I CAN SEND A MESSAGE TO THE LISTENERS?
}
