import com.google.transit.realtime.GtfsRealtime.FeedEntity; //导入依赖的package包/类
@Test
public void testParseFrom() throws IOException {
  InputStream in = getClass().getResourceAsStream("vehicle_position.pb");
  FeedMessage feed = FeedMessage.parseFrom(in);
  assertEquals(1, feed.getEntityCount());
  FeedEntity entity = feed.getEntity(0);
  assertEquals(entity.getId(), "1");
  assertTrue(entity.hasVehicle());
}
 

import com.google.transit.realtime.GtfsRealtime.FeedEntity; //导入依赖的package包/类
@Override
public void run()
{
  try
  {
    URL url = new URL(urlStr);
    HttpURLConnection myURLConnection = (HttpURLConnection)url.openConnection();
    if (headers != null && headers.length > 0) 
    {
      for (int i = 0; i < headers.length; i++)
      {
        String[] nameValue = headers[i].split(":");
        myURLConnection.setRequestProperty (nameValue[0], nameValue[1]);
      }
    }
    
    //myURLConnection.setRequestProperty ("Authorization", basicAuth);
    //String userCredentials = "username:password";
    //String basicAuth = "Basic " + new String(new Base64().encode(userCredentials.getBytes()));
    //myURLConnection.setRequestProperty ("Authorization", basicAuth);
    //myURLConnection.setRequestMethod("POST");
    //myURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
    //myURLConnection.setRequestProperty("Content-Length", "" + postData.getBytes().length);
    //myURLConnection.setRequestProperty("Content-Language", "en-US");
    //myURLConnection.setUseCaches(false);
    //myURLConnection.setDoInput(true);
    //myURLConnection.setDoOutput(true);  
    
    FeedMessage feed;
    if (isTextFormat == true)
    {
      InputStream inputStream = myURLConnection.getInputStream();
      InputStreamReader reader = new InputStreamReader(inputStream);
      FeedMessage.Builder myProtoBuilder = FeedMessage.newBuilder();
      TextFormat.merge(reader,  myProtoBuilder);
      feed = myProtoBuilder.build();
    }
    else {
      feed = FeedMessage.parseFrom(myURLConnection.getInputStream());          
      //feed = FeedMessage.parseFrom(url.openStream());
    }
    long headerTimestamp = feed.getHeader().getTimestamp();
    for (FeedEntity entity : feed.getEntityList())
    {
      if (entity.hasVehicle())
      {
        getVehiclesAndSendGeoEvents(entity, headerTimestamp);
      }

      if (entity.hasAlert())
      {
        getAlertsAndSendGeoEvents(entity, headerTimestamp);
      }

      if (entity.hasTripUpdate())
      {
        getTripUpdatesAndSendGeoEvents(entity, headerTimestamp);
      }
    } // for
  }
  catch (IOException e)
  {
    LOGGER.error(e.getMessage());
  }
}
 

import com.google.transit.realtime.GtfsRealtime.FeedEntity; //导入依赖的package包/类
private FeedEntity wrapVehiclePosition(VehiclePosition vp) {
  FeedEntity.Builder feb = FeedEntity.newBuilder();
  feb.setVehicle(vp);
  feb.setId(vp.getVehicle().getId());
  return feb.build();
}
 

import com.google.transit.realtime.GtfsRealtime.FeedEntity; //导入依赖的package包/类
private FeedEntity wrapTripUpdate(TripUpdate tu) {
  FeedEntity.Builder feb = FeedEntity.newBuilder();
  feb.setTripUpdate(tu);
  feb.setId(tu.getVehicle().getId());
  return feb.build();
}