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

總結

以上是生活随笔為你收集整理的Cloud Foundry Java客户端–流事件的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。