1

「レベル」オブジェクトのリストであるオブジェクトがあり、2 つの方法で Spring Boot Rest Controller を使用してそれらを転送することをテストしています。

  1. JSON では、Rest Controller で次のようなものを使用します。

     @RequestMapping(value = "/api/v1/layers/{layername}", method =         RequestMethod.GET, produces = "application/json")
 public @ResponseBody List<Level>  query(@PathVariable String layername,
               @RequestParam("northEastLat") Float northEastLat,
               @RequestParam("northEastLng") Float northEastLng,
               @RequestParam("northWestLat") Float northWestLat,
               @RequestParam("northWestLng") Float northWestLng,

               @RequestParam("southEastLat") Float southEastLat,
               @RequestParam("southEastLng") Float southEastLng,
               @RequestParam("southWestLat") Float southWestLat,
               @RequestParam("southWestLng") Float southWestLng
) {

List<Level> poligons=levelService.obtainLevels(layername,southWestLng,southWestLat,northWestLng,northWestLat,northEastLng,northEastLat,southEastLng,southEastLat);
int i=1;
for (Level p : poligons) {

    System.out.println("poligon" + i++ + " is:" + p.toString());
}

return poligons;
}

  2. Protostuff Protobuf 形式では、次のようなものを使用します。

      @RequestMapping(value = "/api/v1/layers/{layername}", method = RequestMethod.GET,produces = "text/plain")
  public String query(@PathVariable String layername,
                @RequestParam("northEastLat") Float northEastLat,
                @RequestParam("northEastLng") Float northEastLng,
                @RequestParam("northWestLat") Float northWestLat,
                @RequestParam("northWestLng") Float northWestLng,

                @RequestParam("southEastLat") Float southEastLat,
                @RequestParam("southEastLng") Float southEastLng,
                @RequestParam("southWestLat") Float southWestLat,
                @RequestParam("southWestLng") Float southWestLng
  ) {


List<Level> poligons=levelService.obtainLevels(layername,southWestLng,southWestLat,northWestLng,northWestLat,northEastLng,northEastLat,southEastLng,southEastLat);
LevelList list = new LevelList(poligons);

byte[] bytes;

int i=1;
for (Level p : poligons) {

    System.out.println("poligon" + i++ + " is:" + p.toString());
}

Schema<LevelList> schema = RuntimeSchema.getSchema(LevelList.class);
LinkedBuffer buffer = LinkedBuffer.allocate();



try
{
    bytes = ProtostuffIOUtil.toByteArray(list, schema, buffer);
}
finally
{
    buffer.clear();
}

 return new String(bytes);
}

Level オブジェクトのフォーマットは次のとおりです。 "レベル":"3","タイプ":null}

レベル オブジェクトは次のとおりです。

@Entity(name = "Level")
@Table(name="Level2G")
@SecondaryTables({
    @SecondaryTable(name="Level3G"),
    @SecondaryTable(name="Level4G")
})
public class Level implements Serializable {

private static final long serialVersionUID = 1L;

// @Column(name = "wkb_geometry",columnDefinition="Geometry")
//@Type(type = "org.hibernate.spatial.GeometryType")
@Column(name="wkb_geometry")
private /*Geometry */ String  wkb_geometry;

@Id
@Column(name="id")
private Integer id;


@Column(name="level")
private String level;

@Transient
private String type;

public Level() {
}

public Level(String  wkb_geometry, Integer id, String level) {
    this.wkb_geometry = wkb_geometry;
    this.id = id;
    this.level = level;
    this.type = "Feature";
}

public Level(String  wkb_geometry, Integer id, String level, String type) {
    this.wkb_geometry = wkb_geometry;
    this.id = id;
    this.level = level;
    this.type = type;
}

public Object getWkb_geometry() {
    return wkb_geometry;
}

public void setWkb_geometry(String  wkb_geometry) {
    this.wkb_geometry = wkb_geometry;
}

public Integer getId() {
    return id;
}

public void setId(Integer id) {
    this.id = id;
}

public String getLevel() {
    return level;
}

public void setLevel(String level) {
    this.level = level;
}

public String getType() {
    return type;
}

public void setType(String type) {
    this.type = type;
}

@Override
public String toString() {
    return "Level{" +
            "wkb_geometry=" + wkb_geometry +
            ", id=" + id +
            ", level='" + level + '\'' +
            ", type='" + type + '\'' +
            '}';
}
 }

LevelList オブジェクトは Level オブジェクトの単なる List です

問題は、Protostuff を使用すると、JSON (3.7kb) と比較してより大きなペイロード (26kb) を取得することです。なんで？

また、2番目のオプションについては、「application / octet-stream」を設定してバイトを直接返すようにしましたが、それでも同じ結果になりました。また、JSON と protobuf の速度を比較しました。protobuf は、ペイロードが大きくてもパフォーマンスが向上します。理由はありますか？

4

2 に答える 2

2

Protostuff と Protobuf は同じものではありません。Protostuff は、さまざまなシリアル化形式を使用できるラッパー ライブラリです。また、使用しているように見えるランタイムスキーマ生成もサポートしています。そのランタイム スキーマでは、メッセージのスキーマについて受信者に伝えるために、メッセージと共に追加のメタデータを送信する必要があります。表示されている大きなメッセージは、ほとんどがこのランタイム スキーマ データによるものだと思います。

.proto標準の Protobuf では、送信者と受信者が両方のプログラムにコンパイルされたファイルによって提供されるスキーマに既に同意していると想定されるため、スキーマはメッセージと共に送信されません。標準ファイルで Protobuf を使用すると、.proto生成されるメッセージが JSON よりもはるかに小さいことがわかります。

于 2016-07-08T22:24:45.527 に答える
0

テストに少なくとも 1 つの問題があります。

バイト配列から文字列へのこの変換は無効です。

bytes = ProtostuffIOUtil.toByteArray(list, schema, buffer);
return new String(bytes);

この String のコンストラクターは、バイト配列を UTF-8 文字列として解析しようとしますが (ほとんどの場合、ロケール設定に依存します)、指定されたデータは定義上、有効な UTF-8 文字列ではありません。

より適切なサイズ比較を行いたい場合は、次の形式でテストを作成する必要があります。

LevelList source = testData();
byte[] jsonData = generateJson(source);
byte[] protobufData = generateProtobuf(source);
System.out.println("JSON=" + jsonData.size() + " Protobuf=" + protobufData.size());

ここでの主なポイントは、他の人がテストを繰り返すことができるように、テストを再現可能にすることです。

于 2016-07-07T18:24:42.110 に答える