Telnet 套接字网关到 Coldfusion 事件网关以连接到 Asterisk AMI

Question

我希望我的 ColdFusion 应用程序能够记录通过 Management API 从 Asterisk 主机通过 telnet 流式传输的事件。 ColdFusion 事件网关可以监听特定端口，但不能自己发起连接，所以我需要一个网关，可以发起到 Asterisk 主机的 telnet 连接（在指定端口上）并将流式事件推送到 ColdFusion 服务器（在一个指定端口）。我真的不想重新发明轮子，那么有什么实用程序可以做到这一点吗？

我的术语可能不正确，因为我不是那么专业，但我希望我已经对要求进行了足够的解释！ “实用程序”可以驻留在 Linux 或 Windows 平台上。

编辑： 要连接到 Asterisk 主机 telnet 流并通过它进行身份验证，必须发送以下内容：

Action: login<CRLF>
Username: usr<CRLF>
Secret: abc123<CRLF>
<CRLF>

我知道之前发布的问题与此类似（但未得到回答），但我很高兴在 ColdFusion 之外找到解决方案

谢谢

Answer 1

使用 Coldfusion 的 Socket 网关。它是内置的，并且是 Coldfusion 中事实上的功能，可以使用基于 TCP/IP 的协议（例如 Telnet）发送和响应消息，

Answer 2

我开始怀疑我是否理解您的要求。您希望您的应用程序“启动连接以收听”。 CF Socket Gateway 可能不会“启动”连接，但它确实“有一个要监听的连接”。为什么要启动你已经拥有的东西？为什么“发起”这个词如此重要？

无论如何，我将您的要求“使用特定端口启动到主机的 telnet 连接”解释为“连接到另一台服务器上的套接字”。你不需要一个完整的网关/重定向器机器。您可以在 Coldfusion Socket Gateway 的 CFC 中执行此操作。它只需要 2 或 3 行代码（在网上搜索“读取和写入套接字”）。

因此，在您的最终设计中，您将在两个套接字之间建立连接。一个在您的 Coldfusion 服务器上，另一个在主机服务器上。连接中的通信是双向的。任意数量的客户端，比如 10 000 个，然后可以在 CF 套接字上侦听来自主机服务器的所有消息。

Answer 3

如果您需要做的只是从 Asterisk 服务器捕获事件，我会建议一种不同的方法。

您似乎正在使用 Asterisk AMI，请查看 Asterisk-Java。根据我的阅读，它是一个 java 库，可以为您处理低级套接字通信和解析，并为与 Asterisk 服务器交互提供更高级别的接口。因此它能够发起连接、捕获事件等等。

理论上，您可以在应用程序启动时打开连接并注册以接收事件。只要连接保持打开状态，应用程序就会从 Asterisk 接收事件。当应用程序结束时，只需关闭连接即可停止事件。

初始化连接

要简单地捕获事件，首先要创建到 Asterisk 服务器的连接。只需提供正确的主机和凭据：

managerFactory = createObject("java", "org.asteriskjava.manager.ManagerConnectionFactory");
connection = managerFactory.init( hostNameOrIP
                                 , portNum
                                 , userName
                                 , theSecret ).createManagerConnection();

注册活动

为了接收事件，您必须首先向连接注册一个ManagerEventListener。通常这需要编写一个自定义的 java 类来实现正确的interface。但是，使用一点 dynamic proxy magic，您可以改用标准 CFC。来自 Asterisk 的任何事件都将直接路由到 CFC，并且可以使用 CF 代码进行处理。

要添加侦听器，请使用名为 onManagerEvent 的单个函数创建 CFC。只要在 Asterisk 服务器上发生注册事件，就会调用此函数。

// YourCFCListener.cfc
component {
    public void function onManagerEvent(any managerEvent)
    {
        // For demo purposes, just output a summary of the event to a log file
        WriteLog( text=arguments.managerEvent.toString(), file="AsteriskListenerLog" );
    }
}

接下来创建一个代理并将其注册到连接中。

proxyListener = createDynamicProxy("path.YourCFCListener"
      , [ "org.asteriskjava.manager.ManagerEventListener"] );
connection.addEventListener( proxyListener );

接收事件：

要开始接收事件，请登录并连接到服务器。使用掩码指定要接收的事件："off"、"on" 或以逗号分隔的特定事件列表（即"system,call,log"）。

// receive ALL events
connection.login("on");

连接打开后，您将看到写入演示日志文件的事件（假设存在服务器活动）。对于一次性测试，让页面sleep() 几秒钟以允许一些事件流动。然后关闭连接并停止事件：

sleep(4000);
connection.logoff()

在真正的应用程序中，您可能会打开一次连接并将其存储在持久范围中，例如应用程序。然后仅在应用程序关闭时关闭它。

查看 API，您可以使用它做更多事情。但是，以上内容应该提供一个基本的 POC 示例来帮助您开始捕获事件。

Answer 4

我以通常的方式创建了 Coldfusion Socket Gateway 的一个实例。例如，请参阅https://www.bennadel.com/blog/2173-using-socket-gateways-to-communicate-between-coldfusion-and-node-js.htm。

我得到了以下设置：

1）监听器CFC的内容（SocketGatewayListener.cfc）：

<cfcomponent>

<cffunction name="onIncomingMessage" returntype="struct" output="false">
<cfargument name="cfevent" >
<cfset var msg = {} >

<cfscript>
/* The code within this cfscript represents the proof of concept.     'xxx.xxx.xxx.xxx' is an IP, 1226 an arbitrary port, so the next line connects to an external socket. Make sure it is listening. */
var socket = createobject("java","java.net.Socket").init('xxx.xxx.xxx.xxx',1226); 
var out = createobject("java","java.io.PrintWriter").init(socket.getOutputStream(), true);
var bufferedWriter = createobject("java","java.io.BufferedWriter").init(out);
/*Send data to external socket */
bufferedWriter.write("Authentication data at #now()#");
bufferedWriter.flush();
</cfscript>

<cfset msg["message"] = cfevent.data.message>

<cfreturn msg>
</cffunction>

</cfcomponent>

2) 配置文件内容（socketGateway.cfg）：

# The port the socket server listens on.
port=9093

3) 我的系统： 冷融合 2016 Windows 7 旗舰版

网猫： 您可以使用可执行的 nc.exe 来侦听或向套接字网关发送消息。网关运行后，使用 DOS 命令进行侦听，例如

nc 127.0.0.1 9093

使用类似命令发送消息

echo 'my test message' | nc 127.0.0.1 9093

大力神 (http://www.hw-group.com/products/hercules/index_en.html): 您可以使用 Hercules GUI 实用程序进行测试。使用它的“TCP Client”向您的套接字网关发送消息，并使用它的“TCP Server”模拟从不同主机监听您的网关的套接字（代码中的 IP 和端口：xxx.xxx.xxx.xxx，第1226章）。

不幸的是，Adobe Coldfusion 的套接字网关未能如您所愿地向所有正在侦听的套接字广播。您只能让它回复消息的发送者。显然，这是设计使然。这是令人惊讶的。默认情况下，您会期望所有侦听套接字都接收消息。我将向 Coldfusion 团队提出功能请求。

我在网络上发现了这两种解决方案，它们似乎提供了对所有人广播的功能以及更多功能：

https://github.com/nmische/cf-websocket-gateway/tree/java-websocket

https://github.com/softwarezman/cf-socketiogateway

但是，当我在 Coldfusion 2016 上测试它们时遇到了很多错误。在接下来的日子里，我将向 Coldfusion 附带的 SocketGateway Java 代码添加广播到所有功能。