Сочетание прото-буферов Google с Джерси/JAX-RS

В настоящее время у меня есть веб-сервис RESTful с конечными точками, которые отображаются через Jersey/JAX-RS:

@Path("/widgets")
public class WidgetResource {
    @GET
    List<Widget> getAllWidgets() {
        // gets Widgets somehow
    }

    @POST
    Widget save(Widget w) {
        // Save widget and return it
    }
}

Я использую Jackson для сериализации/десериализации моих POJO в JSON, и мой сервис отвечает и отправляет мои POJO как application/json.

Теперь я хочу использовать буферы протокола Google (или эквивалентную технологию), чтобы помочь сжать/оптимизировать связь между клиентом и сервисом, поскольку JSON/текст довольно объемный/расточительный.

В действительности у меня есть большой бэкэнд, который состоит из архитектуры "микросервиса"; десятки служб REST, общающихся друг с другом; вот почему я ищу оптимизацию сообщений, посланных назад и вперед между всеми ними.

Итак, я спрашиваю: возможно ли, чтобы Джерси /JAX -RS обслуживали мои конечные точки обслуживания, но чтобы избавиться от вещей Jackson/JSON и заменить его буферами протокола Google? Если да, то каким может выглядеть этот код?

Ответ 1

JAX-RS использует реализации MessageBodyReader и MessageBodyWriter для сериализации/десериализации и от разных типов медиа. Вы можете больше узнать о JAX-RS Entity Providers. Вы можете написать свой собственный дескриптор сериализации /derialization ваших объектов protobuf. Затем просто зарегистрируйте "провайдер (ы)" с приложением, явно или неявно через обнаружение.

Пример

widgets.proto

package widget;

option java_package = "protobuf.example";
option java_outer_classname = "WidgetsProtoc";

message Widget {
    required string id = 1;
    required string name = 2;
}

message WidgetList {
    repeated Widget widget = 1;
}

Когда это скомпилировано, я останусь с классом WidgetsProtoc со статическими внутренними классами Widget и WidgetList.

WidgetResource

import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Response;
import protobuf.example.WidgetsProtoc.Widget;
import protobuf.example.WidgetsProtoc.WidgetList;

@Path("/widgets")
public class WidgetResource {

    @GET
    @Produces("application/protobuf")
    public Response getAllWidgets() {
        Widget widget1 = 
                Widget.newBuilder().setId("1").setName("widget 1").build();
        Widget widget2 = 
                Widget.newBuilder().setId("2").setName("widget 2").build();
        WidgetList list = WidgetList.newBuilder()
                .addWidget(widget1).addWidget(widget2).build();
        return Response.ok(list).build();
    }

    @POST
    @Consumes("application/protobuf")
    public Response postAWidget(Widget widget) {
        StringBuilder builder = new StringBuilder("Saving Widget \n");
        builder.append("ID: ").append(widget.getId()).append("\n");
        builder.append("Name: ").append(widget.getName()).append("\n");
        return Response.created(null).entity(builder.toString()).build();
    }
}

Вы заметите использование типа носителя "application/protobuf". Это не стандартный формат , но в рабочем процессе есть . Кроме того, библиотека Guava определяет этот тип носителя как MediaType.PROTOBUF, что соответствует "application/protobuf", поэтому я решил придерживаться этого.

MessageBodyReader и MessageBodyWriter все определены в одном классе. Вы можете сделать это отдельно. Не имеет значения.

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.lang.annotation.Annotation;
import java.lang.reflect.Type;
import javax.ws.rs.BadRequestException;
import javax.ws.rs.Consumes;
import javax.ws.rs.Produces;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.ext.MessageBodyReader;
import javax.ws.rs.ext.MessageBodyWriter;
import javax.ws.rs.ext.Provider;
import protobuf.example.WidgetsProtoc.Widget;
import protobuf.example.WidgetsProtoc.WidgetList;

@Provider
@Produces("application/protobuf")
@Consumes("application/protobuf")
public class WidgetProtocMessageBodyProvder 
                   implements MessageBodyReader, MessageBodyWriter {

    @Override
    public boolean isReadable(Class type, Type type1, 
            Annotation[] antns, MediaType mt) {
        return Widget.class.isAssignableFrom(type) 
                || WidgetList.class.isAssignableFrom(type);
    }

    @Override
    public Object readFrom(Class type, Type type1, Annotation[] antns, 
            MediaType mt, MultivaluedMap mm, InputStream in) 
            throws IOException, WebApplicationException {
        if (Widget.class.isAssignableFrom(type)) {
            return Widget.parseFrom(in);
        } else if (WidgetList.class.isAssignableFrom(type)) {
            return WidgetList.parseFrom(in);
        } else {
            throw new BadRequestException("Can't Deserailize");
        }
    }

    @Override
    public boolean isWriteable(Class type, Type type1, 
            Annotation[] antns, MediaType mt) {
        return Widget.class.isAssignableFrom(type) 
                || WidgetList.class.isAssignableFrom(type);
    }

    @Override
    public long getSize(Object t, Class type, Type type1, 
            Annotation[] antns, MediaType mt) {  return -1; }

    @Override
    public void writeTo(Object t, Class type, Type type1, 
            Annotation[] antns, MediaType mt, 
            MultivaluedMap mm, OutputStream out) 
            throws IOException, WebApplicationException {
        if (t instanceof Widget) {
            Widget widget = (Widget)t;
            widget.writeTo(out);
        } else if (t instanceof WidgetList) {
            WidgetList list = (WidgetList)t;
            list.writeTo(out);
        }
    }  
}

TestCase (убедитесь, что провайдер зарегистрирован как сервером, так и клиентом)

@Test
public void testGetIt() {
    // Get all list
    WidgetList list = target.path("widgets")
                            .request().get(WidgetList.class);
    System.out.println("===== Response from GET =====");
    for (Widget widget: list.getWidgetList()) {
        System.out.println("id: " + widget.getId() 
                         + ", name: " + widget.getName());
    }

    // Post one 
    Widget widget = Widget.newBuilder().setId("10")
                          .setName("widget 10").build();
    Response responseFromPost = target.path("widgets").request()
            .post(Entity.entity(widget, "application/protobuf"));
    System.out.println("===== Response from POST =====");
    System.out.println(responseFromPost.readEntity(String.class));
    responseFromPost.close();
}

Результат:

===== Response from GET =====
id: 1, name: widget 1
id: 2, name: widget 2
===== Response from POST =====
Saving Widget 
ID: 10
Name: widget 10