我遇到了this blog post ，我发现它很棒而且很有启发性，展示了如何对发送到 Akka IO 套接字服务器的字符串消息进行固定长度的成帧。我一直在使用一个我发现的开源库 here called ScalaBuff ，它在 Protocol Buffer 对象之上创建了一个很好的薄层。
我遇到的问题是调整博客作者的(无法找到直接联系他的链接)代码以获取长度(4 字节序列)，然后是 protobuf 字节数组。我可以担心稍后弄清楚哪条消息在线路上，现在我只想让代码与一个示例消息一起工作。
我的问题是我无法将 Akka IO 代码从拉 akka ByteStrings 转换为能够从 protobuf 消息发送和拉取原始字节。这是我对使用 Akka IO 的套接字服务器不熟悉的症状。我可以往返于我的 protobuf 对象(Zombie Sighting)的字节表示，但是我无法从博客中获取示例来处理字节数组而不是字符串。
如果有人对如何从 A 点(上面提到的博客文章)到 B 点(向 Akka IO 套接字服务器发送 protobuf 消息的 Akka IO 套接字客户端)有一些建议、一些示例代码或一些输入。认为我让客户工作......也许)，那会很棒。
最佳答案
尝试这个:
val myByteArray = myByteString.toArray // converts to an Array[Byte]
val myMessage = MyMessage.defaultInstance.mergeFrom(myByteArray)
MyMessage 是 ScalaBuff 编译器使用您的 MyMessage.proto 模板生成的类。请注意，Google protobuf 库有一个单独的 ByteString 类，请确保不要将两者混用。
更新:Kevin 的问题已经解决了，基本上问题是他使用了 Array[Byte] 的 toString 方法，而不是将字节数组包装在一个新的 String() 中，它正确地将字节数组转换为字符串，用于“%s”。格式调用。
关于sockets - 通过 Akka IO 和套接字的 Protocol Buffer 消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/14657435/