c# - Freeswitch 事件套接字库

Question

我正在尝试使用 Event Socket Library (ESL) ( archive ) 来自 FreeSWITCH，但我想这个问题更多的是关于技术和“如何”而不是其他任何事情。

下面的代码是我的问题所在，可以找到here .

static void OutboundModeSync(Object stateInfo)
{
    //...
    while (true)
    {
        Socket sckClient = tcpListener.AcceptSocket();

        //Initializes a new instance of ESLconnection, and connects to the host $host on the port $port, and supplies $password to freeswitch
        ESLconnection eslConnection = new ESLconnection(sckClient.Handle.ToInt32());

        Console.WriteLine("Execute(\"answer\")");
        eslConnection.Execute("answer", String.Empty, String.Empty);
        Console.WriteLine("Execute(\"playback\")");
        eslConnection.Execute("playback", "music/8000/suite-espanola-op-47-leyenda.wav", String.Empty);
        Console.WriteLine("Execute(\"hangup\")");
        eslConnection.Execute("hangup", String.Empty, String.Empty);
    }
    //...
}

static void OutboundModeAsync(Object stateInfo)
{
    //...
    while (true)
    {
        tcpListener.BeginAcceptSocket((asyncCallback) =>
        {
            TcpListener tcpListened = (TcpListener)asyncCallback.AsyncState;

            Socket sckClient = tcpListened.EndAcceptSocket(asyncCallback);

            //Initializes a new instance of ESLconnection, and connects to the host $host on the port $port, and supplies $password to freeswitch
            ESLconnection eslConnection = new ESLconnection(sckClient.Handle.ToInt32());

            ESLevent eslEvent = eslConnection.GetInfo();
            //...
            while (eslConnection.Connected() == ESL_SUCCESS)
            {
                eslEvent = eslConnection.RecvEvent();
                Console.WriteLine(eslEvent.Serialize(String.Empty));
            }

            sckClient.Close();
        }, tcpListener);

        Thread.Sleep(50);
    }
}

(我在 outbound mode 中使用 FreeSWITCH ESL)。据我了解，“Sync”和“ASync”方法都处于无限循环中等待(阻塞)事件，每当从 FreeSWITCH 接收到某个事件时就会使用react。

但是，我想创建一个 Windows 服务来跟踪 FreeSWITCH 向我发出的所有调用。我希望另一个应用程序调用我的服务，并告诉它发送“Foo”到连接“XYZ”。因此，我会跟踪连接字典，其中键是连接(GU)ID。但是，如果该连接正在等待(阻塞)某个事件，我不知道如何使用它来“插入”并发送我的消息，无论是否从 FreeSWITCH 接收到事件来“释放”阻塞线程。

顺便说一句:“插入”是指，如果出于某种原因，例如，我决定挂断连接(例如触发某个计时器)，我希望能够发送挂断，无论连接是否正在等待从 FreeSWITCH 发送的事件(如果没有发生，可能需要很长时间)。

我可以使用recvEventTimed创建“轮询机制”，但这种方法存在三个问题:

1. 投票感觉很脏
2. 每当我想“插入”时，我希望尽快发送消息，而不是晚 50 毫秒(或 1 毫秒)
3. recvEventTimed 似乎会忽略低于约 500 毫秒的任何内容，因此它会疯狂地进行轮询。而且 500 毫秒对我来说延迟太大了。

除了这些(我可以提交错误报告)之外，民意调查感觉不太对劲。

我想“接受连接”，告诉 ESL 等待(阻塞)事件，然后引发事件，以便我可以使用基于事件的方法。我希望处理大量连接，因此我更喜欢低延迟、无(或很少)轮询以及一种干净的方法来处理所有这些连接，在它们持续时，为我提供免费的“双向、非轮询、基于事件”通信。

我考虑过 RX(响应式(Reactive)扩展)并使用 .Net 异步套接字(而不是 FreeSWITCH 提供的二进制文件)和其他方法实现我自己的“ESL”。但我似乎找不到一种方法来整齐地实现我的愿望/要求，而无需大量样板或/和令人讨厌的线程内容等。我很确定我应该能够使用 async/await 但不知道如何准确地做到这一点。任何帮助将非常感激。

简单描述:

* Connection comes in
* Accept connection + get GUID from connection
* Put connection in some collection for later reference
* Bind delegate to connection (`EventReceived` event)
* Use collection to get connection and send a message (preferrably async ("fire and forget"), but blocking COULD be acceptable as long as it only blocks that specific connection) to "butt-in" whenever I want to

该集合将托管在 Windows 服务中，我可以联系该服务以获取我的 FreeSWITCH 连接的 I/O/列出可用连接等。

所以，我想象一些东西，比如“伪代码”:

MyService {
    stopped = false;

    void OnStart {
        while (!stopped) {
          var someconn = esl.waitforconnection();
          var id = someconn.getCallId();
          someconn.EventReceived += MyDelegate(...);
          mydict.add(id, someconn);
        }
    }

    void OnStop {
      stopped = true;
    }

    void ButtIn(string callid, string msg) {
        mydict[callid].send(msg);
    }

    void MyDelegate(EventData evtdata) {
        //Do something with evtdata if desired
    }
}

鉴于 FreeSwitch 提供的 ESL 不是基于事件的，并且只有阻塞“等待事件”或轮询“等待事件 X 毫秒”，我将如何实现这一点？

tl;dr:不想要无限循环/轮询，而是更多基于事件的方法，最好使用 async/await，一旦“底层“ESL 连接””被包装/抽象在我自己的类中，就可以使用干净+简单的代码。需要最佳方法的帮助/建议。没有线程/套接字大师。

Answer 1

NEventSocket ReactiveExtensions 可能会帮助你。

private static async Task CallTracking()
    {
        var client = await InboundSocket.Connect("10.10.10.36", 8021, "ClueCon");

        string uuid = null;

        client.Events.Where(x => x.EventName == EventName.ChannelAnswer)
              .Subscribe(x =>
                  {
                      uuid = x.UUID;
                      Console.WriteLine("Channel Answer Event {0}", x.UUID);
                  });

        client.Events.Where(x => x.EventName == EventName.ChannelHangup)
              .Subscribe(x =>
                  {
                      uuid = null;
                      Console.WriteLine("Channel Hangup Event {0}", x.UUID);
                  });

        Console.WriteLine("Press enter to hang up the current call");
        Console.ReadLine();

        if (uuid != null)
        {
            Console.WriteLine("Hanging up {0}", uuid);
            await client.Play(uuid, "ivr/8000/ivr-call_rejected.wav");
            await client.Hangup(uuid, HangupCause.CallRejected);
        }

        client.Exit();
    }