WampSharp Connection установленный обратный вызов не вызывается

Question

В настоящее время я пробую WampSharp реализацию протокола WAMP.

Я хотел, чтобы код печатал сообщение на консоли, когда клиент подключается к нему. Итак, я создал роутер и клиента. Но сообщение не появляется в консоли. Вот мой код:

маршрутизатор

class Program
{
    static void Main(string[] args)
    {

        const string location = "ws://127.0.0.1:8080/";
        const string realmName = "realm1";

        Task runTask = Run(location, realmName);

        Console.ReadLine();
    }

    private async static Task Run(string wsuri, string realmName)
    {
        using (IWampHost host = new DefaultWampHost(wsuri))
        {
            IWampHostedRealm realm = host.RealmContainer.GetRealmByName(realmName);
            host.Open();

            DefaultWampChannelFactory factory = new DefaultWampChannelFactory();
            IWampChannel channel = factory.CreateJsonChannel(wsuri, realmName);

            IWampClientConnectionMonitor monitor = channel.RealmProxy.Monitor;
            monitor.ConnectionError += ConnectionError;
            monitor.ConnectionEstablished += ConnectionEstablished;

            Console.WriteLine("Server is running on " + wsuri);

            while(true)
            {
                await Task.Delay(TimeSpan.FromSeconds(1))
                .ConfigureAwait(false);
            }
        }
    }

    private static void ConnectionEstablished(object sender, WampSessionEventArgs e)
    {
        Console.WriteLine("A client as connected");
    }

    private static void ConnectionError(object sender, WampConnectionErrorEventArgs e)
    {
        Console.WriteLine("A connections error occured");
    }


}

клиент:

class Program
{
    static void Main(string[] args)
    {
        const string location = "ws://127.0.0.1:8080/";

        DefaultWampChannelFactory channelFactory = new DefaultWampChannelFactory();

        IWampChannel channel = channelFactory.CreateJsonChannel(location, "realm1");
        IWampRealmProxy realmProxy = channel.RealmProxy;

        channel.Open().Wait();

        Console.ReadLine();
    }
}

Вероятно, это проблема C#, а не проблема WampSharp, но на всякий случай я поставлю два тега wamp на этот вопрос.

Answer 1

Вам не нужно создавать WampChannel на стороне маршрутизатора. Вы должны подписаться на события области вместо:

private static void Run(string wsuri, string realmName)
{
    using (IWampHost host = new DefaultWampHost(wsuri))
    {
        IWampHostedRealm realm = host.RealmContainer.GetRealmByName(realmName);
        realm.SessionCreated += SessionCreated;
        realm.SessionClosed += SessionRemoved;

        host.Open();

        Console.WriteLine("Server is running on " + wsuri);

        Console.ReadLine();
    }
}

private static void SessionCreated(object sender, WampSessionEventArgs wampSessionEventArgs)
{
    Console.WriteLine("Client connected");
}

private static void SessionRemoved(object sender, WampSessionCloseEventArgs wampSessionCloseEventArgs)
{
    Console.WriteLine("Client disconnected");
}

Если вы заинтересованы в обнаружении подключения / отключения канала на стороне клиента, вы можете подписаться на упомянутые вами события:

const string location = "ws://127.0.0.1:8080/";
const string realm = "realm1";

DefaultWampChannelFactory channelFactory = new DefaultWampChannelFactory();

IWampChannel channel = channelFactory.CreateJsonChannel(location, realm);
IWampClientConnectionMonitor monitor = channel.RealmProxy.Monitor;
monitor.ConnectionEstablished += ConnectionEstablised;
monitor.ConnectionError += ConnectionError;
monitor.ConnectionBroken += ConnectionBroken;

await channel.Open().ConfigureAwait(false);