煙花火的人生

摘要： 1、遇到了個問題，目前使用的是spring cloud stream里的streamBridge給kafka發(fā)送消息，但是當(dāng)對多個kafka節(jié)點發(fā)送消息的時候，發(fā)現(xiàn)不太好搞，在網(wǎng)上找了一下資料，發(fā)現(xiàn)也都有些缺失，導(dǎo)致不能用，然后就自己摸索了一下，發(fā)現(xiàn)如下配置是可以使用： stream: defaul 閱讀全文

摘要： 架構(gòu)總是在不斷修正演變的過程中得到完善！！！ 需求背景： 接到了一個判斷報文中規(guī)則來觸發(fā)告警的需求，本以為需求很簡單，具體的告警邏輯就不贅述了，大體的流程是： 接收到報文，報文中有定義規(guī)則和對應(yīng)的當(dāng)前值，判斷當(dāng)前值是否需要觸發(fā)告警，如果需要則觸發(fā)告警，存儲告警，通過mqtt推送告警信息給前端。 實現(xiàn) 閱讀全文

摘要： 1、問題： 在進行功能開發(fā)的時候遇到一個需求，具體需求如下： 在某個服務(wù)A中接收到消息，對消息體進行校驗，判斷消息體中的數(shù)據(jù)是否需要產(chǎn)生告警，若產(chǎn)生告警，則將告警信息發(fā)送到kafka中，由另一個服務(wù)B接收到消息并記錄到mongo中； 當(dāng)A服務(wù)在此接收到消息，發(fā)現(xiàn)以前的某個告警已經(jīng)恢復(fù)，則再次發(fā)送消息 閱讀全文

摘要： 1、問題： 在使用mqtt進行數(shù)據(jù)接收并將其轉(zhuǎn)發(fā)到kafka的過程中，出現(xiàn)了個問題，mqtt總是自動斷開并嘗試重連，但是很快就又斷開嘗試重連，如此反復(fù)。 報的錯誤為：o.e.p.c.mqttv3.internal.ClientState - 445: Timed out as no activity 閱讀全文

摘要： 1、問題： 今天出現(xiàn)了比較奇怪的問題，使用mongo查詢數(shù)據(jù)的時候，前端傳來的是2023-11-02 00:00:00 但是后端接收到的是2023-11-02T00:00，使用的是LocalDateTime來接收，這出現(xiàn)秒丟失的問題就導(dǎo)致在進行mongo時間范圍查詢的時候，原本的時間范圍是 2023 閱讀全文

摘要： 1、問題： 在使用條件查詢mongdb數(shù)據(jù)庫的時候，涉及到使用時間范圍來查詢數(shù)據(jù)，比如當(dāng)時使用的是：1990-01-01T00:00:00 到1900-02-02T00:00:00查詢的是1月1號到1月2號兩天的數(shù)據(jù)，但是在使用 Query.query(criteria)；進行查詢的時候，和使用 A 閱讀全文

摘要： 1、問題： 在一次告警中心功能的演示時，告警列表頁中的實時告警數(shù)據(jù)，每次都跟彈窗的告警提示信息查一秒，有時候有事正常的，就很奇怪。 2、解決： 經(jīng)過進行代碼斷點，發(fā)現(xiàn)在插入告警時間時，使用的LocalDateTime，該時間時帶有納秒時間的，比如在程序中顯示的時間值是：1990-01-01T00:0 閱讀全文

摘要： 1、背景： 前邊寫了個這樣的業(yè)務(wù)需求：從算法服務(wù)那邊會不斷的發(fā)送過來一些預(yù)警的數(shù)據(jù)和預(yù)警恢復(fù)的數(shù)據(jù)，當(dāng)有新預(yù)警數(shù)據(jù)過來時，會進行數(shù)據(jù)庫記錄和redis緩存，當(dāng)有該預(yù)警的恢復(fù)過來時會將數(shù)據(jù)庫狀態(tài)修改并清除緩存，我的做法是使用了緩存雙刪的策略，即先刪緩存，再更新數(shù)據(jù)庫，再刪緩存。 但是此時還是出現(xiàn)了問題 閱讀全文

摘要： 1、背景： 有這樣一個需求，就是目前在OA系統(tǒng)的所有請求都會打到A服務(wù)器上，A服務(wù)器作為OA系統(tǒng)的門戶服務(wù)，但是現(xiàn)在有個獨立的文件備份服務(wù)，也想通過A服務(wù)器來讓OA系統(tǒng)調(diào)用，里邊包括了下載文件的功能， 此時比如把文件備份服務(wù)部署到B服務(wù)器上，需要下載的文件也在B服務(wù)器上，文件備份服務(wù)提供了個接口，用 閱讀全文

摘要： 1、問題： 在執(zhí)行mysql數(shù)據(jù)庫更新操作，根據(jù)條件更新其中一列的值，具體的更新語句類似如下： update people set name = 'zhangsan' where id = 1 a and age = 24; 但是在Java中使用 parallelStream().foreach(a 閱讀全文