04 redis發布訂閱 java(redis消息隊列還有其他嗎)

f(message instanceof SmsMessageVo){

SmsMessageVo messageVo = (SmsMessageVo) message;            //發送短信

SmsSender smsSender = SmsSenderFactory.buildEMaySender();

smsSender.setMobile(messageVo.getMobile());

smsSender.setContent(messageVo.getContent());            boolean sendSucc = false;            //判斷短信類型

//驗證碼短信

if(messageVo.getType() == (byte)SmsType.VERIFICATION.getType()){

sendSucc = smsSender.send();

}            if(!sendSucc){                return;

}            // 異步更新短信表狀態為發送成功

final Integer smsId = messageVo.getSmsId();

Executor executor = Executors.newSingleThreadExecutor();

executor.execute(new Runnable() {                public void run() {

SmsQueue smsQueue = new SmsQueue();

smsQueue.setSmsId(smsId);

smsQueue.setStatus((byte)SmsSendStatus.SEND.getType());

smsQueue.setProcessTime(new Date());

smsQueueService.updateSmsQueue(smsQueue);

}

});

}

}

}123456789101112131415161718192021222324252627282930313233343536373839404142434445

4.總結

下面使用一張流程圖，來總結Redis消息隊列和短信服務。 

閱讀全文

java服務redis重啟后需要重啟嗎

Java服務不需要重啟，當Redis重啟后，Java應用程序會自動重新連接到Redis。這是因為Java應用程序中的Redis客戶端會自動嘗試重新建立連接。在Redis重啟后，客戶端會向Redis發送PING命令，如果連接成功，則Redis會返回PONG響應，Java應用程序會收到這個響應并繼續執行。如果連接失敗，則客戶端會嘗試重新連接，直到連接成功或達到最大連接嘗試次數。

需要注意的是，在Redis重啟后，可能會出現一段時間無法訪問Redis的情況，因為Redis需要重新加載數據到內存中。如果Java應用程序需要立即訪問Redis，可以通過設置Redis的持久化配置參數來避免這種情況。另外，如果Java應用程序中有使用Redis的緩存數據，建議設置緩存過期時間，以避免緩存數據過期后無法及時更新的情況。

redis頻道收到發布者信息后可以只推信息給一個訂閱者嗎

Redis 的 SUBSCRIBE 命令可以讓客戶端訂閱任意數量的頻道， 每當有新信息發送到被訂閱的頻道時， 信息就會被發送給所有訂閱指定頻道的客戶端。

作為例子， 下圖展示了頻道 channel1 ， 以及訂閱這個頻道的三個客戶端 —— client2 、 client5 和 client1 之間的關系：

很赞哦!（2279）