使用rabbitmq stomp发送protobuf(二进制)数据

Question

我在客户端使用protobuf.js创建了一个rabbitmq stomp的例子。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二进制数据)。如果通过"content-length"解决了问题，请指导我将"content-length"设置为stomp header。

请帮帮我。没人知道吗?

Answer 1

我知道我是在2年后回答的!但我想我应该分享:)

我正在做一个使用rabbitmq stomp发送ProtoBuf编码数据的项目。

我遇到了同样的问题:我可以发送，但无法在接收端解码。

我让它工作简单地通过使用另一个编码:

• 改变:

  var buffer = car.encode();
  

  :

  var buffer = car.encode64();
  

• 改变:

  var carDec =Car.decode64(buffer);
  

  :

  var carDec =Car.decode64(buffer);
  

这解决了我的问题，我希望它也能解决你的问题。