ルートを追跡すると、一般ユーザー向けアプリに 適切な車両を判断できますそのためには、まず ルートのフォロー、ルートの進捗状況の更新、ルートのフォローの停止 表示されます。
このドキュメントでは、そのプロセスについて説明します。
始める前に
以下の項目が設定されていることを確認してください。
一般ユーザー向けアプリのバックエンド サービスが導入されており、サービスが用意されている いくつかのプロダクトを提供しています
アプリの地図を設定している。
ルートのフォローを開始する
バックエンド サーバーで消費者と車両を照合する場合は、
移動経路の共有を使用してルートのフォローを開始するには、JourneySharingSessionしてください。
次のサンプルコードは、アクティビティの共有後にジャーニーの共有を開始する方法を示しています。 ビューが読み込まれます。
Java
public class MainActivity extends AppCompatActivity
implements ConsumerViewModel.JourneySharingListener {
// Class implementation
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
// Create a TripModel instance to listen for updates to the trip specified by this trip name.
String tripName = ...;
TripModelManager tripModelManager = consumerApi.getTripModelManager();
TripModel tripModel = tripModelManager.getTripModel(tripName);
// Create a JourneySharingSession instance based on the TripModel.
JourneySharingSession session = JourneySharingSession.createInstance(tripModel);
// Add the JourneySharingSession instance on the map for updating the UI.
consumerController.showSession(session);
// Register for trip update events.
tripModel.registerTripCallback(new TripModelCallback() {
@Override
public void onTripETAToNextWaypointUpdated(
TripInfo tripInfo, @Nullable Long timestampMillis) {
// ...
}
@Override
public void onTripActiveRouteRemainingDistanceUpdated(
TripInfo tripInfo, @Nullable Integer distanceMeters) {
// ...
}
// ...
});
}
@Override
protected void onDestroy() {
super.onDestroy();
if (journeySharingSession != null) {
journeySharingSession.stop();
}
}
}
Kotlin
class SampleAppActivity : AppCompatActivity(), ConsumerViewModel.JourneySharingListener {
// Class implementation
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
// Create a TripModel instance to listen for updates to the trip specified by this trip name.
val tripName = "tripName"
val tripModelManager = consumerApi.getTripModelManager()
val tripModel = tripModelManager.getTripModel(tripName)
// Create a JourneySharingSession instance based on the TripModel.
val session = JourneySharingSession.createInstance(tripModel)
// Add the JourneySharingSession instance on the map for updating the UI.
consumerController.showSession(session)
// Register for trip update events.
tripModel.registerTripCallback(
object : TripModelCallback() {
override fun onTripETAToNextWaypointUpdated(
tripInfo: TripInfo,
timestampMillis: Long?,
) {
// ...
}
override fun onTripActiveRouteRemainingDistanceUpdated(
tripInfo: TripInfo,
distanceMeters: Int?,
) {
// ...
}
// ...
})
}
override fun onDestroy() {
super.onDestroy()
journeySharingSession?.stop()
}
}
移動状況を更新
車両に必要な距離など、移動状況の詳細を更新する 推定到着時刻を予測する場合、アプリは 次の例に示すように、リスナーを登録して設定します。
TripModelオブジェクトにリスナーを登録します。Java
// Create a TripModel instance for listening to updates to the trip specified by this trip name. String tripName = ...; TripModelManager tripModelManager = consumerApi.getTripModelManager(); TripModel tripModel = tripModelManager.getTripModel(tripName); // Create a JourneySharingSession instance based on the TripModel. JourneySharingSession session = JourneySharingSession.createInstance(tripModel); // Add the JourneySharingSession instance on the map for updating the UI. consumerController.showSession(session); // Register for trip update events. tripModel.registerTripCallback(new TripModelCallback() { @Override public void onTripETAToNextWaypointUpdated( TripInfo tripInfo, @Nullable Long timestampMillis) { // ... } @Override public void onTripActiveRouteRemainingDistanceUpdated( TripInfo tripInfo, @Nullable Integer distanceMeters) { // ... } // ... });Kotlin
// Create a TripModel instance for listening to updates to the trip specified by this trip name. val tripName = "tripName" val tripModelManager = consumerApi.getTripModelManager() val tripModel = tripModelManager.getTripModel(tripName) // Create a JourneySharingSession instance based on the TripModel. val session = JourneySharingSession.createInstance(tripModel) // Add the JourneySharingSession instance on the map for updating the UI. consumerController.showSession(session) // Register for trip update events. tripModel.registerTripCallback( object : TripModelCallback() { override fun onTripETAToNextWaypointUpdated( tripInfo: TripInfo, timestampMillis: Long?, ) { // ... } override fun onTripActiveRouteRemainingDistanceUpdated( tripInfo: TripInfo, distanceMeters: Int?, ) { // ... } // ... })TripModelOptionsを使用してルートのリスナーを設定します。Java
// Set refresh interval to 2 seconds. TripModelOptions tripOptions = TripModelOptions.builder().setRefreshIntervalMillis(2000).build(); tripModel.setTripModelOptions(tripOptions);Kotlin
// Set refresh interval to 2 seconds. val tripOptions = TripModelOptions.builder().setRefreshIntervalMillis(2000).build() tripModel.setTripModelOptions(tripOptions)
ルートのフォローを停止する
ルートのフォローが不要になった場合、アプリによるルートのフォローを ルートが運転手によってバックエンドで COMPLETE とマークされたものと見なします。停止中のプロセス 共有により、Fleet Engine への不要なネットワーク リクエストを回避し、メモリ不足を回避できる 防ぐことができます。
以下に示すように、JourneySharingSession を使用してルートのフォローを停止します。
見てみましょう。
Java
public class MainActivity extends AppCompatActivity
implements ConsumerViewModel.JourneySharingListener {
// Class implementation
@Override
protected void onDestroy() {
super.onDestroy();
if (journeySharingSession != null) {
journeySharingSession.stop();
}
}
}
Kotlin
class SampleAppActivity : AppCompatActivity(), ConsumerViewModel.JourneySharingListener {
// Class implementation
override fun onDestroy() {
super.onDestroy()
journeySharingSession?.stop()
}
}
ルートエラーを処理する
onTripRefreshError メソッドは、移動中に発生したエラーを表示します。
モニタリングできます。エラー メッセージは Google Cloud のエラー標準に従います。詳細な
エラー メッセージの定義とすべてのエラーコードについては、Google Cloud のエラー
ドキュメントをご覧ください。
ルートのモニタリング中に発生する可能性のある一般的なエラーは次のとおりです。
| HTTP | RPC | 説明 |
|---|---|---|
| 400 | INVALID_ARGUMENT | クライアントが無効なルート名を指定しました。旅行名は
形式は providers/{provider_id}/trips/{trip_id} です。「
provider_id は、プロジェクトが所有する Cloud プロジェクトの ID です。
サービスプロバイダによって異なります |
| 401 | UNAUTHENTICATED | このエラーは、有効な認証情報がない場合に表示されます。 たとえば、JWT トークンがルート ID や JWT トークンなしで署名されている場合など の有効期限が切れています。 |
| 403 | PERMISSION_DENIED | このエラーは、クライアントに十分な権限がない場合に表示されます。 （たとえば、コンシューマ ロールを持つユーザーが updateTrip を呼び出そうとした場合）は、 JWT トークンが無効か、クライアント プロジェクトで API が有効になっていません。 JWT トークンがないか、トークンが はリクエストされたルート ID と一致しません。 |
| 429 | RESOURCE_EXHAUSTED | リソースの割り当てがゼロであるか、トラフィックのレートが上限を超えています。 |
| 503 | UNAVAILABLE | サービス利用不可。通常、サーバーがダウンしています。 |
| 504 | DEADLINE_EXCEEDED | リクエスト期限を超えました。このエラーは、呼び出し元が メソッドのデフォルトの期限（つまり、 サーバーがリクエストを処理するには、要求された期限では足りません）。 期限内にリクエストが完了しませんでした。 |
コンシューマ SDK エラーの処理
Consumer SDK がコールバックを使用して、ルート更新情報のエラーをユーザーアプリに送信します。
メカニズムです。コールバック パラメータはプラットフォーム固有の戻り値の型（
TripUpdateError
、
NSError
。
ステータス コードを抽出する
通常、コールバックに渡されるエラーは gRPC エラーですが、 ステータス コードの形式で追加情報を抽出します。対象: ステータス コードの完全なリストについては、 ステータス コードと gRPC での使用
Java
エラーの詳細を示す gRPC ステータス コードを抽出できます。
onTripUpdateError() から返された TripUpdateError から取得。
// Called when there is a trip update error.
@Override
public void onTripUpdateError(TripInfo tripInfo, TripUpdateError error) {
Status.Code code = error.getStatusCode();
}
Kotlin
エラーの詳細を示す gRPC ステータス コードを抽出できます。
onTripUpdateError() から返された TripUpdateError から取得。
// Called when there is a trip update error.
override fun onTripUpdateError(tripInfo: TripInfo, error: TripUpdateError) {
val code = error.getStatusCode()
}
ステータス コードを解釈する
ステータス コードは、サーバーおよびネットワーク関連のエラーと、 クライアントサイドのエラーです。
サーバー エラーとネットワーク エラー
次のステータス コードは、ネットワーク エラーまたはサーバー エラーを示すものです。 解決のための対応は不要ですConsumer SDK が自動的に 復元します。
| ステータス コード | 説明 |
|---|---|
| ABORTED | サーバーがレスポンスの送信を停止しました。この問題は通常 発生します。 |
| CANCELLED | サーバーが送信レスポンスを終了しました。これは通常
次の場合に起こります。
アプリがバックグラウンドに送られたときや、テーブルで状態が変化したときに ユーザーアプリ。 |
| INTERRUPTED | |
| DEADLINE_EXCEEDED | サーバーの応答に時間がかかりすぎました。 |
| UNAVAILABLE | サーバーにアクセスできませんでした。これは通常、ネットワークや 困難です。 |
クライアントエラー
次のステータス コードはクライアント エラーを示します。 解決できます。Consumer SDK がルートの更新を再試行し続けます。 履歴の共有は終了しますが 復元はできません
| ステータス コード | 説明 |
|---|---|
| INVALID_ARGUMENT | ユーザー アプリが指定したルート名が無効です。旅行名は
providers/{provider_id}/trips/{trip_id} の形式を使用します。
|
| NOT_FOUND | ルートが作成されない。 |
| PERMISSION_DENIED | ユーザー アプリに十分な権限がありません。このエラーは、次の場合に発生します。
|
| RESOURCE_EXHAUSTED | リソース割り当てがゼロであるか、トラフィック フローのレートが 制限します。 |
| UNAUTHENTICATED | JWT トークンが無効なため、リクエストが認証に失敗しました。この JWT トークンがルート ID なしで署名された場合、または JWT トークンの有効期限が切れたとき。 |