Azure SignalR服务：客户端间消息端到端加密及群组消息安全实现问询

我有一个用于和无服务器Azure SignalR服务协商的Azure HTTP触发函数，协商代码如下：

var hubConnection = new HubConnectionBuilder()
                .WithUrl("http://localhost:7071", options =>
                {
                    options.Headers.Add("x-ms-signalr-userid", SystemUserId!);
                    options.Headers.Add("x-functions-key", ConnectionParameters!.SecretKey!);
                })
                .WithAutomaticReconnect([TimeSpan.Zero, TimeSpan.Zero, TimeSpan.FromMilliseconds(5)])
                .Build();

消息通过Upstream在已连接的客户端之间收发，但发现消息是明文传输的，服务器端可以直接读取。Upstream函数伪代码如下：

[Function("SendMessage")]
[SignalROutput(HubName = "MyHub")]
public SignalRMessageAction SendMessageToUser([SignalRTrigger("MyHub", "Category", "msgSent", "username", "message")] SignalRInvocationContext invocationContext, string username, string message)
{
    return new SignalRMessageAction() { .... }
}

请问如何实现类似WhatsApp的端到端加密机制提升隐私性？另外，如何保障群组消息仅群组内用户可读？

一、实现端到端加密（E2EE） #

端到端加密的核心是只有发送方和接收方持有解密密钥，服务器仅作为消息中转，无法读取明文内容。结合你的Azure SignalR场景，可按以下步骤实现：

1. 密钥交换机制 #

• 使用**椭圆曲线加密（ECDH）**作为密钥交换方案：每个客户端生成一对EC密钥对，公钥上传到服务器（仅用于其他客户端获取），私钥本地存储。
• 单聊场景：发送方先获取接收方的公钥，通过ECDH协商出共享密钥，再用对称加密算法（比如AES-GCM）加密消息内容后发送。
• 群组场景：可以指定群管理员生成群密钥，通过单聊E2EE通道分发给每个群成员；或者使用基于签名的群密钥协商方案，确保只有群成员能获取有效密钥。

2. 客户端加密/解密逻辑修改 #

发送消息前，客户端先对消息内容加密：

// 伪代码：客户端加密消息
string plainTextMessage = "要发送的内容";
byte[] sharedKey = GetSharedKeyWithReceiver(receiverUserId); // 通过ECDH获取的共享密钥
byte[] encryptedMessage = AesGcmEncrypt(plainTextMessage, sharedKey);
// 将加密后的字节数组转为Base64字符串，方便传输
string encryptedMessageStr = Convert.ToBase64String(encryptedMessage);
// 发送加密后的消息
await hubConnection.SendAsync("msgSent", username, encryptedMessageStr);

接收方收到消息后，先解密再处理：

// 伪代码：客户端解密消息
hubConnection.On<string, string>("receiveMessage", (sender, encryptedMsgStr) =>
{
    byte[] encryptedMsg = Convert.FromBase64String(encryptedMsgStr);
    byte[] sharedKey = GetSharedKeyWithSender(senderUserId);
    string plainText = AesGcmDecrypt(encryptedMsg, sharedKey);
    // 处理明文消息
});

3. 服务器端角色调整 #

服务器端不再处理明文消息，仅负责转发加密后的内容：

[Function("SendMessage")]
[SignalROutput(HubName = "MyHub")]
public SignalRMessageAction SendMessageToUser(
    [SignalRTrigger("MyHub", "Category", "msgSent", "username", "encryptedMessage")] 
    SignalRInvocationContext invocationContext, 
    string username, 
    string encryptedMessage)
{
    // 直接转发加密消息，无需解密
    return new SignalRMessageAction
    {
        UserId = username,
        Target = "receiveMessage",
        Arguments = new[] { invocationContext.UserId, encryptedMessage }
    };
}

注意：服务器端不要存储任何私钥或共享密钥，仅作为公钥的存储中转节点（可用Azure Table Storage或Cosmos DB存储用户公钥）。

二、保障群组消息仅群内用户可读 #

需结合端到端加密与服务端权限控制，从两方面入手：

1. 服务端群组成员验证 #

• 维护群组与成员的映射关系：用Azure Cosmos DB或SQL数据库存储群组ID对应的成员列表（仅存用户ID，不涉及密钥）。
• 转发群组消息前，先验证发送方是否属于该群组，同时只将消息转发给群内用户：

[Function("SendGroupMessage")]
[SignalROutput(HubName = "MyHub")]
public SignalRMessageAction SendGroupMessage(
    [SignalRTrigger("MyHub", "Category", "groupMsgSent", "groupId", "encryptedMessage")] 
    SignalRInvocationContext invocationContext, 
    string groupId, 
    string encryptedMessage)
{
    // 从数据库查询该群组的所有成员ID
    List<string> groupMembers = GetGroupMembersFromDb(groupId);
    // 验证发送方是否在群内
    if (!groupMembers.Contains(invocationContext.UserId))
    {
        throw new UnauthorizedAccessException("无权限发送该群组消息");
    }
    // 仅转发给群内成员
    return new SignalRMessageAction
    {
        UserIds = groupMembers,
        Target = "receiveGroupMessage",
        Arguments = new[] { invocationContext.UserId, encryptedMessage }
    };
}

2. 群组密钥安全分发 #

• 群密钥仅分发给群内成员：新成员加入时，由群管理员通过单聊E2EE通道将群密钥加密后发送给新成员；或使用群公钥加密群密钥，只有持有群私钥的成员能解密（适合较大群组）。
• 成员退出群组时，立即更新群密钥，并重新分发给剩余成员，防止已退出成员解密后续消息。

内容的提问来源于stack exchange，提问作者Arash