Cloud Foundry Java用戶端–流事件

Cloud Foundry Java用戶端提供了基于Java的綁定，用于與正在運作的Cloud Foundry執行個體進行互動。 這個項目的優點之一是它采用了基于Reactive Stream的API作為方法簽名，特别是使用Reactor實作，這在使用流資料時特别有用。

在這篇文章中，我想展示一個真正使該庫發揮作用的特定用例-在Cloud Foundry的流事件中

Loggregator是Cloud Foundry中的子系統，負責彙總系統内産生的所有日志，并提供了将該資訊流式傳輸到外部系統的方式。 Loggregator中的“流量控制器”元件公開了基于Websocket的端點，這些端點流出了這些事件，Cloud Foundry Java用戶端抽象了基礎的websocket用戶端連接配接詳細資訊，并提供了一種使用此資訊的簡潔方法。

作為前提條件，您将需要一個運作中的Cloud Foundry執行個體來試用該示例，并使它在本地運作的最佳方法是使用PCF Dev 。

假設您有一個正在運作的執行個體，使用cf-java-client庫從代碼連接配接到該執行個體的方式如下：

SpringCloudFoundryClient cfClient = SpringCloudFoundryClient.builder()
                .host("api.local.pcfdev.io")
                .username("admin")
                .password("admin")
                .skipSslValidation(true)
                .build();
           

使用此方法，可以通過以下方式建立流量控制器的用戶端：

DopplerClient dopplerClient = ReactorDopplerClient.builder()
      .cloudFoundryClient(cfClient)
      .build();
           

基本上就是這樣，多普勒用戶端提供了流式處理基礎事件的方法，如果您對所有未過濾的資訊（适當地稱為firehose）感興趣，則可以通過以下方式進行：

Flux<Event> cfEvents = this.dopplerClient.firehose(
    FirehoseRequest.builder()
      .subscriptionId(UUID.randomUUID().toString()).build());
           

結果是Reactor庫中的Flux類型封裝了流資料，可以通過附加訂戶來觀察流資料，例如，對于訂戶的基本示例，隻需将事件以以下方式記錄到控制台即可：

cfEvents.subscribe(e -> LOGGER.info(e.toString()));
           

但是， Flux的真正功能在于它提供的非常強大的流利方法，是以，例如，如果我對僅應用程式級日志的子集感興趣，那麼我實質上想過濾資料，從中提取日志并通過以下方式列印日志：

cfEvents
 .filter(e -> LogMessage.class.isInstance(e))
 .map(e -> (LogMessage)e)
 .map(LogMessage::getMessage)
 .subscribe(LOGGER::info);
           

如果您想使用此示例（作為附加獎勵已啟用了Spring Boot） ，請在github存儲庫中使用它 。

翻譯自: https://www.javacodegeeks.com/2016/05/cloud-foundry-java-client-streaming-events.html