0

我有一个 winform 桌面应用程序。我已经引用了 signalr.client 并启动了与我的服务器的连接。我在 connection_stateChanged() 事件中收到一条已连接的消息。

我的困难是：我在我的服务器代码中在哪里捕获/添加客户端连接？我需要添加任何客户端连接，然后我打算将 fileSystemWatcher 放在特定于该 connectionid 的目录中。然后，当文件进入（在我的服务器上）时，我想通知我的 .net 客户端这个文件。完成后，我希望我的客户重新连接以通过相同的标准接收更多消息。

这是我到目前为止所拥有的：

[ServerCode] 在 Global.asax.cs 页面中：

  protected void Application_Start(object sender, EventArgs e)
    {
        RouteTable.Routes.MapConnection<ClientListener>("echo", "/echo");
    }

在我的 App_code 文件夹中的一个类中：

[

HubName("MotionIQ")]
public class ClientListener : Hub
{
    static ConcurrentDictionary<string, string> dic = new ConcurrentDictionary<string, string>();

    public void Send(string name, string message)
    {
        // Call the broadcastMessage method to update clients.
        Clients.All.broadcastMessage(name, message);
    }

    public void sendToSpecific(string name, string message, string to)
    {
        // Call the broadcastMessage method to update clients.
        Clients.Caller.broadcastMessage(name, message);
        Clients.Client(dic[to]).broadcastMessage(name, message);
    }

    public void Notify(string name, string id)
    {
        if (dic.ContainsKey(name))
        {
            Clients.Caller.differentName();
        }
        else
        {
            dic.TryAdd(name, id);

            foreach (KeyValuePair<String, String> entry in dic)
            {
                Clients.Caller.online(entry.Key);
            }

            Clients.Others.enters(name);
        }
    }

    public override Task OnDisconnected()
    {
        var name = dic.FirstOrDefault(x => x.Value == Context.ConnectionId.ToString());
        string s;
        dic.TryRemove(name.Key, out s);
        return Clients.All.disconnected(name.Key);
  }

[在我的 .net c# 桌面客户端应用程序中]

public void Init(bool _isLocal)
{
    var connection = new Connection("http://www.informedmotion.co.uk:12722/echo");//MotionIQ");
    connection.Received += new Action<string>(connection_Received);
    connection.StateChanged += new Action<StateChange>(connection_StateChanged);
    // Start the connection
    connection.Start().Wait();
    string line = null;
    while ((line = Console.ReadLine()) != null)
    {
        // Send a message to the server
        connection.Send(line).Wait();
    }
}
void connection_StateChanged(StateChange obj)
{

}

void connection_Received(string obj)
{

}

我快到了还是我做错了？

4

1 回答 1

2

除非有令人信服的理由使用 PersistentConnection，否则建议使用 Hubs。

这是关于在 Hub 类上处理事件的文档：

http://www.asp.net/signalr/overview/signalr-20/hubs-api/handling-connection-lifetime-events

于 2013-11-01T17:47:49.263 回答