jjzjj

ios - 是否可以同时运行不同的 Erlang OTP 版本?

coder 2024-01-14 原文

我正在尝试将 Apple 的 voip 推送通知添加到我们的应用程序中。我们的后端提供程序由 Erlang 的 Ejabberd 服务器和 apns4erl 服务器 1.0.4 编写。

目前,apns4erl 2 具有发送 voip 推送通知的能力。但它需要 OTP 19+ 才能编译,而我们的系统在 OTP 17.3 上运行。

那么我可以知道是否可以同时运行这两个 OTP?我无法将 OTP 升级到 19+。新图书馆需要 19 岁以上。

是否有好的方法可以满足此要求,或者我需要将新库移植到旧库中?

谢谢,

埃里克

最佳答案

在阅读本文时请记住,您应该真正找到一种方法来更新您现有的服务,以便与更新的运行时保持同步。我曾经处理过卡在遗留运行时上的问题,只是因为有人认为他们需要以一种无法升级的方式在某个地方 fork 一个特定的模块——这简直是一场噩梦。

TL;DR:(但无论如何你都应该阅读它)

是的,我刚刚确认您可以通过 disterl 连接 R17 和 R20 节点并发送消息:

R17节点:

ceverett@changa:/opt/erlang/R17.5/bin$ ./erl -name bar -cookie walnut
Erlang/OTP 17 [erts-6.4] [source] [64-bit] [smp:2:2] [async-threads:10] [hipe] [kernel-poll:false]

Eshell V6.4  (abort with ^G)
(bar@changa.shinden.tsuriai.jp)1> P = spawn(fun Wait() -> receive {From, Message} -> From ! {received, Message}, Wait() end end).
<0.44.0>
(bar@changa.shinden.tsuriai.jp)2> global:register_name(waiter, P).
yes

R20节点:

ceverett@changa:~$ erl -name foo -cookie walnut                                                                                                                                                                                                                              
Erlang/OTP 20 [RELEASE CANDIDATE 2] [erts-9.0] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:10] [hipe] [kernel-poll:false]                                                                                                                                         
                                                                                                                                                                                                                                                                             
Eshell V9.0  (abort with ^G)
(foo@changa.shinden.tsuriai.jp)1> net_kernel:connect('bar@changa.shinden.tsuriai.jp').
true
(foo@changa.shinden.tsuriai.jp)2> global:send(waiter, {self(), "blah blah blah"}).
<7489.44.0>
(foo@changa.shinden.tsuriai.jp)3> flush().
Shell got {received,"blah blah blah"}
ok

请注意,上面的 R20 节点首先启动,因此这是运行的 EPMD 版本。我不知道这是否重要,我也不知道 EPMD 在 R17 和 R20 之间是否发生了变化。

这是所有未记录的功能。阅读下文以了解更面向 future 的方式来做到这一点。

连接不同版本的两个节点的记录方式是使用 +R 运行时标志。我认为这是一个非常不可靠的 hack(和我上面展示的一样不可靠),除非你首先对它进行了彻底的测试——并且它可能会产生意想不到的副作用,具体取决于所涉及的版本(并且不知道 future 会发生什么) ).但是这是一个实际的运行时标志,它的存​​在显然是有原因的。参见 legoscia's answer有关此的更多详细信息。

讨论

无论 Erlang 运行时的两个版本是否通过 disterl 兼容,用 Erlang 编写网络应用程序真的很容易。您始终可以通过 TCP 连接两个任何不同的事物。

对此的简单解决方案是使用当前版本的 Erlang(目前为 R20.1)在 Erlang 中编写网络应用程序,接收 Apple voip 推送,并将它们转发到您的主应用程序。

写:

  • R17 系统中的单个 TCP 套接字处理进程。
  • R20 中的 Apple VOIP 推送服务处理程序和与 R17 TCP 套接字处理程序对话的 TCP 套接字连接进程。

在您的系统中对待 Apple VOIP 服务,就好像它作为应用程序的 native 部分存在一样。 R17 节点中的套接字处理程序 VOIP 服务。确保在编写它的接口(interface)函数时考虑到这一点——以后如果您可以将代码迁移到 R20,那么您就不必担心这个细节,因为它已经被 Erlang 的内部协议(protocol)抽象化了。

至于推送更新本身,您可以创建任何类型的协议(protocol)。

Erlang 的 external term format R17 和 R20 之间没有变化,因此您可以通过让 Apple VOIP 端套接字处理程序(在 R20 节点上)执行类似以下操作来在两个节点之间发送 native 消息:

notify_node(Socket, VOIP_Data) ->
    Message = term_to_binary({push, VOIP_Data}),
    ok = gen_tcp:send(Socket, Message),
    log(info, "Message sent").

在接收节点(R17 节点)上:

loop(Parent, Debug, State = #s{socket = Socket}) ->
    receive
        {tcp, Socket, Bin} ->
            {push, VOIP_Data} = binary_to_term(Bin, [safe]),
            {ok, NewState} = do_stuff(VOIP_Data, State)
            loop(Parent, Debug, NewState);
        %% Your other stuff
        %% OTP system stuff
    end.

您也可以将 R17 端写为 gen_server,监听:

handle_info({tcp, Socket, Bin}, State = #s{socket = Socket}) ->
    %% whatever

我只是碰巧经常将套接字处理进程视为 proc_lib 进程,而不是 gen_servers。但在大多数情况下这并不重要。

另一种方法是使用二进制文件:

notify_node(Socket, VOIP_Data) ->
    Message = <<"PUSH ", VOIP_Data>>,
    ok = gen_tcp:send(Socket, Message),
    log(info, "Message sent").

在接收节点(R17 节点)上:

loop(Parent, Debug, State = #s{socket = Socket}) ->
    receive
        {tcp, Socket, <<"PUSH ", VOIP_Data/binary>>} ->
            {ok, NewState} = do_stuff(VOIP_Data, State)
            loop(Parent, Debug, NewState);
        %% Your other stuff
        %% OTP system stuff
    end.

这实际上取决于VOIP_Data 的性质。如果它本身是一个二进制文件,并且 R20 Apple 推送服务应该只传递它而不检查它,那么原始二进制方法很简单。如果 R20 端要解释消息并将其转换为自己的 Erlang 消息,那么使用 binary_to_term/1/term_to_binary/2 形式。

关于ios - 是否可以同时运行不同的 Erlang OTP 版本?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46801836/

有关ios - 是否可以同时运行不同的 Erlang OTP 版本?的更多相关文章

  1. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

    总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  2. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法? - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  3. ruby-on-rails - 如何验证 update_all 是否实际在 Rails 中更新 - 2

    给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息? 最佳答案 在Rails3中,update_all不返回任何有意义的信息,除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru

  4. ruby - 使用 Vim Rails,您可以创建一个新的迁移文件并一次性打开它吗? - 2

    使用带有Rails插件的vim,您可以创建一个迁移文件,然后一次性打开该文件吗?textmate也可以这样吗? 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件,这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails,您可以创建一个新的迁移文件并一次性打开它吗?,我们在StackOverflow上找到一个类似的问题: https://sta

  5. ruby - 如何每月在 Heroku 运行一次 Scheduler 插件? - 2

    在选择我想要运行操作的频率时,唯一的选项是“每天”、“每小时”和“每10分钟”。谢谢!我想为我的Rails3.1应用程序运行调度程序。 最佳答案 这不是一个优雅的解决方案,但您可以安排它每天运行,并在实际开始工作之前检查日期是否为当月的第一天。 关于ruby-如何每月在Heroku运行一次Scheduler插件?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/8692687/

  6. ruby - 我可以使用 Ruby 从 CSV 中删除列吗? - 2

    查看Ruby的CSV库的文档,我非常确定这是可能且简单的。我只需要使用Ruby删除CSV文件的前三列,但我没有成功运行它。 最佳答案 csv_table=CSV.read(file_path_in,:headers=>true)csv_table.delete("header_name")csv_table.to_csv#=>ThenewCSVinstringformat检查CSV::Table文档:http://ruby-doc.org/stdlib-1.9.2/libdoc/csv/rdoc/CSV/Table.html

  7. ruby-on-rails - 如何在 ruby​​ 中使用两个参数异步运行 exe? - 2

    exe应该在我打开页面时运行。异步进程需要运行。有什么方法可以在ruby​​中使用两个参数异步运行exe吗?我已经尝试过ruby​​命令-system()、exec()但它正在等待过程完成。我需要用参数启动exe,无需等待进程完成是否有任何ruby​​gems会支持我的问题? 最佳答案 您可以使用Process.spawn和Process.wait2:pid=Process.spawn'your.exe','--option'#Later...pid,status=Process.wait2pid您的程序将作为解释器的子进程执行。除

  8. ruby - 无法运行 Rails 2.x 应用程序 - 2

    我尝试运行2.x应用程序。我使用rvm并为此应用程序设置其他版本的ruby​​:$rvmuseree-1.8.7-head我尝试运行服务器,然后出现很多错误:$script/serverNOTE:Gem.source_indexisdeprecated,useSpecification.Itwillberemovedonorafter2011-11-01.Gem.source_indexcalledfrom/Users/serg/rails_projects_terminal/work_proj/spohelp/config/../vendor/rails/railties/lib/r

  9. ruby - 检查数组是否在增加 - 2

    这个问题在这里已经有了答案:Checktoseeifanarrayisalreadysorted?(8个答案)关闭9年前。我只是想知道是否有办法检查数组是否在增加?这是我的解决方案,但我正在寻找更漂亮的方法:n=-1@arr.flatten.each{|e|returnfalseife

  10. ruby - 我可以使用 aws-sdk-ruby 在 AWS S3 上使用事务性文件删除/上传吗? - 2

    我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后,每个操作都应在S3上回滚。S3Object这可能吗?? 最佳答案 虽然S3API具有批量删除功能,但它不支持事务,因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST),因此每个上传操作都是通过一个独立的API调用完成的

随机推荐