Blazor Serverでchat実装したいが特定ユーザーへの送信ができない

Question

実現したいこと

特定のユーザー向けにメッセージを送信したい

発生している問題・分からないこと

Clients.Allにて全員に送信できることはできている
受信もできているので基本的なコードは間違っていない

問題は await Clients.Users(targetIds).SendAsyncで特定のUserIDに送信したいがそこが上手くいかない

public override Task OnConnectedAsync()
{
Console.WriteLine($"SignalR接続: UserIdentifier = {Context.UserIdentifier}");
return base.OnConnectedAsync();
}

public class CustomUserIdProvider : IUserIdProvider
{
public string? GetUserId(HubConnectionContext connection)
{
var userId = connection.User?.FindFirst(ClaimTypes.NameIdentifier)?.Value;
return string.IsNullOrWhiteSpace(userId) ? null : userId;
}
}
の部分でIDがNullになっている
このページを開いている段階で自身のIDが取れていない＝SignalRも認識できない
とのことになるのかなと思っています

@rendermode InteractiveServerで実現はしたいが、BlazorServerだとそもそもHubは使わないなど
情報がどっちが正しいのか不明です

Blazor は初心者です　約３か月です
C#は独学ですが５年ほどしていますがAsp netなどWebシステムは初めて構築しています
基本はAzure系をベースにしています　AzureApp / Azure SQL Database / Azure Storage
やりたいことはほぼ実現できるまで学習しましたが、特定ユーザー向けChatで引っかかっています

該当のソースコード

@page "/chat/{InquiryId:int}"

@rendermode InteractiveServer

@using Microsoft.AspNetCore.SignalR.Client
@using System.Security.Claims
@using Microsoft.AspNetCore.SignalR
@using HpqWebApp.Hubs

@inject IChatService ChatService
@inject UserManager<ApplicationUser> UserManager
@inject AuthenticationStateProvider AuthenticationStateProvider
@inject NavigationManager NavigationManager
@inject IHubContext<ChatHub> HubContext

<PageTitle>Chat</PageTitle>

<h3>問い合わせID: @InquiryId</h3>

<ul>
    @foreach (var m in Messages)
    {
        <li><b>@m.SentUserId:</b> @m.Text (@m.SentAt.ToShortTimeString())</li>
    }
</ul>

<input @bind="SentName" placeholder="送信者" />
<input @bind="MessageText" @onkeydown="HandleKeyPress" placeholder="メッセージを入力" />
<button @onclick="SendMessage">送信</button>

@code {

    [Parameter] public int InquiryId { get; set; }

    private HubConnection? hubConnection;

    private string CurrentUser { get; set; }
    private string UserRole = "A_User";
    private string HdwCode;
    private string MessageText { get; set; }
    private string SentName { get; set; }

    private List<ChatMessageDetailDto> Messages = new();

    protected override async Task OnInitializedAsync()
    {
        var user = await AuthenticationStateProvider.GetCurrentUserAsync(UserManager);
        if (user is null)
        {
            return;
        }

        //現在ユーザー取得
        CurrentUser = user.Id;

        //Hub設定
        hubConnection = new HubConnectionBuilder()
        .WithUrl(NavigationManager.ToAbsoluteUri("/chathub"))
        .Build();

        //履歴取得
        Messages = await ChatService.GetChatMessagesAsync(InquiryId);

        //受信設定
        hubConnection.On<string, string, int>("ReceiveMessage", (sentName, message, inquiryId) =>
        {
            var msg = new ChatMessageDetailDto
                {
                    InquiryId = inquiryId,
                    Text = message,
                    SentUserName = sentName
                };

            Messages.Add(msg);
            InvokeAsync(StateHasChanged);
        });

        await hubConnection.StartAsync();

    }

    /// <summary>
    /// メッセ―ジ送信
    /// </summary>
    /// <returns></returns>
    private async Task SendMessage()
    {
        if (string.IsNullOrWhiteSpace(MessageText)) return;

        var msg = new ChatMessageDetailDto
            {
                InquiryId = InquiryId,
                Text = MessageText,
                SentUserName = SentName,
                RoleName = UserRole,
                SentUserId = CurrentUser
            };

        //表示
        Messages.Add(msg);

        await ChatService.SaveMessageAsync(msg);

        // SignalR で対象ユーザーに送信
        if (hubConnection is not null)
        {
            await hubConnection.SendAsync("SendMessage", CurrentUser, SentName, MessageText, InquiryId);
        }

        MessageText = string.Empty;

    }

    private async Task HandleKeyPress(KeyboardEventArgs e)
    {
        if (e.Key == "Enter")
            await SendMessage();
    }
}

 public class ChatHub(
    UserManager<ApplicationUser> userManager,
    IChatService chatService) : Hub
 {
     private readonly UserManager<ApplicationUser> _userManager = userManager;
     private readonly IChatService _chatService = chatService;

     //接続時に UserIdentifier がどうなっているか確認
     public override Task OnConnectedAsync()
     {
         Console.WriteLine($"SignalR接続: UserIdentifier = {Context.UserIdentifier}");
         return base.OnConnectedAsync();
     }

     public async Task SendMessage(string senderId, string sentName, string messageText, int inquiryId)
     {
         //送信UserID     
         var sender = await _userManager.FindByIdAsync(senderId!);
         if (sender == null) return;

         //ロール取得
         var roles = await _userManager.GetRolesAsync(sender);
         var userRole = roles.FirstOrDefault() ?? "User";

         List<ApplicationUser> targetUsers;

         if (userRole == "User")
         {
             // 一般ユーザー → 管理者 or SVR へ
             var adminUsers = await _userManager.GetUsersInRoleAsync("Admin");
             var svrUsers = await _userManager.GetUsersInRoleAsync("SVR");

             // 例: BaseCode が一致する管理者/SVR のみに通知
             var filteredAdmins = adminUsers.Where(u => u.BaseCode == sender.BaseCode);
             var filteredSvrs = svrUsers.Where(u => u.BaseCode == sender.BaseCode);

             targetUsers = filteredAdmins.Concat(filteredSvrs).ToList();
         }
         else
         {
             // 管理者 or SVR → 一般ユーザー側へ
             targetUsers = await _chatService.GetInquiryUsersAsync(inquiryId);
         }

         // 宛先の UserId リスト
         var targetIds = targetUsers.Select(u => u.Id).Distinct().ToList();

         // 宛先ユーザーのみへ送信
         await Clients.Users(targetIds).SendAsync("ReceiveMessage", sentName, messageText, inquiryId);

         await Clients.All.SendAsync("ReceiveMessage", sentName, messageText, inquiryId);
     }
 }

試したこと・調べたこと

• teratailやGoogle等で検索した
• ソースコードを自分なりに変更した
• 知人に聞いた
• その他

上記の詳細・結果

ChatGPTやCopilotにも聞いたが上手くいかない
そもそもページを開く段階で
public override Task OnConnectedAsync()
public string? GetUserId(HubConnectionContext connection)
が２回呼ばれ、２回目はNullになってしまう

補足

特になし

Answer 1

自己解決しました
自己解釈ですが、Blazor ServerではClients.Groupでないと送信できない

ChatPageで自身のConnectionIdを登録

    hubConnection = new HubConnectionBuilder()
         .WithUrl(NavigationManager.ToAbsoluteUri($"/chathub?user={User.Id}&inq={InquiryId}"))
         .Build();

これでグループにログイン者のConnectionIdが登録される

登録したグループを下記で送信

 await hubConnection.SendAsync("SendMessageToInquiry", User.Id, SentName, InputMessageText, InquiryId);

リアルタイムで受信・更新できました
一先ず正規なやり方か分かりませんが、デバッグ環境、本番環境でもできました

Hubは下記です

public quiryId);class ChatHub() : Hub
{
    public override async Task OnConnectedAsync()
    {
        var http = Context.GetHttpContext();
        var userId = http?.Request.Query["user"];
        var inquiryId = http?.Request.Query["inq"];

        // 問い合わせIDがある場合 → グループに登録
        if (!string.IsNullOrEmpty(inquiryId))
        {
            var connectid = Context.ConnectionId;
            await Groups.AddToGroupAsync(Context.ConnectionId, $"INQ_{inquiryId}");
            Console.WriteLine($"User {userId} joined group INQ_{inquiryId} ConeId_{connectid}");
        }

        await base.OnConnectedAsync();
    }

    public async Task SendMessageToInquiry(string senderId, string sentName, string messageText, int inquiryId)
    {
        // 同じグループに登録した全員へ送信
        await Clients.Group($"INQ_{inquiryId}").SendAsync("ReceiveMessage", sentName, messageText + "S", inquiryId);
    }
}

ChatPage.razor

    protected override async Task OnInitializedAsync()
    {
        var user = await AuthenticationStateProvider.GetCurrentUserAsync(UserManager);
        if (user is null)
        {
            return;
        }

        User = user;

        //問合IDを元にグループチャット
        hubConnection = new HubConnectionBuilder()
             .WithUrl(NavigationManager.ToAbsoluteUri($"/chathub?user={User.Id}&inq={InquiryId}"))
             .Build();

        //履歴取得
        ChatMessages = await ChatService.GetChatMessagesAsync(InquiryId);

        // メッセージ受信イベント登録
        hubConnection.On<string, string, int>("ReceiveMessage", (sentName, message, inquiryId) =>
        {
            var msg = new ChatMessageDetailDto
                {
                    InquiryId = inquiryId,
                    Text = message,
                    SentUserName = sentName
                };

            ChatMessages.Add(msg);
            InvokeAsync(StateHasChanged);
        });

        await hubConnection.StartAsync();
    }

 /// <summary>
 /// メッセ―ジ送信
 /// </summary>
 /// <returns></returns>
 private async Task SendMessage()
 {

     if (string.IsNullOrWhiteSpace(InputMessageText)) return;

     var msg = new ChatMessageDetailDto
         {
             InquiryId = InquiryId,
             Text = InputMessageText,
             SentUserName = SentName,
             RoleName = UserRole,
             SentUserId = User.Id
         };

     // DBに保存
     await ChatService.SaveMessageAsync(msg);

     // SignalRで送信（接続状態を確認）
     if (hubConnection is not null)
     {
         if (hubConnection.State != HubConnectionState.Connected)
         {
             try
             {
                 // 接続がまだならStartAsyncで接続
                 await hubConnection.StartAsync();
             }
             catch
             {
                 // 接続失敗時はログ出力だけにして続行
                 Console.WriteLine("SignalR接続失敗: メッセージ送信できませんでした");
                 return;
             }
         }

         // 接続済みなら送信
         await hubConnection.SendAsync("SendMessageToInquiry", User.Id, SentName, InputMessageText, InquiryId);
     }

     // 入力クリア
     InputMessageText = string.Empty;

 }