websocket Blazor未接收在服务器端创建的信号

w6lpcovy  于 2023-06-06  发布在  其他
关注(0)|答案(2)|浏览(126)

下面的例子我在服务器端调用,但客户端不接收,有时它工作,但有时它不工作(更多的不工作比它的工作)
这应该是非常简单的,但它不是,任何建议将帮助我这么多!

服务器端

public class Startup
{
    public Startup(IConfiguration configuration)
    {
        Configuration = configuration;
    }

    public IConfiguration Configuration { get; }

    // This method gets called by the runtime. Use this method to add services to the container.
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddControllers().AddNewtonsoftJson(options =>
        {
            options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
        });

        var connection = @"data source=comandai.database.windows.net;initial catalog=HojeTaPago;persist security info=True;user id=Comandai;password=Ck@21112009;MultipleActiveResultSets=True;";
        services.AddDbContext<ComandaiContext>(options => options.UseSqlServer(connection));

        services.AddSignalR(options => options.KeepAliveInterval = TimeSpan.FromSeconds(5));

        services.Configure<CookiePolicyOptions>(options =>
        {
            options.CheckConsentNeeded = context => true;
            options.MinimumSameSitePolicy = SameSiteMode.None;
        });

        services.AddResponseCompression(opts =>
        {
            opts.MimeTypes = ResponseCompressionDefaults.MimeTypes.Concat(
                new[] { "application/octet-stream" });
        });

        services.AddSwaggerGen(c =>
        {
            c.SwaggerDoc("v1", new OpenApiInfo { Title = "HojeTaPago API", Version = "v1" });
            c.AddSecurityDefinition("basic", new OpenApiSecurityScheme
            {
                Name = "Authorization",
                Type = SecuritySchemeType.Http,
                Scheme = "basic",
                In = ParameterLocation.Header,
                Description = "Basic Authorization header using the Bearer scheme."
            });

            c.AddSecurityRequirement(new OpenApiSecurityRequirement
            {
                {
                      new OpenApiSecurityScheme
                        {
                            Reference = new OpenApiReference
                            {
                                Type = ReferenceType.SecurityScheme,
                                Id = "basic"
                            }
                        },
                        new string[] {}
                }
            });
        });

        services.AddCors(options => options.AddPolicy("CorsPolicy",
        builder =>
        {
            builder.AllowAnyMethod().AllowAnyHeader()
                   .AllowCredentials();
        }));
    }

    // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        app.UseResponseCompression();

        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }

        // Enable middleware to serve generated Swagger as a JSON endpoint.
        app.UseSwagger();

        // Enable middleware to serve swagger-ui (HTML, JS, CSS, etc.),
        // specifying the Swagger JSON endpoint.
        app.UseSwaggerUI(c =>
        {
            c.SwaggerEndpoint("/swagger/v1/swagger.json", "HojeTaPago API V1");
            c.RoutePrefix = string.Empty;
        });

        app.UseHttpsRedirection();

        app.UseRouting();

        app.UseCors("CorsPolicy");

        app.UseAuthentication();

        app.UseAuthorization();

        app.UseMiddleware<AuthenticationMiddleware>();

        app.UseEndpoints(endpoints =>
        {
            endpoints.MapHub<NovoPedidoHub>("/novopedidohub");
            endpoints.MapControllers();
        });
    }
}

我在哪里使用信号r

await _novoPedidoContext.Clients.All.SendAsync("NovoPedido", ListaComandaItem);

客户端- Blazor

public class Startup
{
    public Startup(IConfiguration configuration)
    {
        Configuration = configuration;
    }

    public IConfiguration Configuration { get; }

    // This method gets called by the runtime. Use this method to add services to the container.
    // For more information on how to configure your application, visit https://go.microsoft.com/fwlink/?LinkID=398940
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddRazorPages();
        services.AddServerSideBlazor();
        services.AddBlazoredLocalStorage();
        services.AddBootstrapCss();
        services.AddTransient<HubConnectionBuilder>();
    }

    // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }
        else
        {
            app.UseExceptionHandler("/Error");
            // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
            app.UseHsts();
        }

        app.UseHttpsRedirection();
        app.UseStaticFiles();

        app.UseRouting();

        app.UseEndpoints(endpoints =>
        {
            endpoints.MapBlazorHub();
            endpoints.MapFallbackToPage("/_Host");
        });
    }
}

在那里我叫。

protected override async Task OnInitializedAsync()
{
    DataService dataService = new DataService();
    PedidosParaAceitar = new List<Comanda>(await dataService.BuscarComandasAbertas());

    connection = _hubConnectionBuilder.WithUrl(dataService.servidor + "novopedidohub",
        opt =>
        {
            opt.Transports = HttpTransportType.WebSockets;
            opt.SkipNegotiation = true;
        }).Build();

    connection.On<List<ComandaItem>>("NovoPedido", async lista =>
    {
        var idEstabelecimento = await localStorage.GetItemAsync<int>("IdEstabelecimento");

        if (lista.FirstOrDefault().Comanda.IdEstabelecimento == idEstabelecimento)
        {
            if (PedidosParaAceitar == null)
                PedidosParaAceitar = new List<Comanda>();

            if (PedidosParaAceitar.Count(x => x.Id == lista.FirstOrDefault().IdComanda) > 0)
                foreach (var comandaitem in lista)
                {
                    PedidosParaAceitar.FirstOrDefault(x => x.Id == lista.FirstOrDefault().IdComanda).ComandaItem.Add(comandaitem);
                }
            else
                PedidosParaAceitar.Add(await dataService.BuscarComandaAberta(lista.FirstOrDefault().IdComanda));

            StateHasChanged();
        }
    });

    await connection.StartAsync();
}

nr9pn0ug

nr9pn0ug1#

您没有在标记中指定这是客户端(WASM)还是服务器端Blazor。
在看这个问题时,我注意到ConfigureServices中的这一行:

services.AddServerSideBlazor();

因此,您正在尝试使用SignalR,这是一个来自服务器的 * 客户端通信库 *。在服务器端Blazor中,所有C#代码都在服务器上运行。在这方面,SignalR是冗余的,因为Blazor已经使用它来在客户端和服务器之间进行通信。
幸运的是,我最近写了一个应用程序来测试这一点。我创建了一个服务器端的Blazor应用,并编写了这个服务:

public class TalkService
    {
        public TalkService()
        {
            history = new List<string>();
        }

        public Action<string> OnChange { get; set; }

        // inform all users of new message
        public Task SendAsync(string message)
        {
            // add to history
            history.Add(message);
            // ensure only last 10 shown
            if (history.Count > 10) history.RemoveAt(0);
            OnChange.Invoke(message);
            return Task.FromResult(0);
        }

        private readonly List<string> history;

        public IReadOnlyList<string> GetHistory() => history;
    }

然后我在Startup.cs中的ConfigureServices()方法中将其注册为服务器上的Singleton(所有客户端使用相同的服务):

services.AddSingleton<TalkService>();

然后重写Index.razor如下:

@page "/"
@inject TalkService service

<p>Talk App started</p>

<p>Send a message: <input type="text"@bind="@message" />
    <button class="btn btn-sm btn-primary" @onclick="Send"  >Send</button>
    </p>

@foreach (var m in messages)
{
    <p>@m</p>
}
@code {
    string message;

    async Task Send()
    {
        if(!string.IsNullOrWhiteSpace(message))
            await service.SendAsync(message);
        message = string.Empty;
    }

    List<string> messages;

    protected override void OnParametersSet()
    {
        // load history
        messages = service.GetHistory().ToList();

        // register for updates
        service.OnChange += ChangeHandler;
    }

    protected void ChangeHandler(string message)
    {
        messages.Add(message);
        InvokeAsync(StateHasChanged);
    }
}

谈话服务当然是一个基本的“聊天”示例。它是一个Singleton,所以所有引用它的页面/客户端都使用相同的示例。该服务有一个简单的事件OnChange,客户端(如Index页面)可以侦听其他位置的更改。
SignalR不需要这个应用程序,因为它已经“存在”的服务器端。

Demo App

演示应用程序还有一个后台服务,可以生成时间消息。我已经把这个推到GitHub上作为指导:
https://github.com/conficient/BlazorServerWithSignalR

qhhrdooz

qhhrdooz2#

我有一个类似的问题,你和发现的问题,通过添加错误处理的signalR连接。当我这样做的时候,我发现我在如何处理我的消息方面有一个错误,这个错误只是被连接吞掉了。
我建议在创建连接时添加.ConfigureLogging(x => x.AddApplicationInsights()),如下所示:

connection = _hubConnectionBuilder.WithUrl(dataService.servidor + "novopedidohub",
    opt =>
    {
        opt.Transports = HttpTransportType.WebSockets;
        opt.SkipNegotiation = true;
    })
.ConfigureLogging(x => x.AddApplicationInsights())
.Build();

相关问题