Akka IO.TCP với Json

Question

Tôi đã viết một ứng dụng khách và máy chủ bằng cách sử dụng akka.io.tcp và tôi gặp sự cố khi đọc thư được khách hàng gửi. Tôi đã sử dụng json để gửi tin nhắn. Ở phía khách hàng, tôi viết thông điệp theo cách này:

connection ! Write(ByteString(msgString)) 

Ở phía máy chủ tôi đã điều sau đây:

override def receive: Receive = { 
    case Received(data) => listener ! Json.parse(data.utf8String) 
    case PeerClosed => { 
    context stop self 
    } 
} 

Vấn đề là AKKA được đọc nhiều hơn một thông điệp cùng một lúc, vì vậy tôi nhận được một Json không hợp lệ. Có cách nào để làm cho akka chỉ đọc một tin nhắn cùng một lúc không?

Answer 1

Mô-đun TCP của Akka (và được thiết kế là) rất "mức thấp", vì vậy chúng tôi không cung cấp bất kỳ loại dấu phân cách khung nào. Bạn nên xử lý nó giống như một khối xây dựng cấp TCP, sau đó bạn phải xây dựng công cụ của bạn trên.

Trong ví dụ của bạn, diễn viên sẽ phải tổng hợp các khối dữ liệu đến và phát hiện khi tài liệu json được "hoàn thành", sau đó kích hoạt tính năng unmarshalling.

Ý tưởng cung cấp thứ gì đó trong hộp này khá hấp dẫn ... Tôi sẽ hỏi các bạn về kế hoạch của chúng tôi để hỗ trợ các loại trường hợp sử dụng này.

Tuy nhiên, tôi hy vọng điều này sẽ hữu ích!