GetX第三篇-依賴注入 為什么要使用依賴注入 依賴注入是什么 本來接受各種參數(shù)來構造一個對象睦擂，現(xiàn)在只接受一個參數(shù)——已經(jīng)實例化的對象邑彪。 依賴注入的目的 依賴注入是為了將依賴...
發(fā)簡信
IP屬地：北京
-
Flutter狀態(tài)管理終極方案GetX第三篇——依賴注入
-
Flutter | 深入理解BuildContext
前言 最近看到一些剛接觸Flutter的同學在進行頁面跳轉的時候宣虾，出現(xiàn)了這個問題。 代碼是這樣的 一眼看上去好像沒什么問題隅很，解決方式也很簡單碘赖，把home部分作為一個新的Wid...
-
讀<<高效能閱讀>>有感
本文作者：劉代明,現(xiàn)在奇虎360搜索技術部任web服務端技術專家職位。 祝大家閱讀愉快外构。 前言 每當我拿起書本時普泡，總有一個習慣：強迫自己從前往后，從頭讀到尾审编。 買了書后撼班，迫不...
-
httprouter源碼閱讀
本文作者：劉代明,現(xiàn)在奇虎360搜索技術部任web服務端技術專家職位。 祝大家閱讀愉快垒酬。 前言 在go web開發(fā)中砰嘁，很多時候會選用一款web框架，隨著項目功能增加勘究，接口也越...
-
發(fā)現(xiàn)kafka丟消息后的排查
背景： 最近在用kafka做消息中間件矮湘，producer從hive中讀取消息發(fā)送到kafka，后端storm對消息分類發(fā)送到elasticsearch建立索引口糕。 問題：...
-
行如風1 ·這種方法應該是有問題的.行不通,原因如下:
1)在beginTransaction在恢復或者做快照之前調用,這里返回的是一個mysql的connection對象,在這里事務的載體就是這個connection對象
2)precommit是第一次預提交,如果你看過兩階段的源碼你就會發(fā)現(xiàn),這個是在給你傳入的那個事物的載體對象做快照,對應你這里的就是mysql的connection,,接下來flink會將這個connection存儲到狀態(tài)后端,connection可不是一個普通對象,是一個數(shù)據(jù)庫的連接,能序列化成功?
3)commit,這個是快照成功了.flink內部已經(jīng)將你上次的事務的載體對象給保存完畢了,在notifyCheckpointComplete里回調用戶的commit方法,通知用戶checkpoint成功了
connection根本就不能序列化,這是其一,
其二:即便這種方式可行,也會非常不穩(wěn)定,因為每一次commit的提交都是一個checkpoin的過程,checkpoint的時間有長有短,如果遇到數(shù)據(jù)量大,checkpoint的時間長缅阳，那就意味著你在beginTransaction創(chuàng)建的這個鏈接得一直是打開的狀態(tài),只到checkpoin完成才可以,那你得設置足夠長的connectionTimeOut時間和socketTimeOut時間
其三:.如果flink某次任務失敗了,你是從checkpoint中恢復上一個mysql的連接? -
boltdb源碼閱讀前言 最近抽時間看了boltdb的源碼[https://github.com/boltdb/bolt]，代碼量不大（大概4000行左右）景描，而且支持事務十办，結構也很清晰秀撇，由于比較...
-
Openresty協(xié)程調度對比Go協(xié)程調度
在web編程領域，Openresty與Go均有十分優(yōu)秀的處理能力向族，在面對高并發(fā)的web編程呵燕，兩者一般都是首選的技術方案。這兩者我也一直使用件相，而且兩者均有協(xié)程再扭，現(xiàn)總結下，留個備...
-
從一個模糊詞查詢需求的處理方案討論到一種極速匹配方案的實現(xiàn)背景 某天夜矗，我們的產(chǎn)品經(jīng)理突然找到我泛范，說我們的廣告業(yè)務上線后效果不錯，但是需要做敏感詞過濾處理侯养，需要接入一個模糊詞詞典和一個精確詞詞典。然后我拿到了這兩份詞典澄干，兩份違禁詞加起...
-
從MongoID的生成討論分布式唯一ID生成方案
背景 MongoDB逛揩，想必大家都使用過，在數(shù)據(jù)落盤后麸俘，查詢該條數(shù)據(jù)時辩稽，會發(fā)現(xiàn)其會自動生成一條"_id"，如： db.test.insert({"name":"tom"}) 查...
