C#的SignalR技术是什么?实现Web实时通信的C# SignalR框架教程

来源:这里教程网 时间:2026-02-21 17:31:38 作者:

SignalR 是 ASP.NET 的一个开源库,它简化了在 Web 应用中添加实时功能的过程。通过 SignalR,服务器可以主动向客户端推送数据,而不需要客户端频繁轮询。这使得开发聊天应用、实时仪表盘、通知系统等变得非常高效和简单。

SignalR 是什么?

SignalR 是 C# 中用于实现 Web 实时通信的框架,属于 ASP.NET 生态的一部分。它封装了底层通信细节(如 WebSocket、Server-Sent Events、长轮询等),自动选择最佳传输方式,让开发者专注于业务逻辑。

主要特点包括:

自动连接管理:客户端连接、断开、重连都由 SignalR 自动处理。 双向通信:服务器可随时调用客户端方法,客户端也能调用服务器端方法。 跨平台支持:支持 .NET 客户端、JavaScript 客户端,甚至可通过 REST 调用触发广播。 高扩展性:可集成 Redis 等后端实现多服务器负载均衡。

创建一个简单的 SignalR 实时聊天示例

下面通过一个基础聊天室例子,演示如何使用 SignalR 实现服务端与前端的实时通信。

1. 创建 ASP.NET Core 项目

使用命令行创建新项目:

dotnet new web -n ChatApp

进入项目目录并添加 SignalR 包(.NET 6+ 已内置):

cd ChatApp

2. 创建 Hub 类

Hub 是 SignalR 的核心类,负责处理客户端和服务端之间的消息传递。

新建文件

ChatHub.cs

using Microsoft.AspNetCore.SignalR;
<p>public class ChatHub : Hub
{
public async Task SendMessage(string user, string message)
{
await Clients.All.SendAsync("ReceiveMessage", user, message);
}
}</p>

上面代码定义了一个

SendMessage
方法,当被调用时,会将消息广播给所有连接的客户端(通过
ReceiveMessage
方法)。

3. 配置 Startup(或 Program.cs)

Program.cs
中注册 SignalR 服务和路由:

var builder = WebApplication.CreateBuilder(args);
<p>// 添加 SignalR 服务
builder.Services.AddSignalR();</p><p>var app = builder.Build();</p><p>app.UseStaticFiles(); // 支持 wwwroot 下的静态文件</p><p>app.MapHub<ChatHub>("/chathub");</p><p>app.Run();</p>

4. 添加前端页面

在项目根目录创建

wwwroot/index.html

<!DOCTYPE html>
<html>
<head>
    <title>SignalR 聊天室</title>
</head>
<body>
    <input type="text" id="userInput" placeholder="用户名" />
    <input type="text" id="messageInput" placeholder="输入消息" />
    <button onclick="sendMessage()">发送</button>
    <ul id="messagesList"></ul>
<pre class='brush:php;toolbar:false;'><!-- 引入 SignalR JavaScript 客户端 -->
<script src="https://cdnjs.cloudflare.com/ajax/libs/microsoft-signalr/7.0.0/signalr.min.js"></script>
<script>
    const connection = new signalR.HubConnectionBuilder()
        .withUrl("/chathub")
        .build();
    // 启动连接
    connection.start().catch(err => console.error(err));
    // 接收消息
    connection.on("ReceiveMessage", function (user, message) {
        const li = document.createElement("li");
        li.textContent = `${user}: ${message}`;
        document.getElementById("messagesList").appendChild(li);
    });
    // 发送消息到服务器
    function sendMessage() {
        const user = document.getElementById("userInput").value;
        const message = document.getElementById("messageInput").value;
        connection.invoke("SendMessage", user, message).catch(err => console.error(err));
    }
</script>

相关推荐

热文推荐