जावा डेवलपर के लिए अक्का (भाग 1)

हाल ही में, कुछ प्रोग्रामिंग भाषाएं दिखाई दी हैं जो JVM को निष्पादन के लिए एक मंच के रूप में उपयोग करती हैं। हाल ही में चर्चा करने के लिए सबसे विषयों में से एक स्काला है। इस लेख में मैं इसे अच्छी तरह से विचार करने के लायक नहीं हूं या नहीं, मैं सिर्फ यह बताना चाहता हूं कि आप जावा का उपयोग करके और स्काला में एक भी लाइन लिखे बिना इस भाषा के टूल का उपयोग कैसे कर सकते हैं।

अभिनेताओं की अवधारणा स्कैला से बहुत पहले पैदा हुई थी और जावा सहित विभिन्न प्रोग्रामिंग भाषाओं में लागू की गई थी। संक्षेप में, अभिनेता एक वस्तु है जो इसे भेजे गए संदेशों को संसाधित करता है। यह महत्वपूर्ण है कि संदेश अपरिवर्तनीय हैं और उनके प्रसंस्करण का क्रम उस क्रम से मेल खाता है जिसमें वे प्राप्त होते हैं। दरअसल, यह अवधारणा का आधार है, और फिर कार्यान्वयन की विशेषताएं सामने आती हैं: क्या वस्तु के लिए संदेश कतार को बचाया जाता है, क्या प्रक्रिया में संदेश प्रसंस्करण कोड को बदलना संभव है, चाहे अभिनेता एक धागा या थ्रेड पूल से जुड़ा हो, अन्य मशीनों पर अभिनेताओं को संदेश भेजने की क्षमता और आदि

सामान्य तौर पर, यदि कोई जेईई से परिचित है, तो अभिनेता संदेश बीन के समान है, केवल संदेश कतार जेवीएम के अंदर रहती है।
स्काला भाषा के लेखक ने स्काला भाषा के लिए अभिनेताओं की अवधारणा को लागू करने का फैसला किया और इसे अक्का नाम दिया और इस परियोजना को एक वाणिज्यिक ओपन सोर्स प्रोजेक्ट के रूप में विकसित कर रहा है। परियोजना काफी सक्रिय रूप से विकसित हो रही है, वर्तमान संस्करण 1.1.3 और संस्करण 2.0 पर काम चल रहा है, जिसे वे गिरावट में जारी करने जा रहे हैं। वितरित कतारों और समूहों के बेहतर संगठन के लिए समर्थन होगा।

मैंने अक्का क्यों चुना? सबसे पहले, मैं वितरित कंप्यूटिंग और उच्च-लोड सिस्टम की जटिलता से निपटने के लिए एक नया तरीका महसूस करना चाहता था। दूसरा और बहुत महत्वपूर्ण दस्तावेज है। केवल दो जेटलैंग और अक्का परियोजनाएं वर्तमान में अभिनेताओं के बारे में सक्रिय हैं, और अकाका जावा और स्काला दोनों के लिए विस्तृत प्रलेखन के साथ कोड उदाहरण और जहां और क्यों के विस्तृत विवरण के साथ कैद है। और वास्तव में तीसरा कारण प्रौद्योगिकी का उपयोग करने के लाभों को प्राप्त करने के लिए एक नई भाषा सीखने की आवश्यकता की कमी है।

तो चलिए शुरू करते हैं।

अक्का का उपयोग करते हुए कुछ लिखने के लिए, आपको akka.io/downloads डिस्ट्रीब्यूशन किट डाउनलोड करनी होगी या निम्न लाइब्रेरियों को मावेन से जोड़ना होगा।

< repository > <br> < id > akka.repository </ id > <br> < name > Akka Maven Repository </ name > <br> < url > akka.io/repository </ url > <br> </ repository > <br><br> < dependency > <br> < groupId > se.scalablesolutions.akka </ groupId > <br> < artifactId > akka-actor </ artifactId > <br> < version > 1.1.3 </ version > <br> </ dependency > <br><br> < dependency > <br> < groupId > se.scalablesolutions.akka </ groupId > <br> < artifactId > akka-typed-actor </ artifactId > <br> < version > 1.1.3 </ version > <br> </ dependency > <br><br> * This source code was highlighted with Source Code Highlighter .

अक्का दो प्रकार के अभिनेताओं को लागू करता है - अनटाइपडैक्टर और टाइपेडैक्टर। UntypedActor onReceive विधि के माध्यम से संदेशों को संसाधित करने के लिए एक मानक इंटरफ़ेस प्रदान करता है

import akka.actor.UntypedActor;

public class TestUntypedActor extends UntypedActor {

public void onReceive(Object message) throws Exception {
if (message instanceof MySuperMessage) {
System. out .println( "We've got super message - " + message);
} else if (message instance of String) {
System. out .println( "Process string - " + message);
}
}

* This source code was highlighted with Source Code Highlighter .

इस तरह हमें बहुत सी कक्षाएं मिलती हैं जिन्हें आप संदेश भेजकर बातचीत कर सकते हैं।
TypedActor के लिए, आपको पहले इंटरैक्शन इंटरफ़ेस का वर्णन करना होगा, और फिर अभिनेता का उपयोग करके इसे लागू करना होगा।

interface RegistrationService {
void register(User user, Credentials cred);
User getUserFor(String username);
}

import akka.actor.TypedActor;

public class RegistrationServiceImpl extends TypedActor implements RegistrationService {
public void register(User user, Credentials cred) {
... //
}

public User getUserFor(String username) {
... //
return user;
}
}

* This source code was highlighted with Source Code Highlighter .

इस मामले में, हमारे पास अभिनेताओं का उपयोग करके व्यावसायिक तर्क और कार्यान्वयन के लिए इंटरफेस के साथ कई कक्षाएं होंगी। और यदि आप अपने एप्लिकेशन में स्प्रिंग का उपयोग करते हैं, तो मौजूदा अनुप्रयोगों में अभिनेताओं का एकीकरण कॉन्फ़िगरेशन स्तर पर होगा और लगभग दर्द रहित होगा (अगले लेखों में मैं दिखाऊंगा कि कैसे)।

इसलिए हमारे पास अभिनेता का वर्णन है और अब किसी भी तरह से कक्षाओं के उदाहरण बनाने के लिए आवश्यक है, क्योंकि यहां सरल नया काम नहीं करता है। एक्टर्स फैक्ट्री का इस्तेमाल अनटिप्डएक्टर बनाने के लिए किया जाता है।

ActorRef testActor = Actors.actorOf(TestUntypedActor. class );

* This source code was highlighted with Source Code Highlighter .

निर्माण के बाद, कारखाना अभिनेता के एक विशिष्ट उदाहरण के लिए एक लिंक (ActorRef) लौटाता है, जिसे एक विशिष्ट उदाहरण (दूरस्थ अभिनेता के मामले में) को संदेश भेजने के लिए क्रमबद्ध या किसी अन्य मशीन पर भेजा जा सकता है।

TypedActor बनाने के लिए निम्न कोड का उपयोग करें।

// - , -
UserService service =
(UserService) TypedActor.newInstance(UserService. class , UserServiceImpl. class );

// TypedActor

UserService service = TypedActor.newInstance(UserService. class , new TypedActorFactory() {
public TypedActor create() {
return new UserServiceImpl( "default user storage" ));
});

* This source code was highlighted with Source Code Highlighter .

जो अभिनेता के साथ संवाद स्थापित करने के लिए इंटरफ़ेस का लिंक देता है।

अक्का अभिनेताओं को संदेश भेजने के तीन प्रकारों को लागू करता है: आग-और-भूल ("भेजना और भूल जाना", परिणाम के इंतजार के बिना संदेश का अतुल्यकालिक भेजना), अनुरोध-उत्तर ("सवाल-जवाब"), संदेश भेजना और प्रतिक्रिया की प्रतीक्षा करना, तुल्यकालिक मोड) , अनुरोध-उत्तर-भविष्य के साथ ("भविष्य में एक प्रतिक्रिया भेजें और प्राप्त करें", एक संदेश भेजना और एक विशेष वस्तु का उपयोग करके कोड में आगे प्रतिक्रिया प्राप्त करना)।

अनटाइपडऐक्टर के लिए, सभी तीन विधियां इस तरह दिखती हैं

actorRef.sendOneWay( "Hello" ); //

actorRef.sendOneWay( new MySuperObject(), ontext()); // . context actor' ( ), context().reply()

Object result = actorRef.sendRequestReply( "get result" ); // . context() ( ActorTimeoutException)

Future<MyResult> future = actorRef.sendRequestReplyFuture( "Hello" ); // . context() . Future await ( ), result ( ), exception ( )

* This source code was highlighted with Source Code Highlighter .

TypedActor के लिए, कॉलिंग के तरीके विधि हस्ताक्षर पर निर्भर करते हैं। यदि विधि मान मान (शून्य) नहीं लौटाती है, तो आग-और-भूल कॉल का उपयोग किया जाता है। यदि कोई वस्तु वापस की जाती है, तो अनुरोध-उत्तर का उपयोग किया जाता है। यदि विधि भविष्य में वापस आती है, तो अनुरोध-उत्तर-साथ-भविष्य का उपयोग किया जाता है।

ठीक है, आज के लिए आखिरी - अनटाइपड डॉक्टर्स को शुरू करना और फ्री रिसोर्सेस को बंद करना न भूलें। यदि आप एक अभिनेता को संदेश भेजते हैं जो शुरू नहीं हुआ है, तो उन्हें उसकी बारी में जोड़ा जाएगा और संसाधित नहीं किया जाएगा। इसलिए, यह समझने के लिए कि कुछ काम नहीं कर रहा है मुश्किल होगा।