Cloud Foundry Java客戶端提供了基于Java的綁定，用于與正在運(yùn)行的Cloud Foundry實(shí)例進(jìn)行交互。 這個項(xiàng)目的優(yōu)點(diǎn)之一是它采用了基于Reactive Stream的API作為方法簽名，特別是使用Reactor實(shí)現(xiàn)，這在使用流數(shù)據(jù)時特別有用。

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

Loggregator是Cloud Foundry中的子系統(tǒng)，負(fù)責(zé)匯總系統(tǒng)內(nèi)產(chǎn)生的所有日志，并提供了將該信息流式傳輸?shù)酵獠肯到y(tǒng)的方式。 Loggregator中的“流量控制器”組件公開了基于Websocket的端點(diǎn)，這些端點(diǎn)流出了這些事件，Cloud Foundry Java客戶端抽象了基礎(chǔ)的websocket客戶端連接詳細(xì)信息，并提供了一種使用此信息的簡潔方法。

作為前提條件，您將需要一個運(yùn)行中的Cloud Foundry實(shí)例來試用該示例，并使它在本地運(yùn)行的最佳方法是使用PCF Dev 。

假設(shè)您有一個正在運(yùn)行的實(shí)例，使用cf-java-client庫從代碼連接到該實(shí)例的方式如下：

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

使用此方法，可以通過以下方式創(chuàng)建流量控制器的客戶端：

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

從本質(zhì)上來說，多普勒客戶端提供了流式處理基礎(chǔ)事件的方法，如果您對所有未過濾的信息（適當(dāng)?shù)胤Q為firehose）感興趣，則可以通過以下方式進(jìn)行：

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

結(jié)果是來自Reactor庫的Flux類型封裝了流數(shù)據(jù)，可以通過附加訂戶來觀察流數(shù)據(jù)，例如對于訂戶的基本示例，只需將事件以以下方式記錄到控制臺即可：

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

但是， Flux的真正功能在于它提供的非常強(qiáng)大的流利方法，因此，例如，如果我對僅是應(yīng)用程序級別日志的子集感興趣，那么我本質(zhì)上想過濾數(shù)據(jù)，從中提取日志并通過以下方式打印日志：

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。