YoyoMooc.StuManagement.Web/Pages/ChatMessageBase.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.AspNetCore.Components;
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.Extensions.Configuration;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace YoyoMooc.StuManagement.Web.Pages
{
    public class ChatMessageBase : ComponentBase
    {
        protected HubConnection _hubConnection;

        [Inject]
        public IConfiguration Configuration { get; set; }

        protected List<string> _messages = new List<string>();
        protected string _userInput;
        protected string _messageInput;

        [Inject]
        private NavigationManager NavigationManager { get; set; }

        protected async override Task OnInitializedAsync()
        {
            var baseaddress = Configuration["webAddress"] + "chatHub";
            //"http://localhost:3368/chatHub"

            _hubConnection = new HubConnectionBuilder()
                .WithUrl(NavigationManager.ToAbsoluteUri(baseaddress))
                .Build();

            _hubConnection.On<string, string>("ReceiveMessage", (user, message) =>
            {
                var encodedMsg = $"{user}: {message}";
                _messages.Add(encodedMsg);
                StateHasChanged();
            });

            await _hubConnection.StartAsync();
        }

        protected async Task Send()
        {
            await _hubConnection.SendAsync("SendMessage", _userInput, _messageInput);
        }

        public bool IsConnected =>
            _hubConnection.State == HubConnectionState.Connected;
    }
}