0

我正在开发 android 应用程序并SignalR在我的asp.net服务器和自定义 java 客户端SignalA上使用。我面临以下问题：当客户端加入某个组时，它没有收到加入后立即发送的消息。这是来自服务器的一段代码：

Task.Factory.StartNew(() => context.Groups.Add(groupId, connectionId)).
    ContinueWith(t => Groups.Send(groupId, message));

在客户端，我收到带有新组令牌的回调，但没有收到第一条发送的消息（但是收到了之后发送的消息）。用官方 C# 客户端尝试同样的事情效果很好。因此，似乎在处理新的组令牌之前收到了第一条消息。

经过长时间尝试比较 C# 和 java 客户端代码后，我还没有找到解决方案。我正在寻找关于如何在 C# 客户端中处理这种情况的解释（或代码参考），以便我能够在 java 客户端中实现相同的逻辑。

PS如果有办法在android上使用官方C#客户端而不是使用自定义java客户端，那会更轻松。

PPS 有一些“肮脏”的方法可以解决我的问题，例如在加入群组或从客户端发送确认消息后在服务器上稍作延迟，但我仍在寻找“干净”的修复方法。

4

1 回答 1

5

没有理由使用Task.Factory.StartNew.

context.Groups.Add(connectionId, groupName)已经返回了Task在向groupName您期望由connectionId.

你打电话时

Task.Factory.StartNew(() => context.Groups.Add(connectionId, groupName))

你得到一个Task<Task>.

这意味着当您调用Groups.Send(groupName, message)inside of 时ContinueWith，只有外部 Task 已完成，并且connectionId尚未完全添加到groupdName.

如果您运行的是 .NET 4.5，重写此代码的最简单方法是使用 async/await 模式，如下所示：

public async Task AddToGroupAndSend(IPersistentConnectionContext context,
                                    string connectionId, 
                                    string groupName,
                                    object message)
{
    await context.Groups.Add(connectionId, groupName);
    await context.Groups.Send(groupName, message);
}

如果您正在运行 .NET 4.0，则可以继续使用ContinueWith，但无需Task.Factory.StartNew：

public Task AddToGroupAndSend(IPersistentConnectionContext context,
                              string connectionId, 
                              string groupName,
                              object message)
{
    // This doesn't appropriately handle faulted or canceled tasks
    return context.Groups.Add(connectionId, groupName)
                  .ContinueWith(t => groups.Send(groupName, message));
}

如果您不介意让代码同步执行，您甚至可以执行以下操作：

public void AddToGroupAndSend(IPersistentConnectionContext context,
                              string connectionId, 
                              string groupName,
                              object message)
{
    context.Groups.Add(connectionId, groupName).Wait().
    groups.Send(groupName, message).Wait();
}

注意：在我的示例connectionId中是第一个参数，context.Groups.Add并且groupName是第二个参数。这是这些参数的正确顺序，与您在问题中的编写方式相反。

我不知道为什么您以前的代码可以与 C# 客户端一起使用，但不能与 Java 一起使用。鉴于您的问题中提供的代码，我希望任何一个客户端都会错过第一条发送的消息。

于 2013-03-11T12:35:00.603 回答