SignalR Могу ли я передать DataSet

Question

У меня есть приложение SignalR в двух частях. У меня есть базовые сообщения, идущие туда и обратно между MVC-приложением (SignalR Server) и службой Windows (SignalR Client). Служба Windows находится на внутренней машине, на которой есть база данных AdventureWork2012. Управление желает, чтобы клиент службы Windows - SignalR запросил базу данных и отправил обратно DataSet через SignalR. Может ли SignalR передавать данные? Я получаю исключение «Недопустимый URI: строка Uri слишком длинная». в журнале событий, когда я вызываю метод сервера.

Вот MVC сервер-концентратор:

public class AlphaHub : Hub 
    { 
     public void Hello(string message) 
     { 
      // We got the string from the Windows Service 
      // using SignalR. Now need to send to the clients 
      Clients.All.addNewMessageToPage(message); 

      // Call Windows Service 
      string message1 = System.Environment.MachineName; 
      Clients.All.Notify(message1); 


     } 
     public void Register(string registrationID,string connectionID) 
     { 
      // We got the string from the Windows Service 
      // using SignalR. Now need to send to the clients 
      System.Web.HttpContext.Current.Application["registrationID"] = registrationID + "|" + connectionID; 
     } 

     public void RecieveDataSet(DataSet ds) 
     { 
      Clients.All.addNewMessageToPage("Data Set recieved"); 
     } 

Здесь Windows Service Code, который генерирует исключение на линии:

await alphaProxy.Invoke("RecieveDataSet", employees); 

Код является:

protected override async void OnStart(string[] args) 
     { 
      eventLog1.WriteEntry("In OnStart"); 
      try 
      { 
       var hubConnection = new HubConnection("http://www.someurl.com/signalr", useDefaultUrl: false); 
       IHubProxy alphaProxy = hubConnection.CreateHubProxy("AlphaHub"); 

       await hubConnection.Start(); 
       string cid = hubConnection.ConnectionId.ToString(); 
       eventLog1.WriteEntry("ConnectionID: " + cid); 
       // Invoke method on hub 

       await alphaProxy.Invoke("Hello", "Message from Service - ConnectionID: " + cid + " - " + System.Environment.MachineName.ToString() + " " + DateTime.Now.ToString()); 
       await 
        alphaProxy.Invoke("Register", "81577f58-0e05-43f4-b322-fbf0d9d1e79e", 
         hubConnection.ConnectionId.ToString()); 


       alphaProxy.On("addNewMessageToPage",() => eventLog1.WriteEntry("Notified!")); 

       DataSet employees = new DataSet(); 
       string connString = "..."; 
       SqlConnection conn = new SqlConnection(connString); 
       string queryString = "SELECT * FROM [HumanResources].[Employee]"; 
       SqlDataAdapter adapter = new SqlDataAdapter(queryString, conn); 
       adapter.Fill(employees, "HumanResources.Employee"); 

       await alphaProxy.Invoke("RecieveDataSet", employees); 
      } 
      catch (Exception ex) 
      { 
       eventLog1.WriteEntry(ex.Message); 
      } 
     } 

Возможно ли передать DataSet? Если нет, мне нужно сериализовать/десериализовать? Если да, можете ли вы показать код для этого?

Answer 1

Я рекомендую вам преобразовать ваш набор данных в объект передачи данных и передать это. С SignalR вы можете передавать каждый объект, поскольку он гидратирован, что позволяет вам уведомлять наблюдателей не только при получении, но также и при добавлении любого нового элемента. Я не тестировал этот код, поэтому я, возможно, пропустил что-то, но он должен дать вам эту идею.

adapter.Fill(employees, "HumanResources.Employee"); 
foreach (var dr in employees) 
{ 
    var empDto = new EmployeeDto 
    { 
     FirstName = dr.Fields("FirstName"), 
     LastName = dr.Fields("LastName"), 
     // Additional fields go here... 
    }; 
    alphaProxy.Clients.ReceiveDataSet(empDto); // Serializes the dto as json by default. 
} 

Конечно, если вы хотите, чтобы отправить полный список в ответ вы должны быть в состоянии изменить это немного:

adapter.Fill(employees, "HumanResources.Employee"); 
var items = new List<EmployeeDto>(); 
foreach (var dr in employees) 
{ 
    var empDto = new EmployeeDto 
    { 
     FirstName = dr.Fields("FirstName"), 
     LastName = dr.Fields("LastName"), 
     // Additional fields go here... 
    }; 
    items.Add(empDto); 
} 
alphaProxy.Clients.ReceiveDataSet(items); // Serializes the dto as json array by default. 

Answer 2

http://www.asp.net/signalr/overview/signalr-20/hubs-api/hubs-api-guide-net-client#clientmethodswithoutparms

Смотрите руководство прохождения методов и без Params.

Answer 3

Вы хотите, чтобы ваши сообщения были довольно легкими с SignalR по многим причинам (особенно с масштабированием через объединительные платы), поэтому я НЕ передал бы что-то большое, как DataSet, через сообщение SignalR лично. То, что я обычно предлагаю для больших полезных нагрузок, заключается в том, что вы отправляете конкретное сообщение, которое сообщает браузеру, что оно должно обновлять данные, которые он затем выполняет, загружая с помощью традиционного GET какой-либо службы на основе REST. Таким образом, вы получаете уведомления об обновлениях в режиме реального времени, но вы используете традиционный HTTP GET для передачи фактической полезной нагрузки.