0

我正在尝试将数据包从 ejabberd 发送到 Python 脚本，然后 python 脚本将执行他的功能并返回（真或假）。我找到了它的项目名称：ErlPort，它有助于将 Erlang 连接到许多其他编程语言。

它正在 100% 工作，但是当收到很多数据包 ejabberd 关闭时。

这个例子工作 100% 但是当像我之前所说的那样发送大量数据包时崩溃：

我的 Python 脚本

from erlport import Port, Protocol, String

class SecurityProtocol(Protocol):
    def handle_security(self, body):
        BadList = ["bad1", "bad2"]
        body = String(body).lower()
        body = u" " + body + u" "
        for x in BadList:
            if body.count(x): return True
        return False

if __name__ == "__main__":
    proto = SecurityProtocol()
    proto.run(Port(use_stdio=True))

在 (ejabberd_c2s.erl) 第 1896 行 --> ejabberd v2.1.13 ：

security(Body) ->
    Port = open_port({spawn, "python -u /home/ejabberd/lib/ejabberd/ebin/security.py"}, [{packet, 1}, binary, use_stdio]),
    ReqData = term_to_binary({security, Body}),
    port_command(Port, ReqData),
    receive
        {Port, {data, RespData}} ->
            binary_to_term(RespData)
    after
        5000 ->
            {error, timeout}
    end.

privacy_check_packet(StateData, From, To, Packet, Dir) ->
    case Packet of
        {xmlelement, "message", _, _} ->
            LBody = xml:get_subtag_cdata(Packet, "body"),
            case security(LBody) of
                true -> deny;
                false -> ejabberd_hooks:run_fold(privacy_check_packet, StateData#state.server, allow, [StateData#state.user, StateData#state.server, StateData#state.privacy_list, {From, To, Packet}, Dir]);
                _ -> "Error TimeOut"
            end
    end.

错误是： http: //paste.ubuntu.com/15414683/

有什么方法可以将 ejabberd 与 Python 脚本连接起来而不会出现任何错误或问题？

4

0 回答 0