Geek asks and answers

Buffer protocol messages through Akka IO and Sockets

I stumbled upon this blog post , which I found surprising and enlightening, showing how to make a fixed-length framework of string messages sent to Akka IO Socket Server. I worked with an open source library, I found here called ScalaBuff , which creates a nice thin layer on top of protocol buffer objects.

I had a problem in adapting the author of the blog (I could not find a link to contact him directly) to take the length (4-byte sequence), and then the protobuf byte array. I can worry about figuring out which message was sent later, right now I just want the code to work with one example message.

My problem is that it is difficult for me to convert the Akka IO akka ByteStrings retrieval code into the ability to send and retrieve raw bytes from the protobuf message. This is a symptom of my lack of familiarity with socket servers using Akka IO. I can get from the byte representation of my protobuf object (

+5
source share
1 answer

Try the following:

val myByteArray = myByteString.toArray // converts to an Array[Byte]
val myMessage = MyMessage.defaultInstance.mergeFrom(myByteArray)

MyMessage is a class generated by the ScalaBuff compiler using the MyMessage.proto template. Please note: the Google protobuff library has a separate ByteString class, make sure you do not mix the two.

: , , toString [Byte] , String(), , "% s".format.

0

More articles:


All Articles