3

クライアント側でprotobuf.jsを使用してrabbitmq stompの例を1つ作成しました。protobuf の例のリンク: https://github.com/dcodeIO/ProtoBuf.js

メッセージファイルの内容を送信する:-

var Game = builder.build("Game");
var Car = Game.Cars.Car;
var car = new Car("Rusty", "mayur");
var buffer = car.encode();      

var mq_username = "guest",
mq_password = "guest",
mq_vhost    = "/",
mq_url      = 'http://192.168.0.14:15674/stomp',
mq_queue1 = '/queue/A3';
var client = Stomp.client(mq_url);
function on_connect() 
{

client.send(mq_queue1, { priority: 9}, buffer); 

}
window.onload = function () 
{
client.connect(
        mq_username,
        mq_password,
        on_connect,
        on_connect_error,
        mq_vhost
      );    

}

ファイルの内容を受け取る:-

  var Game = builder.build("Game");
  var Car = Game.Cars.Car;
  var car = new Car("Rusty", "mayur");
  var buffer = car.encode();        

  var mq_username = "guest",
  mq_password = "guest",
  mq_vhost    = "/",
  mq_url      = 'http://192.168.0.14:15674/stomp',
  mq_queue1 = '/queue/A3';
  var client = Stomp.client(mq_url);
  function on_connect() 
  {
        un = client.subscribe(mq_queue1, on_message);

  }
function on_message(m) 
{
  console.log('message received'); 
  console.log(m);
  var buffer = m.body;
  alert(buffer);                     
  var carDec =Car.decode(buffer);                         
  alert(carDec.model);

}
  window.onload = function () 
  {
        client.connect(
            mq_username,
            mq_password,
            on_connect,
            on_connect_error,
            mq_vhost
          );    

  }

stomp(protobuf binary data)で送信されたデータをデコードできません。"content-length"で問題が解決した場合は、 stomp ヘッダーに " content -length"を設定するように案内してください。

私を助けてください。誰もこれについて知りませんか？

4

1 に答える 1

5

私は2年後に答えていることを知っています! しかし、私は共有すべきだと思いました:)

私は、rabbitmq stomp を使用して ProtoBuf でエンコードされたデータを送信するプロジェクトに取り組んでいます。

私は同じ問題に直面しました。送信はできましたが、受信側でデコードできませんでした。

別のエンコーディングを使用するだけで機能するようになりました。

  • 変化する：

    var buffer = car.encode();

    に：

    var buffer = car.encode64();

  • 変化する：

    var carDec =Car.decode64(buffer);

    に：

    var carDec =Car.decode64(buffer);

これで私の問題は解決しました。あなたの問題も解決することを願っています。

于 2015-06-09T12:38:52.107 に答える