0

我对asp.net-core上的signalr2不太熟悉，请原谅我，我正在尝试创建一个关于如何使用signalr2与管理员和客户端实现实时CRUD应用程序的POC，但是我遇到了signalr数据推送的问题，我继续走NullReferenceException: Object reference not set to an instance of an object.这条线await Clients.All.SendAsync("BroadcastData", data);

以下是我使用查找的一些在线示例设置集线器的方法：

public class OddPublisher : Hub
    {

        private readonly IOddServices _oddService;

        public OddPublisher(IOddServices oddService)
        {
            _oddService = oddService;
        }

        public async Task BroadcastData()
        {
            var data = _oddService.ClientQueryOdds();
            await Clients.All.SendAsync("BroadcastData", data); //breaks here
        }

    }

这是由管理员触发的，在成功提交和保存数据时，我调用BroadcastData()

    public class BaseController : Controller
    {
        public IOddServices _oddService;
        public readonly OddPublisher _publisher;
        public BaseController(IOddServices oddService, )
        {
            _oddService = oddService;
            _teamService = teamService;

            _publisher = new OddPublisher(oddService);
        }


        [HttpPost]
        public async Task<IActionResult> odd_entry(CreateOdd dto)
        {
            //somecode here...

            var results = _validator.Validate(dto);

            if(!results.IsValid)
            {
                results.AddToModelState(ModelState, null);

                return View(dto);
            }

            _oddService.CreateOddAndTeam(dto);

            await _publisher.BroadcastData(); //Breaks

            return RedirectToAction(nameof(index));
        }
    }

按照 Microsoft Asp.Net Core Signalr 文档中建议的所有说明进行操作，我的 Startup 已添加所有必需的服务。

这是客户端和JS文件，

"use strict";

var connection = new signalR.HubConnectionBuilder().withUrl("/oddPublisher").build();

connection.on("BroadcastData", data => {

    console.table(data);
    //getAll();
})


connection.start().then(function () {
    getAll();
}).catch(function (err) {
    return console.error(err.toString());
});


function getAll() {
    var model = $('#dataModel');
    $.ajax({
        url: '/home/GetLatestOddData',
        contentType: 'application/html ; charset:utf-8',
        type: 'GET',
        dataType: 'html',
        success: function (result) { model.empty().append(result); }
    });
}

在这里需要一些帮助，我仍然不知道做错了什么，如果我能得到任何帮助，我将不胜感激。

先感谢您。

4

1 回答 1

0

事实证明，我需要将 IHubContext 注入到我的集线器中才能访问客户端。

于 2019-06-16T10:10:18.337 回答