Как я могу отправить сообщение конкретному пользователю с ядром signalR в asp.netcore - PullRequest
Новая
       14

Как я могу отправить сообщение конкретному пользователю с ядром signalR в asp.netcore

0 голосов
/ 16 июня 2019

У меня проблемы с ядром сигнала R, я не могу отправить сообщение конкретному пользователю из концентратора.Я хочу сделать так:

Мне нужно отправить сообщение конкретному пользователю в концентраторе, но я отправил сообщение всем пользователям, подключенным в концентраторе, затем отфильтровал его в файле сценариев Java, а затем добавить элемент сообщения всписок по номеру 

public JsonResult SendMessage(string id, string messagetext)
{
   _hubContext.Clients.All.SendAsync("LoadData", id, messagetext);
   return Json(1);
}

connection.on("LoadData", function (id,messageText) {
   var MyId = $('#UserIdLoggedIn').val();
   var message = messageText;
   if (MyId == id) {
       //appending 
           $("#header ul").append('<li class="him">' + message + '</li>');
       //appending end
   }
});

1 Ответ

0 голосов
/ 16 июня 2019

Чтобы отправить сообщение конкретному пользователю, вам нужно иметь идентификатор соединения

Сначала я определю Hub, чтобы код js мог вызывать веб-сервер 

public class ConnectionHub : Hub
    {
        public async Task Send(string userId)
        {
            var message = $"Send message to you with user id {userId}";
            await Clients.Client(userId).SendAsync("ReceiveMessage", message);
        }

        public string GetConnectionId()
        {
            return Context.ConnectionId;
        }
    }

Тогда в моем startup.cs 

        public void ConfigureServices(IServiceCollection services)
        {
            services.Configure(options =>
            {
                options.CheckConsentNeeded = context => true;
                options.MinimumSameSitePolicy = SameSiteMode.None;
            });

services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
            services.AddSignalR();
        }

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
            else
            {
                app.UseExceptionHandler("/Home/Error");
            }

            app.UseStaticFiles();
            app.UseCookiePolicy();
            app.UseSignalR(routes =>
            {
                routes.MapHub<ConnectionHub>("/connectionHub");
            });
            app.UseMvc(routes =>
            {
                routes.MapRoute(
                    name: "default",
                    template: "{controller=Home}/{action=Index}/{id?}");
            });
        }

Наконец, в Index.cshtml у меня будет код ниже 

(function () {
        var connection = new signalR.HubConnectionBuilder().withUrl("/connectionHub").build();

        connection.start().then(function () {
            console.log("connected");

            connection.invoke('getConnectionId')
                .then(function (connectionId) {
                    sessionStorage.setItem('conectionId', connectionId);
                    // Send the connectionId to controller
                }).catch(err => console.error(err.toString()));;


        });

        $("#sendmessage").click(function () {
            var connectionId = sessionStorage.getItem('conectionId');
            connection.invoke("Send", connectionId);
        });

        connection.on("ReceiveMessage", function (message) {
            console.log(message);
        });

    })();

Вы можете прочитать мой полный блог здесь

...