自由切换事件套接字库

我正在尝试使用FreeSWITCH中的事件套接字库(ESL((存档(，但我想这个问题更多的是关于技术和"如何"而不是其他任何事情。

下面的代码是我的问题，可以在这里找到。

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);
    }
}

(我在出站模式下使用 FreeSWITCH ESL(。据我了解，"Sync"和"ASync"方法都处于无限循环中，等待(阻塞(事件，每当从FreeSWITCH收到某些事件时都会做出反应。

但是，我想创建一个Windows服务来跟踪FreeSWITCH向我抛出的所有呼叫。我希望另一个应用程序调用我的服务，并告诉它发送"Foo"到连接"XYZ"。所以我会跟踪一个连接字典，其中键是连接 (GU(ID。但是，如果该连接正在等待(阻塞(事件，则无论是否从 FreeSWITCH 收到事件以"释放"阻塞线程，我都看不到如何使用它来"对接"并发送我的消息。

顺便说一句：通过"对接"，我的意思是，如果出于某种原因，例如，我决定要挂断连接(例如触发某些计时器(，我希望能够发送挂断，无论连接是否正在等待从 FreeSWITCH 发送事件(如果什么都没有发生，可能需要很长时间(。

我可以使用recvEventTimed创建一个"轮询机制"，但这种方法有三个问题：

轮询感觉很脏
每当我想"对接"时，我希望我的消息尽快发送，而不是 50 毫秒(或 1 毫秒(以后
recvEventTimed似乎忽略了低于 ~500ms 的任何内容，因此它会疯狂地轮询。500 毫秒对我来说延迟太多了。

除了这些(我可以提交错误报告(，轮询感觉不对。

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

我已经考虑了RX(反应式扩展(并使用.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 ms的事件"，我将如何实现这一点？

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

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();
    }

我认为您描述的逻辑使用入站套接字会更容易实现。您可以订阅您感兴趣的事件，并执行后台任务。您也可以在多线程应用程序中执行此操作，以便一个线程读取 ESL 事件，而其他线程与业务逻辑的其他部分进行通信。

相关内容

最新更新

热门标签：