Erlang: Let’s talk to java
試了一下傳說中的 JInterface ，使用 OtpErlang.jar 的整個(gè)過程其實(shí)非常簡(jiǎn)單，似乎比 JMS 的程序都簡(jiǎn)單。
首先，我們要用 java 實(shí)現(xiàn)的原始 erlang 程序如下，沒錯(cuò)，就是巨簡(jiǎn)單的 echo ，我們的目標(biāo)是要把它用 java 來改寫，不僅寫服務(wù)端，也要寫客戶端。
- - module ( echo_client ) .
- ?
- - export ([ run / 0 ]) .
- ?
- run () ?->
- ? ?? Msg ?=? " Hello Echo! " ,
- ? ? { echo ,? abc @ merlin } ! { self () ,? Msg },
- ? ?? io : format ( " send ~p ~n " ,? [ Msg ]) ,
- ? ?? receive
- ? ? ? ?? Res ?->
- ? ? ? ? ? ?? io : format ( " received ~p ~n " ,? [ Res ])
- ? ?? end .
- - module ( echo_server ) .
- ?
- - export ([ start / 0 ]) .
- ?
- start () ?->
- ? ?? register ( echo ,? self ()) ,
- ? ?? io : format ( " echo start~n " ,? []) ,
- ? ?? loop () .
- ?
- loop () ?->
- ? ?? receive
- ? ? ? ? { Pid ,? Msg } ->
- ? ? ? ? ? ?? io : format ( " received ~p from ~p~n " ,? [ Msg ,? Pid ]) ,
- ? ? ? ? ? ?? Pid ?!? Msg ;
- ? ? ? ?? Any ?->
- ? ? ? ? ? ?? io : format ( " received ~p ~n " ,? [ Any ])
- ? ?? end ,
- ? ?? loop () .
寫得并不嚴(yán)密，用了一堆硬編碼，主要是個(gè)示例，就那么個(gè)意思，大家將就著看。
先說一下 JInterface 的一些基本概念。JInterface 的目的是：為 Java 提供一個(gè)包，使得 Java 程序在外部可以看起來就像一個(gè)標(biāo)準(zhǔn)的 Erlang Node 能以標(biāo)準(zhǔn)的 Erlang 方式與其他的節(jié)點(diǎn)進(jìn)行通訊。它包裝了 Erlang 節(jié)點(diǎn)之間分布式的通訊協(xié)議，編碼解碼，以及基本的 Erlang 操作，也就是 pid register send receive link unlink 等等，樸實(shí)無華。不過，作為兩個(gè)語言之間的接口包，有了這些基本功能也就足夠了。
根據(jù) Erlang 的目錄慣例， JInterface 的 Jar 在 ERLANG_HOME/lib/jinterface-x.x/priv 目錄下，名字為 OtpErlang.jar 。注意，必須使用和你當(dāng)前 Erlang 版本下的包，否則出了什么妖怪問題，別來問我，就算是問我，我也不知道該怎么辦。:D 之前一直有一個(gè)誤解，想當(dāng)然的以為 JInterface 會(huì)用 JNI 什么的來實(shí)現(xiàn)，而自從碰過一次以后，對(duì) JNI 這種“難以掌控”的東西總覺得有點(diǎn)畏難，所以，遲遲都沒有動(dòng)手，沒想到，竟是純 Java 實(shí)現(xiàn)的一個(gè)包。用起來方便，部署起來也漂亮。爽！
閑話休提，直接上代碼得了。先是 Client 的代碼。
- package ? com . test . erlang ;
- ?
- import ? java . io . IOException ;
- ?
- import ? com . ericsson . otp . erlang .*;
- ?
- public ? class ? ErlangEchoClient ?{
- ? ?
- ? ?? public ? static ? void ? main ( String [] ? args ) ? throws ? IOException ?{
- ? ? ? ?
- ? ? ? ?? String ? v ?= System . getProperties () . getProperty ( " OtpConnection.trace " ) ;
- ? ? ? ?? System . out . println ( " OtpConnection.trace= " + v ) ;
- ? ? ? ?
- ? ? ? ?? OtpNode ? self ?=? new ? OtpNode ( " bcd " ,? " 123 " ) ;
- ? ? ? ?
- ? ? ? ?? System . out . println ( " node: " + self . node ()) ;
- ? ? ? ?? System . out . println ( " cookie: " + self . cookie ()) ;
- ? ? ? ?
- ? ? ? ?? if ? ( self . ping ( " abc " ,? 2000 )) ?{
- ? ? ? ? ? ?? System . out . println ( " remote is up " ) ;
- ? ? ? ? }? else ?{
- ? ? ? ? ? ?? System . out . println ( " remote is not up " ) ;
- ? ? ? ? ? ?? return ;
- ? ? ? ? }
- ? ? ? ?
- ? ? ? ?? String ? text ?=? " Hi there " ;
- ? ? ? ?
- ? ? ? ?? OtpMbox ? mbox ?=? self . createMbox () ;
- ? ? ? ?
- ? ? ? ?? OtpErlangObject [] ? msg ?=? new ? OtpErlangObject [ 2 ] ;
- ? ? ? ?? msg [ 0 ] ?=? mbox . self () ;
- ? ? ? ?? msg [ 1 ] ?=? new ? OtpErlangString ( text ) ;
- ? ? ? ?? OtpErlangTuple ? tuple ?=? new ? OtpErlangTuple ( msg ) ;
- ?
- ? ? ? ?? mbox . send ( " echo " ,? " abc " ,? tuple ) ;
- padding-top: 0px !important; padding-right: 0px !important; padding-bottom: 0px !important; padding-left: 20px; display: list-item !important; font-size: 12px !important; line-height: 20px !important; border-left-width: 1px; border-left-style: solid; border-left-color: #c3ced9; border-top-width: 1px; border-top-style: solid; border-top-color: #e3eef9 !important; background-color: #f9fbfc !impo
- 2011-03-02 16:58
- 瀏覽 527
- 評(píng)論(0)
- 分類: 編程語言
- 相關(guān)推薦
發(fā)表評(píng)論
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫作最大的動(dòng)力，如果您喜歡我的文章，感覺我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
評(píng)論