av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Java如何使用ReentrantLock實現長輪詢

瀏覽:4日期:2022-08-14 16:52:13
Java代碼1. ReentrantLock

加鎖阻塞,一個condition對應一個線程,以便于喚醒時使用該condition一定會喚醒該線程

/** * 獲取探測點數據,長輪詢實現 * @param messageId * @return */ public JSONObject getToutData(String messageId) {Message message = toutMessageCache.get(messageId);if (message == null) { // 等待 lock.lock(); try {Condition condition = lock.newCondition();conditionMap.put(messageId + '_data', condition);condition.await(CONNECTION_HOLD_TIMEOUT, TimeUnit.SECONDS); // 等待60s } catch (InterruptedException e) {// 等待超時, do nothing } finally {lock.unlock(); }}// 再次嘗試獲取message = toutMessageCache.get(messageId);if (message == null) { // 如果還沒有, 返回空對象 return null;}byte[] bytes = message.getDataBytes();if (bytes == null) { return null;}String resStr = new String(bytes, StandardCharsets.UTF_8);//log.info('resStr: {}', resStr);JSONObject resObj;try { resObj = new JSONObject(resStr); resObj.put('invokeTime', DateUtil.format(new Date(resObj.getLong('invokeTime')), DatePattern.NORM_DATETIME_MS_PATTERN));} catch (Exception e) { resObj = new JSONObject();}return resObj; }2. 回調

當異步數據返回,使用上一步的condition喚醒線程

public void callback(Message message) { String messageId = message.getId(); toutMessageCache.put(message.getId(), message); String messageDataId = messageId + '_data'; if (conditionMap.containsKey(messageDataId)) {lock.lock();try { Condition condition = conditionMap.get(messageDataId); condition.signal();} catch (Exception e) { e.printStackTrace();} finally { lock.unlock(); conditionMap.remove(messageDataId);} }}3. 喚醒

執行回調操作

public void distribute(Message message, ChannelHandlerContext ctx) { MessageType messageType = message.getMessageType(); switch (messageType) { case TOUT_DATA_RESPONSE: // 數據響應 toutService.callback(message); break; }}4. 調用

調用時,判斷返回的值是否為空,如果為空,與前端約定,當返回該狀態值時,應再次發起相同請求

/*** 獲取探測數據(使用長輪詢實現)* @param linkId* @return*/@GetMapping('/data')public ResultVO getToutData(String linkId) { JSONObject resObj = toutService.getToutData(linkId); if (resObj == null || resObj.isEmpty()) { return ResultVOUtil.error(ResultEnum.NO_MESSAGE_HOLD_CONNECTION); } return ResultVOUtil.success(resObj);}5.前端實現

簡單使用遞歸實現了當數據返回無效時再次發起請求

let that = thisfunction getData() { if (toutStatus === statusEnum.start) { getToutData({ linkId }).then(res => { if (res.code === ERROR_CODE_OK) { that.toutData = res.data toutStatus = statusEnum.resData that._btnStatus() } else { getData() } }) } } // 遞歸循環調用 getData()

以上就是如何使用ReentrantLock實現長輪詢的詳細內容,更多關于ReentrantLock長輪詢的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 成人午夜性成交 | 亚洲国产精品va在线看黑人 | 国产免费观看一区 | 精品久久久一区 | 国产免费观看久久黄av片涩av | 狠狠综合久久av一区二区小说 | 日韩三级在线 | 久久九| 午夜免费网站 | 水蜜桃久久夜色精品一区 | 欧美亚洲高清 | 日韩成人一区 | 黑人精品欧美一区二区蜜桃 | 欧美成人猛片aaaaaaa | 亚洲精品美女视频 | 亚洲视频中文字幕 | 在线免费观看黄色 | 午夜网 | 亚洲一区二区三区免费在线观看 | 91丨国产| 久久免费视频1 | 久久久久久久久久久福利观看 | 国产黄色精品 | 国产精品无码专区在线观看 | 亚洲精品国产区 | 国产精品国产精品 | 婷婷久久综合 | 亚洲国产一区二区视频 | 亚洲精品乱码久久久久久久久 | 欧美综合在线视频 | 七七婷婷婷婷精品国产 | 国产农村一级国产农村 | 国产视频欧美 | 亚洲欧洲视频 | 久久久久一区 | 久久黄色网 | 亚洲精品乱码久久久久久久久 | 国外成人在线视频网站 | 久久久久国产精品 | 亚洲黄色国产 | 成人三级av|