Как я могу отправить «Сообщение» другому процессу в .Net, не используя SendMessage?

Question

У меня есть несколько приложений, работающих на одной машине. Один из них выполняет работу и записывает журналы на диск о том, что он сделал (я буду называть этот WorkerApp), а другой, который суммирует информацию о поддержке статуса WorkerApp вместе с некоторыми подробностями (я буду называть эту панель мониторинга).

С панели инструментов я хочу дать указание WorkerApp предпринять действие (скажем, «Удаленные службы Ping»), и мне бы хотелось, чтобы WorkerApp отправил Dashboard ответ «понг», когда он его получил.

Я видел примеры использования SendMessage, но это кажется довольно архаичным (нет ли в настоящее время в стандарте 2016 между стандартами связи?).

У меня очень мало опыта работы с Akka.Net, но функция Remoting выглядит как хороший подход, хотя настройка этого кажется немного переборщиной за то, что я хотел бы сделать.

Что является самым простым способом в настоящее время обмениваться данными между двумя процессами в .NET? И есть ли некоторые примеры этого, работая над localmachine?

Answer 1

Я собрал пример Akka.Net для этого. Вот как это выглядит.

DashBoard (рассылает)

using System; 
using Akka.Actor; 
using Akka.Configuration; 

namespace DashBoard 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      var config = ConfigurationFactory.ParseString(@" 
akka { 
    actor { 
     provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote"" 
    } 
    remote { 
     helios.tcp { 
      transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote"" 
      applied-adapters = [] 
      transport-protocol = tcp 
      port = 0 
      hostname = localhost 
     } 
    } 
} 
"); 

      using (var system = ActorSystem.Create("Dashboard", config)) 
      { 
       var server = system.ActorSelection("akka.tcp://WorkerApp@localhost:8081/user/WorkerAppActor"); 
       while (true) 
       { 
        var input = Console.ReadLine(); 
        server.Tell(input); 
       } 
      } 
     } 
    } 
} 

WorkerApp (принимает сообщения)

using System; 
using Akka.Actor; 
using Akka.Configuration; 

namespace WorkerApp 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      var config = ConfigurationFactory.ParseString(@" 
akka { 
    actor { 
     provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote"" 
    } 
    remote { 
     helios.tcp { 
      transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote"" 
      applied-adapters = [] 
      transport-protocol = tcp 
      port = 8081 
      hostname = localhost 
     } 
    } 
} 
"); 

      using (var system = ActorSystem.Create("WorkerApp", config)) 
      { 
       system.ActorOf<WorkerAppActor>("WorkerAppActor"); 

       Console.ReadLine(); 
      } 
     } 
    } 

    class WorkerAppActor : TypedActor, IHandle<string> 
    { 
     public void Handle(string message) 
     { 
      Console.WriteLine($"{DateTime.Now}: {message}"); 
     } 
    } 
} 

Answer 2

Обратите внимание на .Net remoting. Это немного более современно, чем SendMessage, но не много. Это довольно легко использовать. Я думаю, что официальный способ сделать это в наши дни, вероятно, использует WCF, но я уверен, что это точно так же под капотом.

. Удаленный доступ через сеть поддерживает различные каналы (Http, TCP), но в вашем случае я предлагаю удалять IPC. Он сидит поверх названных труб.

Наверное, проще всего, если вы google (.Net remoting), но общая идея - определить класс в вашем «серверном» приложении, полученном из MarshalByRefObject. После того, как вы это сделали, зарегистрируйте его в удаленной инфраструктуре с помощью RemotingConfiguration.RegisterWellKnownServiceType.

Ваше клиентское приложение может затем создать экземпляр класса с помощью Activator.CreateObject, и тогда вам будет хорошо идти.

Одна вещь, о которой нужно знать: похоже, вам нужен механизм обратного вызова, поэтому ваша панель мониторинга не заблокирована в ожидании вашего WorkerApp. Это поддерживается в удалении сети .Net, но вам нужно создать два канала - один для исходящих вызовов (от Dashboard to WorkerApp), а затем другой для входящих обратных вызовов.

Еще одно предложение: ваш рабочий класс (тот, который получен из MarshalByRefObject) будет легче справиться, если вы также обнаружите интерфейс. Поместите этот интерфейс в DLL, доступный для обоих приложений, и жизнь будет проще.

Answer 3

Одно из предложений может заключаться в использовании базы данных или другого постоянного хранилища для создания типа «очереди», на который панель инструментов может вставлять задачи. Это может также сохранять статусы о задачах, которые могут быть обновлены рабочим процессом. Хотя это можно считать «излишним», он приносит множество преимуществ, таких как аудит, историческая отчетность и избыточность серверов/выключение питания. Вероятно, это также упростит приложение в будущем.