Erlang / Elixir से Java और इसके विपरीत। 20 मिनट के लिए साहसिक

हाय सब!

जब आपको Erlang / Elixir दुनिया से जावा और इसके विपरीत से संवाद करना होगा - तो बहुत सारे विकल्प नहीं हैं। हर किसी के लिए एक परित्यक्त जेंथफेस और एक नई एनकॉन लाइब्रेरी, जिसका एक मूल उदाहरण बिल्ली के नीचे प्रस्तुत किया गया है।

निर्भरता जोड़ें

JVM एप्लिकेशन में Encon निर्भरता जोड़ें:

मावेन :

 <dependencies> ... <dependency> <groupId>io.appulse.encon</groupId> <artifactId>encon</artifactId> <version>1.6.4</version> </dependency> ... </dependencies> 

ग्रेडेल :

 dependencies { compile 'io.appulse.encon:encon:1.6.4' } 

नोट: यदि ऐसी कोई आवश्यकता है (उदाहरण के लिए, Ant पर एक परियोजना), तो जार फ़ाइलों के रूप में निर्भरता GitHub पर रिलीज़ अनुभाग में पाई जा सकती है।

Erlang नोड्स लॉन्च करें

 import io.appulse.encon.Node; import io.appulse.encon.Nodes; import io.appulse.encon.config.NodeConfig; //   . //   - .  encon-config NodeConfig config = NodeConfig.builder() // true -   , // false ( ) -   .shortName(true) .cookie("secret") .build(); // ,   EPMD     Erlang  Node node = Nodes.singleNode("echo-node", config); 

नोट: उपरोक्त उदाहरण के लिए काम करने के लिए, आपको या तो EPMD डेमॉन या इसके जावा कार्यान्वयन को चलाना होगा।

मेलबॉक्स बनाना

मेलबॉक्स, उर्फ ​​प्रक्रिया, एरलंग टर्मिनल में:

 import io.appulse.encon.mailbox.Mailbox; Mailbox mailbox = node.mailbox() .name("popa") //  .build(); 

नोड्स के लिए कनेक्शन

नोट: आप {, } नोड {, } या PID (यदि कोई हो) के प्रारूप का उपयोग करके स्वचालित रूप से एक संदेश भेजकर एर्लांग / अमृत या जावा से एक कनेक्शन शुरू कर सकते हैं।

आप net_adm:ping/1 माध्यम से Erlang से पिंग संदेश भेजकर नोड्स के बीच संचार शुरू कर सकते हैं net_adm:ping/1 :

 (erlang@localhost)1> net_adm:ping('java@localhost'). pong (erlang@localhost)2> 

{Name, Node} को एक संदेश भेजना भी संभव है, जहां Node 'java@localhost' फॉर्म का एक परमाणु है, और Name PID या पंजीकृत मेलबॉक्स नाम है जो जावा पक्ष पर मौजूद है।

 (erlang@localhost)1> {my_process, 'java@localhost'} ! hello. hello (erlang@localhost)2> 

यदि मेलबॉक्स जावा पक्ष पर मौजूद है, तो यह एक संदेश प्राप्त करेगा।

जावा से संदेश भेजना

Mailbox send तरीकों Mailbox पूरा परिवार होता है:

• send ( ErlangPid , ErlangTerm ) - किसी दूरस्थ या स्थानीय PID को संदेश भेजता है;
• send ( String , ErlangTerm ) - शब्द को उसी मेलबॉक्स के नाम से स्थानीय मेलबॉक्स में भेजता है;
• send ( String , String , ErlangTerm ) - इसके नाम से एक रिमोट / लोकल नोड और एक मेलबॉक्स को संदेश भेजता है।

आइए इसे आज़माएं, एरलांग-खोल खोलें और इसे नाम के साथ पंजीकृत करें ... 'shell' :

 (erlang@localhost)1> erlang:register(shell, self()). true (erlang@localhost)2> 

अब, हम जावा से एक संदेश भेज सकते हैं (नोड के साथ संचार स्वचालित रूप से स्थापित किया जाएगा):

 import static io.appulse.encon.terms.Erlang.atom; mailbox.send("erlang@localhost", "shell", atom("hello")); 

हम एर्लैंग लौटते हैं और प्राप्त संदेश को पढ़ते हैं:

 (erlang@localhost) 1> flush(). Shell got hello ok (erlang@localhost) 2> 

जावा में संदेश प्राप्त करना

एक आने वाले संदेश को प्राप्त करने के लिए, आपको एक Mailbox विधि का उपयोग करना होगा: receive() या receive(timeout, timeUnit) , जो किसी नए संदेश या निश्चित समय की प्रतीक्षा कर सकता है।

 import io.appulse.encon.Node; import io.appulse.encon.Nodes; import io.appulse.encon.config.NodeConfig; import io.appulse.encon.connection.regular.Message; import io.appulse.encon.mailbox.Mailbox; public class Main { public static void main (String[] args) { NodeConfig config = NodeConfig.builder() .shortName(true) .build(); Node node = Nodes.singleNode("java@localhost", config); Mailbox mailbox = node.mailbox() .name("my_process") .build(); Message message = mailbox.receive(); System.out.println("Incoming message: " + message.getBody().asText()); } } 

Erlang नोड प्रारंभ करें और एक संदेश भेजें:

 $> erl -sname erlang@localhost ... (erlang@localhost)1> {my_process, 'java@localhost'} ! hello. 

निष्कर्ष

ये और कई अन्य उदाहरण परियोजना वेबसाइट और / या GitHub पेज पर अध्ययन किए जा सकते हैं।