7
के साथ अक्का आईओटीसीपी मैंने akka.io.tcp का उपयोग कर क्लाइंट और सर्वर लिखा है और क्लाइंट द्वारा भेजे गए संदेशों को पढ़ने में मुझे समस्या है। मैंने संदेशों को भेजने के लिए जेसन का उपयोग किया है। ग्राहक के पक्ष में, मैं इस तरह से संदेश लिखें:जेसन
connection ! Write(ByteString(msgString))
सर्वर साइड में मैं निम्नलिखित है:
override def receive: Receive = {
case Received(data) => listener ! Json.parse(data.utf8String)
case PeerClosed => {
context stop self
}
}
समस्या है अक्का एक समय में एक से अधिक संदेश पढ़ रही है, तो मुझे एक अवैध जेसन मिल गया। क्या एक समय में अक्का को सिर्फ एक संदेश पढ़ने का कोई तरीका है?
मैं यहां गलत हो सकता हूं, लेकिन मेरा मानना है कि यह हिस्सा आपके ऊपर होगा। आपको उस तर्क को लिखना होगा जो जानता है कि एक अनुरोध कब समाप्त होता है और दूसरा शुरू होता है और अपूर्ण अनुरोधों पर होल्डिंग को संभालने में सक्षम होता है और जब उन्हें अंदर आता है तो उन्हें बाकी के साथ जोड़ना। मैं नेटटी शब्दावली में विश्वास करता हूं, यह पाइपलाइन में फ़्रेमडेलिमीटर होगा , लेकिन मुझे विश्वास नहीं है कि वर्तमान में अक्का टीसीपी में एक समान सुविधा है (हालांकि मैं गलत हो सकता हूं)। – cmbaxter