Akka IOとソケットによるプロトコルバッファメッセージ

Question

this blog postを見つけました。これは、Akka IOソケットサーバーに送信された文字列メッセージの固定長フレーミングを行う方法を示しています。私はhere called ScalaBuffというオープンソースライブラリを使って作業しており、プロトコルバッファオブジェクトの上に素敵な薄いレイヤーを作成しています。

私が抱えている問題は、長さ（4バイトシーケンス）とその後のprotobufバイト配列を取るブログ作成者（彼に直接連絡するためのリンクを見つけることができませんでした）を適合させることです。私は後でどのメッセージがワイヤ上にあるのか心配することができます。ただ今、ただ一つのサンプルメッセージでコードを動作させたいだけです。

私の問題は、Akka IOコードをakka ByteStringsをプルすることからprotobufメッセージから生のバイトを送信してプルすることに問題があることです。これは、Akka IOを使用してソケットサーバに精通していないという症状です。私のprotobufオブジェクト（Zombie Sighting）のバイト表現に行き着くことができますが、文字列の代わりにバイト配列を処理するためのサンプルをブログから取得できません。

ポイントA（上記のブログ記事）からポイントB（Akka IOソケットにprotobufメッセージを送信するAkka IOソケットクライアント）を取得する方法に関するアドバイスやサンプルコード、サーバー..私はクライアントが動作していると思う..多分）、それは素晴らしいだろう。

Answer 1

これを試してみてください：

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

MyMessageがあなたのMyMessage.protoテンプレートを使用してScalaBuff-コンパイラで生成されたクラスです。 GoogleのprotobufライブラリにはByteStringクラスが別に用意されているので、2つを混ぜないように注意してください。

更新：Kevinの問題は解決されました。基本的には、バイト配列を新しいString（）にラップするのではなく、Array [Byte]のtoStringメソッドを使用していました。 "％s" .format呼び出しで使用される文字列。