Реализация уведомлений SignalR с Angular и C # для конкретного клиента - PullRequest
Новая
       70

Реализация уведомлений SignalR с Angular и C # для конкретного клиента

0 голосов
/ 23 сентября 2019

Я пытаюсь реализовать центр уведомлений SignalR, используя C # и Angular 8 для конкретного клиента.

Я успешно выполнил реализацию уведомления braodcast для конкретного клиента, используя проверку имени пользователя, которая также выполняет широковещательную рассылку всем клиентам и проверку имени пользователя по угловому коду.

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

Я делюсь кодом, который я пробовал, используя имя пользователя, но мне нужны некоторые настройкинаоборот (может быть, путем регистрации идентификатора соединения / имени пользователя).Пожалуйста, нужна ваша поддержка.

Я уже проверил все сообщения от stackoverflow, но не дал конкретного ответа на него.

package.json: 

{
  "name": "angular-client",
  "version": "0.0.0",
  "scripts": {
    "ng": "ng",
    "start": "ng serve",
    "build": "ng build",
    "test": "ng test",
    "lint": "ng lint",
    "e2e": "ng e2e"
  },
  "private": true,
  "dependencies": {
    "@angular/animations": "~7.2.0",
    "@angular/common": "~7.2.0",
    "@angular/compiler": "~7.2.0",
    "@angular/core": "~7.2.0",
    "@angular/forms": "~7.2.0",
    "@angular/platform-browser": "~7.2.0",
    "@angular/platform-browser-dynamic": "~7.2.0",
    "@angular/router": "~7.2.0",
    "@aspnet/signalr": "^1.1.4",
    "core-js": "^2.5.4",
    "font-awesome": "^4.7.0",
    "primeicons": "^1.0.0",
    "primeng": "^8.0.0-rc.1",
    "rxjs": "~6.3.3",
    "tslib": "^1.9.0",
    "zone.js": "~0.8.26"
  },
  "devDependencies": {
    "@angular-devkit/build-angular": "~0.13.0",
    "@angular/cli": "~7.3.8",
    "@angular/compiler-cli": "~7.2.0",
    "@angular/language-service": "~7.2.0",
    "@types/node": "~8.9.4",
    "@types/jasmine": "~2.8.8",
    "@types/jasminewd2": "~2.0.3",
    "codelyzer": "~4.5.0",
    "jasmine-core": "~2.99.1",
    "jasmine-spec-reporter": "~4.2.1",
    "karma": "~4.0.0",
    "karma-chrome-launcher": "~2.2.0",
    "karma-coverage-istanbul-reporter": "~2.0.1",
    "karma-jasmine": "~1.1.2",
    "karma-jasmine-html-reporter": "^0.2.2",
    "protractor": "~5.4.0",
    "ts-node": "~7.0.0",
    "tslint": "~5.11.0",
    "typescript": "~3.2.2"
  }
}

Angular -app.component.ts 

import { Component, OnInit } from '@angular/core';
import { MessageService } from 'primeng/api';

import * as signalR from '@aspnet/signalr';

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css'],
  providers: [MessageService]
})
export class AppComponent implements OnInit {

  constructor(private messageService: MessageService) { }

  ngOnInit(): void {
    const connection = new signalR.HubConnectionBuilder()
      .configureLogging(signalR.LogLevel.Information)
      .withUrl("http://localhost:5627/notify")
      .build();

    connection.start().then(function () {
      console.log('Connected!');
    }).catch(function (err) {
      return console.error(err.toString());
    });

    connection.on("BroadcastMessage", (type: string, payload: string, username: string) => {
      console.log("username:"+username);
      if(username == 'myuser') {
        this.messageService.add({ severity: type, summary: payload, detail: 'Via Apointment - '+username });
      }
    });
  }
}

C # - MessageController.ts: 

using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.SignalR;
using SignalRHub;
using System;

namespace SignalR_Hub.Controllers
{
    [Route("api/message")]
    [ApiController]
    public class MessageController : ControllerBase
    {
        private IHubContext<NotifyHub, ITypedHubClient> _hubContext;

        public MessageController(IHubContext<NotifyHub, ITypedHubClient> hubContext)
        {
            _hubContext = hubContext;
        }

        [HttpPost]
        public string Post([FromBody]Message msg)
        {
            string retMessage;



            try
            {
                // For Broadcasting
                //_hubContext.Clients.All.BroadcastMessage(msg.Type, msg.Payload);
                //retMessage = "Success";

                // For Specific Client
                _hubContext.Clients.All.BroadcastMessage(msg.Type, msg.Payload, msg.Username);
                retMessage = "Success";
            }
            catch (Exception e)
            {
                retMessage = e.ToString();
            }

            return retMessage;
        }
    }
}

Запрос с использованием сервиса RestFul: 

{
 "Type": "info",
 "Payload": "One new Client is waiting for you.",
 "username": "myuser"
}

Пожалуйста, дайте мне знать, если вам нужнолюбая информация.

1 Ответ

0 голосов
/ 23 сентября 2019

Я полагаю, что на этот вопрос здесь был дан ответ:

сигнализатор, отправляющий сообщение конкретному пользователю

Вы можете использовать идентификатор соединенияи сопоставьте его с и connectionID и пользователем.

...