Cloud Foundry Java客户端–流事件
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)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: linux大于号是什么意思(linux大
- 下一篇: javaone_JavaOne 2012