mongodb データベースからのドキュメントを処理する非同期プロセスを実装しています。新しいオブジェクトがコレクションに存在するかどうかを確認してからキューに入れるマスター スレッドのようなもの ( RabbitMQ) と、キューからのメッセージを処理するいくつかのハンドラー (現在は 1 つ) があります。したがって、メッセージをキューに入れるときは、amqpプロトコルを使用しているため、メッセージをバイナリ形式にシリアル化する必要があります。メッセージを処理するときは、オブジェクトをバイナリ データから戻す必要があります。ちなみに私はrabbitmqviaで操作していますamqp gem
でやろうとしましたがBSON gem、ハッシュのみを処理して例外をスローし、オブジェクト自体をシリアル化しようとしています。しようとmsgpack-rails gemしていますが、「undefined method .to_msgpack」エラーがスローされます。
ですから、高速からバイナリへのシリアル化、およびバイナリからの逆シリアル化を手伝ってください。ありがとう。