Buffers de Protocolo ZeroMQ +

Aquí hay un ejemplo que envía y recibe mensajes a través de java y en C++:

Serialización en java:

Person person = Person.newBuilder().setName("chand")
    .setEmail("[email protected]").setId(55555).build();
socket.send(person.toByteArray(), 0);

Des-serializar en java:

byte[] reply = socket.recv(0);
Person person2 = Person.parseFrom(reply);

Serialización en C++:

Person p = Person();
std::string str;
p.SerializeToString(&str);
int sz = str.length();
zmq::message_t *query = new message_t(sz);
memcpy(query->data (), str.c_str(), sz);
socket->send (*query);

De-serializign en C++

zmq::message_t resultset(100);
socket->recv (&resultset);

Person p = Person();
p.ParseFromArray(resultset.data(), resultset.size());
printf("\n Server : %s", p.name().c_str());

No estoy seguro de que PUB/SUB en 0mq funcione con protobuf, porque 0mq espera un tema de cadena a la cabeza del msg.. pero protobuf pone un descriptor de campo primero.

En realidad aquí hay un enlace con una solución.

Http://www.dotkam.com/2011/09/09/zeromq-and-google-protocol-buffers /

Salud

Siempre necesita serializar cuando se comunica. Las estructuras son de acceso aleatorio. Las capas de comunicación, como ZeroMQ, son en serie.

Puede usar la "serialización predeterminada" que viene con su idioma.

Por ejemplo, en C++ una estructura sin punteros tendrá un cierto diseño binario que se puede convertir directamente en una matriz de bytes. Este diseño binario es, indirectamente, su capa de serialización, y es tanto específico del lenguaje como del compilador.

Siempre y cuando limítese a estructuras que no tienen punteros y están usando el mismo compilador y lenguaje en ambos extremos de la tubería... no dude en evitar una biblioteca que haga serialización adicional sobre el diseño predeterminado proporcionado.