383.10. 例
camel-zipkin を有効にするには、最初に設定する必要があります
ZipkinTracer zipkin = new ZipkinTracer();
// Configure a reporter, which controls how often spans are sent
// (the dependency is io.zipkin.reporter2:zipkin-sender-okhttp3)
sender = OkHttpSender.create("http://127.0.0.1:9411/api/v2/spans");
zipkin.setSpanReporter(AsyncReporter.create(sender));
// and then add zipkin to the CamelContext
zipkin.init(camelContext);上記の設定は、Camel ルートのすべての入力メッセージと出力メッセージをトレースします。
XML で ZipkinTracer を使用するには、スクライブと zipkin トレーサー Bean を定義するだけです。Camel はそれらを自動的に検出して使用します。
<!-- configure how to reporter spans to a Zipkin collector
(the dependency is io.zipkin.reporter2:zipkin-reporter-spring-beans) -->
<bean id="http" class="zipkin2.reporter.beans.AsyncReporterFactoryBean">
<property name="sender">
<bean id="sender" class="zipkin2.reporter.beans.OkHttpSenderFactoryBean">
<property name="endpoint" value="http://localhost:9411/api/v2/spans"/>
</bean>
</property>
<!-- wait up to half a second for any in-flight spans on close -->
<property name="closeTimeout" value="500"/>
</bean>
<!-- setup zipkin tracer -->
<bean id="zipkinTracer" class="org.apache.camel.zipkin.ZipkinTracer">
<property name="serviceName" value="dude"/>
<property name="spanReporter" ref="http"/>
</bean>383.10.1. ServiceName
ただし、Camel エンドポイントをわかりやすい論理名にマップする場合は、マッピングを追加できます。
- ServiceName *
次のように、すべてのイベントがフォールバックして使用するグローバルサービス名を設定できます。
zipkin.setServiceName("invoices");これにより、すべての入力および出力 zipkin トレースに同じサービス名が使用されます。アプリケーションが異なるサービスを使用する場合は、それらをよりきめ細かいクライアント/サーバーサービスマッピングにマッピングする必要があります。
383.10.2. クライアントサービスとサーバーサービスのマッピング
- ClientServiceMappings
- ServerServiceMappings
アプリケーションが他の人が呼び出すことができるサービスをホストしている場合、Camel ルートエンドポイントをサーバーサービスマッピングにマッピングできます。たとえば、Camel アプリケーションに次のルートがあるとします。
from("activemq:queue:inbox")
.to("http:someserver/somepath");これをサーバーサービスとして作成するには、次のマッピングを追加します。
zipkin.addServerServiceMapping("activemq:queue:inbox", "orders");次に、メッセージがその受信トレイキューから消費されると、サービス名が orders の zipkin サーバーイベントになります。
ここで、http:someserver/somepath への呼び出しもサービスであり、クライアントサービス名にマップするとします。これは次のように実行できます。
zipkin.addClientServiceMapping("http:someserver/somepath", "audit");次に、同じ Camel アプリケーションで、入力エンドポイントと出力エンドポイントを異なる zipkin サービス名にマップしました。
サービスマッピングではワイルドカードを使用できます。すべての出力呼び出しを同じ HTTP サーバーに一致させるには、次のようにします。
zipkin.addClientServiceMapping("http:someserver*", "audit");