Erlang: Let’s talk to java
试了一下传说中的 JInterface ，使用 OtpErlang.jar 的整个过程其实非常简单，似乎比 JMS 的程序都简单。
首先，我们要用 java 实现的原始 erlang 程序如下，没错，就是巨简单的 echo ，我们的目标是要把它用 java 来改写，不仅写服务端，也要写客户端。
- - 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 () .
写得并不严密，用了一堆硬编码，主要是个示例，就那么个意思，大家将就着看。
先说一下 JInterface 的一些基本概念。JInterface 的目的是：为 Java 提供一个包，使得 Java 程序在外部可以看起来就像一个标准的 Erlang Node 能以标准的 Erlang 方式与其他的节点进行通讯。它包装了 Erlang 节点之间分布式的通讯协议，编码解码，以及基本的 Erlang 操作，也就是 pid register send receive link unlink 等等，朴实无华。不过，作为两个语言之间的接口包，有了这些基本功能也就足够了。
根据 Erlang 的目录惯例， JInterface 的 Jar 在 ERLANG_HOME/lib/jinterface-x.x/priv 目录下，名字为 OtpErlang.jar 。注意，必须使用和你当前 Erlang 版本下的包，否则出了什么妖怪问题，别来问我，就算是问我，我也不知道该怎么办。:D 之前一直有一个误解，想当然的以为 JInterface 会用 JNI 什么的来实现，而自从碰过一次以后，对 JNI 这种“难以掌控”的东西总觉得有点畏难，所以，迟迟都没有动手，没想到，竟是纯 Java 实现的一个包。用起来方便，部署起来也漂亮。爽！
闲话休提，直接上代码得了。先是 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
发表评论
评论